cluster

Jul 28, 2026

Changes in this version

+ var ErrMembershipTakeoverUnavailable = errors.New("membership_takeover_unavailable")

+ type ClusterMasterGateRecord struct

+ ID int

+ func (ClusterMasterGateRecord) TableName() string

type ConnectionLifetime

+ InstanceID string

type RESPHandler

+ func (h *RESPHandler) BeginFingerprintCancellationForLifetime(ctx context.Context, lifetime ConnectionLifetime) (int64, error)

type Repository

+ func (r *Repository) BeginFingerprintCancellationForLifetime(ctx context.Context, lifetime ConnectionLifetime) (int64, error)

type SubscribeMembershipRequest

+ Takeover bool

Jul 24, 2026

Changes in this version

+ var ErrInFlightSnapshotCursorExpired = errors.New("in-flight snapshot cursor expired")

type InFlightObservationReadModel

+ FreshUntil *time.Time

+ type InFlightSnapshotCursor struct

+ CreatedAt time.Time

+ CredentialID string

+ Cursor string

+ ExpiresAt time.Time

+ Model string

+ Observation InFlightObservationReadModel

+ ReadAt time.Time

+ States []CredentialConcurrencyState

+ Total int

+ type InFlightSnapshotCursorInput struct

+ CredentialID string

+ Model string

+ Observation InFlightObservationReadModel

+ States []CredentialConcurrencyState

+ type ManagementInFlightSnapshotCursorItemRecord struct

+ CredentialID string

+ Cursor string

+ Model string

+ ObservedPresent bool

+ Ordinal int64

+ RequestID string

+ RequestKind string

+ StartedAt time.Time

+ StatePresent bool

+ func (ManagementInFlightSnapshotCursorItemRecord) TableName() string

+ type ManagementInFlightSnapshotCursorObservedRecord struct

+ CredentialID string

+ Cursor string

+ ObservedAccounted int64

+ ObservedInFlight int64

+ ObservedUnaccounted int64

+ func (ManagementInFlightSnapshotCursorObservedRecord) TableName() string

+ type ManagementInFlightSnapshotCursorRecord struct

+ AggregatesComplete bool

+ CoverageComplete bool

+ CreatedAt time.Time

+ CredentialID string

+ Cursor string

+ DetailsTruncated bool

+ ExpiresAt time.Time

+ FreshUntil *time.Time

+ MinimumProcessedBarrierRevision *int64

+ Model string

+ ObservedAt *time.Time

+ Payload JSONB

+ ProtocolCoverageComplete bool

+ SchemaVersion int

+ Stale bool

+ Total int64

+ func (ManagementInFlightSnapshotCursorRecord) TableName() string

+ type ManagementInFlightSnapshotCursorStateModelRecord struct

+ AdmittedInFlight int64

+ CredentialID string

+ Cursor string

+ MaxInFlight int64

+ Model string

+ func (ManagementInFlightSnapshotCursorStateModelRecord) TableName() string

+ type ManagementInFlightSnapshotCursorStateRecord struct

+ AdmittedInFlight int64

+ CredentialID string

+ Cursor string

+ EffectiveAt time.Time

+ MaxInFlight *int64

+ ModelCount int64

+ ObservationBarrier int64

+ PolicyVersion int64

+ func (ManagementInFlightSnapshotCursorStateRecord) TableName() string

type Repository

+ func (r *Repository) CreateInFlightSnapshotCursor(ctx context.Context, input InFlightSnapshotCursorInput, ttl time.Duration) (InFlightSnapshotCursor, error)

+ func (r *Repository) DeleteAppLogs(ctx context.Context) (int64, error)

+ func (r *Repository) ReadInFlightSnapshotCursorPage(ctx context.Context, cursor string, credentialID string, model string, ...) (InFlightSnapshotCursor, error)

Jul 23, 2026

Changes in this version

+ const UsageTokenAccountingQualityComplete

+ const UsageTokenAccountingQualityInconsistent

+ const UsageTokenAccountingQualityUnclassified

+ const UsageTokenAccountingSchemaVersion

+ var ErrInvalidModelChannelGroupID = errors.New("model channel group id must be greater than zero")

+ func ModelGroupDetailChannelIDs(record *ModelGroupDetailRecord) ([]uint, error)

+ func QuotaSnapshotVersion(provider string) int

type ModelGroupDetailRecord

+ Channels JSONB

type ModelGroupDetailUpdate

+ Channels *[]uint

type QuotaCredentialSnapshot

+ ResetCredits *QuotaResetCredits

+ type QuotaResetCredit struct

+ ExpiresAt *time.Time

+ GrantedAt time.Time

+ ID string

+ Status string

+ type QuotaResetCredits struct

+ AvailableCount *int

+ Credits []QuotaResetCredit

+ ObservedAt time.Time

type QuotaSnapshotRecord

+ ResetCredits JSONB

type QuotaSnapshotWrite

+ ReceivedAt *time.Time

+ ReplaceResetCredits bool

+ ResetCredits *QuotaResetCredits

type Repository

+ func (r *Repository) AllowedDispatchIDsForAPIKeyModel(ctx context.Context, apiKey string, modelID string) ([]string, []string, error)

+ func (r *Repository) RunUsageTokenAccountingBackfillBatch(ctx context.Context) (UsageTokenAccountingBackfillResult, error)

+ func (r *Repository) UsageTokenBreakdownV2Ready(ctx context.Context) (bool, error)

type RuntimeAdapter

+ func (a *RuntimeAdapter) AllowedDispatchIDsForAPIKeyModel(ctx context.Context, apiKey string, modelID string) ([]string, []string, error)

type UsageObservabilityAggregateItem

+ TokenBreakdown UsageTokenBreakdown

type UsageObservabilityTokens

+ TokenBreakdown UsageTokenBreakdown

type UsageObservabilityTotals

+ TokenBreakdown UsageTokenBreakdown

type UsageObservabilityTrendPoint

+ TokenBreakdown UsageTokenBreakdown

type UsageRecord

+ AccountingCacheReadTokens int64

+ AccountingCacheWriteTokens int64

+ AccountingInputTokens int64

+ AccountingOutputTokens int64

+ AccountingReasoningTokens int64

+ AccountingTotalTokens int64

+ NonReasoningOutputTokens int64

+ TokenAccountingQuality string

+ TokenAccountingVersion int

+ UncachedInputTokens int64

+ UnclassifiedTokens int64

+ type UsageTokenAccountingBackfillResult struct

+ Done bool

+ Scanned int

+ Skipped bool

+ Updated int64

+ type UsageTokenBreakdown struct

+ Input UsageTokenInputBreakdown

+ Output UsageTokenOutputBreakdown

+ Quality string

+ SchemaVersion int

+ TotalTokens int64

+ UnclassifiedTokens int64

+ func (b UsageTokenBreakdown) Valid() bool

+ type UsageTokenInputBreakdown struct

+ CacheReadTokens int64

+ CacheWriteTokens int64

+ TotalTokens int64

+ UncachedTokens int64

+ type UsageTokenOutputBreakdown struct

+ NonReasoningTokens int64

+ ReasoningTokens int64

+ TotalTokens int64

Jul 23, 2026

Changes in this version

+ const HomeIncarnationActive

+ const HomeIncarnationExpired

+ const HomeIncarnationFenced

+ const HomeIncarnationRetired

+ const InFlightAccounted

+ const InFlightFrameOverflow

+ const InFlightFramePart

+ const InFlightUnaccounted

+ const MembershipStateActive

+ const MembershipStateCanceling

+ const MembershipStateClosed

+ const QuiescenceStatusAcknowledged

+ const QuiescenceStatusFenced

+ const QuiescenceStatusPending

+ var ErrConcurrencyCounterInvalid = errors.New("credential concurrency counter is invalid")

+ var ErrConcurrencyCredentialNotFound = errors.New("credential concurrency policy credential not found")

+ var ErrConcurrencyDuplicateModel = errors.New("duplicate credential concurrency model")

+ var ErrConcurrencyHomeCapabilityMissing = errors.New("active Home lacks credential concurrency limiter capability")

+ var ErrConcurrencyHomeCapabilityRequired = errors.New("Home concurrency capability is required")

+ var ErrConcurrencyInvalidLimit = errors.New("invalid credential concurrency limit")

+ var ErrConcurrencyInvalidModel = errors.New("invalid credential concurrency model")

+ var ErrConcurrencyInvalidRelease = errors.New("credential concurrency release is invalid")

+ var ErrConcurrencyLegacyMembershipActive = errors.New("legacy CPA membership is active")

+ var ErrConcurrencyNodeUnavailable = errors.New("credential concurrency node is unavailable")

+ var ErrConcurrencyPolicyVersionConflict = errors.New("credential concurrency policy version conflict")

+ var ErrConcurrencyProtocolRequired = errors.New("credential concurrency protocol version 1 is required")

+ var ErrConcurrencyReleaseExceedsActive = errors.New("credential concurrency release exceeds active count")

+ var ErrConcurrencySQLiteMultiHome = errors.New("active concurrency limits require a single SQLite Home")

+ var ErrCredentialConcurrencyOrphan = errors.New("credential concurrency policy would be orphaned")

+ var ErrCredentialIdentityConflict = errors.New("credential identity conflict")

+ var ErrCredentialUUIDMappingRequired = errors.New("credential uuid mapping required")

+ var ErrCredentialValidation = errors.New("credential validation failed")

+ var ErrDuplicateCPACertificate = errors.New("CPA certificate is already owned by an active membership")

+ var ErrFingerprintNotQuiescent = errors.New("fingerprint is not quiescent")

+ var ErrFingerprintQuiescenceSetIncomplete = errors.New("fingerprint quiescence set is incomplete")

+ var ErrHomeIncarnationFenced = errors.New("Home incarnation is fenced")

+ var ErrHomeIncarnationInactive = errors.New("Home incarnation is not active")

+ var ErrHomeIncarnationNotFound = errors.New("Home incarnation not found")

+ var ErrInFlightFrameInvalid = errors.New("invalid in-flight snapshot frame")

+ var ErrInFlightLifetimeMismatch = errors.New("in-flight snapshot lifetime mismatch")

+ var ErrInFlightRevisionConflict = errors.New("conflicting in-flight snapshot revision")

+ var ErrInFlightRevisionOverflow = errors.New("in-flight snapshot revision overflow")

+ var ErrInFlightRevisionStale = errors.New("stale in-flight snapshot revision")

+ var ErrLifecycleConfigInUse = errors.New("lifecycle configuration is in use")

+ var ErrLifecycleConfigRevisionMismatch = errors.New("lifecycle configuration revision does not match")

+ var ErrMembershipNotActive = errors.New("CPA membership is not active")

+ var ErrQuiescenceRevisionMismatch = errors.New("fingerprint quiescence revision does not match")

+ func DatabaseNow(ctx context.Context, tx *gorm.DB) (time.Time, error)

+ func DeleteFingerprintConcurrencyCountersTx(ctx context.Context, tx *gorm.DB, fingerprint string) error

+ func IsConcurrencySaturated(err error) bool

+ func ValidateCredentialConcurrencyLifecycle(nodeHeartbeatTimeout time.Duration, cfg config.CredentialConcurrencyConfig) error

+ type AuthConcurrencyPatchRequest struct

+ Auth *coreauth.Auth

+ AuthChanged bool

+ CredentialID string

+ ExpectedPolicyVersion *int64

+ PolicyPatch ConcurrencyPolicyPatch

+ type CPAInFlightSnapshotAttemptRecord struct

+ AggregateGroupCount int

+ BarrierRevision int64

+ CertificateFingerprint string

+ DetailsTruncated bool

+ EncodedBytes int64

+ HighestSeenRevision int64

+ MembershipConnectedAt time.Time

+ ObservedAt time.Time

+ PartCount int

+ ReceivedPartCount int

+ State string

+ UpdatedAt time.Time

+ func (CPAInFlightSnapshotAttemptRecord) TableName() string

+ type CPAInFlightSnapshotPartRecord struct

+ CertificateFingerprint string

+ CreatedAt time.Time

+ EncodedBytes int

+ MembershipConnectedAt time.Time

+ PartIndex int

+ Payload []byte

+ Revision int64

+ UpdatedAt time.Time

+ func (CPAInFlightSnapshotPartRecord) TableName() string

+ type CPAInFlightSnapshotRecord struct

+ BarrierRevision int64

+ CertificateFingerprint string

+ DetailsTruncated bool

+ MembershipConnectedAt time.Time

+ NodeID string

+ ObservedAt time.Time

+ Payload JSONB

+ Revision int64

+ UpdatedAt time.Time

+ func (CPAInFlightSnapshotRecord) TableName() string

+ type CPANodeMembershipRecord struct

+ CPACancelBound time.Duration

+ CPAHeartbeatTimeout time.Duration

+ CancelRevision int64

+ CancelStartedAt *time.Time

+ CertificateFingerprint string

+ ConnectedAt time.Time

+ ExpectedQuiescenceCount int64

+ HomeIP string

+ HomePort int

+ HomeStartedAt time.Time

+ LastSeenAt time.Time

+ LifecycleConfigRevision int64

+ NodeID string

+ ProtocolVersion int

+ ReclaimGrace time.Duration

+ State string

