io.atomix.protocols.backup

Class PrimaryBackupClient

java.lang.Object

io.atomix.protocols.backup.PrimaryBackupClient

All Implemented Interfaces:

io.atomix.primitive.PrimitiveClient<MultiPrimaryProtocol>

public class PrimaryBackupClient
extends Object
implements io.atomix.primitive.PrimitiveClient<MultiPrimaryProtocol>

Primary-backup client.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PrimaryBackupClient.Builder Primary-backup client builder.

Constructor Summary

Constructors

Constructor and Description
PrimaryBackupClient(String clientName, io.atomix.cluster.ClusterService clusterService, PrimaryBackupClientProtocol protocol, io.atomix.primitive.partition.PrimaryElection primaryElection, io.atomix.primitive.session.SessionIdService sessionIdService, io.atomix.utils.concurrent.ThreadContextFactory threadContextFactory)

Method Summary

Modifier and Type	Method and Description
static PrimaryBackupClient.Builder	builder() Returns a new primary-backup client builder.
CompletableFuture<Void>	close() Closes the primary-backup client.
CompletableFuture<Set<String>>	getPrimitives(io.atomix.primitive.PrimitiveType primitiveType)
io.atomix.primitive.proxy.PrimitiveProxy	newProxy(String primitiveName, io.atomix.primitive.PrimitiveType primitiveType, MultiPrimaryProtocol primitiveProtocol)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PrimaryBackupClient

public PrimaryBackupClient(String clientName,
                           io.atomix.cluster.ClusterService clusterService,
                           PrimaryBackupClientProtocol protocol,
                           io.atomix.primitive.partition.PrimaryElection primaryElection,
                           io.atomix.primitive.session.SessionIdService sessionIdService,
                           io.atomix.utils.concurrent.ThreadContextFactory threadContextFactory)

Method Detail

builder

public static PrimaryBackupClient.Builder builder()

Returns a new primary-backup client builder.

Returns:

a new primary-backup client builder

newProxy

public io.atomix.primitive.proxy.PrimitiveProxy newProxy(String primitiveName,
                                                         io.atomix.primitive.PrimitiveType primitiveType,
                                                         MultiPrimaryProtocol primitiveProtocol)

Specified by:

newProxy in interface io.atomix.primitive.PrimitiveClient<MultiPrimaryProtocol>

getPrimitives

public CompletableFuture<Set<String>> getPrimitives(io.atomix.primitive.PrimitiveType primitiveType)

Specified by:

getPrimitives in interface io.atomix.primitive.PrimitiveClient<MultiPrimaryProtocol>

close

public CompletableFuture<Void> close()

Closes the primary-backup client.

Returns:

future to be completed once the client is closed