resolver

Documentation

Index

• Variables
• type CheckStateFunction
  • func CheckCompleted() CheckStateFunction
  • func CheckForState(expectedStates ...store.LocalExecutionStateType) CheckStateFunction
  • func CheckForTerminalStates() CheckStateFunction
  • func CheckForUnexpectedState(expectedStates ...store.LocalExecutionStateType) CheckStateFunction
• type StateResolver
  • func NewStateResolver(params StateResolverParams) *StateResolver
  • func (r *StateResolver) Wait(ctx context.Context, executionID string, ...) error
• type StateResolverParams

Variables

var DefaultStateResolverParams = StateResolverParams{
	MaxWaitAttempts: 500,
	WaitDelay:       20 * time.Millisecond,
}

Types

type CheckStateFunction

type CheckStateFunction func(store.LocalExecutionState) (bool, error)

func CheckCompleted

func CheckCompleted() CheckStateFunction

func CheckForState

func CheckForState(expectedStates ...store.LocalExecutionStateType) CheckStateFunction

func CheckForTerminalStates

func CheckForTerminalStates() CheckStateFunction

func CheckForUnexpectedState

func CheckForUnexpectedState(expectedStates ...store.LocalExecutionStateType) CheckStateFunction

type StateResolver

type StateResolver struct {
	// contains filtered or unexported fields
}

func NewStateResolver

func NewStateResolver(params StateResolverParams) *StateResolver

func (*StateResolver) Wait

func (r *StateResolver) Wait(
	ctx context.Context,
	executionID string,
	checkStateFunctions ...CheckStateFunction) error

type StateResolverParams

type StateResolverParams struct {
	ExecutionStore  store.ExecutionStore
	MaxWaitAttempts int
	WaitDelay       time.Duration
}