+ UpdatedAt time.Time

+ func (CPANodeMembershipRecord) TableName() string

+ type CPANodeParticipationRecord struct

+ CertificateFingerprint string

+ CreatedAt time.Time

+ HomeIP string

+ HomePort int

+ HomeStartedAt time.Time

+ MembershipConnectedAt time.Time

+ func (CPANodeParticipationRecord) TableName() string

+ type CPANodeQuiescenceRecord struct

+ CancelRevision int64

+ CertificateFingerprint string

+ HomeIP string

+ HomePort int

+ HomeStartedAt time.Time

+ MembershipConnectedAt time.Time

+ Status string

+ UpdatedAt time.Time

+ func (CPANodeQuiescenceRecord) TableName() string

type CPANodeRecord

+ ActiveHandlers int

+ CertificateFingerprint string

+ HomeStartedAt time.Time

+ LatestCancelRevision int64

+ OpenConnections int

+ type ConcurrencyActivationGateRecord struct

+ ActivePolicyCount int64

+ ID int

+ func (ConcurrencyActivationGateRecord) TableName() string

+ type ConcurrencyAdmissionError struct

+ RetryAfterMS int64

+ Type string

+ func (e *ConcurrencyAdmissionError) ConcurrencyType() string

+ func (e *ConcurrencyAdmissionError) Error() string

+ func (e *ConcurrencyAdmissionError) Unwrap() error

+ type ConcurrencyAdmissionRequest struct

+ CredentialID string

+ Lifetime ConnectionLifetime

+ Model string

+ ProtocolVersion int

+ type ConcurrencyAdmissionResult struct

+ Accounted bool

+ CredentialID string

+ Model string

+ type ConcurrencyCredentialReferenceChecker struct

+ func (ConcurrencyCredentialReferenceChecker) HasCredentialReferences(ctx context.Context, tx *gorm.DB, credentialID string) (bool, error)

+ type ConcurrencyObservationBarrierRecord struct

+ ID int

+ Revision int64

+ UpdatedAt time.Time

+ func (ConcurrencyObservationBarrierRecord) TableName() string

+ type ConcurrencyPolicyPatch struct

+ MaxInFlight OptionalLimit

+ MaxInFlightByModel OptionalModelLimitMap

+ type ConcurrencyReleaseRequest struct

+ CredentialID string

+ Lifetime ConnectionLifetime

+ Model string

+ ReleaseSeq int64

+ type ConnectionLifetime struct

+ ConnectedAt time.Time

+ Controlled bool

+ Fingerprint string

+ Home HomeIncarnationID

+ Subscription bool

type Coordinator

+ func (c *Coordinator) HomeIncarnation() (HomeIncarnationID, bool)

+ func (c *Coordinator) Initialize(ctx context.Context) error

+ func (c *Coordinator) RetireHomeIncarnation(ctx context.Context) error

type CoordinatorOptions

+ StartupRecovery StartupRecovery

+ type CredentialConcurrencyCounterRecord struct

+ ActiveCount int64

+ CertificateFingerprint string

+ CredentialID string

+ LastReleaseSeq int64

+ Model string

+ UpdatedAt time.Time

+ func (CredentialConcurrencyCounterRecord) TableName() string

+ type CredentialConcurrencyExchangePolicy struct

+ MaxInFlight *int64

+ MaxInFlightByModel map[string]int64

+ type CredentialConcurrencyModelPolicyRecord struct

+ CredentialID string

+ MaxInFlight int64

+ Model string

+ func (CredentialConcurrencyModelPolicyRecord) TableName() string

+ type CredentialConcurrencyModelState struct

+ AdmittedInFlight int64

+ MaxInFlight int64

+ Model string

+ type CredentialConcurrencyPolicy struct

+ CredentialID string

+ EffectiveAt time.Time

+ MaxInFlight *int64

+ MaxInFlightByModel map[string]int64

+ ObservationBarrierRevision int64

+ Version int64

+ type CredentialConcurrencyPolicyRecord struct

+ CreatedAt time.Time

+ CredentialID string

+ EffectiveAt time.Time

+ MaxInFlight *int64

+ ObservationBarrierRevision int64

+ UpdatedAt time.Time

+ Version int64

+ func (CredentialConcurrencyPolicyRecord) TableName() string

+ type CredentialConcurrencyState struct

+ AdmittedInFlight int64

+ CredentialID string

+ EffectiveAt time.Time

+ MaxInFlight *int64

+ Models []CredentialConcurrencyModelState

+ ObservationBarrier int64

+ PolicyVersion int64

+ type CredentialReferenceChecker interface

+ HasCredentialReferences func(context.Context, *gorm.DB, string) (bool, error)

type ExportOptions

+ NodeHeartbeatTimeout time.Duration

+ type HomeIncarnationID struct

+ IP string

+ Port int

+ StartedAt time.Time

+ type HomeProcessIncarnationRecord struct

+ Capabilities JSONB

+ FenceReason string

+ FencedAt *time.Time

+ HomeIP string

+ HomePort int

+ LastSeenAt time.Time

+ StartedAt time.Time

+ State string

+ func (HomeProcessIncarnationRecord) TableName() string

type ImportOptions

+ NodeHeartbeatTimeout time.Duration

+ type InFlightAccountedStatus string

+ type InFlightAggregate struct

+ Count int64

+ CredentialID string

+ Model string

+ Status InFlightAccountedStatus

+ type InFlightFrameKind string

+ type InFlightIngestIdentity struct

+ CertificateFingerprint string

+ MembershipConnectedAt time.Time

+ NodeID string

+ type InFlightIngestResult struct

+ Accepted bool

+ Published bool

+ Revision int64

+ State string

+ type InFlightLimits struct

+ MaxAggregateGroups int

+ MaxDetails int

+ MaxPartBytes int

+ MaxPartCount int

+ MaxRevisionBytes int

+ MaxStringBytes int

+ func DefaultInFlightLimits() InFlightLimits

+ func InFlightLimitsFromConfig(cfg config.CredentialInFlightConfig) (InFlightLimits, error)

+ type InFlightObservationReadModel struct

+ AggregatesComplete bool

+ CoverageComplete bool

+ Credentials []InFlightObservedCredentialItem

+ Details []InFlightRequestDetail

+ DetailsTruncated bool

+ MinimumProcessedBarrierRevision *int64

+ ObservedAt *time.Time

+ ProtocolCoverageComplete bool

+ Stale bool

+ type InFlightObservedCredentialItem struct

+ CredentialID string

+ Models []InFlightObservedModelItem

+ ObservedAccounted int64

+ ObservedInFlight int64

+ ObservedUnaccounted int64

+ type InFlightObservedModelItem struct

+ Model string

+ ObservedAccounted int64

+ ObservedInFlight int64

+ ObservedUnaccounted int64

+ type InFlightRequestDetail struct

+ CredentialID string

+ Model string

+ RequestID string

+ RequestKind string

+ StartedAt time.Time

+ type InFlightSnapshotFrame struct

+ AggregateGroupCount int

+ Aggregates []InFlightAggregate

+ BarrierRevision int64

+ Details []InFlightRequestDetail

+ DetailsTruncated bool

+ Kind InFlightFrameKind

+ ObservedAt time.Time

+ PartCount *int

+ PartIndex *int

+ Revision int64

+ type InFlightSnapshotPayload struct

+ Aggregates []InFlightAggregate

+ Details []InFlightRequestDetail

+ DetailsTruncated bool

+ type LifecycleConfigRecord struct

+ ID int

+ NodeHeartbeatTimeout time.Duration

+ Payload JSONB

+ Revision int64

+ UpdatedAt time.Time

+ func (LifecycleConfigRecord) TableName() string

+ type OptionalLimit struct

+ Null bool

+ Set bool

+ Value int64

+ func (o *OptionalLimit) UnmarshalJSON(data []byte) error

+ type OptionalModelLimitMap struct

+ Null bool

+ Set bool

+ Value map[string]*int64

+ func (o *OptionalModelLimitMap) UnmarshalJSON(data []byte) error

type QuotaCredentialSnapshot

+ Plan *QuotaPlan

type QuotaListQuery

+ IDs map[string]struct{}

+ type QuotaPlan struct

+ Name string

+ Premium bool

type QuotaSnapshotRecord

+ PlanName string

+ PlanPremium *bool

type QuotaSnapshotWrite

+ Plan *QuotaPlan

+ ReplacePlan bool

type RESPHandler

+ func (h *RESPHandler) BeginFingerprintCancellation(ctx context.Context, fingerprint string) (int64, error)

+ func (h *RESPHandler) ClassifyConnection(ctx context.Context, fingerprint string) (ConnectionLifetime, error)

+ func (h *RESPHandler) RefreshCPALiveness(ctx context.Context, lifetime ConnectionLifetime) error

+ func (h *RESPHandler) SubscribeMembership(ctx context.Context, fingerprint string, nodeID string, protocolVersion int, ...) (ConnectionLifetime, error)

type Repository

+ func (r *Repository) AcknowledgeQuiescence(ctx context.Context, fingerprint string, connectedAt time.Time, revision int64, ...) error

+ func (r *Repository) AdmitCredentialConcurrency(ctx context.Context, req ConcurrencyAdmissionRequest) (ConcurrencyAdmissionResult, error)

+ func (r *Repository) ApplyConcurrencyRelease(ctx context.Context, req ConcurrencyReleaseRequest) error

+ func (r *Repository) BeginFingerprintCancellation(ctx context.Context, fingerprint string) (int64, error)

+ func (r *Repository) ClassifyConnection(ctx context.Context, fingerprint string, home HomeIncarnationID) (ConnectionLifetime, error)

+ func (r *Repository) CleanupExpiredInFlightStaging(ctx context.Context, retention time.Duration) error

+ func (r *Repository) CleanupInFlightLifetime(ctx context.Context, fingerprint string, connectedAt time.Time) error

+ func (r *Repository) CleanupStaleMemberships(ctx context.Context) error

+ func (r *Repository) CompleteFingerprintCancellation(ctx context.Context, fingerprint string, connectedAt time.Time, revision int64) error

+ func (r *Repository) EnsureLifecycleConfig(ctx context.Context, nodeHeartbeatTimeout time.Duration) (LifecycleConfigRecord, error)

+ func (r *Repository) ExportCredentialConcurrencyPolicies(ctx context.Context, root map[string]any) error

+ func (r *Repository) FenceHomeIncarnation(ctx context.Context, id HomeIncarnationID, reason string) error

+ func (r *Repository) ForceClaimEligibleQuotaProbe(ctx context.Context, credentialID string, owner string, now time.Time, ...) (bool, error)

+ func (r *Repository) GetCredentialConcurrencyPolicy(ctx context.Context, credentialID string) (CredentialConcurrencyPolicy, error)

+ func (r *Repository) HeartbeatHomeIncarnation(ctx context.Context, id HomeIncarnationID) error

+ func (r *Repository) ImportCredentialConcurrencyPolicies(ctx context.Context, root map[string]any) error

+ func (r *Repository) ImportCredentialConcurrencyPoliciesTx(ctx context.Context, tx *gorm.DB, root map[string]any) error

+ func (r *Repository) IngestInFlightFrame(ctx context.Context, identity InFlightIngestIdentity, raw []byte, ...) (InFlightIngestResult, error)

+ func (r *Repository) LifecycleConfig(ctx context.Context) (config.CredentialConcurrencyConfig, error)

+ func (r *Repository) ListAuthsUnscoped(ctx context.Context, tx *gorm.DB) ([]*coreauth.Auth, error)

+ func (r *Repository) ListCredentialConcurrencyPolicies(ctx context.Context) ([]CredentialConcurrencyPolicy, error)

+ func (r *Repository) ListPendingQuiescence(ctx context.Context, home HomeIncarnationID) ([]CPANodeQuiescenceRecord, error)

+ func (r *Repository) LockActiveConcurrencyLifetimeTx(ctx context.Context, tx *gorm.DB, lifetime ConnectionLifetime) error

+ func (r *Repository) PatchAuthAndConcurrency(ctx context.Context, request AuthConcurrencyPatchRequest) error

+ func (r *Repository) PatchCredentialConcurrencyPolicy(ctx context.Context, credentialID string, patch ConcurrencyPolicyPatch, ...) (CredentialConcurrencyPolicy, error)

+ func (r *Repository) ReadConcurrencyState(ctx context.Context) ([]CredentialConcurrencyState, error)

+ func (r *Repository) ReadInFlightObservation(ctx context.Context, staleAfter time.Duration) (InFlightObservationReadModel, error)

+ func (r *Repository) ReconcileProviderAuths(ctx context.Context, key string, next []*coreauth.Auth, ...) error

+ func (r *Repository) RecordParticipation(ctx context.Context, lifetime ConnectionLifetime) error

+ func (r *Repository) RecoverStaleQuiescence(ctx context.Context) error

+ func (r *Repository) RefreshCPALiveness(ctx context.Context, lifetime ConnectionLifetime) error

+ func (r *Repository) RegisterHomeIncarnation(ctx context.Context, ip string, port int, capabilities []string) (HomeIncarnationID, error)

+ func (r *Repository) ReplaceCPANodeSnapshotForIncarnation(ctx context.Context, home HomeIncarnationID, nodes []node.Node, ...) error

