Documentation
¶
Overview ¶
Package compatible wires generation-local per-instance compatible backend concurrency limits into the attempt authority coordinator.
Index ¶
- Constants
- type AttemptProvider
- func (p *AttemptProvider) AdmitAttempt(ctx context.Context, in authority.AttemptAdmission) (authority.Decision, error)
- func (p *AttemptProvider) ReleaseAttempt(_ context.Context, in authority.AttemptRelease) error
- func (p *AttemptProvider) SettleAttempt(_ context.Context, in authority.AttemptSettlement) (authority.Settlement, error)
- type Limits
- type Runtime
Constants ¶
View Source
const (
ProviderID = "compatible-admission"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AttemptProvider ¶
type AttemptProvider struct {
// contains filtered or unexported fields
}
AttemptProvider enforces per-compatible-instance limits at the backend-attempt seam.
func NewAttemptProvider ¶
func NewAttemptProvider(rt *Runtime) *AttemptProvider
NewAttemptProvider returns a provider backed by rt. Nil rt is a no-op provider.
func (*AttemptProvider) AdmitAttempt ¶
func (p *AttemptProvider) AdmitAttempt(ctx context.Context, in authority.AttemptAdmission) (authority.Decision, error)
func (*AttemptProvider) ReleaseAttempt ¶
func (p *AttemptProvider) ReleaseAttempt(_ context.Context, in authority.AttemptRelease) error
func (*AttemptProvider) SettleAttempt ¶
func (p *AttemptProvider) SettleAttempt(_ context.Context, in authority.AttemptSettlement) (authority.Settlement, error)
type Runtime ¶
type Runtime struct {
// contains filtered or unexported fields
}
Runtime holds generation-local compatible admission state.
func AttemptRegistration ¶
func AttemptRegistration(limits Limits, store concurrencyapp.LeaseStore) (authority.AttemptRegistration, *Runtime, error)
AttemptRegistration returns a descriptor-bound attempt registration for limits.
func NewRuntime ¶
func NewRuntime(limits Limits, store concurrencyapp.LeaseStore) (*Runtime, error)
NewRuntime constructs an immutable compatible admission runtime for one generation. store is the generation-local lease persistence port (wired from infra at composition).
Source Files
Click to show internal directories.
Click to hide internal directories.