selectacct

Aug 19, 2026

Changes in this version

type Scheduler

+ func (s Scheduler) PickBest(candidates []account.Account) (account.Account, error)

Aug 18, 2026

Changes in this version

+ const MinStickyRetentionHeadroom

type Scheduler

+ func (s Scheduler) UsableForStickySession(provider account.Provider, accountID string) bool

Aug 3, 2026

Changes in this version

type SchedulerRef

+ func (r *SchedulerRef) AdvanceAccountGeneration(generation uint64)

+ func (r *SchedulerRef) BeginRefreshIfStaleForAccountGeneration(ttl time.Duration, generation uint64) bool

+ func (r *SchedulerRef) FinishRefreshForAccountGeneration(scheduler Scheduler, update bool, generation uint64) bool

+ func (r *SchedulerRef) SetForAccountGeneration(scheduler Scheduler, generation uint64) bool

Jul 28, 2026

Changes in this version

+ const DefaultExhaustedTTL

+ const LiveDebitPerRequest

+ const MinNewSessionHeadroom

+ const VelocityProjectionMinutes

+ var ErrNoAccounts = errors.New("no accounts available")

+ func ModelKey(model string) string

+ func ScoreKey(provider account.Provider, accountID string) string

+ type LimitWindow struct

+ Feature string

+ LimitWindowSeconds int64

+ Name string

+ ResetAfterSeconds int64

+ UsedPercent float64

+ type Scheduler struct

+ func NewScheduler(scores []Score) Scheduler

+ func (s Scheduler) Exhausted(provider account.Provider, accountID string) bool

+ func (s Scheduler) ForModel(model string) Scheduler

+ func (s Scheduler) HasModelPool(model string) bool

+ func (s Scheduler) Pick(candidates []account.Account) (account.Account, error)

+ func (s Scheduler) ScoreFor(provider account.Provider, accountID string) Score

+ func (s Scheduler) UsableForNewSession(provider account.Provider, accountID string) bool

+ func (s Scheduler) WithLiveDebits(debits map[string]int) Scheduler

+ func (s Scheduler) WithScore(score Score) Scheduler

+ func (s Scheduler) WithSessionCounts(counts map[string]int) Scheduler

+ type SchedulerRef struct

+ func NewSchedulerRef(scheduler Scheduler) *SchedulerRef

+ func (r *SchedulerRef) BeginRefreshIfStale(ttl time.Duration) bool

+ func (r *SchedulerRef) ExhaustedUntilFor(provider account.Provider, accountID, poolKey string) (time.Time, bool)

+ func (r *SchedulerRef) FinishRefresh(scheduler Scheduler, update bool)

+ func (r *SchedulerRef) Get() Scheduler

+ func (r *SchedulerRef) LiveDebits() map[string]int

+ func (r *SchedulerRef) MarkExhausted(provider account.Provider, accountID, poolKey string)

+ func (r *SchedulerRef) MarkExhaustedUntil(provider account.Provider, accountID, poolKey string, until time.Time)

+ func (r *SchedulerRef) MarkModelIncompatible(provider account.Provider, accountID, model string)

+ func (r *SchedulerRef) MarkModelIncompatibleUntil(provider account.Provider, accountID, model string, until time.Time)

+ func (r *SchedulerRef) ModelIncompatibleUntilFor(provider account.Provider, accountID, model string) (time.Time, bool)

+ func (r *SchedulerRef) NoteRouted(provider account.Provider, accountID string)

+ func (r *SchedulerRef) Set(scheduler Scheduler)

+ func (r *SchedulerRef) SetUpdatedAt(updatedAt time.Time)

+ func (r *SchedulerRef) Stale(ttl time.Duration) bool

+ func (r *SchedulerRef) Touch()

+ type Score struct

+ AccountID string

+ ExpiryPressure float64

+ Fresh bool

+ Headroom float64

+ ModelScores map[string]Score

+ Provider account.Provider

+ Sessions int

+ ShortHeadroom float64

+ ShortResetAfterSeconds int64

+ func ScoreFromLimitWindows(accountID string, sessions int, windows []LimitWindow) Score