com.hazelcast.internal.partition

Interface PartitionReplicaVersionManager

All Known Implementing Classes:

PartitionReplicaManager

public interface PartitionReplicaVersionManager

PartitionReplicaVersionManager maintains partition replica version handling. It keeps versions for each partition and ServiceNamespace pair.

Since:

3.9

Method Summary

Modifier and Type	Method and Description
Collection<ServiceNamespace>	getNamespaces(int partitionId) Returns all registered namespaces for given partition ID
long[]	getPartitionReplicaVersions(int partitionId, ServiceNamespace namespace) Returns replica versions for given partition and namespace.
ServiceNamespace	getServiceNamespace(Operation operation) Returns ServiceNamespace for given operation.
long[]	incrementPartitionReplicaVersions(int partitionId, ServiceNamespace namespace, int backupCount) Increments replica versions for given partition and namespace by the number of backup count.
boolean	isPartitionReplicaVersionStale(int partitionId, ServiceNamespace namespace, long[] replicaVersions, int replicaIndex) Returns whether given replica version is behind the current version or not.
void	updatePartitionReplicaVersions(int partitionId, ServiceNamespace namespace, long[] replicaVersions, int replicaIndex) Updates the partition replica version and triggers replica sync if the replica is dirty (e.g.

Method Detail

getNamespaces

Collection<ServiceNamespace> getNamespaces(int partitionId)

Returns all registered namespaces for given partition ID

Parameters:

partitionId - partition ID

Returns:

known namespaces for partition ID

isPartitionReplicaVersionStale

boolean isPartitionReplicaVersionStale(int partitionId,
                                       ServiceNamespace namespace,
                                       long[] replicaVersions,
                                       int replicaIndex)

Returns whether given replica version is behind the current version or not.

Parameters:

partitionId - partition ID

namespace - replica namespace

replicaVersions - replica versions

replicaIndex - specific replica index

Returns:

true if given version is stale, false otherwise

getPartitionReplicaVersions

long[] getPartitionReplicaVersions(int partitionId,
                                   ServiceNamespace namespace)

Returns replica versions for given partition and namespace.

Parameters:

partitionId - partition ID

namespace - replica namespace

Returns:

replica versions

updatePartitionReplicaVersions

void updatePartitionReplicaVersions(int partitionId,
                                    ServiceNamespace namespace,
                                    long[] replicaVersions,
                                    int replicaIndex)

Updates the partition replica version and triggers replica sync if the replica is dirty (e.g. the received version is not expected and this node might have missed an update)

Parameters:

partitionId - the ID of the partition for which we received a new version

namespace - replica namespace

replicaVersions - the received replica versions

replicaIndex - the index of this replica

incrementPartitionReplicaVersions

long[] incrementPartitionReplicaVersions(int partitionId,
                                         ServiceNamespace namespace,
                                         int backupCount)

Increments replica versions for given partition and namespace by the number of backup count.

Parameters:

partitionId - partition ID

namespace - replica namespace

backupCount - number of desired backups

Returns:

incremented replica versions

getServiceNamespace

ServiceNamespace getServiceNamespace(Operation operation)

Returns ServiceNamespace for given operation. If operation is instance of ServiceNamespaceAware then ServiceNamespaceAware.getServiceNamespace() will be used. Otherwise NonFragmentedServiceNamespace will be returned.

Parameters:

operation - operation

Returns:

service namespace for operation