daemon

Apr 8, 2026

Changes in this version

+ type AddCommentInput struct

+ Body AddCommentRequest

+ type AddCommentOutput struct

+ Body *storage.Response

+ type CancelJobInput struct

+ Body CancelJobRequest

+ type CancelJobOutput struct

+ Body struct{ ... }

+ type CloseReviewInput struct

+ Body CloseReviewRequest

+ type CloseReviewOutput struct

+ Body struct{ ... }

type EnqueueRequest

+ MinSeverity string

+ type GetReviewInput struct

+ JobID int64

+ SHA string

+ type GetReviewOutput struct

+ Body *storage.Review

+ type GetStatusInput struct

+ type GetStatusOutput struct

+ Body storage.DaemonStatus

+ type GetSummaryInput struct

+ All string

+ Branch string

+ Repo string

+ Since string

+ type GetSummaryOutput struct

+ Body *storage.Summary

type HTTPClient

+ func (c *HTTPClient) GetAllCommentsForJob(jobID, commitID int64, gitRef string) ([]storage.Response, error)

+ type ListBranchesInput struct

+ Repo []string

+ type ListBranchesOutput struct

+ Body struct{ ... }

+ type ListCommentsInput struct

+ CommitID int64

+ JobID int64

+ SHA string

+ type ListCommentsOutput struct

+ Body struct{ ... }

+ type ListJobsInput struct

+ Before int64

+ Branch string

+ BranchIncludeEmpty string

+ Closed string

+ ExcludeJobType string

+ GitRef string

+ ID int64

+ JobType string

+ Limit int

+ Offset int

+ Repo string

+ RepoPrefix string

+ Status string

+ type ListJobsOutput struct

+ Body struct{ ... }

+ type ListReposInput struct

+ Branch string

+ Prefix string

+ type ListReposOutput struct

+ Body struct{ ... }

+ type RerunJobInput struct

+ Body RerunJobRequest

+ type RerunJobOutput struct

+ Body struct{ ... }

Mar 24, 2026

Changes in this version

+ var MaxUnixPathLen = func() int { ... }()

+ func DefaultSocketPath() string

+ type DaemonEndpoint struct

+ Address string

+ Network string

+ func ParseEndpoint(serverAddr string) (DaemonEndpoint, error)

+ func (e DaemonEndpoint) BaseURL() string

+ func (e DaemonEndpoint) ConfigAddr() string

+ func (e DaemonEndpoint) HTTPClient(timeout time.Duration) *http.Client

+ func (e DaemonEndpoint) IsUnix() bool

+ func (e DaemonEndpoint) Listener() (net.Listener, error)

+ func (e DaemonEndpoint) Port() int

+ func (e DaemonEndpoint) String() string

type EnqueueRequest

+ Since string

type Event

+ WorktreePath string

type RuntimeInfo

+ Network string

+ func (r RuntimeInfo) Endpoint() DaemonEndpoint

Mar 7, 2026

Changes in this version

+ type PingInfo struct

+ PID int

+ Service string

+ Version string

+ func ProbeDaemon(addr string, timeout time.Duration) (*PingInfo, error)

Mar 6, 2026

Changes in this version

type EnqueueRequest

+ Provider string

Mar 3, 2026

Changes in this version

type Client

+ MarkReviewClosed func(jobID int64) error

+ type CloseReviewRequest struct

+ Closed bool

+ JobID int64

type HTTPClient

+ func (c *HTTPClient) MarkReviewClosed(jobID int64) error

Feb 25, 2026

Changes in this version

+ const MaxErrorLogEntries

type HookRunner

+ func (hr *HookRunner) WaitUntilIdle()

type Server

+ func (s *Server) Close() error

Feb 25, 2026

Changes in this version

+ func ExactReposOnly(repos []string) []string

+ type RepoResolver struct

+ func (r *RepoResolver) Resolve(ctx context.Context, ci *config.CIConfig, envFn ghEnvFn) ([]string, error)

Feb 24, 2026

Changes in this version

+ func CleanJobLogs(maxAge time.Duration) int

+ func JobLogDir() string

