com.alipay.sofa.jraft.entity

Class LogEntry

java.lang.Object

com.alipay.sofa.jraft.entity.LogEntry

All Implemented Interfaces:

Checksum

public class LogEntry
extends Object
implements Checksum

A replica log entry.

Author:

boyan (boyan@alibaba-inc.com) 2018-Mar-12 3:13:02 PM

Field Summary

Fields

Modifier and Type	Field and Description
static ByteBuffer	EMPTY_DATA

Constructor Summary

Constructors

Constructor and Description
LogEntry()
LogEntry(EnumOutter.EntryType type)

Method Summary

Modifier and Type	Method and Description
long	checksum() Calculate a checksum value for this entity.
boolean	decode(byte[] content) Deprecated.
byte[]	encode() Deprecated.
boolean	equals(Object obj)
long	getChecksum() Returns the checksum of the log entry.
ByteBuffer	getData() Returns the log data, it's not read-only, you SHOULD take care it's modification and thread-safety by yourself.
LogId	getId()
List<PeerId>	getLearners()
List<PeerId>	getOldLearners()
List<PeerId>	getOldPeers()
List<PeerId>	getPeers()
ByteBuffer	getReadOnlyData() Creates a new, read-only byte buffer that shares this log entry's data buffer's content.
EnumOutter.EntryType	getType()
boolean	hasChecksum() Returns whether the log entry has a checksum.
int	hashCode()
boolean	hasLearners()
boolean	isCorrupted() Returns true when the log entry is corrupted, it means that the checksum is mismatch.
void	setChecksum(long checksum)
void	setData(ByteBuffer data)
void	setId(LogId id)
void	setLearners(List<PeerId> learners)
void	setOldLearners(List<PeerId> oldLearners)
void	setOldPeers(List<PeerId> oldPeers)
void	setPeers(List<PeerId> peers)
void	setType(EnumOutter.EntryType type)
ByteBuffer	sliceData() Creates a new byte buffer whose content is a shared subsequence of this log entry's data buffer's content.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.alipay.sofa.jraft.entity.Checksum

checksum, checksum

Field Detail

EMPTY_DATA

public static final ByteBuffer EMPTY_DATA

Constructor Detail

LogEntry

public LogEntry()

LogEntry

public LogEntry(EnumOutter.EntryType type)

Method Detail

getLearners

public List<PeerId> getLearners()

setLearners

public void setLearners(List<PeerId> learners)

getOldLearners

public List<PeerId> getOldLearners()

setOldLearners

public void setOldLearners(List<PeerId> oldLearners)

hasLearners

public boolean hasLearners()

checksum

public long checksum()

Description copied from interface: Checksum

Calculate a checksum value for this entity.

Specified by:

checksum in interface Checksum

Returns:

checksum value

encode

@Deprecated
public byte[] encode()

Deprecated.

Please use LogEntryEncoder instead.

Returns:

encoded byte array

decode

@Deprecated
public boolean decode(byte[] content)

Deprecated.

Please use LogEntryDecoder instead.

Returns:

whether success to decode

hasChecksum

public boolean hasChecksum()

Returns whether the log entry has a checksum.

Returns:

true when the log entry has checksum, otherwise returns false.

Since:

1.2.26

isCorrupted

public boolean isCorrupted()

Returns true when the log entry is corrupted, it means that the checksum is mismatch.

Returns:

true when the log entry is corrupted, otherwise returns false

Since:

1.2.6

getChecksum

public long getChecksum()

Returns the checksum of the log entry. You should use hasChecksum to check if it has checksum.

Returns:

checksum value

setChecksum

public void setChecksum(long checksum)

getType

public EnumOutter.EntryType getType()

setType

public void setType(EnumOutter.EntryType type)

getId

public LogId getId()

setId

public void setId(LogId id)

getPeers

public List<PeerId> getPeers()

setPeers

public void setPeers(List<PeerId> peers)

getOldPeers

public List<PeerId> getOldPeers()

setOldPeers

public void setOldPeers(List<PeerId> oldPeers)

getData

public ByteBuffer getData()

Returns the log data, it's not read-only, you SHOULD take care it's modification and thread-safety by yourself.

Returns:

the log data

sliceData

public ByteBuffer sliceData()

Creates a new byte buffer whose content is a shared subsequence of this log entry's data buffer's content.

Returns:

The new byte buffer

getReadOnlyData

public ByteBuffer getReadOnlyData()

Creates a new, read-only byte buffer that shares this log entry's data buffer's content.

Returns:

the new, read-only byte buffer

setData

public void setData(ByteBuffer data)

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object