org.opendaylight.controller.cluster.raft.messages

Class AppendEntries

java.lang.Object

org.opendaylight.controller.cluster.raft.messages.AbstractRaftRPC

org.opendaylight.controller.cluster.raft.messages.AppendEntries

All Implemented Interfaces:

akka.dispatch.ControlMessage, Serializable, RaftRPC

public class AppendEntries
extends AbstractRaftRPC

Invoked by leader to replicate log entries (§5.3); also used as heartbeat (§5.2).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AppendEntries(long term, @NonNull String leaderId, long prevLogIndex, long prevLogTerm, @NonNull List<ReplicatedLogEntry> entries, long leaderCommit, long replicatedToAllIndex, short payloadVersion)
AppendEntries(long term, @NonNull String leaderId, long prevLogIndex, long prevLogTerm, @NonNull List<ReplicatedLogEntry> entries, long leaderCommit, long replicatedToAllIndex, short payloadVersion, short recipientRaftVersion, @Nullable String leaderAddress)

Method Summary

Modifier and Type	Method and Description
@NonNull List<ReplicatedLogEntry>	getEntries()
Optional<String>	getLeaderAddress()
long	getLeaderCommit()
@NonNull String	getLeaderId()
short	getLeaderRaftVersion()
short	getPayloadVersion()
long	getPrevLogIndex()
long	getPrevLogTerm()
long	getReplicatedToAllIndex()
String	toString()

Methods inherited from class org.opendaylight.controller.cluster.raft.messages.AbstractRaftRPC

getTerm, setTerm

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AppendEntries

public AppendEntries(long term,
                     @NonNull String leaderId,
                     long prevLogIndex,
                     long prevLogTerm,
                     @NonNull List<ReplicatedLogEntry> entries,
                     long leaderCommit,
                     long replicatedToAllIndex,
                     short payloadVersion,
                     short recipientRaftVersion,
                     @Nullable String leaderAddress)

AppendEntries

public AppendEntries(long term,
                     @NonNull String leaderId,
                     long prevLogIndex,
                     long prevLogTerm,
                     @NonNull List<ReplicatedLogEntry> entries,
                     long leaderCommit,
                     long replicatedToAllIndex,
                     short payloadVersion)

Method Detail

getLeaderId

public @NonNull String getLeaderId()

getPrevLogIndex

public long getPrevLogIndex()

getPrevLogTerm

public long getPrevLogTerm()

getEntries

public @NonNull List<ReplicatedLogEntry> getEntries()

getLeaderCommit

public long getLeaderCommit()

getReplicatedToAllIndex

public long getReplicatedToAllIndex()

getPayloadVersion

public short getPayloadVersion()

getLeaderAddress

public Optional<String> getLeaderAddress()

getLeaderRaftVersion

public short getLeaderRaftVersion()

toString

public String toString()

Overrides:

toString in class Object