backpressure

type Acquirer interface {
	Acquire(context.Context) (context.Context, func(), error)
}

type Event struct {
	Component   string
	Dependency  string
	Resource    string
	Strategy    string
	Outcome     Outcome
	Wait        time.Duration
	InFlight    int
	MaxInflight int
	Err         error
}

type Limiter struct {
	// contains filtered or unexported fields
}

type NopObserver struct{}

type Observer interface {
	OnBackpressure(ctx context.Context, event Event)
}

type Options struct {
	Component  string
	Dependency string
	Observer   Observer
}

type Outcome string

type Stats struct {
	Component     string
	Name          string
	Dependency    string
	Strategy      string
	Enabled       bool
	MaxInflight   int
	InFlight      int
	TimeoutMillis int64
	Degraded      bool
	Reason        string
}