io.seata.saga.engine.store.impl

Class StateLogStoreImpl

java.lang.Object

io.seata.saga.engine.store.impl.StateLogStoreImpl

All Implemented Interfaces:

StateLogStore

public class StateLogStoreImpl
extends Object
implements StateLogStore

Method Summary

Modifier and Type	Method and Description
void	clearUp(ProcessContext context) clear the LocalThread
StateInstance	getStateInstance(String stateInstanceId, String machineInstId) Get state instance
StateMachineInstance	getStateMachineInstance(String stateMachineInstanceId) Get state machine instance
StateMachineInstance	getStateMachineInstanceByBusinessKey(String businessKey, String tenantId) Get state machine instance by businessKey
List<StateInstance>	queryStateInstanceListByMachineInstanceId(String stateMachineInstanceId) Get a list of state instances by state machine instance id
List<StateMachineInstance>	queryStateMachineInstanceByParentId(String parentId) Query the list of state machine instances by parent id
void	recordStateFinished(StateInstance stateInstance, ProcessContext context) Record state execution end event
void	recordStateMachineFinished(StateMachineInstance machineInstance, ProcessContext context) Record status end event
void	recordStateMachineRestarted(StateMachineInstance machineInstance, ProcessContext context) Record state machine restarted
void	recordStateMachineStarted(StateMachineInstance machineInstance, ProcessContext context) Record state machine startup events
void	recordStateStarted(StateInstance stateInstance, ProcessContext context) Record state start execution event
StateLogStore	unwrap()
static StateLogStore	wrap(StateLogStore actual)

Methods inherited from class java.lang.Object

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

Method Detail

recordStateMachineStarted

public void recordStateMachineStarted(StateMachineInstance machineInstance,
                                      ProcessContext context)

Description copied from interface: StateLogStore

Record state machine startup events

Specified by:

recordStateMachineStarted in interface StateLogStore

Parameters:

machineInstance - the state machine instance

context - the state machine process context

recordStateMachineFinished

public void recordStateMachineFinished(StateMachineInstance machineInstance,
                                       ProcessContext context)

Description copied from interface: StateLogStore

Record status end event

Specified by:

recordStateMachineFinished in interface StateLogStore

Parameters:

machineInstance - the state machine instance

context - the state machine process context

recordStateMachineRestarted

public void recordStateMachineRestarted(StateMachineInstance machineInstance,
                                        ProcessContext context)

Description copied from interface: StateLogStore

Record state machine restarted

Specified by:

recordStateMachineRestarted in interface StateLogStore

Parameters:

machineInstance - the state machine instance

context - the state machine process context

recordStateStarted

public void recordStateStarted(StateInstance stateInstance,
                               ProcessContext context)

Description copied from interface: StateLogStore

Record state start execution event

Specified by:

recordStateStarted in interface StateLogStore

Parameters:

stateInstance - the state machine instance

context - the state machine process context

recordStateFinished

public void recordStateFinished(StateInstance stateInstance,
                                ProcessContext context)

Description copied from interface: StateLogStore

Record state execution end event

Specified by:

recordStateFinished in interface StateLogStore

Parameters:

stateInstance - the state machine instance

context - the state machine process context

getStateMachineInstance

public StateMachineInstance getStateMachineInstance(String stateMachineInstanceId)

Description copied from interface: StateLogStore

Get state machine instance

Specified by:

getStateMachineInstance in interface StateLogStore

Parameters:

stateMachineInstanceId - the state machine instance id

Returns:

the state machine instance

getStateMachineInstanceByBusinessKey

public StateMachineInstance getStateMachineInstanceByBusinessKey(String businessKey,
                                                                 String tenantId)

Description copied from interface: StateLogStore

Get state machine instance by businessKey

Specified by:

getStateMachineInstanceByBusinessKey in interface StateLogStore

Parameters:

businessKey - the businessKey

tenantId - the tenant id

Returns:

state machine message

queryStateMachineInstanceByParentId

public List<StateMachineInstance> queryStateMachineInstanceByParentId(String parentId)

Description copied from interface: StateLogStore

Query the list of state machine instances by parent id

Specified by:

queryStateMachineInstanceByParentId in interface StateLogStore

Parameters:

parentId - the state machine parent's id

Returns:

the state machine instance list

getStateInstance

public StateInstance getStateInstance(String stateInstanceId,
                                      String machineInstId)

Description copied from interface: StateLogStore

Get state instance

Specified by:

getStateInstance in interface StateLogStore

Parameters:

stateInstanceId - the state instance id

machineInstId - the machine instance id

Returns:

state instance message

queryStateInstanceListByMachineInstanceId

public List<StateInstance> queryStateInstanceListByMachineInstanceId(String stateMachineInstanceId)

Description copied from interface: StateLogStore

Get a list of state instances by state machine instance id

Specified by:

queryStateInstanceListByMachineInstanceId in interface StateLogStore

Parameters:

stateMachineInstanceId - the state machine instance id

Returns:

state instance list

clearUp

public void clearUp(ProcessContext context)

Description copied from interface: StateLogStore

clear the LocalThread

Specified by:

clearUp in interface StateLogStore

Parameters:

context - the context

wrap

public static StateLogStore wrap(StateLogStore actual)

unwrap

public StateLogStore unwrap()