io.openmessaging.storage.dledger.statemachine

Interface StateMachine

public interface StateMachine

Finite state machine, which should be implemented by user.

Method Summary

Modifier and Type	Method and Description
default String	generateDLedgerId(String dLedgerGroupId, String dLedgerSelfId) User must create DLedgerId by this method, it will generate the DLedgerId with format like that: 'dLedgerGroupId#dLedgerSelfId'
String	getBindDLedgerId() User should return the DLedgerId which can be created by the method 'StateMachine#generateDLedgerId'
void	onApply(CommittedEntryIterator iter) Update the user statemachine with a batch a tasks that can be accessed through |iterator|.
void	onError(DLedgerException error) Once a critical error occurs, disallow any task enter the Dledger node until the error has been fixed and restart it.
void	onShutdown() Invoked once when the raft node was shut down.
boolean	onSnapshotLoad(SnapshotReader reader) User defined snapshot load function.
boolean	onSnapshotSave(SnapshotWriter writer) User defined snapshot generate function.

Method Detail

onApply

void onApply(CommittedEntryIterator iter)

Update the user statemachine with a batch a tasks that can be accessed through |iterator|.

Parameters:

iter - iterator of committed entry

onSnapshotSave

boolean onSnapshotSave(SnapshotWriter writer)

User defined snapshot generate function.

Parameters:

writer - snapshot writer

onSnapshotLoad

boolean onSnapshotLoad(SnapshotReader reader)

User defined snapshot load function.

Parameters:

reader - snapshot reader

Returns:

true on success

onShutdown

void onShutdown()

Invoked once when the raft node was shut down. Default do nothing

onError

void onError(DLedgerException error)

Once a critical error occurs, disallow any task enter the Dledger node until the error has been fixed and restart it.

Parameters:

error - DLedger error message

generateDLedgerId

default String generateDLedgerId(String dLedgerGroupId,
                                 String dLedgerSelfId)

User must create DLedgerId by this method, it will generate the DLedgerId with format like that: 'dLedgerGroupId#dLedgerSelfId'

Parameters:

dLedgerGroupId - the group id of the DLedgerServer

dLedgerSelfId - the self id of the DLedgerServer

Returns:

generated unique DLedgerId

getBindDLedgerId

String getBindDLedgerId()

User should return the DLedgerId which can be created by the method 'StateMachine#generateDLedgerId'

Returns:

DLedgerId