server

Aug 16, 2026

Changes in this version

type ReactiveQueueManager

+ func (rqm *ReactiveQueueManager) SetDashboardBaseURLFn(fn func() string)

+ func (rqm *ReactiveQueueManager) SetSlackNotifier(n SlackNotifierWiring)

type RuntimeDeps

+ SlackNotifier *services.SlackNotifier

type Server

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ServerDependencies

+ SlackNotifier *services.SlackNotifier

+ type SlackNotifierWiring interface

+ MaybeNotifyQueueDepthThreshold func(ctx context.Context, cfg *config.Config, depth, threshold int, ...) bool

+ NotifyReviewQueueItem func(ctx context.Context, cfg *config.Config, item *session.ReviewItem, ...)

Aug 14, 2026

Changes in this version

type ReactiveQueueManager

+ func (rqm *ReactiveQueueManager) SetCallbackDispatcher(d *services.CallbackDispatcher)

type RuntimeDeps

+ TriggerFireEventRepo session.TriggerFireEventRepository

type ServerDependencies

+ TriggerFireEventRepo session.TriggerFireEventRepository

Aug 13, 2026

Changes in this version

+ func EnsureNetworkTLSCerts(networks map[string][]string) (caFile string, certs map[string]*NetworkCert, err error)

+ func GetCertificateByLocalAddr(certs map[string]*NetworkCert) func(*tls.ClientHelloInfo) (*tls.Certificate, error)

+ type NetworkCert struct

+ Cert tls.Certificate

+ Key string

+ SANs []string

type RuntimeDeps

+ QuotaGate *services.QuotaGate

type ServerDependencies

+ QuotaGate *services.QuotaGate

Aug 10, 2026

Changes in this version

type RuntimeDeps

+ SessionSummaryGenerator *session.SessionSummaryGenerator

type ServerDependencies

+ SessionSummaryGenerator *session.SessionSummaryGenerator

Jul 21, 2026

Changes in this version

+ type OneShotPRCreator interface

+ RunOneShotForSession func(ctx context.Context, sessionID, prompt string, timeoutSeconds int32) (string, error)

type ReactiveQueueManager

+ func (rqm *ReactiveQueueManager) SetOneShotRunner(r OneShotPRCreator)

type RuntimeDeps

+ BacklogEnabledCheck func() bool

type ServerDependencies

+ BacklogEnabledCheck func() bool

Jul 6, 2026

Changes in this version

+ type BuildOptions struct

+ EntClient *ent.Client

type CoreDeps

+ ErrorRegistry *services.ErrorRegistry

+ func BuildCoreDepsWithOptions(opts BuildOptions) (*CoreDeps, error)

type ReactiveQueueManager

+ func (rqm *ReactiveQueueManager) OnControllerStatusChange(inst *session.Instance, _ detection.DetectedStatus)

type RuntimeDeps

+ AnalyticsEntClient *ent.Client

+ BacklogService *services.BacklogService

+ CDPDeps cdp.DepsResult

+ Config *config.Config

+ ErrorRegistry *services.ErrorRegistry

+ GitHubUserService *services.GitHubUserService

+ HeadlessPool *headless.Pool

+ InsightsService *services.InsightsService

+ Registry *session.Registry

+ SyncLoop *session.SyncLoop

+ UserPRCache *githubpkg.UserPRCache

+ VNCDeps vnc.DepsResult

+ WorkflowRepo session.WorkflowRepository

+ WorkflowScheduler *workflows.Scheduler

+ WorktreePRPoller *session.WorktreePRPoller

+ func (rt *RuntimeDeps) ToServerDeps() *ServerDependencies

type Server

+ func NewServerWithDeps(addr string, deps *ServerDependencies) *Server

type ServerDependencies

+ AnalyticsEntClient *ent.Client

+ BacklogService *services.BacklogService

+ CDPDeps cdp.DepsResult

+ ErrorRegistry *services.ErrorRegistry

+ GitHubUserService *services.GitHubUserService

+ HeadlessPool *headless.Pool

+ InsightsService *services.InsightsService

+ Registry *session.Registry

+ SyncLoop *session.SyncLoop

+ UserPRCache *githubpkg.UserPRCache

+ VNCDeps vnc.DepsResult

+ WorkflowRepo session.WorkflowRepository

+ WorkflowScheduler *workflows.Scheduler

+ WorktreePRPoller *session.WorktreePRPoller

type ServiceDeps

+ Registry *session.Registry

Apr 26, 2026

Changes in this version

type RuntimeDeps

+ UnfinishedScanner *unfinished.Scanner

+ UnfinishedStateStore *unfinished.StateStore

+ UnfinishedWorkService *services.UnfinishedWorkService

type ServerDependencies

+ UnfinishedScanner *unfinished.Scanner

+ UnfinishedStateStore *unfinished.StateStore

+ UnfinishedWorkService *services.UnfinishedWorkService

