resolver

package
v1.2.2-rc3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 1, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL