scheduler

type Credential = model.Credential

type CredentialScheduler interface {
	// Pick selects the best available credential matching the given filter.
	// tried is an optional set of credential IDs that have already been attempted.
	Pick(ctx context.Context, filter Filter, tried map[string]struct{}) (*ManagedCredential, error)

	// MarkResult updates credential availability state from a request result.
	MarkResult(ctx context.Context, result Result)

	// SetSelector replaces the active credential selector.
	SetSelector(s CredentialSelector)

	// SetQuotaCooldownDisabled disables quota cooldown handling when true.
	SetQuotaCooldownDisabled(disable bool)

	// RegisterCredential adds a new credential to the scheduler.
	RegisterCredential(cred *ManagedCredential)

	// UpdateCredential synchronizes updated credential state into the scheduler.
	UpdateCredential(cred *ManagedCredential)

	// DeregisterCredential removes a credential from the scheduler.
	DeregisterCredential(id string)

	// Rebuild recreates the complete scheduler state from a credential snapshot.
	Rebuild(creds []*ManagedCredential)
}

type CredentialSelector interface {
	PickFromBucket(bucket *ReadyBucket, predicate func(*ManagedCredential) bool) *ManagedCredential
}

type Error = model.Error

type FillFirstSelector struct{}

type Filter struct {
	Type            string
	CredentialScope string
	Model           string
	Selector        string
}

type ManagedCredential = model.ManagedCredential

type ModelState = model.ModelState

type PredicateCredentialFunc func(cred *ManagedCredential) bool

type QuotaState = model.QuotaState

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

type Result struct {
	CredentialID   string
	Model          string
	Success        bool
	RetryAfter     *time.Duration
	Error          *Error
	CredentialWide bool
}

type RoundRobinSelector struct{}