+ func (r *Repository) ReplaceConfigSnapshotWithLifecycleConfig(ctx context.Context, nodeHeartbeatTimeout time.Duration, values map[string]any) error

+ func (r *Repository) ReplaceConfigSnapshotWithLifecycleConfigAndCreatePluginTask(ctx context.Context, nodeHeartbeatTimeout time.Duration, values map[string]any, ...) (node.PluginTask, error)

+ func (r *Repository) RequireActiveCPAMembership(ctx context.Context, tx *gorm.DB, identity InFlightIngestIdentity) (CPANodeMembershipRecord, error)

+ func (r *Repository) RetireHomeIncarnation(ctx context.Context, id HomeIncarnationID) error

+ func (r *Repository) RetireProviderAuth(ctx context.Context, credentialID string) error

+ func (r *Repository) SubscribeMembership(ctx context.Context, request SubscribeMembershipRequest) (CPANodeMembershipRecord, error)

+ func (r *Repository) UpdateLifecycleConfig(ctx context.Context, nodeHeartbeatTimeout time.Duration, ...) (int64, error)

+ func (r *Repository) WithConcurrencyActivationGate(ctx context.Context, fn func(*gorm.DB, *ConcurrencyActivationGateRecord) error) error

+ type StartupRecovery func(context.Context, HomeIncarnationID) error

+ type SubscribeMembershipRequest struct

+ Fingerprint string

+ Home HomeIncarnationID

+ LifecycleConfigRevision int64

+ NodeID string

+ ProtocolVersion int

Jul 21, 2026

Changes in this version

+ const PeriodLimitErrInvalidLimit

+ const PeriodLimitErrInvalidResetMode

+ const PeriodLimitErrInvalidResetWindows

+ const PeriodLimitErrInvalidTimezone

+ const PeriodLimitErrInvalidWeekResetDay

+ const PeriodLimitErrInvalidWeekResetHour

+ const PeriodLimitErrInvalidWindowMode

+ const UserMailJobStatusFailed

+ const UserMailJobStatusPending

+ const UserMailJobStatusSending

+ const UserMailJobStatusSent

+ const UserMailJobStatusSuperseded

+ const UserSecurityTokenPurposeEmailVerification

+ const UserSecurityTokenPurposePasswordReset

+ var ErrUserMailJobClaimLost = errors.New("user mail job claim is no longer active")

+ var ErrUserSecurityTokenInvalid = errors.New("user security token is invalid or expired")

+ func HashUserSecurityValue(value string) string

+ func IsUserEmailConflictError(err error) bool

+ type DatabaseSnapshotExportOptions struct

+ HomeCommit string

+ HomeVersion string

+ Path string

+ Progress func(DatabaseSnapshotProgress)

+ type DatabaseSnapshotImportResult struct

+ Tables []DatabaseSnapshotImportTableResult

+ func ImportDatabaseSnapshot(ctx context.Context, db *gorm.DB, snapshot *ValidatedDatabaseSnapshot, ...) (DatabaseSnapshotImportResult, error)

+ type DatabaseSnapshotImportTableResult struct

+ Imported int64

+ Name string

+ Skipped int64

+ type DatabaseSnapshotManifest struct

+ CreatedAt time.Time

+ Format string

+ FormatVersion int

+ HomeCommit string

+ HomeVersion string

+ SourceBackend DatabaseBackend

+ Tables []DatabaseSnapshotManifestTable

+ func ExportDatabaseSnapshot(ctx context.Context, db *gorm.DB, opts DatabaseSnapshotExportOptions) (DatabaseSnapshotManifest, error)

+ type DatabaseSnapshotManifestTable struct

+ Name string

+ Restore bool

+ Rows int64

+ SHA256 string

+ type DatabaseSnapshotProgress struct

+ Operation string

+ Rows int64

+ Skipped int64

+ Table string

type PeriodLimitConfigError

+ Code string

+ Field string

type Repository

+ func (r *Repository) AllowUserSecurityActionWithRetry(ctx context.Context, action string, scopeHash string, limit int, ...) (bool, time.Duration, error)

+ func (r *Repository) ClaimUserMailJob(ctx context.Context, workerID string, now time.Time, lease time.Duration) (*UserMailJobRecord, error)

+ func (r *Repository) CompleteUserMailJob(ctx context.Context, jobID uint, workerID string, now time.Time) error

+ func (r *Repository) ConsumeUserEmailVerificationToken(ctx context.Context, tokenHash string, now time.Time) (*UserRecord, error)

+ func (r *Repository) ConsumeUserPasswordResetToken(ctx context.Context, tokenHash string, passwordHash string, now time.Time) (*UserRecord, error)

+ func (r *Repository) EnqueueUserMailJob(ctx context.Context, userID uint, purpose string, emailVersion uint64, ...) (*UserMailJobRecord, error)

+ func (r *Repository) FailUserMailJob(ctx context.Context, job *UserMailJobRecord, workerID string, errorCode string, ...) error

+ func (r *Repository) GetUserByEmail(ctx context.Context, email string) (*UserRecord, error)

+ func (r *Repository) InvalidateUserSecurityTokenHash(ctx context.Context, tokenHash string, now time.Time) error

+ func (r *Repository) PurgeExpiredUserSecurity(ctx context.Context, now time.Time, retention time.Duration) error

+ func (r *Repository) RenewUserMailJobClaim(ctx context.Context, jobID uint, workerID string, now time.Time, ...) error

+ func (r *Repository) ReplaceUserSecurityToken(ctx context.Context, record UserSecurityTokenRecord) error

+ func (r *Repository) ReplaceUserSecurityTokenForMailJob(ctx context.Context, jobID uint, workerID string, ...) error

+ func (r *Repository) SupersedeUserMailJob(ctx context.Context, jobID uint, workerID string, now time.Time) error

+ type UserMailJobRecord struct

+ Attempts int

+ ClaimExpiresAt *time.Time

+ ClaimedBy string

+ CreatedAt time.Time

+ EmailVersion uint64

+ ID uint

+ LastErrorCode string

+ NextAttemptAt time.Time

+ Purpose string

+ SentAt *time.Time

+ SessionVersion uint64

+ Status string

+ UpdatedAt time.Time

+ UserID uint

+ func (UserMailJobRecord) TableName() string

type UserRecord

+ Email *string

+ EmailVerifiedAt *time.Time

+ EmailVersion uint64

+ SessionVersion uint64

+ type UserSecurityThrottleRecord struct

+ Count int

+ ExpiresAt time.Time

+ Key string

+ UpdatedAt time.Time

+ func (UserSecurityThrottleRecord) TableName() string

+ type UserSecurityTokenRecord struct

+ CreatedAt time.Time

+ EmailVersion uint64

+ ExpiresAt time.Time

+ ID uint

+ Purpose string

+ TokenHash string

+ UsedAt *time.Time

+ UserID uint

+ func (UserSecurityTokenRecord) TableName() string

type UserUpdate

+ Email *string

+ type ValidatedDatabaseSnapshot struct

+ func OpenDatabaseSnapshot(ctx context.Context, path string) (*ValidatedDatabaseSnapshot, error)

+ func (s *ValidatedDatabaseSnapshot) Close() error

+ func (s *ValidatedDatabaseSnapshot) Manifest() DatabaseSnapshotManifest

+ func (s *ValidatedDatabaseSnapshot) ValidateForBackend(ctx context.Context, backend DatabaseBackend) error

Jul 20, 2026

Changes in this version

type Repository

+ func (r *Repository) RunUsageDerivedColumnBackfillBatch(ctx context.Context) (UsageDerivedColumnBackfillResult, error)

+ type UsageDerivedColumnBackfillResult struct

+ Done bool

+ Scanned int

+ Skipped bool

+ Updated int64

Jul 19, 2026

Changes in this version

+ const BillingReportTimezoneUTC

type BillingBalanceQuery

+ ToExclusive *time.Time

type BillingChargeQuery

+ ToExclusive *time.Time

type BillingOverviewQuery

+ ToExclusive *time.Time

type BillingRange

+ FromAt *time.Time

+ ToAtExclusive *time.Time

type BillingSettings

+ ReportTimezone string

type BillingSettingsPatch

+ ReportTimezone *string

Jul 19, 2026

Changes in this version

+ const UsageObservabilityMaxTrendBuckets

+ var ErrAPIKeySelectorMismatch = errors.New("api key selector mismatch")

+ var ErrPluginStoreAuthConflict = errors.New("plugin store auth update conflict")

+ var ErrUsageObservabilityTooManyTrendBuckets = errors.New("usage overview trend bucket limit exceeded")

+ func IsAPIKeyConflictError(err error) bool

+ type APIKeyAdminUpdate struct

+ APIKey *string

+ Channels *[]uint

+ ModelGroups *[]uint

+ UserID *uint

type APIKeyEntry

+ ID uint

type APIKeyEntryUpdate

+ ID uint

+ type APIKeySelector struct

+ APIKey string

+ ID uint

+ Index *int

type BillingOverviewQuery

+ Timezone string

type BillingRange

+ Timezone string

+ type PluginStoreAuthKeyRecord struct

+ ID uint

+ Key []byte

+ KeyVersion int

+ func (PluginStoreAuthKeyRecord) TableName() string

+ type PluginStoreAuthRecord struct

+ ApplyTo JSONB

+ AuthType string

+ Enabled bool

+ EncryptedCredentials []byte

+ HeaderName string

+ ID uint

+ KeyVersion int

+ Match string

+ Name string

+ Version int64

+ func (PluginStoreAuthRecord) TableName() string

+ type PluginStoreAuthSealFunc func(id uint) ([]byte, int, error)

type Repository

+ func (r *Repository) ClientCertificateFingerprintActive(ctx context.Context, certificateID string, fingerprint string) (bool, error)

+ func (r *Repository) CreateAPIKey(ctx context.Context, update APIKeyEntryUpdate) (*APIKeyRecord, error)

+ func (r *Repository) CreatePluginStoreAuth(ctx context.Context, record *PluginStoreAuthRecord, ...) error

+ func (r *Repository) DeleteAPIKey(ctx context.Context, selector APIKeySelector) error

+ func (r *Repository) DeletePluginStoreAuth(ctx context.Context, id uint) error

+ func (r *Repository) EnsurePluginStoreAuthKey(ctx context.Context) ([]byte, int, error)

+ func (r *Repository) GetPluginStoreAuth(ctx context.Context, id uint) (*PluginStoreAuthRecord, error)

+ func (r *Repository) ListPluginStoreAuth(ctx context.Context) ([]PluginStoreAuthRecord, error)

+ func (r *Repository) PluginStoreAuthRevision(ctx context.Context) (int64, error)

+ func (r *Repository) UpdateAPIKey(ctx context.Context, selector APIKeySelector, update APIKeyAdminUpdate) (*APIKeyRecord, error)

+ func (r *Repository) UpdatePluginStoreAuth(ctx context.Context, record *PluginStoreAuthRecord) error

Jul 16, 2026

Changes in this version

+ var ErrQuotaProbeLeaseLost = errors.New("quota probe lease is no longer owned")

+ func NormalizeQuotaWindowValues(window *QuotaWindow)

+ func SafeQuotaRequestID(value string) string

+ type QuotaCollectionError struct

+ Code string

+ Message string

+ OccurredAt *time.Time

+ RequestID *string

+ Retryable bool

+ UpstreamStatusCode *int

+ type QuotaCredentialSnapshot struct

+ Account *string

+ AuthIndex *string

+ CollectionStatus string

+ ConsecutiveFailure int

+ CredentialID string

+ CredentialStatus string

+ CredentialType string

+ EarliestResetAt *time.Time

+ Error *QuotaCollectionError

+ ExpiresAt *time.Time

+ Freshness string

+ Label string

+ LastAttemptAt *time.Time

+ LastSuccessAt *time.Time

+ NextProbeAt *time.Time

+ ObservedAt *time.Time

+ PrimaryWindows []QuotaWindow

+ Project *string

+ Provider string

+ QuotaStatus string

+ Runtime *QuotaRuntime

+ Source *string

+ WindowCount int

+ Windows []QuotaWindow

+ type QuotaFacetOption struct

+ Count int

+ Value string

+ type QuotaFacets struct

+ CollectionStatuses []QuotaFacetOption

+ CredentialStatuses []QuotaFacetOption

+ Freshness []QuotaFacetOption

+ Providers []QuotaFacetOption

+ QuotaStatuses []QuotaFacetOption

+ Sources []QuotaFacetOption

+ type QuotaListQuery struct

+ CollectionStatuses map[string]struct{}

+ CredentialStatuses map[string]struct{}

+ Freshness map[string]struct{}

+ Limit int

+ Now time.Time

+ Offset int

+ Providers map[string]struct{}

+ QuotaStatuses map[string]struct{}

+ Search string

+ Sort string

+ Sources map[string]struct{}

+ type QuotaListResult struct

+ Facets QuotaFacets

+ GlobalSummary QuotaSummary

+ Items []QuotaCredentialSnapshot

+ Summary QuotaSummary

+ Total int

+ type QuotaRuntime struct

+ CPANodeID string

+ CPANodeLabel string

+ HomeID string

+ HomeLabel string

+ type QuotaSnapshotRecord struct

+ CPANodeID string

+ CPANodeLabel string

+ CollectionStatus string

+ CollectorVersion int

+ ConsecutiveFailure int

+ CreatedAt time.Time

+ CredentialID string

+ ErrorCode string

+ ErrorMessage string

+ ErrorOccurredAt *time.Time

+ ErrorRequestID string

+ ErrorRetryable bool

+ ErrorStatusCode int

+ ExpiresAt *time.Time

+ HomeID string

+ HomeLabel string

+ LastAttemptAt *time.Time

+ LastSuccessAt *time.Time

+ NextProbeAt *time.Time

+ ObservedAt *time.Time

+ ParserVersion int

+ ProbeLeaseExpiresAt *time.Time

+ ProbeLeaseOwner string

+ QuotaStatus string

+ Source string

+ UpdatedAt time.Time

+ func (QuotaSnapshotRecord) TableName() string

+ type QuotaSnapshotWrite struct

+ ClearProbeLease bool

+ CollectionStatus string

+ CollectorVersion int

+ ConsecutiveFailure int

+ CredentialID string

+ Error *QuotaCollectionError

+ ExpectedProbeOwner string

+ ExpiresAt *time.Time

+ LastAttemptAt *time.Time

+ LastSuccessAt *time.Time

+ MaxAcceptedObservedAt *time.Time

+ NextProbeAt *time.Time

+ ObservedAt *time.Time

+ ParserVersion int

+ QuotaStatus string

+ ReplaceWindows bool

+ Runtime *QuotaRuntime

+ Source string

+ Windows []QuotaWindow

+ type QuotaSummary struct

+ Collecting int

+ Error int

+ Exhausted int

+ Healthy int

+ LastObservedAt *time.Time

+ Low int

+ NeedsAttention int

+ Never int

+ Stale int

+ TotalCredentials int

+ Unknown int

+ Unsupported int

+ type QuotaWindow struct

+ Currency *string

+ ExpiresAt *time.Time

+ ID string

+ IsUnlimited bool

+ Label *string

+ Limit *float64

+ Mode string

+ ObservedAt time.Time

+ PeriodUnit string

+ PeriodValue *float64

+ Priority int

+ Remaining *float64

+ RemainingRatio *float64

+ ResetAt *time.Time

+ Scope string

+ ScopeID *string

+ Source string

+ Status string

+ Unit string

+ Used *float64

+ UsedRatio *float64

+ WindowSeconds *int64

+ type QuotaWindowRecord struct

+ CreatedAt time.Time

+ CredentialID string

+ Currency string

+ ExpiresAt *time.Time

+ IsUnlimited bool

+ Label string

+ Limit *float64

+ Mode string

+ ObservedAt time.Time

+ PeriodUnit string

+ PeriodValue *float64

+ Priority int

+ Remaining *float64

+ RemainingRatio *float64

+ ResetAt *time.Time

+ Scope string

+ ScopeID string

+ Source string

+ Status string

+ Unit string

+ UpdatedAt time.Time

+ Used *float64

+ UsedRatio *float64

+ WindowID string

+ WindowSeconds *int64

+ func (QuotaWindowRecord) TableName() string

type Repository

+ func (r *Repository) ClaimEligibleQuotaProbe(ctx context.Context, credentialID string, owner string, now time.Time, ...) (bool, error)

+ func (r *Repository) ClaimQuotaProbe(ctx context.Context, credentialID string, owner string, now time.Time, ...) (bool, error)

+ func (r *Repository) DialectName() string

+ func (r *Repository) FailQuotaProbe(ctx context.Context, credentialID string, owner string, ...) error

+ func (r *Repository) FailQuotaProbeAt(ctx context.Context, credentialID string, owner string, ...) error

+ func (r *Repository) GetQuotaCredential(ctx context.Context, credentialID string, now time.Time) (*QuotaCredentialSnapshot, error)

+ func (r *Repository) ListQuotaCredentials(ctx context.Context, query QuotaListQuery) (QuotaListResult, error)

+ func (r *Repository) UpsertQuotaSnapshot(ctx context.Context, input QuotaSnapshotWrite) (bool, error)

Jul 14, 2026

Changes in this version

+ const BillingModelPriceImportSourceModelsDev

+ var ErrBillingImportIdempotencyConflict = errors.New("billing import idempotency key was reused with a different request")

+ var ErrBillingImportInvalidSelection = errors.New("billing import invalid selection")

+ var ErrBillingImportOperationNotFound = errors.New("billing import operation not found")

+ var ErrBillingImportOverwriteRequired = errors.New("billing import overwrite confirmation required")

+ var ErrBillingImportPreviewExpired = errors.New("billing import preview expired")

+ var ErrBillingImportPreviewNotFound = errors.New("billing import preview not found")

+ var ErrBillingImportPreviewStale = errors.New("billing import preview stale")

+ var ErrBillingImportRuleConflict = errors.New("billing import rule conflict")

+ func SanitizeUsagePayloadSecrets(payload string) (string, error)

+ func ValidateBillingModelPriceImportPreviewInput(input BillingModelPriceImportPreviewInput) error

+ type BillingModelPriceImportAlias struct

+ SourceModels []string

+ TargetModel string

+ type BillingModelPriceImportApplyInput struct

+ ConfirmOverwrite bool

+ IdempotencyKey string

+ PreviewID string

+ PreviewRevision string

+ SelectedKeys []string

+ type BillingModelPriceImportCatalog struct

+ FetchedAt time.Time

+ Models []BillingModelPriceImportCatalogModel

+ SourceURL string

+ Version string

+ type BillingModelPriceImportCatalogModel struct

+ ContextBandIssues []string

+ ContextBands []BillingModelPriceImportContextBand

+ Cost *BillingModelPriceImportCost

+ InvalidPriceFields []string

+ Model string

+ Name string

+ Provider string

+ UnsupportedDimensions []string

+ type BillingModelPriceImportContextBand struct

+ Cost BillingModelPriceImportCost

+ InvalidPriceFields []string

+ MinInputTokens int64

+ MissingPriceFields []string

+ UnsupportedDimensions []string

+ type BillingModelPriceImportCost struct

+ CacheRead float64

+ CacheWrite float64

+ Input float64

+ Output float64

+ Request float64

+ type BillingModelPriceImportMatchOverride struct

+ SourceModel string

+ SourceProvider string

+ TargetModel string

+ TargetProvider string

+ type BillingModelPriceImportMultiplierRule struct

+ ID string

+ Label string

+ MatchMode string

+ Multiplier float64

+ Pattern string

+ type BillingModelPriceImportOperation struct

+ AppliedAt time.Time

+ Atomic bool

+ OperationID string

+ PreviewID string

+ Rows []BillingModelPriceImportOperationRowResult

+ Status string

+ Summary BillingModelPriceImportSummary

+ type BillingModelPriceImportOperationRecord struct

+ AppliedAt time.Time

+ Atomic bool

+ CreatedAt time.Time

+ ID string

+ IdempotencyKey string

+ PreviewID string

+ PreviewRevision string

+ RequestHash string

+ Result JSONB

+ SelectionHash string

+ Status string

+ func (BillingModelPriceImportOperationRecord) TableName() string

+ type BillingModelPriceImportOperationRowResult struct

+ Action string

+ ErrorCode string

+ ErrorMessage string

+ Key string

+ Model string

+ Provider string

+ ResourceID string

+ Status string

+ type BillingModelPriceImportPolicy struct

+ Aliases []BillingModelPriceImportAlias

+ DefaultMultiplier float64

+ IncludeZeroCost bool

+ MultiplierRules []BillingModelPriceImportMultiplierRule

+ OverwriteMode string

+ RowMultipliers map[string]float64

+ type BillingModelPriceImportPreview struct

+ Atomic bool

+ ExpiresAt time.Time

+ GeneratedAt time.Time

+ PreviewID string

+ PreviewRevision string

+ Rows []BillingModelPriceImportPreviewRow

+ Source string

+ SourceFetchedAt time.Time

+ SourceModelCount int

+ SourceURL string

+ SourceVersion string

+ Summary BillingModelPriceImportSummary

+ type BillingModelPriceImportPreviewInput struct

+ MatchOverrides []BillingModelPriceImportMatchOverride

+ Policy BillingModelPriceImportPolicy

+ Source string

+ Targets []BillingModelPriceImportTarget

+ type BillingModelPriceImportPreviewRecord struct

+ Atomic bool

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ GeneratedAt time.Time

+ ID string

+ Payload JSONB

+ Revision string

+ Source string

+ SourceFetchedAt time.Time

+ SourceModelCount int

+ SourceURL string

+ SourceVersion string

+ func (BillingModelPriceImportPreviewRecord) TableName() string

+ type BillingModelPriceImportPreviewRow struct

+ Action string

+ Applicable bool

+ ExistingRule *BillingModelPriceImportRuleSnapshot

+ Final *BillingModelPriceImportCost

+ Label string

+ MatchedModel string

+ MatchedName string

+ MatchedProvider string

+ MinInputTokens int64

+ Model string

+ Multiplier float64

+ Official *BillingModelPriceImportCost

+ Provider string

+ Reasons []BillingModelPriceImportReason

+ RowKey string

+ SelectedDefault bool

+ ServiceTier string

+ Status string

+ WriteRule *BillingModelPriceImportWriteRule

+ type BillingModelPriceImportReason struct

+ Candidates []string

+ Code string

+ Message string

+ type BillingModelPriceImportRuleSnapshot struct

+ CacheReadPricePerMillion float64

+ CacheWritePricePerMillion float64

+ Enabled bool

+ ID string

+ InputPricePerMillion float64

+ MinInputTokens int64

+ Model string

+ Note string

+ OutputPricePerMillion float64

+ Provider string

+ RequestPrice float64

+ Revision string

+ ServiceTier string

+ Source string

+ type BillingModelPriceImportSummary struct

+ Conflicts int

+ Creates int

+ Failed int

+ Overwrites int

+ Reviews int

+ Skips int

+ Total int

+ UpdatesSync int

+ type BillingModelPriceImportTarget struct

+ Label string

+ MinInputTokens int64

+ Model string

+ Provider string

+ Scopes []string

+ ServiceTier string

+ type BillingModelPriceImportWriteRule struct

+ Enabled bool

+ MinInputTokens int64

+ Note string

+ ServiceTier string

+ Source string

type BillingModelPriceRecord

+ Revision int64

+ type BillingTierDiagnostics struct

+ EligibleRequests int64

+ FallbackRequests int64

+ LastResponseTierAt *time.Time

+ ResponseTierRequests int64

+ Supported bool

+ WindowEnd *time.Time

+ WindowStart *time.Time

type CredentialConfigCounts

+ XAIKeys int

type Repository

+ func (r *Repository) ApplyBillingModelPriceImport(ctx context.Context, input BillingModelPriceImportApplyInput) (*BillingModelPriceImportOperation, error)

+ func (r *Repository) CreateBillingModelPriceImportPreview(ctx context.Context, input BillingModelPriceImportPreviewInput, ...) (*BillingModelPriceImportPreview, error)

+ func (r *Repository) GetBillingModelPriceImportOperation(ctx context.Context, id string) (*BillingModelPriceImportOperation, error)

+ func (r *Repository) GetBillingTierDiagnostics(ctx context.Context) (BillingTierDiagnostics, error)

+ func (r *Repository) RunUsageCacheReadBackfillBatch(ctx context.Context) (UsageCacheReadBackfillResult, error)

+ func (r *Repository) UpsertAuthPreservingDisabled(ctx context.Context, auth *coreauth.Auth, op string) (*AuthRecord, error)

+ type UsageCacheReadBackfillResult struct

+ Done bool

+ Scanned int

+ Skipped bool

+ Updated int64

type UsageRecord

+ CacheReadTokensPresent bool

Jul 10, 2026

Changes in this version

+ const BillingServiceTierSourceRequest

+ const BillingServiceTierSourceResponse

+ const BillingServiceTierWildcard

+ var ErrBillingInvalidModelPrice = errors.New("invalid billing model price")

+ var ErrOAuthSessionNotPending = errors.New("oauth session is not pending")

type BillingModelPricePatch

+ MinInputTokens *int64

+ ServiceTier *string

type BillingModelPriceRecord

+ MinInputTokens int64

+ ServiceTier string

type BillingModelPriceUpdate

+ MinInputTokens int64

+ ServiceTier string

type BillingPriceSnapshot

+ EffectiveServiceTier string

+ MatchedServiceTier string

+ MinInputTokens int64

+ RequestedServiceTier string

+ ResponseServiceTier string

+ ResponseTierFallback bool

+ ServiceTierSource string

+ type BillingSettings struct

+ ServiceTierSource string

+ type BillingSettingsPatch struct

+ ServiceTierSource *string

type Repository

+ func (r *Repository) GetBillingSettings(ctx context.Context) (BillingSettings, error)

+ func (r *Repository) UpdateBillingSettings(ctx context.Context, patch BillingSettingsPatch) (BillingSettings, error)

type UsageRecord

+ RequestServiceTier string

+ ResponseServiceTier string

Jul 9, 2026

Changes in this version

+ const DefaultPeriodWindowMode

+ const DefaultUserTimezone

+ const DefaultWeekResetDay

