wait

Oct 3, 2026

Changes in this version

+ const DefaultPollInterval

+ const MaxPollInterval

+ var ErrEventStreamEnded = errors.New("wait: event stream ended before a terminal status")

+ func ExtractStatus(doc PollDoc, query string) (string, bool)

+ func IsUnknownStatus(err error) bool

+ type ErrUnknownStatus struct

+ Query string

+ Status string

+ func (e *ErrUnknownStatus) Error() string

+ type EventLoopSpec struct

+ MatchField string

+ Pending []string

+ StatusQuery string

+ Terminal map[string]contract.ResultOutcome

+ Timeout time.Duration

+ type EventStream interface

+ Recv func(ctx context.Context) (PollDoc, error)

+ type LoopSpec struct

+ Interval time.Duration

+ Pending []string

+ StatusQuery string

+ Terminal map[string]contract.ResultOutcome

+ Timeout time.Duration

+ type Outcome struct

+ Attempts int

+ Outcome contract.ResultOutcome

+ Status string

+ TimedOut bool

+ func Run(ctx context.Context, spec LoopSpec, poll Poller) (Outcome, error)

+ func RunEvent(ctx context.Context, spec EventLoopSpec, resource string, stream EventStream) (Outcome, error)

+ type PollDoc map[string]any

+ type Poller func(ctx context.Context) (PollDoc, error)