api

Apr 10, 2026

Changes in this version

type Deps

+ ModelDetailLister func(ctx context.Context) []llm.ModelInfo

Apr 10, 2026

Changes in this version

type Deps

+ ReloadFunc func() error

+ RestartFunc func() error

Apr 10, 2026

Changes in this version

+ const FrameTypeActivity

+ type ActivityFrame struct

+ Adapter string

+ Agent string

+ ConversationID string

+ Summary string

+ Type string

type Server

+ func (s *Server) WSHub() *WSHub

type WSHub

+ func (h *WSHub) Broadcast(frame any)

Apr 7, 2026

Changes in this version

+ func ScopesFromRecord(rec *SessionRecord) []string

type SessionManager

+ Store *SessionStore

+ func (sm *SessionManager) CreateWithRequest(w http.ResponseWriter, r *http.Request, s Session) error

+ type SessionRecord struct

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ ID string

+ IP string

+ LastSeenAt time.Time

+ Scopes string

+ UserAgent string

+ type SessionStore struct

+ func NewInMemorySessionStore() (*SessionStore, error)

+ func NewSessionStore(dbPath string) (*SessionStore, error)

+ func (ss *SessionStore) Close() error

+ func (ss *SessionStore) Count(ctx context.Context) (int, error)

+ func (ss *SessionStore) Create(ctx context.Context, email string, scopes []string, userAgent, ip string, ...) (string, error)

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

+ func (ss *SessionStore) DeleteAllByEmail(ctx context.Context, email string) (int64, error)

+ func (ss *SessionStore) Get(ctx context.Context, id string) (*SessionRecord, error)

+ func (ss *SessionStore) ListByEmail(ctx context.Context, email string) ([]SessionRecord, error)

+ func (ss *SessionStore) PurgeExpired(ctx context.Context) (int64, error)

+ func (ss *SessionStore) Touch(ctx context.Context, id string) error

Apr 6, 2026

Changes in this version

type WSHub

+ func (h *WSHub) StartCleanup(ctx context.Context)

Apr 6, 2026

Changes in this version

+ const FrameTypeApprovalResponse

+ const FrameTypeCancel

+ const FrameTypeChatRequest

+ const FrameTypeError

+ const FrameTypePing

+ const FrameTypePong

+ func ParseClientFrame(data []byte) (any, error)

+ type ApprovalResponseFrame struct

+ Action string

+ ApprovalID string

+ Type string

+ type CancelFrame struct

+ SessionID string

+ Type string

+ type ChatRequestFrame struct

+ Agent string

+ Message string

+ ResumeAfterSeq int64

+ Seq int64

+ SessionID string

+ Type string

+ UserID string

+ UserName string

type Deps

+ OAuthDeps *OAuthDeps

+ type OAuthDeps struct

+ PendingMgr *oauth.PendingManager

+ TokenStore *oauth.TokenStore

+ type PingFrame struct

+ Type string

+ type PongFrame struct

+ Type string

+ type ReplayBuffer struct

+ func NewReplayBuffer(capacity int, ttl time.Duration) *ReplayBuffer

+ func (b *ReplayBuffer) Append(frame WSEventFrame)

+ func (b *ReplayBuffer) Len() int

+ func (b *ReplayBuffer) ReplaySince(afterSeq int64) []WSEventFrame

+ type ReplayStore struct

+ func NewReplayStore(capacity int, ttl time.Duration) *ReplayStore

+ func (s *ReplayStore) Buffer(sessionID string) *ReplayBuffer

+ func (s *ReplayStore) Cleanup()

+ func (s *ReplayStore) Len() int

+ func (s *ReplayStore) Remove(sessionID string)

+ type SSEStreamSession struct

+ func NewSSEStreamSession(w http.ResponseWriter) *SSEStreamSession

+ func (s *SSEStreamSession) SendContent(text string)

+ func (s *SSEStreamSession) SendDone(sessionID string)

+ func (s *SSEStreamSession) SendError(message string)

+ func (s *SSEStreamSession) SendEvent(evt agent.ChatEvent)

+ type StreamSession interface

+ SendContent func(text string)

+ SendDone func(sessionID string)

+ SendError func(message string)

+ SendEvent func(evt agent.ChatEvent)

