resolver

Documentation

Index

• Variables
• type CheckStateFunction
  • func CheckCompleted() CheckStateFunction
  • func CheckForState(expectedStates ...models.ExecutionStateType) CheckStateFunction
  • func CheckForTerminalStates() CheckStateFunction
  • func CheckForUnexpectedState(expectedStates ...models.ExecutionStateType) 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(*models.Execution) (bool, error)

func CheckCompleted

func CheckCompleted() CheckStateFunction

func CheckForState

func CheckForState(expectedStates ...models.ExecutionStateType) CheckStateFunction

func CheckForTerminalStates

func CheckForTerminalStates() CheckStateFunction

func CheckForUnexpectedState

func CheckForUnexpectedState(expectedStates ...models.ExecutionStateType) 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
}