io.atomix.protocols.raft.partition

Class RaftPartition

java.lang.Object

io.atomix.protocols.raft.partition.RaftPartition

All Implemented Interfaces:

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

public class RaftPartition
extends Object
implements io.atomix.primitive.partition.Partition<RaftProtocol>

Abstract partition.

Constructor Summary

Constructors

Constructor and Description
RaftPartition(io.atomix.primitive.partition.PartitionId partitionId, io.atomix.storage.StorageLevel storageLevel, File dataDirectory)

Method Summary

Modifier and Type	Method and Description
Collection<io.atomix.cluster.NodeId>	backups()
File	dataDirectory() Returns the partition data directory.
CompletableFuture<Void>	delete() Deletes the partition.
io.atomix.primitive.PrimitiveClient<RaftProtocol>	getPrimitiveClient()
io.atomix.primitive.partition.PartitionId	id()
Collection<io.atomix.cluster.NodeId>	members() Returns the identifiers of partition members.
String	name() Returns the partition name.
io.atomix.cluster.NodeId	primary()
io.atomix.storage.StorageLevel	storageLevel() Returns the Raft partition storage level.
long	term()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RaftPartition

public RaftPartition(io.atomix.primitive.partition.PartitionId partitionId,
                     io.atomix.storage.StorageLevel storageLevel,
                     File dataDirectory)

Method Detail

id

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

Specified by:

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

name

public String name()

Returns the partition name.

Returns:

the partition name

term

public long term()

Specified by:

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

primary

public io.atomix.cluster.NodeId primary()

Specified by:

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

backups

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

Specified by:

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

members

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

Returns the identifiers of partition members.

Returns:

partition member instance ids

storageLevel

public io.atomix.storage.StorageLevel storageLevel()

Returns the Raft partition storage level.

Returns:

the Raft partition storage level

dataDirectory

public File dataDirectory()

Returns the partition data directory.

Returns:

the partition data directory

getPrimitiveClient

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

Specified by:

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

delete

public CompletableFuture<Void> delete()

Deletes the partition.

Returns:

future to be completed once the partition has been deleted

toString

public String toString()

Overrides:

toString in class Object