+ func JobLogExists(jobID int64) bool

+ func JobLogPath(jobID int64) string

+ func ParseJobIDFromLogName(name string) (int64, bool)

+ func ReadJobLog(jobID int64) ([]byte, error)

Feb 23, 2026

Changes in this version

+ func DefaultActivityLogPath() string

+ type ActivityEntry struct

+ Component string

+ Details map[string]string

+ Event string

+ Message string

+ Timestamp time.Time

+ type ActivityLog struct

+ func NewActivityLog(path string) (*ActivityLog, error)

+ func (a *ActivityLog) Close() error

+ func (a *ActivityLog) Log(event, component, message string, details map[string]string)

+ func (a *ActivityLog) Recent() []ActivityEntry

+ func (a *ActivityLog) RecentN(n int) []ActivityEntry

Feb 18, 2026

Changes in this version

+ func DeleteCompactMetadata(jobID int64) error

+ func IsValidCompactOutput(output string) bool

type Client

+ Remap func(req RemapRequest) (*RemapResult, error)

+ type CompactMetadata struct

+ SourceJobIDs []int64

+ func ReadCompactMetadata(jobID int64) (*CompactMetadata, error)

type EnqueueRequest

+ JobType string

type GitHubAppTokenProvider

+ func (p *GitHubAppTokenProvider) APIRequest(method, path string, body io.Reader, installationID int64) (*http.Response, error)

type HTTPClient

+ func (c *HTTPClient) Remap(req RemapRequest) (*RemapResult, error)

+ type RemapMapping struct

+ Author string

+ NewSHA string

+ OldSHA string

+ PatchID string

+ Subject string

+ Timestamp string

+ type RemapRequest struct

+ Mappings []RemapMapping

+ RepoPath string

+ type RemapResult struct

+ Remapped int

+ Skipped int

Feb 11, 2026

Changes in this version

type OutputLine

+ func NormalizeCodexOutput(line string) *OutputLine

Feb 9, 2026

Changes in this version

+ type CIPoller struct

+ func NewCIPoller(db *storage.DB, cfgGetter ConfigGetter, broadcaster Broadcaster) *CIPoller

+ func (p *CIPoller) HealthCheck() (bool, string)

+ func (p *CIPoller) Start() error

+ func (p *CIPoller) Stop()

type EnqueueRequest

+ ReviewType string

+ type GitHubAppTokenProvider struct

+ func NewGitHubAppTokenProvider(appID int64, pemData string) (*GitHubAppTokenProvider, error)

+ func (p *GitHubAppTokenProvider) TokenForInstallation(installationID int64) (string, error)

type Server

+ func (s *Server) Broadcaster() Broadcaster

+ func (s *Server) ConfigWatcher() *ConfigWatcher

+ func (s *Server) SetCIPoller(cp *CIPoller)

Feb 3, 2026

Changes in this version

type Event

+ Findings string

Jan 31, 2026

Changes in this version

+ type HookRunner struct

+ func NewHookRunner(cfgGetter ConfigGetter, broadcaster Broadcaster) *HookRunner

+ func (hr *HookRunner) Stop()

Jan 30, 2026

Changes in this version

type WorkerPool

+ func (wp *WorkerPool) IsJobPendingCancel(jobID int64) bool

Jan 29, 2026

Changes in this version

type EnqueueRequest

+ OutputPrefix string

Jan 27, 2026

Changes in this version

type EnqueueRequest

+ Branch string

Jan 26, 2026

Changes in this version

type AddressReviewRequest

+ JobID int64

+ type JobOutput struct

+ type JobOutputResponse struct

+ HasMore bool

+ JobID int64

+ Lines []OutputLine

+ Status string

+ type OutputBuffer struct

+ func NewOutputBuffer(maxPerJob, maxTotal int) *OutputBuffer

+ func (ob *OutputBuffer) Append(jobID int64, line OutputLine)

+ func (ob *OutputBuffer) CloseJob(jobID int64)

+ func (ob *OutputBuffer) GetLines(jobID int64) []OutputLine

+ func (ob *OutputBuffer) IsActive(jobID int64) bool

