Package io.microraft.persistence

Interface RaftStoreSerializer

public interface RaftStoreSerializer

Similarly to the RaftModelFactory, users of the RaftStore implementations must provide methods for converting a few of their types into binary data for persistence. This logic is expected to be relatively straightforward for the implementer, since similar logic will exist within the Transport. It should be noted that serialization performed here may need to be deserialized for an indefinite period and so evolution of any relevant types should be considered by the implementer.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	RaftStoreSerializer.Serializer<T>

Method Summary

Modifier and Type	Method	Description
RaftStoreSerializer.Serializer<io.microraft.model.log.LogEntry>	logEntrySerializer()
RaftStoreSerializer.Serializer<io.microraft.model.persistence.RaftEndpointPersistentState>	raftEndpointPersistentStateSerializer()
RaftStoreSerializer.Serializer<RaftEndpoint>	raftEndpointSerializer()
RaftStoreSerializer.Serializer<io.microraft.model.log.RaftGroupMembersView>	raftGroupMembersViewSerializer()
RaftStoreSerializer.Serializer<io.microraft.model.persistence.RaftTermPersistentState>	raftTermPersistentState()
RaftStoreSerializer.Serializer<io.microraft.model.log.SnapshotChunk>	snapshotChunkSerializer()

Method Details

raftGroupMembersViewSerializer

RaftStoreSerializer.Serializer<io.microraft.model.log.RaftGroupMembersView> raftGroupMembersViewSerializer()

raftEndpointSerializer

RaftStoreSerializer.Serializer<RaftEndpoint> raftEndpointSerializer()

logEntrySerializer

RaftStoreSerializer.Serializer<io.microraft.model.log.LogEntry> logEntrySerializer()

snapshotChunkSerializer

RaftStoreSerializer.Serializer<io.microraft.model.log.SnapshotChunk> snapshotChunkSerializer()

raftEndpointPersistentStateSerializer

RaftStoreSerializer.Serializer<io.microraft.model.persistence.RaftEndpointPersistentState> raftEndpointPersistentStateSerializer()

raftTermPersistentState

RaftStoreSerializer.Serializer<io.microraft.model.persistence.RaftTermPersistentState> raftTermPersistentState()