+ const DefaultWeekResetHour

+ const PeriodResetModeCounter

+ const PeriodResetModeWindowOnly

+ const PeriodWindow1d

+ const PeriodWindow30d

+ const PeriodWindow5h

+ const PeriodWindow7d

+ const PeriodWindowModeCalendar

+ const PeriodWindowModeFirstUse

+ const PeriodWindowModeFixed

+ const PeriodWindowModeRolling

+ const PeriodWindowModeSliding

+ func CanonicalPeriodWindowMode(mode string, allowCalendar bool) string

+ func DefaultHeartbeatTimeout() time.Duration

+ func UsagePayloadWithRuntimeMetadata(payload string, metadata UsageRuntimeMetadata) (string, error)

+ type OptionalFloatUpdate struct

+ Clear bool

+ Set bool

+ Value float64

+ type PeriodLimitConfigError struct

+ Message string

+ func (e PeriodLimitConfigError) Error() string

type Repository

+ func (r *Repository) AppendUsageWithRuntime(ctx context.Context, payload string, metadata UsageRuntimeMetadata) (*UsageRecord, error)

+ func (r *Repository) BuildUserPeriodLimitsStatus(ctx context.Context, userID uint, now time.Time) (UserPeriodLimitsStatus, error)

+ func (r *Repository) ListCPANodeSnapshots(ctx context.Context, cutoff time.Time) ([]CPANodeRecord, error)

+ func (r *Repository) ListClusterNodes(ctx context.Context, cutoff time.Time) ([]ClusterNodeRecord, error)

+ func (r *Repository) ResetUserPeriodLimits(ctx context.Context, userID uint, windows []string, mode string, now time.Time) (UserPeriodLimitResetResult, error)

+ func (r *Repository) SumUserChargeAmountSince(ctx context.Context, userID uint, since time.Time) (float64, error)

+ func (r *Repository) UsageObservabilityFilterOptions(ctx context.Context, query UsageObservabilityRecordQuery) (UsageObservabilityFilterOptions, error)

type RuntimeAdapter

+ func (a *RuntimeAdapter) SetHomePort(port int)

type UsageObservabilityError

+ Reason string

+ UpstreamStatusCode int

+ type UsageObservabilityFilterOptions struct

+ CPANodes []string

+ EventTypes []string

+ HomeIPs []string

+ Models []string

+ Providers []string

+ StatusCodes []int

type UsageObservabilityRecord

+ EventType string

+ UpstreamStatusCode int

type UsageObservabilityRecordQuery

+ CPANode string

+ EventType string

type UsageObservabilityRuntime

+ CPAIP string

+ CPALabel string

+ CPANodeID string

+ CPAPort int

+ HomePort int

type UsageRecord

+ CPAIP string

+ CPALabel string

+ CPANodeID string

+ CPAPort int

+ EventType string

+ HomePort int

+ UpstreamRequestID string

+ UpstreamStatusCode int

+ func UsageRecordFromPayloadWithRuntime(payload string, metadata UsageRuntimeMetadata) (*UsageRecord, error)

+ type UsageRuntimeMetadata struct

+ CPAIP string

+ CPALabel string

+ CPANodeID string

+ CPAPort int

+ HomeIP string

+ HomePort int

+ type UserPeriodLimitResetResult struct

+ At time.Time

+ Limits UserPeriodLimitsStatus

+ Mode string

+ UserID uint

+ Windows []string

+ type UserPeriodLimitsStatus struct

+ Credits float64

+ CreditsUnlimited bool

+ Timezone string

+ UserID uint

+ Windows []UserPeriodWindowStatus

+ type UserPeriodWindowStatus struct

+ Active bool

+ Enabled bool

+ ID string

+ Limit *float64

+ Mode string

+ Remaining *float64

+ ResetAt *time.Time

+ UsageEpoch *time.Time

+ Used float64

+ WeekResetDay *int

+ WeekResetHour *int

+ WindowEnd *time.Time

+ WindowStart *time.Time

type UserRecord

+ CreditsUnlimited bool

+ Limit1dCredits *float64

+ Limit30dCredits *float64

+ Limit5hCredits *float64

+ Limit7dCredits *float64

+ PeriodWindowStart1d *time.Time

+ PeriodWindowStart30d *time.Time

+ PeriodWindowStart5h *time.Time

+ PeriodWindowStart7d *time.Time

+ Timezone string

+ UsageEpoch1d *time.Time

+ UsageEpoch30d *time.Time

+ UsageEpoch5h *time.Time

+ UsageEpoch7d *time.Time

+ WeekResetDay int

+ WeekResetHour int

+ WindowMode1d string

+ WindowMode30d string

+ WindowMode5h string

+ WindowMode7d string

type UserUpdate

+ CreditsUnlimited *bool

+ Limit1dCredits OptionalFloatUpdate

+ Limit30dCredits OptionalFloatUpdate

+ Limit5hCredits OptionalFloatUpdate

+ Limit7dCredits OptionalFloatUpdate

+ Timezone *string

+ WeekResetDay *int

+ WeekResetHour *int

+ WindowMode1d *string

+ WindowMode30d *string

+ WindowMode5h *string

+ WindowMode7d *string

Jul 8, 2026

Changes in this version

type AuthRecord

+ NextRetryAfter *time.Time

type Repository

+ func (r *Repository) UsageObservabilityHealthDetails(ctx context.Context, query UsageObservabilityRecordQuery, subject string) (map[string]UsageObservabilityHealthDetail, error)

+ func (r *Repository) UsageObservabilityRealtime(ctx context.Context, query UsageObservabilityRealtimeQuery) (UsageObservabilityRealtimeSnapshot, error)

+ type UsageObservabilityHealthDetail struct

+ LastErrorAt *time.Time

+ LastErrorMessage string

+ LastErrorStatus int

+ NextRetryAt *time.Time

+ type UsageObservabilityLatencyDistributionBucket struct

+ Bucket string

+ RequestCount int64

+ type UsageObservabilityRealtimeQuery struct

+ BucketSeconds int

+ CredentialType string

+ Endpoint string

+ From *time.Time

+ GroupBy string

+ HomeIP string

+ Model string

+ Provider string

+ To *time.Time

+ type UsageObservabilityRealtimeSnapshot struct

+ CurrentUsage []UsageObservabilityAggregateItem

+ LatencyDistribution []UsageObservabilityLatencyDistributionBucket

+ Velocity []UsageObservabilityRealtimeVelocityPoint

+ type UsageObservabilityRealtimeVelocityPoint struct

+ BucketEnd time.Time

+ BucketStart time.Time

+ ErrorRate float64

+ RPM float64

+ TPM float64

Jul 8, 2026

Changes in this version

+ type CPANodeRecord struct

+ ClientCount int

+ ClientIP string

+ ConnectedAt time.Time

+ CreatedAt time.Time

+ HomeIP string

+ HomePort int

+ LastSeenAt time.Time

+ NodeID string

+ NodeKey string

+ UpdatedAt time.Time

+ func (CPANodeRecord) TableName() string

type Repository

+ func (r *Repository) ListLiveCPANodes(ctx context.Context, cutoff time.Time) ([]CPANodeRecord, error)

+ func (r *Repository) ReplaceCPANodeSnapshot(ctx context.Context, homeIP string, homePort int, nodes []node.Node, ...) error

Jul 6, 2026

Changes in this version

type AuthIndex

+ ModelStates map[string]*coreauth.ModelState

+ NextRetryAfter time.Time

+ Quota coreauth.QuotaState

type Repository

+ func (r *Repository) MutateAuth(ctx context.Context, uuid string, op string, ...) (*coreauth.Auth, *AuthRecord, bool, error)

type RuntimeAdapter

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

Jul 1, 2026

Changes in this version

+ const UsageObservabilityBillingBasisCharge

+ const UsageObservabilityBillingBasisUnknown

+ const UsageObservabilityCurrencyCredits

+ const UsageObservabilityDefaultGroupLimit

+ const UsageObservabilityDefaultRecordLimit

+ const UsageObservabilityMaxGroupLimit

+ const UsageObservabilityMaxRecordLimit

type Repository

+ func (r *Repository) GetUsageObservabilityPayloadSummary(ctx context.Context, id string) (*UsageObservabilityPayloadSummary, error)

+ func (r *Repository) GetUsageObservabilityRecord(ctx context.Context, id string) (*UsageObservabilityRecord, error)

+ func (r *Repository) ListUsageObservabilityAggregates(ctx context.Context, query UsageObservabilityAggregateQuery) (UsageObservabilityAggregateResult, error)

+ func (r *Repository) ListUsageObservabilityRecords(ctx context.Context, query UsageObservabilityRecordQuery) (UsageObservabilityRecordListResult, error)

+ func (r *Repository) UsageObservabilityOverview(ctx context.Context, query UsageObservabilityOverviewQuery) (UsageObservabilityOverview, error)

+ type UsageObservabilityActivityPoint struct

+ BucketEnd time.Time

+ BucketStart time.Time

+ ErrorRate float64

+ FailedCount int64

+ RequestCount int64

+ Status string

+ SuccessCount int64

+ SuccessRate float64

+ type UsageObservabilityAggregateItem struct

+ AvgLatencyMS *float64

+ CacheCreationTokens int64

+ CacheRate float64

+ CacheReadTokens int64

+ CachedTokens int64

+ Currency string

+ ErrorRate float64

+ FailedCount int64

+ ID string

+ InputTokens int64

+ Label string

+ LastUsedAt *time.Time

+ Metadata map[string]any

+ OutputTokens int64

+ P95LatencyMS *float64

+ ReasoningTokens int64

+ RequestCount int64

+ SuccessCount int64

+ SuccessRate float64

+ TotalAmount *float64

+ TotalTokens int64

+ type UsageObservabilityAggregateQuery struct

+ CredentialType string

+ Direction string

+ Endpoint string

+ From *time.Time

+ GroupBy string

+ HomeIP string

+ Limit int

+ Metric string

+ Model string

+ Offset int

+ Provider string

+ To *time.Time

+ type UsageObservabilityAggregateResult struct

+ Items []UsageObservabilityAggregateItem

+ Total int64

+ type UsageObservabilityBilling struct

+ Amount *float64

+ BalanceAfter *float64

+ BalanceBefore *float64

+ BillingBasis string

+ ChargeID string

+ Currency string

+ MatchedPriceRule string

+ type UsageObservabilityClient struct

+ APIKeyID *uint

+ APIKeyLabel string

+ APIKeyMasked string

+ ClientIP string

+ UserID *uint

+ Username string

+ type UsageObservabilityCostBreakdownItem struct

+ Amount float64

+ BillingBasis string

+ Category string

+ Percentage float64

+ Tokens int64

+ type UsageObservabilityCredential struct

+ APIKeyPreview string

+ AuthIndex string

+ CredentialID string

+ CredentialType string

+ Label string

+ NextRetryAt *time.Time

+ Provider string

+ Source string

+ Status string

+ type UsageObservabilityError struct

+ BodyPreview string

+ Message string

+ StatusCode int

+ type UsageObservabilityLiveSummary struct

+ ErrorRate float64

+ P50LatencyMS *float64

+ P95LatencyMS *float64

+ RPM float64

+ SuccessRate float64

+ TPM float64

+ WindowSeconds int

+ type UsageObservabilityOverview struct

+ Activity []UsageObservabilityActivityPoint

+ CostBreakdown []UsageObservabilityCostBreakdownItem

+ Live UsageObservabilityLiveSummary

+ ModelEfficiency []UsageObservabilityAggregateItem

+ Range UsageObservabilityOverviewRange

+ Top UsageObservabilityTopGroups

+ Totals UsageObservabilityTotals

+ Trend []UsageObservabilityTrendPoint

+ type UsageObservabilityOverviewQuery struct

+ CredentialType string

+ Endpoint string

+ From *time.Time

+ HomeIP string

+ Interval string

+ Model string

+ Provider string

+ Timezone string

+ To *time.Time

+ type UsageObservabilityOverviewRange struct

+ From string

+ Interval string

+ Timezone string

+ To string

+ type UsageObservabilityPayloadSummary struct

+ MessageCount *int

+ Method *string

+ Stream *bool

+ ToolCount *int

+ type UsageObservabilityPerformance struct

+ LatencyMS int64

+ TPS *float64

+ TTFTMS *int64

+ type UsageObservabilityRecord struct

+ Billing UsageObservabilityBilling

+ Client UsageObservabilityClient

+ Credential UsageObservabilityCredential

+ Endpoint string

+ Error *UsageObservabilityError

+ ExecutorType string

+ Failed bool

+ ID string

+ Model string

+ OriginalModel string

+ Performance UsageObservabilityPerformance

+ Provider string

+ ReasoningEffort string

+ RequestID string

+ Runtime UsageObservabilityRuntime

+ ServiceTier string

+ Source string

+ Status string

+ StatusCode int

+ Timestamp time.Time

+ Tokens UsageObservabilityTokens

+ UpstreamRequestID string

+ UsageID uint

+ type UsageObservabilityRecordListResult struct

+ Records []UsageObservabilityRecord

+ Total int64

+ type UsageObservabilityRecordQuery struct

+ AuthIndex string

+ ClientKey string

+ ClientKeyID *uint