+ func (ob *OutputBuffer) Subscribe(jobID int64) ([]OutputLine, <-chan OutputLine, func())

+ func (ob *OutputBuffer) Writer(jobID int64, normalize OutputNormalizer) *outputWriter

+ type OutputLine struct

+ Text string

+ Timestamp time.Time

+ Type string

+ func NormalizeClaudeOutput(line string) *OutputLine

+ func NormalizeGenericOutput(line string) *OutputLine

+ func NormalizeOpenCodeOutput(line string) *OutputLine

+ type OutputNormalizer func(line string) *OutputLine

+ func GetNormalizer(agentName string) OutputNormalizer

type WorkerPool

+ func (wp *WorkerPool) GetJobOutput(jobID int64) []OutputLine

+ func (wp *WorkerPool) HasJobOutput(jobID int64) bool

+ func (wp *WorkerPool) SubscribeJobOutput(jobID int64) ([]OutputLine, <-chan OutputLine, func())

Jan 25, 2026

Changes in this version

+ type AddCommentRequest struct

+ Comment string

+ Commenter string

+ JobID int64

+ SHA string

type Client

+ AddComment func(jobID int64, commenter, comment string) error

+ GetCommentsForJob func(jobID int64) ([]storage.Response, error)

type EnqueueRequest

+ Model string

type HTTPClient

+ func (c *HTTPClient) AddComment(jobID int64, commenter, comment string) error

+ func (c *HTTPClient) GetCommentsForJob(jobID int64) ([]storage.Response, error)

Jan 25, 2026

Changes in this version

+ func CleanupZombieDaemons() int

+ func IsDaemonAlive(addr string) bool

+ func KillDaemon(info *RuntimeInfo) bool

+ func LegacyRuntimePath() string

+ func RemoveRuntimeForPID(pid int)

+ func RuntimePathForPID(pid int) string

type RuntimeInfo

+ SourcePath string

+ func GetAnyRunningDaemon() (*RuntimeInfo, error)

+ func ListAllRuntimes() ([]*RuntimeInfo, error)

+ func ReadRuntimeForPID(pid int) (*RuntimeInfo, error)

Jan 23, 2026

Changes in this version

type ConfigWatcher

+ func (cw *ConfigWatcher) ReloadCounter() uint64

Jan 23, 2026

Changes in this version

+ type ConfigGetter interface

+ Config func() *config.Config

+ type ConfigWatcher struct

+ func NewConfigWatcher(configPath string, cfg *config.Config, broadcaster Broadcaster) *ConfigWatcher

+ func (cw *ConfigWatcher) Config() *config.Config

+ func (cw *ConfigWatcher) LastReloadedAt() time.Time

+ func (cw *ConfigWatcher) Start(ctx context.Context) error

+ func (cw *ConfigWatcher) Stop()

+ type StaticConfig struct

+ func NewStaticConfig(cfg *config.Config) *StaticConfig

+ func (sc *StaticConfig) Config() *config.Config

type WorkerPool

+ func (wp *WorkerPool) MaxWorkers() int

Jan 21, 2026

Changes in this version

+ var DefaultPollInterval = 2 * time.Second

+ func DefaultErrorLogPath() string

+ func FindAvailablePort(startAddr string) (string, int, error)

+ func RemoveRuntime()

+ func RuntimePath() string

+ func WriteRuntime(addr string, port int, version string) error

+ type AddResponseRequest struct

+ JobID int64

+ Responder string

+ Response string

+ SHA string

+ type AddressReviewRequest struct

+ Addressed bool

+ ReviewID int64

+ type Broadcaster interface

+ Broadcast func(event Event)

+ Subscribe func(repoPath string) (int, <-chan Event)

+ SubscriberCount func() int

+ Unsubscribe func(id int)

+ func NewBroadcaster() Broadcaster

+ type CancelJobRequest struct

+ JobID int64

+ type Client interface

+ AddResponse func(jobID int64, responder, response string) error

+ EnqueueReview func(repoPath, gitRef, agentName string) (int64, error)

+ FindJobForCommit func(repoPath, sha string) (*storage.ReviewJob, error)

+ FindPendingJobForRef func(repoPath, gitRef string) (*storage.ReviewJob, error)

+ GetResponsesForJob func(jobID int64) ([]storage.Response, error)

+ GetReviewByJobID func(jobID int64) (*storage.Review, error)

+ GetReviewBySHA func(sha string) (*storage.Review, error)

+ MarkReviewAddressed func(reviewID int64) error

+ WaitForReview func(jobID int64) (*storage.Review, error)

+ type EnqueueRequest struct

+ Agent string

+ Agentic bool

+ CommitSHA string

+ CustomPrompt string

+ DiffContent string

+ GitRef string

+ Reasoning string

+ RepoPath string

+ type ErrorEntry struct

+ Component string

+ JobID int64

+ Level string

+ Message string

+ Timestamp time.Time

+ type ErrorLog struct

+ func NewErrorLog(path string) (*ErrorLog, error)

+ func (e *ErrorLog) Close() error

+ func (e *ErrorLog) Count24h() int

+ func (e *ErrorLog) Log(level, component, message string, jobID int64)

+ func (e *ErrorLog) LogError(component, message string, jobID int64)

+ func (e *ErrorLog) LogWarn(component, message string, jobID int64)

+ func (e *ErrorLog) Recent() []ErrorEntry

+ func (e *ErrorLog) RecentN(n int) []ErrorEntry

+ type ErrorResponse struct

+ Error string

+ type Event struct

+ Agent string

+ Error string

+ JobID int64

+ Repo string

+ RepoName string

+ SHA string

+ TS time.Time

+ Type string

+ Verdict string

+ func (e Event) MarshalJSON() ([]byte, error)

+ type EventBroadcaster struct

+ func (b *EventBroadcaster) Broadcast(event Event)

+ func (b *EventBroadcaster) Subscribe(repoPath string) (int, <-chan Event)

+ func (b *EventBroadcaster) SubscriberCount() int

+ func (b *EventBroadcaster) Unsubscribe(id int)

+ type HTTPClient struct

+ func NewHTTPClient(addr string) *HTTPClient

+ func NewHTTPClientFromRuntime() (*HTTPClient, error)

+ func (c *HTTPClient) AddResponse(jobID int64, responder, response string) error

+ func (c *HTTPClient) EnqueueReview(repoPath, gitRef, agentName string) (int64, error)

+ func (c *HTTPClient) FindJobForCommit(repoPath, sha string) (*storage.ReviewJob, error)

+ func (c *HTTPClient) FindPendingJobForRef(repoPath, gitRef string) (*storage.ReviewJob, error)

+ func (c *HTTPClient) GetResponsesForJob(jobID int64) ([]storage.Response, error)

+ func (c *HTTPClient) GetReviewByJobID(jobID int64) (*storage.Review, error)

+ func (c *HTTPClient) GetReviewBySHA(sha string) (*storage.Review, error)

+ func (c *HTTPClient) MarkReviewAddressed(reviewID int64) error

+ func (c *HTTPClient) SetPollInterval(interval time.Duration)

+ func (c *HTTPClient) WaitForReview(jobID int64) (*storage.Review, error)

+ type RerunJobRequest struct

+ JobID int64

+ type RuntimeInfo struct

+ Addr string

+ PID int

+ Port int

+ Version string

+ func ReadRuntime() (*RuntimeInfo, error)

+ type Server struct

+ func NewServer(db *storage.DB, cfg *config.Config) *Server

+ func (s *Server) SetSyncWorker(sw *storage.SyncWorker)

+ func (s *Server) Start() error

+ func (s *Server) Stop() error

+ type Subscriber struct

+ Ch chan Event

+ ID int

+ RepoPath string

+ type WorkerPool struct

+ func NewWorkerPool(db *storage.DB, cfg *config.Config, numWorkers int, broadcaster Broadcaster, ...) *WorkerPool

+ func (wp *WorkerPool) ActiveWorkers() int

+ func (wp *WorkerPool) CancelJob(jobID int64) bool

+ func (wp *WorkerPool) Start()

+ func (wp *WorkerPool) Stop()