claudeproxy

package

Go to main page

Versions in this module

v0

v0.0.7

Oct 27, 2026

Changes in this version

+ const OAuthBeta

+ var ErrNotExtendable = errors.New("claudeproxy: session cannot be extended")

type Event

+ ExecutorID string

+ GrantID string

+ LeaseID string

+ Payer string

+ UpstreamKind string

type MintRequest

+ ExecutorID string

+ GrantID string

+ LeaseID string

+ Payer string

+ Upstream *Upstream

type Options

+ Admit func(s *Session, model string) *Denial

+ ExplainClosed bool

+ OnSpend func(s *Session, sp Spend)

+ SessionUpstreams bool

+ Unauthenticated string

+ UserAgent string

type Registry

+ func NewRegistryWithPrefix(baseURL, prefix string) *Registry

+ func (r *Registry) CloseForGrant(leaseID, grantID, reason string) int

+ func (r *Registry) CloseForLease(leaseID, reason string) int

+ func (r *Registry) ClosedReason(token string) (string, bool)

+ func (r *Registry) Extend(id string, until time.Time) (time.Time, error)

+ func (r *Registry) LeaseSessions(leaseID string) []*Session

+ func (r *Registry) Prefix() string

+ func (r *Registry) SessionIDOf(token string) (string, bool)

+ func (r *Registry) SuspendForLease(leaseID, reason string) []string

type RestoreRequest

+ Upstream *Upstream

type Session

+ ExecutorID string

+ GrantID string

+ LeaseID string

+ Payer string

+ func (s *Session) Deadline() time.Time

+ func (s *Session) RenewedAt() time.Time

+ func (s *Session) UpstreamKind() string

type SessionRecord

+ ExecutorID string

+ GrantID string

+ LeaseID string

+ Payer string

+ RenewedAt time.Time

+ UpstreamKind string

+ type SessionRenewer interface

+ RenewSession func(id string, expiresAt, renewedAt time.Time) error

+ type Spend struct

+ CacheRead int64

+ CacheWrite int64

+ CacheWrite1h int64

+ Input int64

+ Model string

+ Output int64

+ Status int

+ func (sp Spend) Tokens() int64

type Upstream

+ OAuth bool

+ func (u Upstream) Kind() string

v0.0.6

Oct 16, 2026

v0.0.5

Oct 12, 2026

Changes in this version

+ var ErrClosedHere = errors.New("claudeproxy: this hub process closed the session")

+ var ErrRecordGone = errors.New("claudeproxy: the session's record is closed or held by another hub process")

+ var ErrSessionExists = errors.New("claudeproxy: a session with that id is already live")

+ var ErrSessionLapsed = errors.New("claudeproxy: session lapsed before it could be restored")

+ var ErrTooManySessions = errors.New("claudeproxy: the session limit is reached")

+ func IntersectModels(a, b []string) []string

+ func SessionIDOf(token string) (string, bool)

type EventKind

+ const EventSessionRestored

+ const EventSessionSuspended

type MintRequest

+ Claims json.RawMessage

type Options

+ Fallback func(w http.ResponseWriter, r *http.Request, sessionID string) bool

type Policy

+ func Narrow(recorded, now Policy) (Policy, error)

type Registry

+ Store SessionStore

+ func (r *Registry) CheckRestore(rec SessionRecord) error

+ func (r *Registry) Checkpoint() int

+ func (r *Registry) DropUnheld(ids []string, held map[string]bool) int

+ func (r *Registry) DurableIDs() []string

+ func (r *Registry) Known(id string) bool

+ func (r *Registry) Restore(req RestoreRequest) (*Session, error)

+ func (r *Registry) Suspend(id, reason string) bool

+ func (r *Registry) SuspendAll(reason string) []string

+ type RestoreRequest struct

+ Detail string

+ From string

+ Record SessionRecord

type Session

+ func (s *Session) Durable() bool

+ type SessionRecord struct

+ Actor string

+ Claims json.RawMessage

+ ExpiresAt time.Time

+ ID string

+ IssuedAt time.Time

+ LastUsed time.Time

+ Policy Policy

+ Project string

+ Ref string

+ Repository string

+ RuleID string

+ RuleName string

+ RunID string

+ RunURL string

+ Subject string

+ TokenSHA256 string

+ Usage Usage

+ Workflow string

+ type SessionStore interface

+ CheckpointSession func(id string, u Usage, lastUsed time.Time) error

+ CloseSession func(id, reason string, at time.Time, u Usage) error

+ SaveSession func(rec SessionRecord) error

v0.0.4

Sep 27, 2026

v0.0.3