+ CredentialID string

+ CredentialType string

+ Endpoint string

+ ExecutorType string

+ From *time.Time

+ HomeIP string

+ Limit int

+ MaxAmount *float64

+ MaxLatencyMS *int64

+ MaxLimit int

+ MinAmount *float64

+ MinLatencyMS *int64

+ Model string

+ Offset int

+ Provider string

+ RequestID string

+ RequestLogSearch string

+ Search string

+ Sort string

+ Status string

+ StatusCode *int

+ To *time.Time

+ User string

+ UserID *uint

+ type UsageObservabilityRuntime struct

+ HomeIP string

+ LogHomeIPRequired bool

+ RequestLogAvailable bool

+ type UsageObservabilityTokens struct

+ CacheCreationTokens int64

+ CacheReadTokens int64

+ CachedTokens int64

+ InputTokens int64

+ OutputTokens int64

+ ReasoningTokens int64

+ TotalTokens int64

+ type UsageObservabilityTopGroups struct

+ ClientKeys []UsageObservabilityAggregateItem

+ Credentials []UsageObservabilityAggregateItem

+ Endpoints []UsageObservabilityAggregateItem

+ Errors []UsageObservabilityAggregateItem

+ Models []UsageObservabilityAggregateItem

+ Providers []UsageObservabilityAggregateItem

+ Users []UsageObservabilityAggregateItem

+ type UsageObservabilityTotals struct

+ ActiveClientKeyCount int64

+ ActiveCredentialCount int64

+ ActiveModelCount int64

+ ActiveUserCount int64

+ AvgLatencyMS *float64

+ AvgTTFTMS *float64

+ BlendedCostPer1M *float64

+ CacheCreationTokens int64

+ CacheReadTokens int64

+ CachedTokens int64

+ Currency string

+ ErrorRate float64

+ FailedCount int64

+ InputTokens int64

+ OutputTokens int64

+ P50LatencyMS *float64

+ P95LatencyMS *float64

+ ReasoningTokens int64

+ RequestCount int64

+ SuccessCount int64

+ SuccessRate float64

+ TotalAmount *float64

+ TotalTokens int64

+ type UsageObservabilityTrendPoint struct

+ AvgLatencyMS *float64

+ BucketEnd time.Time

+ BucketStart time.Time

+ CacheCreationTokens int64

+ CacheReadTokens int64

+ CachedTokens int64

+ FailedCount int64

+ InputTokens int64

+ OutputTokens int64

+ P95LatencyMS *float64

+ ReasoningTokens int64

+ RequestCount int64

+ SuccessCount int64

+ TotalAmount *float64

+ TotalTokens int64

Jun 25, 2026

Changes in this version

+ type PluginStatusRecord struct

+ ClientIP string

+ CreatedAt time.Time

+ FinishedAt *time.Time

+ GOARCH string

+ GOOS string

+ InstallStatus string

+ LoadStatus string

+ NodeID string

+ NodeType string

+ OK bool

+ Overwritten bool

+ Path string

+ Phase string

+ PluginError string

+ PluginID string

+ ReleaseTag string

+ ReportedAt time.Time

+ Repository string

+ SchemaVersion int

+ Skipped bool

+ StartedAt time.Time

+ Task string

+ TaskError string

+ TaskID uint

+ TaskStatus string

+ UpdatedAt time.Time

+ Variant string

+ Version string

+ func (PluginStatusRecord) TableName() string

+ type PluginTaskRecord struct

+ CreatedAt time.Time

+ ID uint

+ Operation string

+ PluginID string

+ TargetNodeID string

+ TargetNodeType string

+ UpdatedAt time.Time

+ func (PluginTaskRecord) TableName() string

type Repository

+ func (r *Repository) CreatePluginTask(ctx context.Context, task node.PluginTask) (node.PluginTask, error)

+ func (r *Repository) ListPendingPluginTasks(ctx context.Context, nodeType string, nodeID string) ([]node.PluginTask, error)

+ func (r *Repository) ListPluginStatuses(ctx context.Context, nodeType string) ([]node.PluginTaskStatus, error)

+ func (r *Repository) ReplaceConfigSnapshotAndCreatePluginTask(ctx context.Context, values map[string]any, task node.PluginTask) (node.PluginTask, error)

+ func (r *Repository) ReplacePluginStatus(ctx context.Context, nodeType string, status node.PluginTaskStatus) error

type RuntimeAdapter

+ func (a *RuntimeAdapter) ListPendingPluginTasks(ctx context.Context, nodeType string, nodeID string) ([]node.PluginTask, error)

+ func (a *RuntimeAdapter) ReplacePluginStatus(ctx context.Context, nodeType string, status node.PluginTaskStatus) error

Jun 14, 2026

Changes in this version

+ type KVGetResult struct

+ Found bool

+ Value []byte

+ type KVRecord struct

+ CreatedAt time.Time

+ ExpiresAt *time.Time

+ Key string

+ UpdatedAt time.Time

+ Value []byte

+ Version int64

+ func (KVRecord) TableName() string

+ type KVSetMode string

+ const KVSetModeAlways

+ const KVSetModeNX

+ const KVSetModeXX

type Repository

+ func (r *Repository) KVDel(ctx context.Context, keys []string) (int64, error)

+ func (r *Repository) KVExpire(ctx context.Context, key string, ttl time.Duration) (bool, error)

+ func (r *Repository) KVGet(ctx context.Context, key string) ([]byte, bool, error)

+ func (r *Repository) KVIncrBy(ctx context.Context, key string, delta int64) (int64, error)

+ func (r *Repository) KVMGet(ctx context.Context, keys []string) ([]KVGetResult, error)

+ func (r *Repository) KVMSet(ctx context.Context, pairs map[string][]byte) error

+ func (r *Repository) KVPurgeExpired(ctx context.Context, now time.Time, limit int) (int64, error)

+ func (r *Repository) KVSet(ctx context.Context, key string, value []byte, ttl time.Duration, ...) (bool, error)

+ func (r *Repository) KVTTL(ctx context.Context, key string) (int64, error)

+ func (r *Repository) ValidateAPIKey(ctx context.Context, apiKey string) (bool, error)

type RuntimeAdapter

+ func (a *RuntimeAdapter) KVDel(ctx context.Context, keys []string) (int64, error)

+ func (a *RuntimeAdapter) KVExpire(ctx context.Context, key string, ttl time.Duration) (bool, error)

+ func (a *RuntimeAdapter) KVGet(ctx context.Context, key string) ([]byte, bool, error)

+ func (a *RuntimeAdapter) KVIncrBy(ctx context.Context, key string, delta int64) (int64, error)

+ func (a *RuntimeAdapter) KVMGet(ctx context.Context, keys []string) ([]home.KVGetResult, error)

+ func (a *RuntimeAdapter) KVMSet(ctx context.Context, pairs map[string][]byte) error

+ func (a *RuntimeAdapter) KVPurgeExpired(ctx context.Context, now time.Time, limit int) (int64, error)

+ func (a *RuntimeAdapter) KVSet(ctx context.Context, key string, value []byte, ttl time.Duration, mode string) (bool, error)

+ func (a *RuntimeAdapter) KVTTL(ctx context.Context, key string) (int64, error)

+ func (a *RuntimeAdapter) ValidateAPIKey(ctx context.Context, apiKey string) (bool, error)

Jun 9, 2026

Changes in this version

+ const BillingBalanceTypeDeduct

+ const BillingBalanceTypeRecharge

+ const BillingPriceSourceDefault

+ const BillingPriceSourceManual

+ const BillingPriceSourceSync

+ const ProxyPoolScopeGlobal

+ const ProxyPoolTestResultFailed

+ const ProxyPoolTestResultPassed

+ const ProxyPoolTestResultUntested

+ var ErrBillingDuplicateModelPrice = errors.New("billing model price already exists")

+ type BillingBalanceQuery struct

+ From *time.Time

+ Limit int

+ Offset int

+ To *time.Time

+ UserID *uint

+ UserText string

+ type BillingBalanceRecord struct

+ Amount float64

+ BalanceAfter float64

+ BalanceBefore float64

+ CreatedAt time.Time

+ ID string

+ Note string

+ Operator string

+ Type string

+ UserID uint

+ func (BillingBalanceRecord) TableName() string

+ type BillingBalanceResult struct

+ Records []BillingBalanceRecord

+ Total int64

+ type BillingBalanceUpdate struct

+ Amount float64

+ Note string

+ Operator string

+ Type string

+ UserID uint

+ type BillingChargeQuery struct

+ From *time.Time

+ Limit int

+ Model string

+ Offset int

+ Provider string

+ To *time.Time

+ UserID *uint

+ UserText string

+ type BillingChargeRecord struct

+ APIKeyID *uint

+ APIKeyLabel string

+ APIKeyMasked string

+ ActualModel string

+ Amount float64

+ BalanceAfter float64

+ BalanceBefore float64

+ CacheTokens int64

+ CreatedAt time.Time

+ Endpoint string

+ ID string

+ InputTokens int64

+ MatchedPriceRule string

+ Model string

+ OriginalModel string

+ OutputTokens int64

+ PayloadHash string

+ PriceSnapshot JSONB

+ Provider string

+ RequestID string

+ RequestSummary string

+ UsageID uint

+ UserID *uint

+ func (BillingChargeRecord) TableName() string

+ type BillingChargeResult struct

+ Records []BillingChargeRecord

+ Total int64

+ type BillingModelPricePatch struct

+ CacheReadPricePerMillion *float64

+ CacheWritePricePerMillion *float64

+ Enabled *bool

+ InputPricePerMillion *float64

+ Model *string

+ Note *string

+ OutputPricePerMillion *float64

+ Provider *string

+ RequestPrice *float64

+ Source *string

+ type BillingModelPriceQuery struct

+ Enabled *bool

+ Model string

+ Provider string

+ type BillingModelPriceRecord struct

+ CacheReadPricePerMillion float64

+ CacheWritePricePerMillion float64

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Enabled bool

+ ID string

+ InputPricePerMillion float64

+ Model string

+ Note string

+ OutputPricePerMillion float64

+ Provider string

+ RequestPrice float64

+ Source string

+ UpdatedAt time.Time

+ func (BillingModelPriceRecord) TableName() string

+ type BillingModelPriceUpdate struct

+ CacheReadPricePerMillion float64

+ CacheWritePricePerMillion float64

+ Enabled bool

+ InputPricePerMillion float64

+ Model string

+ Note string

+ OutputPricePerMillion float64

+ Provider string

+ RequestPrice float64

+ Source string

+ type BillingOverview struct

+ ActiveUserCount int64

+ CacheTokens int64

+ DailyTrend []BillingTrendPoint

+ InputTokens int64

+ OutputTokens int64

+ Range BillingRange

+ RequestCount int64

+ TopModels []BillingTopItem

+ TopProviders []BillingTopItem

+ TopUsers []BillingTopItem

+ TotalBalance float64

+ TotalChargeAmount float64

+ TotalDeductAmount float64

+ TotalRechargeAmount float64

+ type BillingOverviewQuery struct

+ From *time.Time

+ Model string

+ Provider string

+ To *time.Time

+ UserID *uint

+ UserText string

+ type BillingPriceSnapshot struct

+ CacheReadPricePerMillion float64

+ CacheWritePricePerMillion float64

+ InputPricePerMillion float64

+ Model string

+ OutputPricePerMillion float64

+ Provider string

+ RequestPrice float64

+ type BillingRange struct

+ From string

+ To string

+ type BillingTopItem struct

+ Amount float64

+ ID string

+ Label string

+ RequestCount int64

+ type BillingTrendPoint struct

+ ChargeAmount float64

+ Date string

+ RequestCount int64

+ type ProxyPoolPatch struct

+ Enabled *bool

+ Name *string

+ Note *string

+ Priority *int

+ ProxyURL *string

+ Scope *string

+ type ProxyPoolRecord struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Enabled bool

+ ID string

+ LastTestResult string

+ LastTestedAt *time.Time

+ Name string

+ Note string

+ Priority int

+ ProxyURL string

+ Scope string

+ UpdatedAt time.Time

+ func (ProxyPoolRecord) TableName() string

+ type ProxyPoolUpdate struct

+ Enabled *bool

+ Name string

+ Note string

+ Priority int

+ ProxyURL string

+ Scope string

type Repository

+ func (r *Repository) ApplyBillingBalanceRecord(ctx context.Context, update BillingBalanceUpdate) (*BillingBalanceRecord, error)

+ func (r *Repository) BillingOverview(ctx context.Context, query BillingOverviewQuery) (BillingOverview, error)

+ func (r *Repository) CreateBillingModelPrice(ctx context.Context, update BillingModelPriceUpdate) (*BillingModelPriceRecord, error)

+ func (r *Repository) CreateProxyPoolItem(ctx context.Context, update ProxyPoolUpdate) (*ProxyPoolRecord, error)

+ func (r *Repository) DeleteBillingModelPrice(ctx context.Context, id string) error

+ func (r *Repository) DeleteProxyPoolItem(ctx context.Context, id string) error

+ func (r *Repository) GetBillingModelPrice(ctx context.Context, id string) (*BillingModelPriceRecord, error)

