io.atomix.protocols.backup.partition

Class PrimaryBackupPartition

java.lang.Object

io.atomix.protocols.backup.partition.PrimaryBackupPartition

All Implemented Interfaces:

io.atomix.primitive.partition.Partition<MultiPrimaryProtocol>

public class PrimaryBackupPartition
extends Object
implements io.atomix.primitive.partition.Partition<MultiPrimaryProtocol>

Primary-backup partition.

Constructor Summary

Constructors

Constructor and Description
PrimaryBackupPartition(io.atomix.primitive.partition.PartitionId partitionId)

Method Summary

Modifier and Type	Method and Description
Collection<io.atomix.cluster.NodeId>	backups()
CompletableFuture<Void>	close() Closes the primary-backup partition.
io.atomix.primitive.PrimitiveClient<MultiPrimaryProtocol>	getPrimitiveClient()
io.atomix.primitive.partition.PartitionId	id()
String	name() Returns the partition name.
io.atomix.cluster.NodeId	primary()
long	term()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

PrimaryBackupPartition

public PrimaryBackupPartition(io.atomix.primitive.partition.PartitionId partitionId)

Method Detail

id

public io.atomix.primitive.partition.PartitionId id()

Specified by:

id in interface io.atomix.primitive.partition.Partition<MultiPrimaryProtocol>

term

public long term()

Specified by:

term in interface io.atomix.primitive.partition.Partition<MultiPrimaryProtocol>

primary

public io.atomix.cluster.NodeId primary()

Specified by:

primary in interface io.atomix.primitive.partition.Partition<MultiPrimaryProtocol>

backups

public Collection<io.atomix.cluster.NodeId> backups()

Specified by:

backups in interface io.atomix.primitive.partition.Partition<MultiPrimaryProtocol>

name

public String name()

Returns the partition name.

Returns:

the partition name

getPrimitiveClient

public io.atomix.primitive.PrimitiveClient<MultiPrimaryProtocol> getPrimitiveClient()

Specified by:

getPrimitiveClient in interface io.atomix.primitive.partition.Partition<MultiPrimaryProtocol>

close

public CompletableFuture<Void> close()

Closes the primary-backup partition.

toString

public String toString()

Overrides:

toString in class Object