Versions in this module Expand all Collapse all v0 v0.6.1 Apr 29, 2026 v0.6.0 Apr 29, 2026 Changes in this version + type Acquirer interface + Acquire func(context.Context) (context.Context, func(), error) + type Event struct + Component string + Dependency string + Err error + InFlight int + MaxInflight int + Outcome Outcome + Resource string + Strategy string + Wait time.Duration + type Limiter struct + func NewLimiter(maxInflight int, timeout time.Duration) *Limiter + func NewLimiterWithOptions(maxInflight int, timeout time.Duration, opts Options) *Limiter + func (l *Limiter) Acquire(ctx context.Context) (context.Context, func(), error) + func (l *Limiter) Stats(name string) Stats + type NopObserver struct + func (NopObserver) OnBackpressure(context.Context, Event) + type Observer interface + OnBackpressure func(ctx context.Context, event Event) + type Options struct + Component string + Dependency string + Observer Observer + type Outcome string + const OutcomeAcquired + const OutcomeReleased + const OutcomeTimeout + type Stats struct + Component string + Degraded bool + Dependency string + Enabled bool + InFlight int + MaxInflight int + Name string + Reason string + Strategy string + TimeoutMillis int64
Go to main page