+ func (r *Repository) GetProxyPoolItem(ctx context.Context, id string) (*ProxyPoolRecord, error)

+ func (r *Repository) ListBillingBalanceRecords(ctx context.Context, query BillingBalanceQuery) (BillingBalanceResult, error)

+ func (r *Repository) ListBillingCharges(ctx context.Context, query BillingChargeQuery) (BillingChargeResult, error)

+ func (r *Repository) ListBillingModelPrices(ctx context.Context, query BillingModelPriceQuery) ([]BillingModelPriceRecord, error)

+ func (r *Repository) ListProxyPoolItems(ctx context.Context) ([]ProxyPoolRecord, error)

+ func (r *Repository) MarkProxyPoolTestResult(ctx context.Context, id string, result string, testedAt time.Time) (*ProxyPoolRecord, error)

+ func (r *Repository) PatchProxyPoolItem(ctx context.Context, id string, patch ProxyPoolPatch) (*ProxyPoolRecord, error)

+ func (r *Repository) UpdateBillingModelPrice(ctx context.Context, id string, patch BillingModelPricePatch) (*BillingModelPriceRecord, error)

+ func (r *Repository) UpdateProxyPoolItem(ctx context.Context, id string, update ProxyPoolUpdate) (*ProxyPoolRecord, error)

Jun 2, 2026

Changes in this version

+ var ErrAPIKeyExists = errors.New("api key already exists")

+ func IsUserConflictError(err error) bool

+ type APIKeyUserUpdate struct

+ APIKey *string

+ Channels *[]uint

+ ModelGroups *[]uint

type Repository

+ func (r *Repository) ClusterCAKeyPair(ctx context.Context) (*x509.Certificate, *rsa.PrivateKey, error)

+ func (r *Repository) CreateAPIKeyForUser(ctx context.Context, userID uint, update APIKeyUserUpdate) (*APIKeyRecord, error)

+ func (r *Repository) DeleteAPIKeyForUser(ctx context.Context, userID uint, id uint, apiKey string) error

+ func (r *Repository) GetUserByUsername(ctx context.Context, username string) (*UserRecord, error)

+ func (r *Repository) ListAPIKeyRecordsForUser(ctx context.Context, userID uint) ([]APIKeyRecord, error)

+ func (r *Repository) UpdateAPIKeyForUser(ctx context.Context, userID uint, id uint, apiKey string, ...) (*APIKeyRecord, error)

type UserRecord

+ Credits float64

type UserUpdate

+ Credits *float64

Jun 1, 2026

Changes in this version

type UsageRecord

+ ExecutorType string

May 29, 2026

Changes in this version

+ func HTTPClientTLSConfig(tlsConfig *tls.Config, serverName string) (*tls.Config, error)

+ type AppLogQuery struct

+ After *time.Time

+ Before *time.Time

+ ClientIP string

+ HomeIP string

+ Level string

+ Limit int

+ Offset int

+ RequestID string

+ type AppLogQueryResult struct

+ Records []AppLogRecord

+ Total int64

+ type AppLogRecord struct

+ ClientIP string

+ CreatedAt time.Time

+ HomeIP string

+ ID uint

+ Level string

+ Line string

+ RequestID string

+ Timestamp time.Time

+ func AppLogRecordFromPayload(clientIP string, homeIP string, payload string) (*AppLogRecord, error)

+ func (AppLogRecord) TableName() string

type Repository

+ func (r *Repository) AppendAppLog(ctx context.Context, clientIP string, homeIP string, payload string) (*AppLogRecord, error)

+ func (r *Repository) ListAppLogs(ctx context.Context, opts AppLogQuery) (AppLogQueryResult, error)

type RuntimeAdapter

+ func (a *RuntimeAdapter) StoreAppLogPayload(ctx context.Context, clientIP string, payload string) error

type UsageRecord

+ HomeIP string

May 28, 2026

Changes in this version

type UsageRecord

+ ServiceTier string

May 27, 2026

Changes in this version

type UsageRecord

+ Effort string

+ TTFTMS int64

May 26, 2026

Changes in this version

+ var ErrUserNotFound = errors.New("user not found")

+ func ParseUserRecordID(value string) (uint, error)

type APIKeyEntry

+ UserID *uint

type APIKeyEntryUpdate

+ UserID *uint

type APIKeyRecord

+ UserID *uint

type JSONB

+ func NormalizeJSONB(raw json.RawMessage) (*JSONB, error)

type Repository

+ func (r *Repository) CreateUser(ctx context.Context, update UserUpdate) (*UserRecord, error)

+ func (r *Repository) DeleteUser(ctx context.Context, id uint) error

+ func (r *Repository) GetUser(ctx context.Context, id uint) (*UserRecord, error)

+ func (r *Repository) ListUsers(ctx context.Context) ([]UserRecord, error)

+ func (r *Repository) UpdateUser(ctx context.Context, id uint, update UserUpdate) (*UserRecord, error)

+ type UserRecord struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID uint

+ MFA JSONB

+ Passkey JSONB

+ Password string

+ UpdatedAt time.Time

+ Username string

+ func (UserRecord) TableName() string

+ type UserUpdate struct

+ MFA *JSONB

+ Passkey *JSONB

+ Password *string

+ Username *string

May 25, 2026

Changes in this version

+ func ParseChannelRecordID(value string) (uint, error)

+ func ParseModelRecordID(value string) (uint, error)

+ type APIKeyEntry struct

+ APIKey string

+ Channels []uint

+ ModelGroups []uint

+ func APIKeyEntryFromRecord(record *APIKeyRecord) (APIKeyEntry, error)

+ type APIKeyEntryUpdate struct

+ APIKey string

+ Channels *[]uint

+ ModelGroups *[]uint

type APIKeyRecord

+ Channels JSONB

+ ModelGroups JSONB

type APIKeyUpsertStats

+ Updated int

+ type ChannelGroupDetailFilter struct

+ AuthID string

+ ChannelGroupID *uint

+ type ChannelGroupDetailRecord struct

+ AuthID string

+ ChannelGroupID uint

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID uint

+ UpdatedAt time.Time

+ func (ChannelGroupDetailRecord) TableName() string

+ type ChannelGroupDetailUpdate struct

+ AuthID *string

+ ChannelGroupID *uint

+ type ChannelGroupRecord struct

+ ChannelName string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Disabled bool

+ ID uint

+ UpdatedAt time.Time

+ func (ChannelGroupRecord) TableName() string

+ type ChannelGroupUpdate struct

+ ChannelName *string

+ Disabled *bool

+ type ModelGroupDetailFilter struct

+ ModelGroupID *uint

+ ModelID string

+ type ModelGroupDetailRecord struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID uint

+ ModelGroupID uint

+ ModelID string

+ UpdatedAt time.Time

+ func (ModelGroupDetailRecord) TableName() string

+ type ModelGroupDetailUpdate struct

+ ModelGroupID *uint

+ ModelID *string

+ type ModelGroupRecord struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Disabled bool

+ GroupName string

+ ID uint

+ UpdatedAt time.Time

+ func (ModelGroupRecord) TableName() string

+ type ModelGroupUpdate struct

+ Disabled *bool

+ GroupName *string

type Repository

+ func (r *Repository) AllowedAuthIDsForAPIKey(ctx context.Context, apiKey string) ([]string, error)

+ func (r *Repository) AllowedDispatchIDsForAPIKey(ctx context.Context, apiKey string) ([]string, []string, error)

+ func (r *Repository) AllowedModelIDsForAPIKey(ctx context.Context, apiKey string) ([]string, error)

+ func (r *Repository) CreateChannelGroup(ctx context.Context, channelName string, disabled bool) (*ChannelGroupRecord, error)

+ func (r *Repository) CreateChannelGroupDetail(ctx context.Context, channelGroupID uint, authID string) (*ChannelGroupDetailRecord, error)

+ func (r *Repository) CreateModelGroup(ctx context.Context, groupName string, disabled bool) (*ModelGroupRecord, error)

+ func (r *Repository) CreateModelGroupDetail(ctx context.Context, modelGroupID uint, modelID string) (*ModelGroupDetailRecord, error)

+ func (r *Repository) DeleteChannelGroup(ctx context.Context, id uint) error

+ func (r *Repository) DeleteChannelGroupDetail(ctx context.Context, id uint) error

+ func (r *Repository) DeleteModelGroup(ctx context.Context, id uint) error

+ func (r *Repository) DeleteModelGroupDetail(ctx context.Context, id uint) error

+ func (r *Repository) GetChannelGroup(ctx context.Context, id uint) (*ChannelGroupRecord, error)

+ func (r *Repository) GetChannelGroupDetail(ctx context.Context, id uint) (*ChannelGroupDetailRecord, error)

+ func (r *Repository) GetModelGroup(ctx context.Context, id uint) (*ModelGroupRecord, error)

+ func (r *Repository) GetModelGroupDetail(ctx context.Context, id uint) (*ModelGroupDetailRecord, error)

+ func (r *Repository) ListAPIKeyEntries(ctx context.Context) ([]APIKeyEntry, error)

+ func (r *Repository) ListChannelGroupDetails(ctx context.Context, filter ChannelGroupDetailFilter) ([]ChannelGroupDetailRecord, error)

+ func (r *Repository) ListChannelGroups(ctx context.Context) ([]ChannelGroupRecord, error)

+ func (r *Repository) ListModelGroupDetails(ctx context.Context, filter ModelGroupDetailFilter) ([]ModelGroupDetailRecord, error)

+ func (r *Repository) ListModelGroups(ctx context.Context) ([]ModelGroupRecord, error)

+ func (r *Repository) ReplaceAPIKeyEntries(ctx context.Context, entries []APIKeyEntryUpdate) (APIKeyUpsertStats, error)

+ func (r *Repository) UpdateAPIKeyBindings(ctx context.Context, apiKey string, channels *[]uint, modelGroups *[]uint) (*APIKeyRecord, error)

+ func (r *Repository) UpdateAPIKeyChannels(ctx context.Context, apiKey string, channels []uint) (*APIKeyRecord, error)

+ func (r *Repository) UpdateChannelGroup(ctx context.Context, id uint, update ChannelGroupUpdate) (*ChannelGroupRecord, error)

+ func (r *Repository) UpdateChannelGroupDetail(ctx context.Context, id uint, update ChannelGroupDetailUpdate) (*ChannelGroupDetailRecord, error)

+ func (r *Repository) UpdateModelGroup(ctx context.Context, id uint, update ModelGroupUpdate) (*ModelGroupRecord, error)

+ func (r *Repository) UpdateModelGroupDetail(ctx context.Context, id uint, update ModelGroupDetailUpdate) (*ModelGroupDetailRecord, error)

type RuntimeAdapter

+ func (a *RuntimeAdapter) AllowedAuthIDsForAPIKey(ctx context.Context, apiKey string) ([]string, error)

+ func (a *RuntimeAdapter) AllowedDispatchIDsForAPIKey(ctx context.Context, apiKey string) ([]string, []string, error)

+ func (a *RuntimeAdapter) AllowedModelIDsForAPIKey(ctx context.Context, apiKey string) ([]string, error)

May 21, 2026

Changes in this version

type CertificateRecord

+ CertificateFingerprint string

May 19, 2026

Changes in this version

+ func OpenSQLite(ctx context.Context, path string) (*gorm.DB, error)

+ type APIKeyUpsertStats struct

+ Created int

+ Removed int

+ Restored int

+ Unchanged int

+ func (s APIKeyUpsertStats) Changed() bool

type Config

+ SQLite SQLiteConfig

+ func (c *Config) DatabaseBackend() DatabaseBackend

+ type DatabaseBackend string

+ const DatabaseBackendPostgres

+ const DatabaseBackendSQLite

+ type ExportOptions struct

+ AuthDirName string

+ ConfigName string

+ OutputDir string

+ Repository *Repository

+ type ExportStats struct

+ AuthFiles int

+ ConfigBytes int

+ func ExportLocalState(ctx context.Context, opts ExportOptions) (ExportStats, error)

+ type ImportOptions struct

+ AuthDir string

+ ConfigPath string

+ Now time.Time

+ Repository *Repository

+ type ImportStats struct

+ Created int

+ Overwritten int

+ Restored int

+ Skipped int

+ Unchanged int

+ Updated int

+ func ImportLocalState(ctx context.Context, opts ImportOptions) (ImportStats, error)

type JSONB

+ func (JSONB) GormDBDataType(db *gorm.DB, _ *schema.Field) string

+ func (JSONB) GormDataType() string

type PGSQLConfig

+ func (c PGSQLConfig) Configured() bool

type Repository

+ func (r *Repository) UpsertAPIKeys(ctx context.Context, keys []string) (APIKeyUpsertStats, error)

+ func (r *Repository) UpsertAuthWithResult(ctx context.Context, auth *coreauth.Auth, op string) (*AuthRecord, UpsertResult, error)

+ func (r *Repository) UpsertConfigValueWithResult(ctx context.Context, key string, value any) (UpsertResult, error)

+ type SQLiteConfig struct

+ Path string

+ func (c SQLiteConfig) Configured() bool

+ type UpsertResult string

+ const UpsertResultCreated

+ const UpsertResultRestored

+ const UpsertResultUnchanged

+ const UpsertResultUpdated