Sep 27, 2026

v0.0.2

Sep 17, 2026

Changes in this version

+ const DefaultMaxBodyBytes

+ const DefaultMaxOutputTokens

+ const DefaultUpstream

+ const MaxSessions

+ const MaxTTL

+ const MinTTL

+ const TokenPrefix

+ var ErrNoUpstream = errors.New("claudeproxy: no upstream Anthropic credential is configured")

+ var ErrSessionNotFound = errors.New("claudeproxy: no such session")

+ var ErrUnauthenticated = errors.New("claudeproxy: session token not accepted")

+ type Denial struct

+ Message string

+ Reason DenyReason

+ Status int

+ func AllowsPath(method, p string) *Denial

+ func (d *Denial) Error() string

+ type DenyReason string

+ const DenyBodyMalformed

+ const DenyBodyTooLarge

+ const DenyBudget

+ const DenyMethodNotAllowd

+ const DenyModelNotAllowed

+ const DenyPathNotAllowed

+ type Event struct

+ Actor string

+ At time.Time

+ Detail string

+ InputTokens int64

+ Kind EventKind

+ Method string

+ Model string

+ OutputTokens int64

+ Path string

+ Project string

+ Reason DenyReason

+ Ref string

+ Repository string

+ RuleID string

+ RuleName string

+ RunID string

+ SessionID string

+ Status int

+ Subject string

+ Workflow string

+ type EventKind string

+ const EventExchangeAccepted

+ const EventExchangeRejected

+ const EventRejected

+ const EventRelayAllowed

+ const EventRelayDenied

+ const EventSessionClosed

+ const EventSessionMinted

+ type MessageRequest struct

+ MaxTokens *int

+ Model string

+ Stream bool

+ func InspectBody(body []byte) (MessageRequest, error)

+ type MintRequest struct

+ Actor string

+ Policy Policy

+ Project string

+ Ref string

+ Repository string

+ RuleID string

+ RuleName string

+ RunID string

+ RunURL string

+ Subject string

+ TTL time.Duration

+ Workflow string

+ type Minted struct

+ BaseURL string

+ Session *Session

+ Token string

+ type Options struct

+ Now func() time.Time

+ PathPrefix string

+ Transport http.RoundTripper

+ Upstream Upstream

+ type Policy struct

+ MaxBodyBytes int64

+ MaxOutputTokens int

+ MaxRequests int

+ Models []string

+ func (p Policy) AllowsModel(model string) bool

+ func (p Policy) BodyCap() int64

+ func (p Policy) DecideMessages(body []byte) ([]byte, MessageRequest, *Denial)

+ func (p Policy) OutputCap() int

+ type Proxy struct

+ func New(reg *Registry, opts Options) (*Proxy, error)

+ func (p *Proxy) Registry() *Registry

+ func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Registry struct

+ OnEvent func(Event)

+ func NewRegistry(baseURL string) *Registry

+ func (r *Registry) Authenticate(token string) (*Session, error)

+ func (r *Registry) BaseURL() string

+ func (r *Registry) Close(id, reason string) error

+ func (r *Registry) CloseAll(reason string) int

+ func (r *Registry) CloseByRule(ruleID, reason string) int

+ func (r *Registry) Mint(req MintRequest) (*Minted, error)

+ func (r *Registry) ReapExpired() int

+ func (r *Registry) Session(id string) (*Session, bool)

+ func (r *Registry) Sessions() []*Session

+ func (r *Registry) SetClock(now func() time.Time)

+ type Session struct

+ Actor string

+ ExpiresAt time.Time

+ ID string

+ IssuedAt time.Time

+ Policy Policy

+ Project string

+ Ref string

+ Repository string

+ RuleID string

+ RuleName string

+ RunID string

+ RunURL string

+ Subject string

+ Workflow string

+ func (s *Session) CloseReason() string

+ func (s *Session) Closed() bool

+ func (s *Session) Expired(now time.Time) bool

+ func (s *Session) Label() string

+ func (s *Session) LastUsed() time.Time

+ func (s *Session) RemainingRequests() int64

+ func (s *Session) Usage() Usage

+ type Upstream struct

+ APIKey string

+ AuthToken string

+ BaseURL string

+ func (u Upstream) Base() string

+ func (u Upstream) Configured() bool

+ func (u Upstream) Redacted() string

+ func (u Upstream) Validate() error

+ type Usage struct

+ BytesDown int64

+ BytesUp int64

+ CacheRead int64

+ CacheWrite int64

+ Denied int64

+ InputTokens int64

+ OutputTokens int64

+ Requests int64

+ func (u Usage) TotalTokens() int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL