auth

Jul 23, 2026

Changes in this version

+ func CanonicalModelID(model string) string

Jul 23, 2026

Changes in this version

+ const ExcludedConcurrencyCandidatesMetadataKey

+ type ExcludedConcurrencyCandidate struct

+ CredentialID string

+ Model string

Jul 16, 2026

Changes in this version

type Manager

+ func (m *Manager) ShouldRefreshCredential(auth *Auth, now time.Time) bool

Jul 14, 2026

Changes in this version

type DispatchDecision

+ ForceMapping bool

+ OriginalAlias string

Jul 6, 2026

Changes in this version

+ type StateMutator interface

+ MutateAuthState func(ctx context.Context, id string, mutate func(auth *Auth) bool) (*Auth, error)

Jun 25, 2026

Changes in this version

type Manager

+ func (m *Manager) SetPluginAuthRefresher(refresher PluginAuthRefresher)

+ func (m *Manager) SetPluginScheduler(scheduler PluginScheduler)

+ type PluginAuthRefresher interface

+ RefreshAuth func(context.Context, *Auth) (*Auth, bool, error)

+ type PluginScheduler interface

+ PickAuth func(context.Context, pluginapi.SchedulerPickRequest) (pluginapi.SchedulerPickResponse, bool, error)

type Result

+ RetryAfter *time.Duration

May 25, 2026

Changes in this version

+ const AllowedAuthIDsMetadataKey

+ const AllowedModelIDsMetadataKey

May 11, 2026

Changes in this version

+ var ErrFullAuthNotFound = errors.New("full auth not found")

+ type FullAuthResolver interface

+ GetFullAuth func(ctx context.Context, uuid string) (*Auth, error)

type Manager

+ func (m *Manager) RefreshAuthCredential(ctx context.Context, target *Auth) (*Auth, error)

+ func (m *Manager) SetFullAuthResolver(resolver FullAuthResolver)

+ func (m *Manager) SetStore(store Store)

+ func (m *Manager) Shutdown()

May 9, 2026

Changes in this version

+ const RequestedModelMetadataKey

+ func ApplyCustomHeadersFromMetadata(auth *Auth)

+ func ExtractCustomHeadersFromMetadata(metadata map[string]any) map[string]string

+ func ExtractSessionID(headers http.Header, payload []byte, metadata map[string]any) string

+ func OAuthModelAliasChannel(provider, authKind string) string

+ func ProviderRefreshLead(provider string, runtime any) *time.Duration

+ func RegisterRefreshLeadProvider(provider string, factory func() *time.Duration)

+ func RegisterTokenStore(store Store)

+ func WithRequestInfo(ctx context.Context, info *RequestInfo) context.Context

+ func WithSkipPersist(ctx context.Context) context.Context

+ type Auth struct

+ Attributes map[string]string

+ CreatedAt time.Time

+ Disabled bool

+ Failed int64

+ FileName string

+ ID string

+ Index string

+ Label string

+ LastError *Error

+ LastRefreshedAt time.Time

+ Metadata map[string]any

+ ModelStates map[string]*ModelState

+ NextRefreshAfter time.Time

+ NextRetryAfter time.Time

+ Prefix string

+ Provider string

+ ProxyURL string

+ Quota QuotaState

+ Runtime any

+ Status Status

+ StatusMessage string

+ Storage baseauth.TokenStorage

+ Success int64

+ Unavailable bool

+ UpdatedAt time.Time

+ func (a *Auth) AccountInfo() (string, string)

+ func (a *Auth) Clone() *Auth

+ func (a *Auth) DisableCoolingOverride() (bool, bool)

+ func (a *Auth) EnsureIndex() string

+ func (a *Auth) ExpirationTime() (time.Time, bool)

+ func (a *Auth) ProxyInfo() string

+ func (a *Auth) RecentRequestsSnapshot(now time.Time) []RecentRequestBucket

+ func (a *Auth) RequestRetryOverride() (int, bool)

+ func (a *Auth) ToolPrefixDisabled() bool

+ type DispatchDecision struct

+ Auth *Auth

+ PooledModels bool

+ Provider string

+ UpstreamModel string

+ type Error struct

+ Code string

+ HTTPStatus int

+ Message string

+ Retryable bool

+ func (e *Error) Error() string

+ func (e *Error) StatusCode() int

+ type FileTokenStore struct

+ func NewFileTokenStore() *FileTokenStore

+ func (s *FileTokenStore) Delete(ctx context.Context, id string) error

+ func (s *FileTokenStore) List(ctx context.Context) ([]*Auth, error)

+ func (s *FileTokenStore) Save(ctx context.Context, auth *Auth) (string, error)

+ func (s *FileTokenStore) SetBaseDir(dir string)

+ type FillFirstSelector struct

