execute

Documentation

Index

• Constants
• type DeduplicationAction
• type DeduplicationBargeInKey
• type DelegationTokenAwaitKey
• type RegisterVariant
• type SMDelegatedTokenRequest
  • func (s *SMDelegatedTokenRequest) GetStateMachineDeclaration() smachine.StateMachineDeclaration
  • func (s *SMDelegatedTokenRequest) GetSubroutineInitState(ctx smachine.SubroutineStartContext) smachine.InitFunc
  • func (s *SMDelegatedTokenRequest) Init(ctx smachine.InitializationContext) smachine.StateUpdate
• type SMExecute
  • func (s *SMExecute) GetStateMachineDeclaration() smachine.StateMachineDeclaration
  • func (s *SMExecute) Init(ctx smachine.InitializationContext) smachine.StateUpdate
  • func (s *SMExecute) StepWaitExecutionResult(ctx smachine.ExecutionContext) smachine.StateUpdate

Constants

const MaxOutgoingSendCount = 3

Types

type DeduplicationAction

type DeduplicationAction byte

const (
	Stop DeduplicationAction = iota + 1
	SendResultAndStop
	DeduplicateThroughPreviousExecutor
	ContinueExecute
)

type DeduplicationBargeInKey

type DeduplicationBargeInKey struct {
	LookAt   pulse.Number
	Callee   reference.Global
	Outgoing reference.Global
}

type DelegationTokenAwaitKey

type DelegationTokenAwaitKey struct {
	Outgoing reference.Global
}

type RegisterVariant

type RegisterVariant int

const (
	RegisterLifeLine RegisterVariant = iota
	RegisterOutgoingRequest
	RegisterOutgoingResult
	RegisterIncomingResult
)

type SMDelegatedTokenRequest

type SMDelegatedTokenRequest struct {
	// input arguments
	Meta           *rms.Meta
	RequestPayload rms.VDelegatedCallRequest
	// contains filtered or unexported fields
}

func (*SMDelegatedTokenRequest) GetStateMachineDeclaration

func (s *SMDelegatedTokenRequest) GetStateMachineDeclaration() smachine.StateMachineDeclaration

func (*SMDelegatedTokenRequest) GetSubroutineInitState

func (s *SMDelegatedTokenRequest) GetSubroutineInitState(ctx smachine.SubroutineStartContext) smachine.InitFunc

func (*SMDelegatedTokenRequest) Init

func (s *SMDelegatedTokenRequest) Init(ctx smachine.InitializationContext) smachine.StateUpdate

type SMExecute

type SMExecute struct {
	// input arguments
	Meta    *rms.Meta
	Payload *rms.VCallRequest
	// contains filtered or unexported fields
}

func (*SMExecute) GetStateMachineDeclaration

func (s *SMExecute) GetStateMachineDeclaration() smachine.StateMachineDeclaration

func (*SMExecute) Init

func (s *SMExecute) Init(ctx smachine.InitializationContext) smachine.StateUpdate

func (*SMExecute) StepWaitExecutionResult

func (s *SMExecute) StepWaitExecutionResult(ctx smachine.ExecutionContext) smachine.StateUpdate