Check if all map-wide events like {@link EntryEventType#CLEAR_ALL} or {@link EntryEventType#EVICT_ALL} were received. If an event is received, we popu

Returns list of nodes currently in ES cluster

In handling types (e.g. type -> class mapping) we don't care about cases - we use lower cases. <p> But we want to present Data Connections to the us

We make sure that `notifyResponse` can not be called by multiple threads concurrently Only ones that can set a null on `sentConnection` can notify the

@param response return true if invocation completed

Builds a {@link Measurement} instance based on timestamp, value and the metric descriptor in map form.

An implementation must be thread safe if the record might be accessed from multiple threads.

Called after the last call to combine on a specific instance. Enables disposing of the intermediary state. This should be a very fast operation that j

Calls {@link ClientConnectionProcessListener#attemptingToConnectToAddress(Address)} on all listeners after translating the target address.

The returned connection could be different from the one passed to this method if there is already an existing connection to the given member.

Called if the observed {@link RecordStore} is cleared

Notify client engine that a client with given uuid required a resource (lock) on this member @param uuid client uuid

Updates the current cluster ID used for tracking the {@link SubsetMembersView}.

Called when cluster state is changed @param newState new cluster state @see ClusterState

Called during the commit phase of the cluster state change transaction, just after updating the value of the cluster state on the local member, while

Invoked on registered listeners after the new cluster version has been applied. Listeners are executed synchronously immediately after {@code ClusterS

Called after the last call to combine on a specific instance. Enables disposing of the intermediary state. This should be a very fast operation that j

Called after all executions are completed. @param values map of Member-Response pairs

Observes the completion event from the {@link Observable} it is registered with. Only an observer attached to a batch job will ever see this event. Un

Removes the currently set {@link ClassLoader} from this thread's {@link ThreadLocal} variable, if it matches the provided {@link ClassLoader} instance

Called when a connection is established. @param connectedSocket related socket @throws IOException in case of any exceptional case

Deals with cleaning up a closed connection. This method should only be called once by the {@link Connection#close(String, Throwable)} method where it

Called when a new entry is created. @param key the key @param value the value

Called when the observed {@link RecordStore} is being destroyed. The observer should release all resources. The implementations of this method should

Called when the given client endpoint is successfully authenticated. <p> This call performs necessary statistics collection for the given endpoint typ

Called when the given client endpoint is destroyed. <p> This call performs necessary statistics collection for the given endpoint type if the endpoint

{@inheritDoc} Notifies all sent migration tasks that the migration failed.

Accepts the heartbeat message from {@code member} created at {@code timestamp}. The timestamp must be related to the cluster clock, not the local cloc

Called when initial cluster state is received while joining the cluster. @param initialState initial cluster state

Called when proxy is created. Overriding implementations can add initialization specific logic into this method like registering a listener, creating