Module org.jgroups.raft

Package org.jgroups.protocols.raft

Class AppendEntriesRequest

java.lang.Object

org.jgroups.Header

org.jgroups.protocols.raft.RaftHeader

org.jgroups.protocols.raft.AppendEntriesRequest

All Implemented Interfaces:

org.jgroups.Constructable<org.jgroups.Header>, org.jgroups.util.SizeStreamable, org.jgroups.util.Streamable

public class AppendEntriesRequest
extends RaftHeader

Used to send AppendEntries messages to cluster members. The log entries are contained in actual payload of the message, not in this header.

Since:

0.1

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field	Description
protected long	entry_term
protected org.jgroups.Address	leader
protected long	leader_commit
protected long	prev_log_index
protected long	prev_log_term

Fields inherited from class org.jgroups.protocols.raft.RaftHeader

curr_term

Fields inherited from class org.jgroups.Header

prot_id

Constructor Summary

Constructors

Constructor	Description
AppendEntriesRequest()
AppendEntriesRequest(org.jgroups.Address leader, long current_term, long prev_log_index, long prev_log_term, long entry_term, long leader_commit)

Method Summary

Modifier and Type	Method	Description
Supplier<? extends org.jgroups.Header>	create()
short	getMagicId()
void	readFrom(DataInput in)
int	serializedSize()
String	toString()
void	writeTo(DataOutput out)

Methods inherited from class org.jgroups.protocols.raft.RaftHeader

currTerm, currTerm

Methods inherited from class org.jgroups.Header

getProtId, setProtId

Methods inherited from class java.lang.Object

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

Field Details

leader

protected org.jgroups.Address leader

entry_term

protected long entry_term

prev_log_index

protected long prev_log_index

prev_log_term

protected long prev_log_term

leader_commit

protected long leader_commit

Constructor Details

AppendEntriesRequest

public AppendEntriesRequest()

AppendEntriesRequest

public AppendEntriesRequest(org.jgroups.Address leader,
 long current_term,
 long prev_log_index,
 long prev_log_term,
 long entry_term,
 long leader_commit)

Method Details

getMagicId

public short getMagicId()

Specified by:

getMagicId in class org.jgroups.Header

create

public Supplier<? extends org.jgroups.Header> create()

serializedSize

public int serializedSize()

Specified by:

serializedSize in interface org.jgroups.util.SizeStreamable

Overrides:

serializedSize in class RaftHeader

writeTo

public void writeTo(DataOutput out)
             throws IOException

Specified by:

writeTo in interface org.jgroups.util.Streamable

Overrides:

writeTo in class RaftHeader

Throws:

IOException

readFrom

public void readFrom(DataInput in)
              throws IOException,
ClassNotFoundException

Specified by:

readFrom in interface org.jgroups.util.Streamable

Overrides:

readFrom in class RaftHeader

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class RaftHeader