com.hazelcast.enterprise.wan.replication

Interface BatchReplicationStrategy

All Known Implementing Classes:

ConcurrentBatchReplicationStrategy, SerialBatchReplicationStrategy

public interface BatchReplicationStrategy

Strategy defining the high-level WAN replication mechanism. Different replication strategies may choose different ways in which batches are sent to target endpoints.

Method Summary

Modifier and Type	Method and Description
void	complete(com.hazelcast.nio.Address endpoint) Releases the provided target endpoint as available for sending the next event batch.
int	getFirstPartitionId(com.hazelcast.nio.Address endpoint, List<com.hazelcast.nio.Address> endpoints) Returns the first partition ID of the events which should be sent to the provided target endpoint.
com.hazelcast.nio.Address	getNextEventBatchEndpoint(List<com.hazelcast.nio.Address> endpoints) Returns the next available target endpoint from a provided list of available target endpoints.
int	getPartitionIdStep(com.hazelcast.nio.Address endpoint, List<com.hazelcast.nio.Address> endpoints) Returns the step between partition IDs of events which should be sent to the provided target endpoint.
boolean	hasOngoingReplication() Returns true if there is an ongoing replication process.

Method Detail

getNextEventBatchEndpoint

com.hazelcast.nio.Address getNextEventBatchEndpoint(List<com.hazelcast.nio.Address> endpoints)

Returns the next available target endpoint from a provided list of available target endpoints. This method may acquire (reserve) the returned endpoint. It is the responsibility of the user of this strategy to call the complete(Address) method with the returned address to mark the endpoint as available again.

Parameters:

endpoints - the available target endpoints

Returns:

the next available endpoint to which an event batch can be sent

complete

void complete(com.hazelcast.nio.Address endpoint)

Releases the provided target endpoint as available for sending the next event batch.

Parameters:

endpoint - the endpoint to release

getFirstPartitionId

int getFirstPartitionId(com.hazelcast.nio.Address endpoint,
                        List<com.hazelcast.nio.Address> endpoints)

Returns the first partition ID of the events which should be sent to the provided target endpoint.

Parameters:

endpoint - the target endpoint

endpoints - the list of available target endpoints

Returns:

the first partition ID of the events for which the target endpoint is responsible for

getPartitionIdStep

int getPartitionIdStep(com.hazelcast.nio.Address endpoint,
                       List<com.hazelcast.nio.Address> endpoints)

Returns the step between partition IDs of events which should be sent to the provided target endpoint.

Parameters:

endpoint - the target endpoint

endpoints - the list of available target endpoints

Returns:

the step between partition IDs of the events which should be sent to the target endpoint

hasOngoingReplication

boolean hasOngoingReplication()

Returns true if there is an ongoing replication process.