Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.event |
Event classes to define listenters for JCache other than EntryListener
|
com.hazelcast.client |
Contains classes/interfaces related to Client
|
com.hazelcast.client.impl.protocol.task |
Client tasks associated with requests.
|
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.client.impl.protocol.task.transaction |
Client protocol tasks implementations for Transaction related
|
com.hazelcast.client.impl.querycache |
Contains query cache internal implementations for client side.
|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.client.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
com.hazelcast.client.spi.impl |
Provides util classes for the Hazelcast client SPI.
|
com.hazelcast.client.util |
This package contains some utility classes and the base implementations of the
loadbalancer implementations
|
com.hazelcast.collection.impl.common | |
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.executor.impl |
This package contains IExecutorService functionality for Hazelcast.
The IExecutorService extends the ExecutorService and provides all kinds
of additional methods related to distributed systems. |
com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
com.hazelcast.internal.cluster |
Contains the internals for cluster management like discovery, joining etc.
|
com.hazelcast.internal.cluster.fd |
Contains failure detector mechanism and its implementations.
|
com.hazelcast.internal.cluster.impl |
This package contains the implementation of the cluster functionality.
|
com.hazelcast.internal.management |
Contains classes to provide data/operation interface for Management Center.
|
com.hazelcast.internal.nearcache.impl.invalidation |
Invalidations for Near Cache.
|
com.hazelcast.internal.partition |
Contains the internals for partition assignment/management, migration, replication etc.
|
com.hazelcast.internal.usercodedeployment.impl | |
com.hazelcast.internal.usercodedeployment.impl.filter | |
com.hazelcast.internal.util.iterator |
Re-usable implementations of Iterators.
|
com.hazelcast.logging |
This package contains logging functionality for Hazelcast.
Since Hazelcast has a zero dependency policy, Hazelcast provides a logging abstraction like commongs logging, so that different logging frameworks like log4j, can be hooked in. |
com.hazelcast.map |
Contains Hazelcast map module classes.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.querycache |
Contains query cache internal implementation classes.
|
com.hazelcast.map.impl.querycache.event |
This package contains classes for query cache events.
|
com.hazelcast.map.impl.querycache.subscriber |
This package contains classes which are used for
QueryCache
event subscription side. |
com.hazelcast.mapreduce.impl |
This package contains the default implementation for the map reduce framework
internals.
|
com.hazelcast.partition.membergroup |
todo
|
com.hazelcast.quorum |
Contains classes related to cluster quorum.
|
com.hazelcast.quorum.impl |
Contains cluster quorum implementation classes.
|
com.hazelcast.scheduledexecutor |
This package contains ScheduledExecutorService functionality for Hazelcast.
|
com.hazelcast.scheduledexecutor.impl | |
com.hazelcast.spi |
Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services.
|
com.hazelcast.topic.impl |
This package contains ITopic functionality for Hazelcast.
With the ITopic it is possible to create publish subscribe solutions similar to JMS Topics. |
Modifier and Type | Method and Description |
---|---|
Member |
CachePartitionEventData.getMember() |
Constructor and Description |
---|
CachePartitionEventData(String name,
int partitionId,
Member member) |
Modifier and Type | Method and Description |
---|---|
Member |
AbstractICacheEvent.getMember()
Returns the member that fired this event.
|
Member |
ICacheEvent.getMember()
Returns the member that fired this event.
|
Constructor and Description |
---|
AbstractICacheEvent(Object source,
Member member,
int eventType)
Constructs a prototypical Cache Event.
|
CachePartitionLostEvent(Object source,
Member member,
int eventType,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
Member |
LoadBalancer.next()
Returns the next member to route to.
|
Modifier and Type | Method and Description |
---|---|
abstract Collection<Member> |
AbstractMultiTargetMessageTask.getTargets() |
Collection<Member> |
CreateProxiesMessageTask.getTargets() |
Collection<Member> |
DeployClassesMessageTask.getTargets() |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
AuthenticationMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte version,
List<Member> cleanedUpMembers) |
protected abstract ClientMessage |
AuthenticationBaseMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte serializationVersion,
List<Member> cleanedUpMembers) |
protected ClientMessage |
AuthenticationCustomCredentialsMessageTask.encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte version,
List<Member> cleanedUpMembers) |
protected abstract Object |
AbstractMultiTargetMessageTask.reduce(Map<Member,Object> map) |
protected Object |
CreateProxiesMessageTask.reduce(Map<Member,Object> map) |
protected Object |
DeployClassesMessageTask.reduce(Map<Member,Object> map) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
MapAddInterceptorMessageTask.getTargets() |
Collection<Member> |
MapRemoveInterceptorMessageTask.getTargets() |
Modifier and Type | Method and Description |
---|---|
protected Object |
MapAddInterceptorMessageTask.reduce(Map<Member,Object> map) |
protected Object |
MapRemoveInterceptorMessageTask.reduce(Map<Member,Object> map) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
XACollectTransactionsMessageTask.getTargets() |
Modifier and Type | Method and Description |
---|---|
protected Object |
XACollectTransactionsMessageTask.reduce(Map<Member,Object> map) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClientQueryCacheContext.getMemberList() |
Modifier and Type | Method and Description |
---|---|
Member |
ClientClusterProxy.getLocalMember() |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,List<IScheduledFuture<V>>> |
ClientScheduledExecutorProxy.getAllScheduledFutures() |
Set<Member> |
ClientClusterProxy.getMembers() |
<V> Map<Member,IScheduledFuture<V>> |
ClientScheduledExecutorProxy.scheduleOnAllMembers(Callable<V> command,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnAllMembers(Runnable command,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnAllMembersAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
<V> Map<Member,IScheduledFuture<V>> |
ClientScheduledExecutorProxy.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit) |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToAllMembers(Callable<T> task) |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members) |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
MemberSelector memberSelector) |
Modifier and Type | Method and Description |
---|---|
void |
ClientExecutorServiceProxy.executeOnMember(Runnable command,
Member member) |
boolean |
PartitionServiceProxy.isMemberSafe(Member member) |
<V> IScheduledFuture<V> |
ClientScheduledExecutorProxy.scheduleOnMember(Callable<V> command,
Member member,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ClientScheduledExecutorProxy.scheduleOnMember(Runnable command,
Member member,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ClientScheduledExecutorProxy.scheduleOnMemberAtFixedRate(Runnable command,
Member member,
long initialDelay,
long period,
TimeUnit unit) |
<T> Future<T> |
ClientExecutorServiceProxy.submitToMember(Callable<T> task,
Member member) |
<T> void |
ClientExecutorServiceProxy.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback) |
void |
ClientExecutorServiceProxy.submitToMember(Runnable command,
Member member,
ExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
ClientExecutorServiceProxy.executeOnMembers(Runnable command,
Collection<Member> members) |
<V> Map<Member,IScheduledFuture<V>> |
ClientScheduledExecutorProxy.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ClientScheduledExecutorProxy.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit) |
<T> Map<Member,Future<T>> |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members) |
<T> void |
ClientExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members,
MultiExecutionCallback callback) |
void |
ClientExecutorServiceProxy.submitToMembers(Runnable command,
Collection<Member> members,
MultiExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
Member |
ClientClusterService.getMember(Address address)
Gets the member for the given address.
|
Member |
ClientClusterService.getMember(String uuid)
Gets the member with the given UUID.
|
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClientClusterService.getMemberList()
Gets the collection of members.
|
Collection<Member> |
ClientClusterService.getMembers(MemberSelector selector)
Returns a collection of the members that satisfy the given
MemberSelector . |
Modifier and Type | Method and Description |
---|---|
Member |
ClientClusterServiceImpl.getMember(Address address) |
Member |
ClientClusterServiceImpl.getMember(String uuid) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClientClusterServiceImpl.getMemberList() |
Collection<Member> |
ClientClusterServiceImpl.getMembers(MemberSelector selector) |
Modifier and Type | Method and Description |
---|---|
protected Member[] |
AbstractLoadBalancer.getMembers() |
Member |
RoundRobinLB.next() |
Member |
RandomLB.next() |
Member |
StaticLB.next() |
Constructor and Description |
---|
StaticLB(Member member) |
Constructor and Description |
---|
DataAwareItemEvent(String name,
ItemEventType itemEventType,
Data dataItem,
Member member,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
Member |
Cluster.getLocalMember()
Returns this Hazelcast instance member.
|
Member |
ItemEvent.getMember()
Returns the member that fired this event.
|
Member |
MembershipEvent.getMember()
Returns the removed or added member.
|
Member |
MemberAttributeEvent.getMember() |
Member |
AbstractIMapEvent.getMember()
Returns the member that fired this event.
|
Member |
MemberLeftException.getMember()
Returns the member that left the cluster
|
Member |
IMapEvent.getMember()
Returns the member that fired this event.
|
Member |
MigrationEvent.getNewOwner()
Returns the new owner of the migrating partition
|
Member |
MigrationEvent.getOldOwner()
Returns the old owner of the migrating partition
|
Member |
Partition.getOwner()
Returns the current member that owns this partition.
|
Member |
Message.getPublishingMember()
Returns the member that published the message.
|
Modifier and Type | Method and Description |
---|---|
Set<Member> |
MembershipEvent.getMembers()
Returns a consistent view of the the members immediately after this MembershipEvent has been processed.
|
Set<Member> |
InitialMembershipEvent.getMembers()
Returns an immutable set of ordered members at the moment this
InitialMembershipListener is
registered. |
Set<Member> |
Cluster.getMembers()
Set of the current members in the cluster.
|
<T> Map<Member,Future<T>> |
IExecutorService.submitToAllMembers(Callable<T> task)
Submits task to all cluster members and returns a
map of Member-Future pairs representing pending completion of the task on each member.
|
<T> Map<Member,Future<T>> |
IExecutorService.submitToMembers(Callable<T> task,
Collection<Member> members)
Submits a task to given members and returns
map of Member-Future pairs representing pending completion of the task on each member
|
<T> Map<Member,Future<T>> |
IExecutorService.submitToMembers(Callable<T> task,
MemberSelector memberSelector)
Submits a task to selected members and returns a
map of Member-Future pairs representing pending completion of the task on each member.
|
Modifier and Type | Method and Description |
---|---|
void |
IExecutorService.executeOnMember(Runnable command,
Member member)
Executes a task on the specified member.
|
boolean |
PartitionService.isMemberSafe(Member member)
Checks whether the given member is in safe state.
|
void |
MultiExecutionCallback.onResponse(Member member,
Object value)
Called when an execution is completed on a member.
|
boolean |
MemberSelector.select(Member member)
Decides if the given member will be part of an operation or not.
|
<T> Future<T> |
IExecutorService.submitToMember(Callable<T> task,
Member member)
Submits a task to the specified member and returns a Future
representing that task.
|
<T> void |
IExecutorService.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback)
Submits a task to the specified member.
|
<T> void |
IExecutorService.submitToMember(Runnable task,
Member member,
ExecutionCallback<T> callback)
Submits a task to the specified member.
|
Modifier and Type | Method and Description |
---|---|
void |
IExecutorService.executeOnMembers(Runnable command,
Collection<Member> members)
Executes a task on each of the specified members.
|
void |
MultiExecutionCallback.onComplete(Map<Member,Object> values)
Called after all executions are completed.
|
<T> Map<Member,Future<T>> |
IExecutorService.submitToMembers(Callable<T> task,
Collection<Member> members)
Submits a task to given members and returns
map of Member-Future pairs representing pending completion of the task on each member
|
<T> void |
IExecutorService.submitToMembers(Callable<T> task,
Collection<Member> members,
MultiExecutionCallback callback)
Submits a task to the specified members.
|
void |
IExecutorService.submitToMembers(Runnable task,
Collection<Member> members,
MultiExecutionCallback callback)
Submits a task to the specified members.
|
Constructor and Description |
---|
AbstractIMapEvent(Object source,
Member member,
int eventType)
Constructs a prototypical map Event.
|
EntryEvent(Object source,
Member member,
int eventType,
K key,
V value)
Constructs an entry event.
|
EntryEvent(Object source,
Member member,
int eventType,
K key,
V oldValue,
V value)
Constructs an entry event.
|
EntryEvent(Object source,
Member member,
int eventType,
K key,
V oldValue,
V value,
V mergingValue)
Constructs an entry event.
|
ItemEvent(String name,
ItemEventType itemEventType,
E item,
Member member) |
MapEvent(Object source,
Member member,
int eventType,
int numberOfEntriesAffected) |
MemberAttributeEvent(Cluster cluster,
Member member,
MemberAttributeOperationType operationType,
String key,
Object value) |
MemberLeftException(Member member) |
MembershipEvent(Cluster cluster,
Member member,
int eventType,
Set<Member> members) |
Message(String topicName,
E messageObject,
long publishTime,
Member publishingMember) |
MigrationEvent(int partitionId,
Member oldOwner,
Member newOwner,
MigrationEvent.MigrationStatus status) |
Constructor and Description |
---|
InitialMembershipEvent(Cluster cluster,
Set<Member> members) |
MembershipEvent(Cluster cluster,
Member member,
int eventType,
Set<Member> members) |
Modifier and Type | Method and Description |
---|---|
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToAllMembers(Callable<T> task) |
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members) |
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
MemberSelector memberSelector) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutorServiceProxy.executeOnMember(Runnable command,
Member member) |
<T> Future<T> |
ExecutorServiceProxy.submitToMember(Callable<T> task,
Member member) |
<T> void |
ExecutorServiceProxy.submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback) |
void |
ExecutorServiceProxy.submitToMember(Runnable task,
Member member,
ExecutionCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutorServiceProxy.executeOnMembers(Runnable command,
Collection<Member> members) |
<T> Map<Member,Future<T>> |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members) |
<T> void |
ExecutorServiceProxy.submitToMembers(Callable<T> task,
Collection<Member> members,
MultiExecutionCallback callback) |
void |
ExecutorServiceProxy.submitToMembers(Runnable task,
Collection<Member> members,
MultiExecutionCallback callback) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMember |
class |
MemberImpl |
Modifier and Type | Method and Description |
---|---|
Member |
HazelcastInstanceImpl.getLocalEndpoint() |
Member |
HazelcastInstanceProxy.getLocalEndpoint() |
Modifier and Type | Method and Description |
---|---|
DiscoveryService |
Node.createDiscoveryService(DiscoveryConfig discoveryConfig,
Member localMember) |
Modifier and Type | Method and Description |
---|---|
Member |
ClusterService.getLocalMember()
Gets the local member instance.
|
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClusterService.getMembers(MemberSelector selector)
Returns a collection of the members that satisfy the given
MemberSelector . |
Modifier and Type | Method and Description |
---|---|
void |
PhiAccrualClusterFailureDetector.heartbeat(Member member,
long timestamp) |
void |
ClusterFailureDetector.heartbeat(Member member,
long timestamp)
Notifies this failure detector about received heartbeat message from a member.
|
void |
DeadlineClusterFailureDetector.heartbeat(Member member,
long timestamp) |
boolean |
PhiAccrualClusterFailureDetector.isAlive(Member member,
long timestamp) |
boolean |
ClusterFailureDetector.isAlive(Member member,
long timestamp)
Returns true if given member is considered as alive/available.
|
boolean |
DeadlineClusterFailureDetector.isAlive(Member member,
long timestamp) |
long |
PhiAccrualClusterFailureDetector.lastHeartbeat(Member member) |
long |
ClusterFailureDetector.lastHeartbeat(Member member)
Returns the last heartbeat timestamp for a member.
|
long |
DeadlineClusterFailureDetector.lastHeartbeat(Member member) |
void |
PhiAccrualClusterFailureDetector.remove(Member member) |
void |
ClusterFailureDetector.remove(Member member)
Deregister member from tracking and cleanup resources related to this member.
|
void |
DeadlineClusterFailureDetector.remove(Member member) |
double |
PhiAccrualClusterFailureDetector.suspicionLevel(Member member,
long timestamp) |
double |
ClusterFailureDetector.suspicionLevel(Member member,
long timestamp)
Returns suspicion level about a given member.
|
double |
DeadlineClusterFailureDetector.suspicionLevel(Member member,
long timestamp) |
Modifier and Type | Class and Description |
---|---|
class |
MemberSelectingCollection<M extends Member>
An immutable collection that applies all the
MemberSelector instances to
its internal Member collection. |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
ClusterServiceImpl.getCurrentMembersAndMembersRemovedInNotJoinableState() |
Set<Member> |
ClusterServiceImpl.getMembers() |
Collection<Member> |
ClusterServiceImpl.getMembers(MemberSelector selector) |
Set<Member> |
MembershipManager.getMemberSet() |
Modifier and Type | Method and Description |
---|---|
long |
ClusterHeartbeatManager.getLastHeartbeatTime(Member member) |
void |
ClusterServiceImpl.suspectMember(Member suspectedMember,
String reason,
boolean destroyConnection) |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<Object> |
ManagementCenterService.callOnMember(Member member,
Operation operation) |
Modifier and Type | Method and Description |
---|---|
Member |
Invalidation.getMember() |
Modifier and Type | Method and Description |
---|---|
boolean |
PartitionServiceProxy.isMemberSafe(Member member) |
Constructor and Description |
---|
ClassLocator(ConcurrentMap<String,ClassSource> classSourceMap,
ConcurrentMap<String,ClassSource> clientClassSourceMap,
ClassLoader parent,
Filter<String> classNameFilter,
Filter<Member> memberFilter,
UserCodeDeploymentConfig.ClassCacheMode classCacheMode,
NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
static Filter<Member> |
MemberProviderFilterParser.parseMemberFilter(String providerFilter) |
Modifier and Type | Method and Description |
---|---|
boolean |
MemberAttributeFilter.accept(Member member) |
Modifier and Type | Method and Description |
---|---|
Member |
RestartingMemberIterator.next() |
Modifier and Type | Method and Description |
---|---|
Member |
LogEvent.getMember() |
Constructor and Description |
---|
LogEvent(LogRecord logRecord,
Member member) |
Modifier and Type | Method and Description |
---|---|
Member |
EventLostEvent.getMember() |
Constructor and Description |
---|
EventLostEvent(String source,
Member member,
int partitionId) |
MapPartitionLostEvent(Object source,
Member member,
int eventType,
int partitionId) |
Constructor and Description |
---|
DataAwareEntryEvent(Member from,
int eventType,
String source,
Data dataKey,
Data dataNewValue,
Data dataOldValue,
Data dataMergingValue,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
NodeQueryCacheContext.getMemberList() |
Collection<Member> |
QueryCacheContext.getMemberList()
Returns member list of the cluster.
|
Modifier and Type | Method and Description |
---|---|
Member |
SingleIMapEvent.getMember() |
Member |
BatchIMapEvent.getMember() |
Modifier and Type | Method and Description |
---|---|
static IMapEvent |
EventPublisherHelper.createIMapEvent(EventData eventData,
EventFilter filter,
Member member,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
static <V> List<V> |
MapReduceUtil.executeOperation(Collection<Member> members,
OperationFactory operationFactory,
MapReduceService mapReduceService,
NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
Set<Member> |
DefaultMemberGroup.getMembers() |
Iterator<Member> |
DefaultMemberGroup.iterator() |
Iterator<Member> |
MemberGroup.iterator() |
Iterator<Member> |
SingleMemberGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMemberGroup.addMember(Member member) |
void |
MemberGroup.addMember(Member member) |
void |
SingleMemberGroup.addMember(Member member) |
boolean |
DefaultMemberGroup.hasMember(Member member) |
boolean |
MemberGroup.hasMember(Member member) |
boolean |
SingleMemberGroup.hasMember(Member member) |
void |
DefaultMemberGroup.removeMember(Member member) |
void |
MemberGroup.removeMember(Member member) |
void |
SingleMemberGroup.removeMember(Member member) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMemberGroup.addMembers(Collection<Member> members) |
void |
MemberGroup.addMembers(Collection<Member> members) |
void |
SingleMemberGroup.addMembers(Collection<Member> members) |
protected Set<MemberGroup> |
ZoneAwareMemberGroupFactory.createInternalMemberGroups(Collection<? extends Member> allMembers) |
protected Set<MemberGroup> |
HostAwareMemberGroupFactory.createInternalMemberGroups(Collection<? extends Member> allMembers) |
protected Set<MemberGroup> |
SPIAwareMemberGroupFactory.createInternalMemberGroups(Collection<? extends Member> allMembers) |
protected Set<MemberGroup> |
ConfigMemberGroupFactory.createInternalMemberGroups(Collection<? extends Member> members) |
Collection<MemberGroup> |
MemberGroupFactory.createMemberGroups(Collection<? extends Member> members) |
Set<MemberGroup> |
SingleMemberGroupFactory.createMemberGroups(Collection<? extends Member> members) |
Constructor and Description |
---|
SingleMemberGroup(Member member) |
Constructor and Description |
---|
DefaultMemberGroup(Collection<Member> members) |
Modifier and Type | Method and Description |
---|---|
Collection<Member> |
QuorumEvent.getCurrentMembers()
Returns the snapshot of member list at the time quorum happened
|
Modifier and Type | Method and Description |
---|---|
void |
HeartbeatAware.onHeartbeat(Member member,
long timestamp)
Notifies of a received heartbeat.
|
void |
PingAware.onPingLost(Member member)
Notifies the
QuorumFunction of ping loss. |
void |
PingAware.onPingRestored(Member member)
Notifies the
QuorumFunction of a successful ping after one or more pings to that member were lost. |
Modifier and Type | Method and Description |
---|---|
boolean |
QuorumFunction.apply(Collection<Member> members)
Determines if quorum is present based on the current list of members in the cluster.
|
Constructor and Description |
---|
QuorumEvent(Object source,
int threshold,
Collection<Member> currentMembers,
boolean presence) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractPingAwareQuorumFunction.isAlivePerIcmp(Member member) |
void |
RecentlyActiveQuorumFunction.onHeartbeat(Member member,
long timestamp) |
void |
QuorumServiceImpl.onHeartbeat(Member member,
long timestamp) |
void |
ProbabilisticQuorumFunction.onHeartbeat(Member member,
long timestamp) |
void |
QuorumServiceImpl.onPingLost(Member member) |
void |
AbstractPingAwareQuorumFunction.onPingLost(Member member) |
void |
QuorumServiceImpl.onPingRestored(Member member) |
void |
AbstractPingAwareQuorumFunction.onPingRestored(Member member) |
Modifier and Type | Method and Description |
---|---|
boolean |
RecentlyActiveQuorumFunction.apply(Collection<Member> members) |
boolean |
ProbabilisticQuorumFunction.apply(Collection<Member> members) |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,List<IScheduledFuture<V>>> |
IScheduledExecutorService.getAllScheduledFutures()
Fetches and returns all scheduled (not disposed yet) futures from all members in the cluster.
|
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnAllMembers(Callable<V> command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay on all cluster
Member s. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnAllMembers(Runnable command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay on all cluster
Member s. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnAllMembersAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the
given period on all cluster
Member s. |
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay on all
Member s given. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay on all
Member s given. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the
given period on all
Member s given. |
Modifier and Type | Method and Description |
---|---|
<V> IScheduledFuture<V> |
IScheduledExecutorService.scheduleOnMember(Callable<V> command,
Member member,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay at the given
Member . |
IScheduledFuture<?> |
IScheduledExecutorService.scheduleOnMember(Runnable command,
Member member,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay at the given
Member . |
IScheduledFuture<?> |
IScheduledExecutorService.scheduleOnMemberAtFixedRate(Runnable command,
Member member,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the
given period at the given
Member . |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,IScheduledFuture<V>> |
IScheduledExecutorService.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay on all
Member s given. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay on all
Member s given. |
Map<Member,IScheduledFuture<?>> |
IScheduledExecutorService.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the
given period on all
Member s given. |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,List<IScheduledFuture<V>>> |
ScheduledExecutorServiceProxy.getAllScheduledFutures() |
Map<Member,Object> |
InvokeOnMembers.invoke()
Executes the operation on all targets.
|
<V> Map<Member,IScheduledFuture<V>> |
ScheduledExecutorServiceProxy.scheduleOnAllMembers(Callable<V> command,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnAllMembers(Runnable command,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnAllMembersAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
<V> Map<Member,IScheduledFuture<V>> |
ScheduledExecutorServiceProxy.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
<V> IScheduledFuture<V> |
ScheduledExecutorServiceProxy.scheduleOnMember(Callable<V> command,
Member member,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ScheduledExecutorServiceProxy.scheduleOnMember(Runnable command,
Member member,
long delay,
TimeUnit unit) |
IScheduledFuture<?> |
ScheduledExecutorServiceProxy.scheduleOnMemberAtFixedRate(Runnable command,
Member member,
long initialDelay,
long period,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
<V> Map<Member,IScheduledFuture<V>> |
ScheduledExecutorServiceProxy.scheduleOnMembers(Callable<V> command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnMembers(Runnable command,
Collection<Member> members,
long delay,
TimeUnit unit) |
Map<Member,IScheduledFuture<?>> |
ScheduledExecutorServiceProxy.scheduleOnMembersAtFixedRate(Runnable command,
Collection<Member> members,
long initialDelay,
long period,
TimeUnit unit) |
Constructor and Description |
---|
InvokeOnMembers(NodeEngine nodeEngine,
String serviceName,
Supplier<Operation> operationFactory,
Collection<Member> targets) |
Modifier and Type | Method and Description |
---|---|
Member |
NodeEngine.getLocalMember()
Returns the local member.
|
Constructor and Description |
---|
DataAwareMessage(String topicName,
Data messageData,
long publishTime,
Member publishingMember,
SerializationService serializationService) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.