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 ¶
func CheckCompleted ¶
func CheckCompleted() CheckStateFunction
func CheckForState ¶
func CheckForState(expectedStates ...store.ExecutionState) CheckStateFunction
func CheckForTerminalStates ¶
func CheckForTerminalStates() CheckStateFunction
func CheckForUnexpectedState ¶
func CheckForUnexpectedState(expectedStates ...store.ExecutionState) 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 }
Click to show internal directories.
Click to hide internal directories.