+ type WSClientFrame struct

+ Type string

+ type WSConn struct

+ func (c *WSConn) Close(code int, text string)

+ func (c *WSConn) Start()

+ type WSErrorFrame struct

+ Code string

+ Message string

+ SessionID string

+ Type string

+ type WSEventFrame struct

+ Seq int64

+ SessionID string

+ type WSHub struct

+ func NewWSHub(maxConns int, replayTTL time.Duration, logger *slog.Logger) *WSHub

+ func (h *WSHub) ConnCount() int

+ func (h *WSHub) Register(c *WSConn) bool

+ func (h *WSHub) Shutdown()

+ func (h *WSHub) Unregister(c *WSConn)

Apr 4, 2026

Changes in this version

type Deps

+ ModelLister func(ctx context.Context) []string

Apr 4, 2026

Changes in this version

type Deps

+ SetupPIN string

Apr 3, 2026

Changes in this version

type Deps

+ MetricsHandler http.Handler

+ OIDCProvider *OIDCProvider

+ PasswordHash string

+ Sessions *SessionManager

+ type OIDCProvider struct

+ func NewOIDCProvider(ctx context.Context, issuer, clientID, clientSecret, redirectURL string, ...) (*OIDCProvider, error)

+ func (op *OIDCProvider) HandleCallback(w http.ResponseWriter, r *http.Request)

+ func (op *OIDCProvider) HandleLogin(w http.ResponseWriter, r *http.Request)

+ type Session struct

+ Email string

+ ExpiresAt int64

+ Scopes []string

+ type SessionManager struct

+ func NewSessionManager(hexKey string, maxAge time.Duration, secure bool) (*SessionManager, error)

+ func (sm *SessionManager) Clear(w http.ResponseWriter)

+ func (sm *SessionManager) Create(w http.ResponseWriter, s Session) error

+ func (sm *SessionManager) Read(r *http.Request) (*Session, error)

Apr 3, 2026

Changes in this version

type Server

+ func (s *Server) HTTPHandler() http.Handler

Apr 3, 2026

Changes in this version

type Deps

+ KVStore kv.Store

Apr 3, 2026

Changes in this version

type Deps

+ ConfigPath string

Apr 2, 2026

Changes in this version

type Deps

+ BrowserProfiles *browser.ProfileService

Mar 29, 2026

Changes in this version

+ var ValidScopes = map[string]struct

+ func ValidateKeyInput(name string, scopes []string) error

type Deps

+ LifecycleMgr *tool.LifecycleManager

type KeyStore

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

+ func (ks *KeyStore) HasActiveKey(ctx context.Context) (bool, error)

Mar 27, 2026

Changes in this version

+ type APIKeyRecord struct

+ CreatedAt time.Time

+ ID string

+ LastUsedAt *time.Time

+ Name string

+ Revoked bool

+ Scopes []string

+ type Deps struct

+ Approvals *approval.Manager

+ Config *config.Config

+ CostTracker *llm.CostTracker

+ Dispatcher *agent.Dispatcher

+ KeyStore *KeyStore

+ Memory agent.MemoryStore

+ Scheduler *scheduler.Scheduler

+ WebHandler http.Handler

+ type KeyStore struct

+ func NewInMemoryKeyStore() (*KeyStore, error)

+ func NewKeyStore(dbPath string) (*KeyStore, error)

+ func (ks *KeyStore) Create(ctx context.Context, name string, scopes []string) (APIKeyRecord, string, error)

+ func (ks *KeyStore) FindActiveByHash(ctx context.Context, tokenHash string) (*storedKey, error)

+ func (ks *KeyStore) List(ctx context.Context) ([]APIKeyRecord, error)

+ func (ks *KeyStore) Revoke(ctx context.Context, id string) error

+ func (ks *KeyStore) Rotate(ctx context.Context, id string) (APIKeyRecord, string, error)

+ func (ks *KeyStore) TouchLastUsed(ctx context.Context, id string)

+ type Server struct

+ func New(cfg config.APIConfig, deps Deps, logger *slog.Logger) *Server

+ func (s *Server) RequireScope(scope string, next http.HandlerFunc) http.HandlerFunc

+ func (s *Server) Run(ctx context.Context) error