com.hazelcast.internal.partition

Interface InternalPartitionService

All Superinterfaces:

CoreService, IPartitionService

All Known Implementing Classes:

InternalPartitionServiceImpl

public interface InternalPartitionService
extends IPartitionService

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_REPLICA_SYNC_DELAY Delay for anti-entropy replica synchronization.
static String	MIGRATION_EVENT_TOPIC Static constant for dispatching and listening migration events
static int	MIGRATION_RETRY_COUNT Retry count for migration operations.
static long	MIGRATION_RETRY_PAUSE Retry pause for migration operations.
static String	PARTITION_LOST_EVENT_TOPIC Static constant for dispatching and listening internal partition lost events
static long	REPLICA_SYNC_RETRY_DELAY Retry delay for replica synchronization.

Fields inherited from interface com.hazelcast.spi.partition.IPartitionService

SERVICE_NAME

Method Summary

Methods

Modifier and Type	Method and Description
PartitionRuntimeState	createPartitionState()
void	firstArrangement()
InternalPartition[]	getInternalPartitions()
int	getMemberGroupsSize()
InternalPartition	getPartition(int partitionId) Returns the IPartition for a given partitionId.
InternalPartition	getPartition(int partitionId, boolean triggerOwnerAssignment) Returns the IPartition for a given partitionId.
long[]	getPartitionReplicaVersions(int partitionId)
long[]	incrementPartitionReplicaVersions(int partitionId, int totalBackupCount)
boolean	isMemberAllowedToJoin(Address address)
boolean	isPartitionReplicaVersionStale(int partitionId, long[] versions, int replicaIndex)
void	memberAdded(MemberImpl newMember)
void	memberRemoved(MemberImpl deadMember)
void	pauseMigration()
boolean	prepareToSafeShutdown(long timeout, TimeUnit seconds)
void	resumeMigration()
void	updatePartitionReplicaVersions(int partitionId, long[] replicaVersions, int replicaIndex)

Methods inherited from interface com.hazelcast.spi.partition.IPartitionService

addLocalPartitionLostListener, addMigrationListener, addPartitionLostListener, getMaxAllowedBackupCount, getMemberPartitions, getMemberPartitionsMap, getMigrationQueueSize, getPartitionCount, getPartitionId, getPartitionId, getPartitionOwner, getPartitionOwnerOrWait, getPartitions, getPartitionStateVersion, hasOnGoingMigration, hasOnGoingMigrationLocal, isMemberStateSafe, isPartitionOwner, removeMigrationListener, removePartitionLostListener

Field Detail

MIGRATION_RETRY_COUNT

static final int MIGRATION_RETRY_COUNT

Retry count for migration operations.

See Also:

Constant Field Values

MIGRATION_RETRY_PAUSE

static final long MIGRATION_RETRY_PAUSE

Retry pause for migration operations.

See Also:

Constant Field Values

DEFAULT_REPLICA_SYNC_DELAY

static final long DEFAULT_REPLICA_SYNC_DELAY

Delay for anti-entropy replica synchronization.

See Also:

Constant Field Values

REPLICA_SYNC_RETRY_DELAY

static final long REPLICA_SYNC_RETRY_DELAY

Retry delay for replica synchronization.

See Also:

Constant Field Values

MIGRATION_EVENT_TOPIC

static final String MIGRATION_EVENT_TOPIC

Static constant for dispatching and listening migration events

See Also:

Constant Field Values

PARTITION_LOST_EVENT_TOPIC

static final String PARTITION_LOST_EVENT_TOPIC

Static constant for dispatching and listening internal partition lost events

See Also:

Constant Field Values

Method Detail

getPartition

InternalPartition getPartition(int partitionId)

Description copied from interface: IPartitionService

Returns the IPartition for a given partitionId. If owner of the partition is not set yet, it will trigger partition assignment.

The IPartition for a given partitionId will never change, so it can be cached safely.

Specified by:

getPartition in interface IPartitionService

Parameters:

partitionId - the partitionId

Returns:

the IPartition.

getPartition

InternalPartition getPartition(int partitionId,
                             boolean triggerOwnerAssignment)

Description copied from interface: IPartitionService

Returns the IPartition for a given partitionId. If owner of the partition is not set yet and triggerOwnerAssignment is true, it will trigger partition assignment.

The IPartition for a given partitionId will never change, so it can be cached safely.

Specified by:

getPartition in interface IPartitionService

Parameters:

partitionId - the partitionId

triggerOwnerAssignment - flag to trigger partition assignment

Returns:

the IPartition.

getMemberGroupsSize

int getMemberGroupsSize()

pauseMigration

void pauseMigration()

resumeMigration

void resumeMigration()

isMemberAllowedToJoin

boolean isMemberAllowedToJoin(Address address)

memberAdded

void memberAdded(MemberImpl newMember)

memberRemoved

void memberRemoved(MemberImpl deadMember)

prepareToSafeShutdown

boolean prepareToSafeShutdown(long timeout,
                            TimeUnit seconds)

getInternalPartitions

InternalPartition[] getInternalPartitions()

firstArrangement

void firstArrangement()

createPartitionState

PartitionRuntimeState createPartitionState()

isPartitionReplicaVersionStale

boolean isPartitionReplicaVersionStale(int partitionId,
                                     long[] versions,
                                     int replicaIndex)

getPartitionReplicaVersions

long[] getPartitionReplicaVersions(int partitionId)

updatePartitionReplicaVersions

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

incrementPartitionReplicaVersions

long[] incrementPartitionReplicaVersions(int partitionId,
                                       int totalBackupCount)