May 19, 2026

Changes in this version

type CertificateRecord

+ CAFingerprint string

+ ClusterID string

+ EnrollmentSecretHash string

May 18, 2026

Changes in this version

+ type CertificateRecord struct

+ CSRPEM string

+ CertificatePEM string

+ CreatedAt time.Time

+ ID string

+ IP string

+ IsCA bool

+ IsClient bool

+ IsServer bool

+ NotAfter time.Time

+ NotBefore time.Time

+ PrivateKeyPEM string

+ SerialNumber string

+ UpdatedAt time.Time

+ func (CertificateRecord) TableName() string

type RESPHandler

+ func (h *RESPHandler) RequestClientCertificate(ctx context.Context, certificateID string, csrPEM []byte) ([]byte, error)

type Repository

+ func (r *Repository) CreateHomeJWT(ctx context.Context, certificateID string, ip string, port int) (string, error)

+ func (r *Repository) CreatePendingClientCertificate(ctx context.Context) (string, error)

+ func (r *Repository) CurrentMasterNode(ctx context.Context) (*ClusterNodeRecord, error)

+ func (r *Repository) EnsureClusterCertificates(ctx context.Context, ip string) (*tls.Config, error)

+ func (r *Repository) SignClientCertificateRequest(ctx context.Context, certificateID string, csrPEM []byte) ([]byte, []byte, error)

+ func (r *Repository) SignClientCertificateRequestJSON(ctx context.Context, certificateID string, csrPEM []byte) ([]byte, error)

May 16, 2026

Changes in this version

type NodeConfig

+ ExternalPort int

May 13, 2026

Changes in this version

type AuthIndex

+ ModelMetadata map[string]any

May 13, 2026

Changes in this version

+ func IsClientClusterCommand(args []string) bool

+ type APIKeyRecord struct

+ APIKey string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ ID uint

+ UpdatedAt time.Time

+ func (APIKeyRecord) TableName() string

type ClusterNodeRecord

+ ClientCount int

type Coordinator

+ func (c *Coordinator) UpdateClientCount(ctx context.Context, clientCount int) error

type NodeConfig

+ ExternalIP string

type RESPHandler

+ func (h *RESPHandler) UpdateClientCount(ctx context.Context, clientCount int) error

type Repository

+ func (r *Repository) ListLiveClusterNodes(ctx context.Context, cutoff time.Time) ([]ClusterNodeRecord, error)

May 12, 2026

Changes in this version

+ const OAuthSessionTTL

+ func OAuthSessionData(record *OAuthSessionRecord) (map[string]any, error)

+ type CredentialConfigCounts struct

+ ClaudeKeys int

+ CodexKeys int

+ GeminiKeys int

+ OpenAICompatibility int

+ VertexKeys int

+ func ApplyCredentialConfigToRoot(root map[string]any, auths []*coreauth.Auth) CredentialConfigCounts

+ type OAuthSessionRecord struct

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ Data JSONB

+ Error string

+ ExpiresAt time.Time

+ Provider string

+ State string

+ Status string

+ UpdatedAt time.Time

+ func NewOAuthSessionRecord(provider, state string, data map[string]any, now time.Time) (*OAuthSessionRecord, error)

+ func (OAuthSessionRecord) TableName() string

type Repository

+ func (r *Repository) CompleteOAuthSession(ctx context.Context, state string) error

+ func (r *Repository) GetOAuthSession(ctx context.Context, state string) (*OAuthSessionRecord, error)

+ func (r *Repository) MergeOAuthSessionData(ctx context.Context, state string, values map[string]any) error

+ func (r *Repository) SetOAuthSessionError(ctx context.Context, state string, message string) error

+ func (r *Repository) UpsertOAuthSession(ctx context.Context, record *OAuthSessionRecord) error

type UsageRecord

+ CacheCreationTokens int64

+ CacheReadTokens int64

May 11, 2026

Changes in this version

+ const DefaultConfigPath

+ func APIKeyHash(apiKey string) string

+ func ApplyOriginalAuthFileName(auths []*coreauth.Auth, filename string)

+ func AutoMigrate(db *gorm.DB) error

+ func Bootstrap(ctx context.Context, opts BootstrapOptions) error

+ func ClientAddr(ctx context.Context, db *gorm.DB) (string, error)

+ func ConfigRootFromSnapshot(snapshot map[string]json.RawMessage) (map[string]any, error)

+ func DeterministicAPIKeyUUID(provider, baseURL, apiKeyHash, compatName, providerKey string) string

+ func DeterministicVirtualUUID(parentUUID, projectID string) string

+ func EnsureOAuthPayloadUUID(raw []byte) ([]byte, string, bool, error)

+ func ForwardRefreshToMaster(ctx context.Context, master *ClusterNodeRecord, authUUID string, secret string) ([]byte, error)

+ func NormalizeClusterAuth(auth *coreauth.Auth, uuidValue string)

+ func Open(ctx context.Context, cfg PGSQLConfig) (*gorm.DB, error)

+ func RecordToAuth(record *AuthRecord) (*coreauth.Auth, error)

+ func RuntimeConfigFromRoot(root map[string]any) (*appconfig.Config, []byte, error)

+ type AuthIndex struct

+ Attributes map[string]string

+ BaseURL string

+ Disabled bool

+ ID string

+ Index string

+ Label string

+ ModelsHash string

+ Prefix string

+ Provider string

+ Status coreauth.Status

+ UUID string

+ Unavailable bool

+ type AuthRecord struct

+ APIKeyHash string

+ AuthJSON JSONB

+ BaseURL string

+ CompatName string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Disabled bool

+ ID string

+ Index string

+ Label string

+ LastRefreshedAt *time.Time

+ ModelsHash string

+ NextRefreshAfter *time.Time

+ Prefix string

+ Provider string

+ ProviderKey string

+ Status coreauth.Status

+ UUID string

+ Unavailable bool

+ UpdatedAt time.Time

+ Version int64

+ func AuthToRecord(auth *coreauth.Auth) (*AuthRecord, error)

+ func (AuthRecord) TableName() string

+ type BootstrapOptions struct

+ AuthDir string

+ Config *appconfig.Config

+ ConfigPath string

+ Now time.Time

+ Repository *Repository

+ type ClusterEventRecord struct

+ CreatedAt time.Time

+ EntityUUID string

+ ID uint

+ Op string

+ Scope string

+ Version int64

+ func (ClusterEventRecord) TableName() string

+ type ClusterNodeRecord struct

+ IP string

+ IsMaster bool

+ LastSeenAt time.Time

+ Port int

+ SecretHash string

+ StartedAt time.Time

+ func (ClusterNodeRecord) TableName() string

+ type Config struct

+ Node NodeConfig

+ PGSQL PGSQLConfig

+ func LoadConfigOptional(path string) (*Config, bool, error)

+ func (c *Config) Validate() error

+ type ConfigRecord struct

+ CreatedAt time.Time

+ Key string

+ UpdatedAt time.Time

+ Value JSONB

+ Version int64

+ func (ConfigRecord) TableName() string

+ type Coordinator struct

+ func NewCoordinator(repo *Repository, node NodeIdentity, opts CoordinatorOptions) *Coordinator

+ func (c *Coordinator) CurrentMaster(ctx context.Context) (*ClusterNodeRecord, error)

+ func (c *Coordinator) IsMaster() bool

+ func (c *Coordinator) NodeSecret() string

+ func (c *Coordinator) SetOnMasterChanged(callback func(bool))

+ func (c *Coordinator) Start(ctx context.Context) error

+ type CoordinatorOptions struct

+ HeartbeatInterval time.Duration

+ HeartbeatTimeout time.Duration

+ OnMasterChanged func(bool)

+ type DisbandOptions struct

+ AuthDir string

+ ConfigPath string

+ Repository *Repository

+ type DisbandResult struct

+ AuthDir string

+ AuthFiles int

+ ClaudeKeys int

+ CodexKeys int

+ ConfigBytes int

+ ConfigPath string

+ GeminiKeys int

+ OpenAICompatibility int

+ VertexKeys int

+ func Disband(ctx context.Context, opts DisbandOptions) (*DisbandResult, error)

+ type EventWatcher struct

+ func NewEventWatcher(repo *Repository, pollInterval time.Duration, ...) *EventWatcher

+ func NewEventWatcherFrom(repo *Repository, pollInterval time.Duration, lastSeenID int64, ...) *EventWatcher

+ func (w *EventWatcher) Start(ctx context.Context) error

+ type JSONB []byte

+ func (j *JSONB) Scan(value any) error

+ func (j *JSONB) UnmarshalJSON(data []byte) error

+ func (j JSONB) MarshalJSON() ([]byte, error)

+ func (j JSONB) Value() (driver.Value, error)

+ type NodeConfig struct

+ EventPollInterval time.Duration

+ HeartbeatInterval time.Duration

+ HeartbeatTimeout time.Duration

+ Port int

+ type NodeIdentity struct

+ IP string

+ Port int

+ Secret string

+ StartedAt time.Time

+ type PGSQLConfig struct

+ Database string

+ Host string

+ Passowrd string

+ Password string

+ Port int

+ SSLMode string

+ User string

+ func (c PGSQLConfig) DSN() (string, error)

+ func (c PGSQLConfig) Validate() error

+ type RESPHandler struct

+ func NewRESPHandler(coordinator *Coordinator, refresh *RefreshController, repo *Repository) *RESPHandler

+ func (h *RESPHandler) Handle(ctx context.Context, args []string, remoteIP string) ([]byte, error)

+ type RefreshController struct

+ func NewRefreshController(coordinator *Coordinator, runtime *home.Runtime, repo *Repository) *RefreshController

+ func (c *RefreshController) CanAutoRefresh() bool

+ func (c *RefreshController) OnMasterChanged(isMaster bool)

+ func (c *RefreshController) RefreshNow(ctx context.Context, authIndex string) ([]byte, error)

+ type Repository struct

+ func NewRepository(db *gorm.DB) *Repository

+ func (r *Repository) AppendEvent(ctx context.Context, scope, op, entity string, version int64) error

+ func (r *Repository) AppendUsage(ctx context.Context, payload string) (*UsageRecord, error)

+ func (r *Repository) GetAuth(ctx context.Context, uuid string) (*coreauth.Auth, *AuthRecord, error)

+ func (r *Repository) ListAuthIndex(ctx context.Context) ([]AuthIndex, error)

+ func (r *Repository) ListAuths(ctx context.Context) ([]*coreauth.Auth, error)

+ func (r *Repository) LiveClusterNodeByIPAndSecret(ctx context.Context, ip string, secret string, cutoff time.Time) (*ClusterNodeRecord, error)

+ func (r *Repository) LoadConfigAsRuntimeConfig(ctx context.Context) (*appconfig.Config, []byte, error)

+ func (r *Repository) LoadConfigSnapshot(ctx context.Context) (map[string]json.RawMessage, error)

+ func (r *Repository) MaxEventID(ctx context.Context) (int64, error)

+ func (r *Repository) ReplaceConfigSnapshot(ctx context.Context, values map[string]any) error

+ func (r *Repository) SoftDeleteAuth(ctx context.Context, uuid string) error

+ func (r *Repository) UpsertAuth(ctx context.Context, auth *coreauth.Auth, op string) (*AuthRecord, error)

+ func (r *Repository) UpsertConfigValue(ctx context.Context, key string, value any) error

+ func (r *Repository) WithAuthRefreshLock(ctx context.Context, uuid string, ...) (*coreauth.Auth, error)

+ type RuntimeAdapter struct

+ func NewRuntimeAdapter(repo *Repository) *RuntimeAdapter

+ func (a *RuntimeAdapter) ApplyEvent(ctx context.Context, event ClusterEventRecord) error

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

+ func (a *RuntimeAdapter) Enabled() bool

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

+ func (a *RuntimeAdapter) InvalidateFullAuth(uuid string)

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

+ func (a *RuntimeAdapter) ListMinimalAuths() []*coreauth.Auth

+ func (a *RuntimeAdapter) LoadAuthIndex(ctx context.Context) error

+ func (a *RuntimeAdapter) LoadConfigYAML(ctx context.Context) ([]byte, error)

+ func (a *RuntimeAdapter) LoadIndex(ctx context.Context) error

+ func (a *RuntimeAdapter) RefreshAuthIndex(ctx context.Context, uuid string) error

+ func (a *RuntimeAdapter) RemoveAuthIndex(uuid string)

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

+ func (a *RuntimeAdapter) StoreUsagePayload(ctx context.Context, payload string) error

+ type UsageRecord struct

+ APIKey string

+ Alias string

+ AuthIndex string

+ AuthType string

+ CachedTokens int64

+ CreatedAt time.Time

+ Endpoint string

+ FailBody string

+ FailJSON JSONB

+ FailStatusCode int

+ Failed bool

+ ID uint

+ InputTokens int64

+ LatencyMS int64

+ Model string

+ OutputTokens int64

+ PayloadJSON JSONB

+ Provider string

+ ReasoningTokens int64

+ RequestID string

+ Source string

+ Timestamp time.Time

+ TokensJSON JSONB

+ TotalTokens int64

+ func UsageRecordFromPayload(payload string) (*UsageRecord, error)

+ func (UsageRecord) TableName() string