public interface PartitionService
Partition
s
and attach/detach MigrationListener
s to listen partition migration events.Partition
,
MigrationListener
Modifier and Type | Method and Description |
---|---|
String |
addMigrationListener(MigrationListener migrationListener) |
boolean |
forceLocalMemberToBeSafe(long timeout,
TimeUnit unit)
Force local member to be safe by checking and syncing owned partitions with 1st backups.
|
Partition |
getPartition(Object key)
Returns partition which given key belongs to.
|
Set<Partition> |
getPartitions()
Returns all partitions.
|
boolean |
isClusterSafe()
Checks whether the cluster is in a safe state.
|
boolean |
isLocalMemberSafe()
Check if local member is safe to shutdown, means check if 1st backups of partitions
those owned by local member are sync with primary.
|
boolean |
isMemberSafe(Member member)
Check if the given member is safe to shutdown, means check if 1st backups of partitions
those owned by given member are sync with primary.
|
String |
randomPartitionKey()
Generates a random partition key.
|
boolean |
removeMigrationListener(String registrationId) |
Partition getPartition(Object key)
key
- keyString randomPartitionKey()
String addMigrationListener(MigrationListener migrationListener)
migrationListener
- listenerboolean removeMigrationListener(String registrationId)
registrationId
- Id of listener registration.boolean isClusterSafe()
true
if there are no partitions being migrated, and there are sufficient backups
for each partition per the configuration, otherwise false
.boolean isMemberSafe(Member member)
member
- Cluster member to query.true
if member in a safe state, other wise false
.boolean isLocalMemberSafe()
boolean forceLocalMemberToBeSafe(long timeout, TimeUnit unit)
Copyright © 2014 Hazelcast, Inc.. All Rights Reserved.