Versions in this module Expand all Collapse all v0 v0.19.0 Aug 21, 2026 v0.18.1 Aug 20, 2026 Changes in this version + type Decision string + const DecisionCanceled + const DecisionGranted + const DecisionTimeout + type Engine struct + func New() *Engine + func (e *Engine) Await(subject, server string, spec Spec) (*Handle, bool, error) + func (e *Engine) Peek(subject, server string) (*Handle, bool) + func (e *Engine) Pending() int + func (e *Engine) Resolve(subject, server string, d Decision) error + type Handle struct + func (h *Handle) Deadline() time.Time + func (h *Handle) Server() string + func (h *Handle) Spec() Spec + func (h *Handle) Subject() string + func (h *Handle) WaitCtx(ctx context.Context) (Resolution, error) + type Resolution struct + At time.Time + Decision Decision + func (r Resolution) Granted() bool + type Spec struct + CorrelationID string + Session string + TaskID string + Timeout time.Duration
Go to main page