Versions in this module Expand all Collapse all v7 v7.2.89 Aug 2, 2026 v7.2.88 Aug 2, 2026 Changes in this version + var ErrExecutionResourceAlreadyBound = errors.New("execution resource is already bound") + var ErrInvalidExecutionResource = errors.New("invalid execution resource") + var ErrInvalidPendingDispatch = errors.New("invalid pending dispatch") + var ErrRegistryClosed = errors.New("execution registry is closed") + var ErrRegistryNotAccepting = errors.New("execution registry is not accepting dispatches") + type Freeze struct + BarrierRevision int64 + Executions []Observation + Revision int64 + type Observation struct + Accounted bool + CredentialID string + Model string + RequestID string + RequestKind string + StartedAt time.Time + type PendingDispatch struct + func (p *PendingDispatch) End() + type Registry struct + func New() *Registry + func (r *Registry) BeginDispatch() (*PendingDispatch, error) + func (r *Registry) Close() error + func (r *Registry) Drain(ctx context.Context) error + func (r *Registry) FreezeInFlight(_ time.Time) Freeze + func (r *Registry) Install(pending *PendingDispatch, spec ScopeSpec) (*Scope, error) + func (r *Registry) ObserveBarrier(revision int64) + func (r *Registry) SetReleaseSink(rawSink any) + func (r *Registry) WaitPending(ctx context.Context) error + type ReleaseGroup struct + CredentialID string + Model string + type ReleaseSink func(ReleaseGroup, int64) *ReleaseTicket + type ReleaseTicket struct + Group ReleaseGroup + Sequence int64 + func NewReleaseTicket(group ReleaseGroup, sequence int64, done <-chan struct{}) *ReleaseTicket + func (t *ReleaseTicket) Wait(ctx context.Context) error + type Scope struct + func (s *Scope) Bind(closeFn func() error) error + func (s *Scope) End(reason string) + func (s *Scope) EndWithRelease(_ string) *ReleaseTicket + type ScopeSpec struct + Accounted bool + CredentialID string + Kind string + Model string + RequestID string + StartedAt time.Time + type State uint32 + const StateAccepting + const StateClosed + const StateDraining
Go to main page