io.atomix.protocols.backup.protocol

Interface PrimaryBackupClientProtocol

public interface PrimaryBackupClientProtocol

Primary-backup protocol client.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<CloseResponse>	close(io.atomix.cluster.NodeId nodeId, CloseRequest request) Sends a close request to the given node.
CompletableFuture<ExecuteResponse>	execute(io.atomix.cluster.NodeId nodeId, ExecuteRequest request) Sends an execute request to the given node.
CompletableFuture<MetadataResponse>	metadata(io.atomix.cluster.NodeId nodeId, MetadataRequest request) Sends a metadata request to the given node.
void	registerEventListener(io.atomix.primitive.session.SessionId sessionId, Consumer<io.atomix.primitive.event.PrimitiveEvent> listener, Executor executor) Registers a publish request listener.
void	unregisterEventListener(io.atomix.primitive.session.SessionId sessionId) Unregisters the publish request listener for the given session.

Method Detail

execute

CompletableFuture<ExecuteResponse> execute(io.atomix.cluster.NodeId nodeId,
                                           ExecuteRequest request)

Sends an execute request to the given node.

Parameters:

nodeId - the node to which to send the request

request - the request to send

Returns:

a future to be completed with the response

metadata

CompletableFuture<MetadataResponse> metadata(io.atomix.cluster.NodeId nodeId,
                                             MetadataRequest request)

Sends a metadata request to the given node.

Parameters:

nodeId - the node to which to send the request

request - the request to send

Returns:

a future to be completed with the response

close

CompletableFuture<CloseResponse> close(io.atomix.cluster.NodeId nodeId,
                                       CloseRequest request)

Sends a close request to the given node.

Parameters:

nodeId - the node to which to send the request

request - the request to send

Returns:

a future to be completed with the response

registerEventListener

void registerEventListener(io.atomix.primitive.session.SessionId sessionId,
                           Consumer<io.atomix.primitive.event.PrimitiveEvent> listener,
                           Executor executor)

Registers a publish request listener.

Parameters:

sessionId - the session for which to listen for the publish request

listener - the listener to register

executor - the executor with which to execute the listener callback

unregisterEventListener

void unregisterEventListener(io.atomix.primitive.session.SessionId sessionId)

Unregisters the publish request listener for the given session.

Parameters:

sessionId - the session for which to unregister the listener