+ func (s *FillFirstSelector) Pick(ctx context.Context, provider, model string, opts Options, auths []*Auth) (*Auth, error)

+ type Manager struct

+ func NewManager(store Store, selector Selector, _ any) *Manager

+ func (m *Manager) Delete(ctx context.Context, id string) error

+ func (m *Manager) Dispatch(ctx context.Context, providers []string, requestedModel string, opts Options) (*DispatchDecision, error)

+ func (m *Manager) GetByID(id string) (*Auth, bool)

+ func (m *Manager) GetByIndex(index string) (*Auth, bool)

+ func (m *Manager) List() []*Auth

+ func (m *Manager) MarkResult(ctx context.Context, result Result)

+ func (m *Manager) ReconcileRegistryModelStates(_ context.Context, _ string)

+ func (m *Manager) RefreshNow(ctx context.Context, authIndex string) (*Auth, error)

+ func (m *Manager) RefreshSchedulerEntry(authID string)

+ func (m *Manager) Register(ctx context.Context, auth *Auth) (*Auth, error)

+ func (m *Manager) SetConfig(cfg *internalconfig.Config)

+ func (m *Manager) SetOAuthModelAlias(aliases map[string][]internalconfig.OAuthModelAlias)

+ func (m *Manager) SetRoundTripperProvider(p RoundTripperProvider)

+ func (m *Manager) SetSelector(selector Selector)

+ func (m *Manager) StartAutoRefresh(parent context.Context, interval time.Duration)

+ func (m *Manager) StopAutoRefresh()

+ func (m *Manager) Update(ctx context.Context, auth *Auth) (*Auth, error)

+ type ModelState struct

+ LastError *Error

+ NextRetryAfter time.Time

+ Quota QuotaState

+ Status Status

+ StatusMessage string

+ Unavailable bool

+ UpdatedAt time.Time

+ func (m *ModelState) Clone() *ModelState

+ type Options struct

+ Headers http.Header

+ Metadata map[string]any

+ OriginalRequest []byte

+ Query url.Values

+ type PostAuthHook func(context.Context, *Auth) error

+ type QuotaState struct

+ BackoffLevel int

+ Exceeded bool

+ NextRecoverAt time.Time

+ Reason string

+ type RecentRequestBucket struct

+ Failed int64

+ Success int64

+ Time string

+ type RefreshEvaluator interface

+ ShouldRefresh func(now time.Time, auth *Auth) bool

+ type RequestInfo struct

+ Headers http.Header

+ Query url.Values

+ func GetRequestInfo(ctx context.Context) *RequestInfo

+ type Result struct

+ AuthID string

+ AuthIndex string

+ Error *Error

+ Model string

+ Provider string

+ Success bool

+ func NewUsageResult(authIndex, provider, model string, statusCode int, body string) Result

+ type RoundRobinSelector struct

+ func (s *RoundRobinSelector) Pick(ctx context.Context, provider, model string, opts Options, auths []*Auth) (*Auth, error)

+ type RoundTripperProvider interface

+ RoundTripperFor func(auth *Auth) http.RoundTripper

+ type Selector interface

+ Pick func(ctx context.Context, provider, model string, opts Options, auths []*Auth) (*Auth, error)

+ type SessionAffinityConfig struct

+ Fallback Selector

+ TTL time.Duration

+ type SessionAffinitySelector struct

+ func NewSessionAffinitySelector(fallback Selector) *SessionAffinitySelector

+ func NewSessionAffinitySelectorWithConfig(cfg SessionAffinityConfig) *SessionAffinitySelector

+ func (s *SessionAffinitySelector) InvalidateAuth(authID string)

+ func (s *SessionAffinitySelector) Pick(ctx context.Context, provider, model string, opts Options, auths []*Auth) (*Auth, error)

+ func (s *SessionAffinitySelector) Stop()

+ type SessionCache struct

+ func NewSessionCache(ttl time.Duration) *SessionCache

+ func (c *SessionCache) Get(sessionID string) (string, bool)

+ func (c *SessionCache) GetAndRefresh(sessionID string) (string, bool)

+ func (c *SessionCache) Invalidate(sessionID string)

+ func (c *SessionCache) InvalidateAuth(authID string)

+ func (c *SessionCache) Set(sessionID, authID string)

+ func (c *SessionCache) Stop()

+ type Status string

+ const StatusActive

+ const StatusDisabled

+ const StatusError

+ const StatusPending

+ const StatusRefreshing

+ const StatusUnknown

+ type StoppableSelector interface

+ Stop func()

+ type Store interface

+ Delete func(ctx context.Context, id string) error

+ List func(ctx context.Context) ([]*Auth, error)

+ Save func(ctx context.Context, auth *Auth) (string, error)

+ func GetTokenStore() Store