Apr 14, 2026

Changes in this version

type RuntimeDeps

+ PRStatusPoller *session.PRStatusPoller

type ServerDependencies

+ PRStatusPoller *session.PRStatusPoller

type ServiceDeps

+ PRStatusPoller *session.PRStatusPoller

Apr 9, 2026

Changes in this version

type ServerDependencies

+ Instances []*session.Instance

Apr 7, 2026

Changes in this version

+ func ConnectOptions() []connect.HandlerOption

+ func LoadTLSConfig(certFile, keyFile string) (*tls.Config, error)

+ type CoreDeps struct

+ ApprovalStore *services.ApprovalStore

+ EventBus *events.EventBus

+ ReviewQueue *session.ReviewQueue

+ SessionService *services.SessionService

+ Storage *session.Storage

+ func BuildCoreDeps() (*CoreDeps, error)

+ type FilterProvider interface

+ GetIncludeStatistics func() bool

+ GetInitialSnapshot func() bool

+ GetPriorityFilter func() []session.Priority

+ GetReasonFilter func() []session.AttentionReason

+ GetSessionIDs func() []string

+ type ReactiveQueueManager struct

+ func NewReactiveQueueManager(queue *session.ReviewQueue, poller *session.ReviewQueuePoller, ...) *ReactiveQueueManager

+ func (rqm *ReactiveQueueManager) AddStreamClient(ctx context.Context, filtersInterface interface{}) (<-chan *sessionv1.ReviewQueueEvent, string)

+ func (rqm *ReactiveQueueManager) OnItemAdded(item *session.ReviewItem)

+ func (rqm *ReactiveQueueManager) OnItemRemoved(sessionID string)

+ func (rqm *ReactiveQueueManager) OnQueueUpdated(items []*session.ReviewItem)

+ func (rqm *ReactiveQueueManager) RemoveStreamClient(clientID string)

+ func (rqm *ReactiveQueueManager) Start(ctx context.Context)

+ func (rqm *ReactiveQueueManager) Stop()

+ type RuntimeDeps struct

+ ExternalApprovalMonitor *session.ExternalApprovalMonitor

+ ExternalDiscovery *session.ExternalSessionDiscovery

+ HistoryLinker *session.HistoryLinker

+ Instances []*session.Instance

+ ReactiveQueueMgr *ReactiveQueueManager

+ ScrollbackManager *scrollback.ScrollbackManager

+ TmuxStreamerManager *session.ExternalTmuxStreamerManager

+ func BuildRuntimeDeps(svc *ServiceDeps) (*RuntimeDeps, error)

+ type Server struct

+ func NewServer(addr string) *Server

+ func (s *Server) GetAddr() string

+ func (s *Server) GetHostnames() []string

+ func (s *Server) GetOrigins() []string

+ func (s *Server) Mux() *http.ServeMux

+ func (s *Server) RegisterConnectHandler(path string, handler http.Handler)

+ func (s *Server) RegisterHTTPHandler(pattern string, handler http.Handler)

+ func (s *Server) SetHTTPSURL(url string)

+ func (s *Server) SetHostnames(hostnames []string)

+ func (s *Server) SetOrigins(origins []string)

+ func (s *Server) SetupAuth(authMiddleware func(http.Handler) http.Handler)

+ func (s *Server) SetupTLS(cfg *tls.Config)

+ func (s *Server) Shutdown() error

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

+ func (s *Server) StartRemote(ctx context.Context, remoteAddr string, tlsCfg *tls.Config, ...) error

+ type ServerDependencies struct

+ EventBus *events.EventBus

+ ExternalApprovalMonitor *session.ExternalApprovalMonitor

+ ExternalDiscovery *session.ExternalSessionDiscovery

+ HistoryLinker *session.HistoryLinker

+ ReactiveQueueMgr *ReactiveQueueManager

+ ReviewQueue *session.ReviewQueue

+ ReviewQueuePoller *session.ReviewQueuePoller

+ ScrollbackManager *scrollback.ScrollbackManager

+ SessionService *services.SessionService

+ StatusManager *session.InstanceStatusManager

+ Storage *session.Storage

+ TmuxStreamerManager *session.ExternalTmuxStreamerManager

+ func BuildDependencies() (*ServerDependencies, error)

+ type ServiceDeps struct

+ ReviewQueuePoller *session.ReviewQueuePoller

+ StatusManager *session.InstanceStatusManager

+ func BuildServiceDeps(core *CoreDeps) (*ServiceDeps, error)

+ type TLSPaths struct

+ CAFile string

+ CertFile string

+ KeyFile string

+ func EnsureTLSCerts(hostnames []string) (*TLSPaths, error)

+ type WatchReviewQueueFilters struct

+ IncludeStatistics bool

+ InitialSnapshot bool

+ PriorityFilter []session.Priority

+ ReasonFilter []session.AttentionReason

+ SessionIDs []string