process

Documentation

Index

• func NewSQLProcessStore(sqlConfig config.SQL, logger log.Logger) (persistence.ProcessStore, error)
• type HandleStateDecisionRequest
• type HandleStateDecisionResponse

Functions

func NewSQLProcessStore

func NewSQLProcessStore(sqlConfig config.SQL, logger log.Logger) (persistence.ProcessStore, error)

Types

type HandleStateDecisionRequest

type HandleStateDecisionRequest struct {
	Namespace          string
	ProcessId          string
	ProcessType        string
	ProcessExecutionId uuid.UUID
	StateDecision      xcapi.StateDecision
	AppDatabaseConfig  *data_models.InternalAppDatabaseConfig
	WorkerUrl          string

	// for ProcessExecutionRowForUpdate
	ProcessExecutionRowStateExecutionSequenceMaps *data_models.StateExecutionSequenceMapsJson
	ProcessExecutionRowGracefulCompleteRequested  bool
	ProcessExecutionRowStatus                     data_models.ProcessExecutionStatus

	TaskShardId int32
}

type HandleStateDecisionResponse

type HandleStateDecisionResponse struct {
	HasNewImmediateTask bool

	// for ProcessExecutionRowForUpdate to update
	ProcessExecutionRowNewStateExecutionSequenceMaps *data_models.StateExecutionSequenceMapsJson
	ProcessExecutionRowNewGracefulCompleteRequested  bool
	ProcessExecutionRowNewStatus                     data_models.ProcessExecutionStatus
}