io.atomix.protocols.backup.proxy

Class PrimaryBackupProxy

java.lang.Object

io.atomix.primitive.proxy.impl.AbstractPrimitiveProxy

io.atomix.protocols.backup.proxy.PrimaryBackupProxy

All Implemented Interfaces:

io.atomix.primitive.proxy.PrimitiveProxy, io.atomix.primitive.proxy.PrimitiveProxyExecutor

public class PrimaryBackupProxy
extends io.atomix.primitive.proxy.impl.AbstractPrimitiveProxy

Primary-backup proxy.

Nested Class Summary

Nested classes/interfaces inherited from interface io.atomix.primitive.proxy.PrimitiveProxy

io.atomix.primitive.proxy.PrimitiveProxy.State

Constructor Summary

Constructors

Constructor and Description
PrimaryBackupProxy(String clientName, io.atomix.primitive.session.SessionId sessionId, io.atomix.primitive.PrimitiveType primitiveType, PrimitiveDescriptor descriptor, io.atomix.cluster.ClusterService clusterService, PrimaryBackupClientProtocol protocol, io.atomix.primitive.partition.PrimaryElection primaryElection, io.atomix.utils.concurrent.ThreadContext threadContext)

Method Summary

Modifier and Type	Method and Description
void	addEventListener(Consumer<io.atomix.primitive.event.PrimitiveEvent> listener)
void	addStateChangeListener(Consumer<io.atomix.primitive.proxy.PrimitiveProxy.State> listener)
CompletableFuture<Void>	close()
CompletableFuture<io.atomix.primitive.proxy.PrimitiveProxy>	connect()
CompletableFuture<byte[]>	execute(io.atomix.primitive.operation.PrimitiveOperation operation)
io.atomix.primitive.proxy.PrimitiveProxy.State	getState()
String	name()
void	removeEventListener(Consumer<io.atomix.primitive.event.PrimitiveEvent> listener)
void	removeStateChangeListener(Consumer<io.atomix.primitive.proxy.PrimitiveProxy.State> listener)
io.atomix.primitive.PrimitiveType	serviceType()
io.atomix.primitive.session.SessionId	sessionId()

Methods inherited from class io.atomix.primitive.proxy.impl.AbstractPrimitiveProxy

addEventListener, addEventListener, addEventListener, removeEventListener, removeEventListener, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.atomix.primitive.proxy.PrimitiveProxy

invoke, invoke, invoke, invoke

Methods inherited from interface io.atomix.primitive.proxy.PrimitiveProxyExecutor

execute, execute

Constructor Detail

PrimaryBackupProxy

public PrimaryBackupProxy(String clientName,
                          io.atomix.primitive.session.SessionId sessionId,
                          io.atomix.primitive.PrimitiveType primitiveType,
                          PrimitiveDescriptor descriptor,
                          io.atomix.cluster.ClusterService clusterService,
                          PrimaryBackupClientProtocol protocol,
                          io.atomix.primitive.partition.PrimaryElection primaryElection,
                          io.atomix.utils.concurrent.ThreadContext threadContext)

Method Detail

sessionId

public io.atomix.primitive.session.SessionId sessionId()

name

public String name()

serviceType

public io.atomix.primitive.PrimitiveType serviceType()

getState

public io.atomix.primitive.proxy.PrimitiveProxy.State getState()

addStateChangeListener

public void addStateChangeListener(Consumer<io.atomix.primitive.proxy.PrimitiveProxy.State> listener)

removeStateChangeListener

public void removeStateChangeListener(Consumer<io.atomix.primitive.proxy.PrimitiveProxy.State> listener)

execute

public CompletableFuture<byte[]> execute(io.atomix.primitive.operation.PrimitiveOperation operation)

addEventListener

public void addEventListener(Consumer<io.atomix.primitive.event.PrimitiveEvent> listener)

removeEventListener

public void removeEventListener(Consumer<io.atomix.primitive.event.PrimitiveEvent> listener)

connect

public CompletableFuture<io.atomix.primitive.proxy.PrimitiveProxy> connect()

close

public CompletableFuture<Void> close()