storage

Apr 8, 2026

Changes in this version

type DB

+ func (db *DB) GetAllCommentsForJob(jobID, commitID int64, fallbackSHA string) ([]Response, error)

+ func (db *DB) SaveJobCommandLine(jobID int64, cmdLine string) error

type EnqueueOpts

+ MinSeverity string

type ListJobsOption

+ func WithBeforeCursor(id int64) ListJobsOption

type PulledJob

+ MinSeverity string

type Repo

+ func PreferAutoClone(repos []Repo) *Repo

type Response

+ func MergeResponses(primary, extra []Response) []Response

type ReviewJob

+ CommandLine string

+ MinSeverity string

+ func (j ReviewJob) CommitIDValue() int64

type SyncableJob

+ MinSeverity string

Apr 1, 2026

Changes in this version

type DB

+ func (db *DB) CancelJobWithError(jobID int64, errMsg string) error

+ func (db *DB) GetExpiredBatches(timeout time.Duration) ([]CIPRBatch, error)

+ func (db *DB) GetNonTerminalBatchJobIDs(batchID int64) ([]int64, error)

+ func (db *DB) HasMeaningfulBatchResult(batchID int64) (bool, error)

+ func (db *DB) IsBatchExpired(batchID int64, timeout time.Duration) (bool, error)

type EnqueueOpts

+ PromptPrebuilt bool

+ RequestedModel string

+ RequestedProvider string

type PulledJob

+ Provider string

+ RequestedModel string

+ RequestedProvider string

+ type ReenqueueOpts struct

+ Model string

+ Provider string

type ReviewJob

+ PromptPrebuilt bool

+ RequestedModel string

+ RequestedProvider string

type SyncableJob

+ Provider string

+ RequestedModel string

+ RequestedProvider string

Mar 24, 2026

Changes in this version

+ const JobTypeInsights

type EnqueueOpts

+ WorktreePath string

type PulledJob

+ WorktreePath string

type ReviewJob

+ WorktreePath string

+ func (j ReviewJob) IsReviewJob() bool

type SyncableJob

+ WorktreePath string

Mar 17, 2026

Changes in this version

+ type AgentStats struct

+ Agent string

+ Errors int

+ Failed int

+ MedianSecs float64

+ PassRate float64

+ Passed int

+ Total int

type DB

+ func (db *DB) BackfillVerdictBool() (int, error)

+ func (db *DB) GetSummary(opts SummaryOptions) (*Summary, error)

+ func (db *DB) SaveJobTokenUsage(jobID int64, tokenUsageJSON string) error

+ type DurationStats struct

+ QueueP50 float64

+ QueueP90 float64

+ QueueP99 float64

+ ReviewP50 float64

+ ReviewP90 float64

+ ReviewP99 float64

+ type FailureStats struct

+ Errors map[string]int

+ Retries int

+ Total int

+ type JobTypeStats struct

+ Applied int

+ Count int

+ Rebased int

+ Type string

+ type OverviewStats struct

+ Applied int

+ Canceled int

+ Done int

+ Failed int

+ Queued int

+ Rebased int

+ Running int

+ Total int

type PulledJob

+ TokenUsage string

+ type RepoSummary struct

+ Addressed int

+ Failed int

+ Name string

+ Passed int

+ Path string

+ Total int

type ReviewJob

+ TokenUsage string

+ type Summary struct

+ Agents []AgentStats

+ Branch string

+ Duration DurationStats

+ Failures FailureStats

+ JobTypes []JobTypeStats

+ Overview OverviewStats

+ RepoPath string

+ Repos []RepoSummary

+ Since time.Time

+ Verdicts VerdictStats

+ type SummaryOptions struct

+ AllRepos bool

+ Branch string

+ RepoPath string

+ Since time.Time

type SyncableJob

+ TokenUsage string

+ type VerdictStats struct

+ Addressed int

+ Failed int

+ PassRate float64

+ Passed int

+ ResolutionRate float64

+ Total int

Mar 9, 2026

Changes in this version

type DB

+ func (db *DB) FindReusableSessionCandidate(repoID int64, branch, agent, reviewType string) (*ReviewJob, error)

+ func (db *DB) FindReusableSessionCandidates(repoID int64, branch, agent, reviewType string, limit int) ([]ReviewJob, error)

type EnqueueOpts

+ SessionID string

Mar 7, 2026

Changes in this version

type DB

+ func (db *DB) SaveJobSessionID(jobID int64, workerID, sessionID string) error

type PulledJob

+ SessionID string

type ReviewJob

+ SessionID string

type SyncableJob

+ SessionID string

Mar 6, 2026

Changes in this version

type EnqueueOpts

+ Provider string

type ListJobsOption

+ func WithRepoPrefix(prefix string) ListJobsOption

+ type ListReposOption func(*listReposOptions)

+ func WithRepoBranch(branch string) ListReposOption

+ func WithRepoPathPrefix(prefix string) ListReposOption

type ReviewJob

+ Provider string

Mar 3, 2026

Changes in this version

+ type BatchPRRef struct

+ GithubRepo string

+ PRNumber int

type DB

+ func (db *DB) CancelClosedPRBatches(githubRepo string, prNumber int) ([]int64, error)

+ func (db *DB) GetPendingBatchPRs(githubRepo string) ([]BatchPRRef, error)

+ func (db *DB) LatestBatchTimeForPR(githubRepo string, prNumber int) (time.Time, error)

+ func (db *DB) MarkReviewClosed(reviewID int64, closed bool) error

+ func (db *DB) MarkReviewClosedByJobID(jobID int64, closed bool) error

type JobStats

+ Closed int

+ Open int

type ListJobsOption

+ func WithClosed(closed bool) ListJobsOption

type PulledReview

+ Closed bool

type RepoStats

+ ClosedReviews int

+ OpenReviews int

type Review

+ Closed bool

type ReviewJob

+ Closed *bool

type SyncableReview

+ Closed bool

Feb 23, 2026

Changes in this version

+ const JobTypeFix

type DB

+ func (db *DB) CompleteFixJob(jobID int64, agent, prompt, output, patch string) error

+ func (db *DB) MarkJobApplied(jobID int64) error

+ func (db *DB) MarkJobRebased(jobID int64) error

+ func (db *DB) SaveJobPatch(jobID int64, patch string) error

type DaemonStatus

+ AppliedJobs int

+ RebasedJobs int

type EnqueueOpts

+ ParentJobID int64

type JobStatus

+ const JobStatusApplied

+ const JobStatusRebased

type ListJobsOption

+ func WithExcludeJobType(jobType string) ListJobsOption

+ func WithJobType(jobType string) ListJobsOption

type Review

+ VerdictBool *int

type ReviewJob

+ ParentJobID *int64

+ Patch *string

+ func (j ReviewJob) HasViewableOutput() bool

+ func (j ReviewJob) IsFixJob() bool

+ func (j ReviewJob) UsesStoredPrompt() bool

Feb 19, 2026

Changes in this version

type SyncWorker

+ func (w *SyncWorker) SetSkipInitialSync(skip bool) error

Feb 18, 2026

Changes in this version

+ const JobTypeCompact

type DB

+ func (db *DB) FailoverJob(jobID int64, workerID string, backupAgent string) (bool, error)

+ func (db *DB) GetJobsWithReviewsByIDs(jobIDs []int64) (map[int64]JobWithReview, error)

+ func (db *DB) RemapJob(repoID int64, oldSHA, newSHA, patchID string, author, subject string, ...) (int, error)

+ func (db *DB) RemapJobGitRef(repoID int64, oldSHA, newSHA, patchID string, newCommitID int64) (int, error)

type EnqueueOpts

+ JobType string

+ PatchID string

+ type JobWithReview struct

+ Job ReviewJob

+ Review *Review

type PulledJob

+ PatchID string

type ReviewJob

+ PatchID string

+ func (j ReviewJob) IsPromptJob() bool

type SyncableJob

+ PatchID string

Feb 10, 2026

Changes in this version

type DB

+ func (db *DB) CountJobStats(repoFilter string, opts ...ListJobsOption) (JobStats, error)

+ type JobStats struct

+ Addressed int

+ Done int

+ Unaddressed int

Feb 9, 2026

Changes in this version

+ const JobTypeDirty

+ const JobTypeRange

+ const JobTypeReview

+ const JobTypeTask

+ type BatchReviewResult struct

+ Agent string

+ Error string

+ JobID int64

+ Output string

+ ReviewType string

+ Status string

+ type CIPRBatch struct

+ CompletedJobs int

+ FailedJobs int

+ GithubRepo string

+ HeadSHA string

+ ID int64

+ PRNumber int

+ Synthesized bool

+ TotalJobs int

+ type CIPRReview struct

+ GithubRepo string

+ HeadSHA string

+ ID int64

+ JobID int64

+ PRNumber int

type DB

+ func (db *DB) CancelSupersededBatches(githubRepo string, prNumber int, newHeadSHA string) ([]int64, error)

+ func (db *DB) ClaimBatchForSynthesis(batchID int64) (bool, error)

+ func (db *DB) CountBatchJobs(batchID int64) (int, error)

+ func (db *DB) CreateCIBatch(githubRepo string, prNumber int, headSHA string, totalJobs int) (*CIPRBatch, bool, error)

+ func (db *DB) DeleteCIBatch(batchID int64) error

+ func (db *DB) DeleteEmptyBatches() (int, error)

+ func (db *DB) FinalizeBatch(batchID int64) error

+ func (db *DB) GetBatchJobIDs(batchID int64) ([]int64, error)

+ func (db *DB) GetBatchReviews(batchID int64) ([]BatchReviewResult, error)

+ func (db *DB) GetCIBatchByJobID(jobID int64) (*CIPRBatch, error)

+ func (db *DB) GetCIReviewByJobID(jobID int64) (*CIPRReview, error)

+ func (db *DB) GetRepoByIdentityCaseInsensitive(identity string) (*Repo, error)

+ func (db *DB) GetStaleBatches() ([]CIPRBatch, error)

+ func (db *DB) HasCIBatch(githubRepo string, prNumber int, headSHA string) (bool, error)

+ func (db *DB) HasCIReview(githubRepo string, prNumber int, headSHA string) (bool, error)

+ func (db *DB) IncrementBatchCompleted(batchID int64) (*CIPRBatch, error)

+ func (db *DB) IncrementBatchFailed(batchID int64) (*CIPRBatch, error)

+ func (db *DB) IsBatchStale(batchID int64) (bool, error)

+ func (db *DB) ReconcileBatch(batchID int64) (*CIPRBatch, error)

+ func (db *DB) RecordBatchJob(batchID, jobID int64) error

+ func (db *DB) RecordCIReview(githubRepo string, prNumber int, headSHA string, jobID int64) error

+ func (db *DB) UnclaimBatch(batchID int64) error

+ type EnqueueOpts struct

+ Agent string

+ Agentic bool

+ Branch string

+ CommitID int64

+ DiffContent string

+ GitRef string

+ Label string

+ Model string

+ OutputPrefix string

+ Prompt string

+ Reasoning string

+ RepoID int64

+ ReviewType string

type PulledJob

+ JobType string

+ ReviewType string

type ReviewJob

+ JobType string

+ ReviewType string

+ func (j ReviewJob) IsDirtyJob() bool

type SyncableJob

+ JobType string

+ ReviewType string

Jan 30, 2026

Changes in this version

type ListJobsOption

+ func WithBranchOrEmpty(branch string) ListJobsOption

Jan 30, 2026

Changes in this version

+ type ListJobsOption func(*listJobsOptions)

+ func WithAddressed(addressed bool) ListJobsOption

+ func WithBranch(branch string) ListJobsOption

+ func WithGitRef(ref string) ListJobsOption

Jan 29, 2026

Changes in this version

+ type PromptJobOptions struct

+ Agent string

+ Agentic bool

+ Branch string

+ Label string

+ Model string

+ OutputPrefix string

+ Prompt string

+ Reasoning string

+ RepoID int64

type RepoStats

+ AddressedReviews int

+ UnaddressedReviews int

type ReviewJob

+ OutputPrefix string

+ func (j ReviewJob) IsTaskJob() bool

Jan 27, 2026

Changes in this version

+ type BranchListResult struct

+ Branches []BranchWithCount

+ NullsRemaining int

+ TotalCount int

+ type BranchWithCount struct

+ Count int

+ Name string

type DB

+ func (db *DB) ListBranchesWithCounts(repoPaths []string) (*BranchListResult, error)

+ func (db *DB) ListReposWithReviewCountsByBranch(branch string) ([]RepoWithCount, int, error)

+ func (db *DB) UpdateJobBranch(jobID int64, branch string) (int64, error)

type ReviewJob

+ Branch string

Jan 26, 2026

Changes in this version

+ func ExtractRepoNameFromIdentity(identity string) string

type DB

+ func (db *DB) MarkReviewAddressedByJobID(jobID int64, addressed bool) error

Jan 25, 2026

Changes in this version

type DB

+ func (db *DB) AddComment(commitID int64, responder, response string) (*Response, error)

+ func (db *DB) AddCommentToJob(jobID int64, responder, response string) (*Response, error)

+ func (db *DB) GetCommentsForCommit(commitID int64) ([]Response, error)

+ func (db *DB) GetCommentsForCommitSHA(sha string) ([]Response, error)

+ func (db *DB) GetCommentsForJob(jobID int64) ([]Response, error)

+ func (db *DB) GetCommentsToSync(machineID string, limit int) ([]SyncableResponse, error)

+ func (db *DB) MarkCommentSynced(responseID int64) error

+ func (db *DB) MarkCommentsSynced(responseIDs []int64) error

type PulledJob

+ Model string

type ReviewJob

+ Model string

type SyncableJob

+ Model string

Jan 23, 2026

Changes in this version

type DaemonStatus

+ ConfigReloadCounter uint64

Jan 23, 2026

Changes in this version

type DaemonStatus

+ ConfigReloadedAt string

Jan 22, 2026

Changes in this version

type DB

+ func (db *DB) GetAllReviewsForGitRef(gitRef string) ([]Review, error)

Jan 21, 2026

Changes in this version

+ const SyncStateLastJobCursor

+ const SyncStateLastResponseID

+ const SyncStateLastReviewCursor

+ const SyncStateMachineID

+ const SyncStateSyncTargetID

+ var ErrAmbiguousCommit = sql.ErrNoRows

+ var ErrRepoHasJobs = errors.New("repository has existing jobs; use cascade to delete them")

+ func DefaultDBPath() string

+ func GenerateUUID() string

+ func ParseVerdict(output string) string

+ type Commit struct

+ Author string

+ CreatedAt time.Time

+ ID int64

+ RepoID int64

+ SHA string

+ Subject string

+ Timestamp time.Time

+ type ComponentHealth struct

+ Healthy bool

+ Message string

+ Name string

+ type DB struct

+ func Open(dbPath string) (*DB, error)

+ func (db *DB) AddResponse(commitID int64, responder, response string) (*Response, error)

+ func (db *DB) AddResponseToJob(jobID int64, responder, response string) (*Response, error)

+ func (db *DB) BackfillRepoIdentities() (int, error)

+ func (db *DB) BackfillSourceMachineID() error

+ func (db *DB) CancelJob(jobID int64) error

+ func (db *DB) ClaimJob(workerID string) (*ReviewJob, error)

+ func (db *DB) ClearAllSyncedAt() error

+ func (db *DB) CompleteJob(jobID int64, agent, prompt, output string) error

+ func (db *DB) CountStalledJobs(threshold time.Duration) (int, error)

+ func (db *DB) DeleteRepo(repoID int64, cascade bool) error

+ func (db *DB) EnqueueDirtyJob(repoID int64, gitRef, agent, reasoning, diffContent string) (*ReviewJob, error)

+ func (db *DB) EnqueueJob(repoID, commitID int64, gitRef, agent, reasoning string) (*ReviewJob, error)

+ func (db *DB) EnqueuePromptJob(repoID int64, agent, reasoning, customPrompt string, agentic bool) (*ReviewJob, error)

+ func (db *DB) EnqueueRangeJob(repoID int64, gitRef, agent, reasoning string) (*ReviewJob, error)

+ func (db *DB) FailJob(jobID int64, errorMsg string) error

+ func (db *DB) FindRepo(identifier string) (*Repo, error)

+ func (db *DB) GetCommitByID(id int64) (*Commit, error)

+ func (db *DB) GetCommitByRepoAndSHA(repoID int64, sha string) (*Commit, error)

+ func (db *DB) GetCommitBySHA(sha string) (*Commit, error)

+ func (db *DB) GetJobByID(id int64) (*ReviewJob, error)

+ func (db *DB) GetJobCounts() (queued, running, done, failed, canceled int, err error)

+ func (db *DB) GetJobRetryCount(jobID int64) (int, error)

+ func (db *DB) GetJobsToSync(machineID string, limit int) ([]SyncableJob, error)

+ func (db *DB) GetKnownJobUUIDs() ([]string, error)

+ func (db *DB) GetMachineID() (string, error)

+ func (db *DB) GetOrCreateCommit(repoID int64, sha, author, subject string, timestamp time.Time) (*Commit, error)

+ func (db *DB) GetOrCreateCommitByRepoAndSHA(repoID int64, sha, author, subject string, timestamp time.Time) (int64, error)

+ func (db *DB) GetOrCreateRepo(rootPath string, identity ...string) (*Repo, error)

+ func (db *DB) GetOrCreateRepoByIdentity(identity string) (int64, error)

+ func (db *DB) GetRecentReviewsForRepo(repoID int64, limit int) ([]Review, error)

+ func (db *DB) GetRepoByID(id int64) (*Repo, error)

+ func (db *DB) GetRepoByIdentity(identity string) (*Repo, error)

+ func (db *DB) GetRepoByName(name string) (*Repo, error)

+ func (db *DB) GetRepoByPath(rootPath string) (*Repo, error)

+ func (db *DB) GetRepoStats(repoID int64) (*RepoStats, error)

+ func (db *DB) GetResponsesForCommit(commitID int64) ([]Response, error)

+ func (db *DB) GetResponsesForCommitSHA(sha string) ([]Response, error)

+ func (db *DB) GetResponsesForJob(jobID int64) ([]Response, error)

+ func (db *DB) GetResponsesToSync(machineID string, limit int) ([]SyncableResponse, error)

+ func (db *DB) GetReviewByCommitSHA(sha string) (*Review, error)

+ func (db *DB) GetReviewByID(reviewID int64) (*Review, error)

+ func (db *DB) GetReviewByJobID(jobID int64) (*Review, error)

+ func (db *DB) GetReviewsToSync(machineID string, limit int) ([]SyncableReview, error)

+ func (db *DB) GetSyncState(key string) (string, error)

+ func (db *DB) ListJobs(statusFilter string, repoFilter string, limit, offset int, ...) ([]ReviewJob, error)

+ func (db *DB) ListRepos() ([]Repo, error)

+ func (db *DB) ListReposWithReviewCounts() ([]RepoWithCount, int, error)

+ func (db *DB) MarkJobSynced(jobID int64) error

+ func (db *DB) MarkJobsSynced(jobIDs []int64) error

+ func (db *DB) MarkResponseSynced(responseID int64) error

+ func (db *DB) MarkResponsesSynced(responseIDs []int64) error

+ func (db *DB) MarkReviewAddressed(reviewID int64, addressed bool) error

+ func (db *DB) MarkReviewSynced(reviewID int64) error

+ func (db *DB) MarkReviewsSynced(reviewIDs []int64) error

+ func (db *DB) MergeRepos(sourceRepoID, targetRepoID int64) (int64, error)

+ func (db *DB) ReenqueueJob(jobID int64) error

+ func (db *DB) RenameRepo(identifier, newName string) (int64, error)

+ func (db *DB) ResetStaleJobs() error

+ func (db *DB) RetryJob(jobID int64, maxRetries int) (bool, error)

+ func (db *DB) SaveJobPrompt(jobID int64, prompt string) error

+ func (db *DB) SetRepoIdentity(repoID int64, identity string) error

+ func (db *DB) SetSyncState(key, value string) error

+ func (db *DB) UpsertPulledJob(j PulledJob, repoID int64, commitID *int64) error

+ func (db *DB) UpsertPulledResponse(r PulledResponse) error

+ func (db *DB) UpsertPulledReview(r PulledReview) error

+ type DaemonStatus struct

+ ActiveWorkers int

+ CanceledJobs int

+ CompletedJobs int

+ FailedJobs int

+ MachineID string

+ MaxWorkers int

+ QueuedJobs int

+ RunningJobs int

+ Version string

+ type ErrorEntry struct

+ Component string

+ JobID int64

+ Level string

+ Message string

+ Timestamp time.Time

+ type HealthStatus struct

+ Components []ComponentHealth

+ ErrorCount int

+ Healthy bool

+ RecentErrors []ErrorEntry

+ Uptime string

+ Version string

+ type JobStatus string

+ const JobStatusCanceled

+ const JobStatusDone

+ const JobStatusFailed

+ const JobStatusQueued

+ const JobStatusRunning

+ type JobWithPgIDs struct

+ Job SyncableJob

+ PgCommitID *int64

+ PgRepoID int64

+ type PgPool struct

+ func NewPgPool(ctx context.Context, connString string, cfg PgPoolConfig) (*PgPool, error)

+ func (p *PgPool) BatchInsertResponses(ctx context.Context, responses []SyncableResponse) ([]bool, error)

+ func (p *PgPool) BatchUpsertJobs(ctx context.Context, jobs []JobWithPgIDs) ([]bool, error)

+ func (p *PgPool) BatchUpsertReviews(ctx context.Context, reviews []SyncableReview) ([]bool, error)

+ func (p *PgPool) Close()

+ func (p *PgPool) EnsureSchema(ctx context.Context) error

+ func (p *PgPool) GetDatabaseID(ctx context.Context) (string, error)

+ func (p *PgPool) GetOrCreateCommit(ctx context.Context, repoID int64, sha, author, subject string, ...) (int64, error)

+ func (p *PgPool) GetOrCreateRepo(ctx context.Context, identity string) (int64, error)

+ func (p *PgPool) InsertResponse(ctx context.Context, r SyncableResponse) error

+ func (p *PgPool) Ping(ctx context.Context) error

+ func (p *PgPool) Pool() *pgxpool.Pool

+ func (p *PgPool) PullJobs(ctx context.Context, excludeMachineID string, cursor string, limit int) ([]PulledJob, string, error)

+ func (p *PgPool) PullResponses(ctx context.Context, excludeMachineID string, afterID int64, limit int) ([]PulledResponse, int64, error)

+ func (p *PgPool) PullReviews(ctx context.Context, excludeMachineID string, knownJobUUIDs []string, ...) ([]PulledReview, string, error)

+ func (p *PgPool) RegisterMachine(ctx context.Context, machineID, name string) error

+ func (p *PgPool) Tx(ctx context.Context, fn func(tx pgx.Tx) error) error

+ func (p *PgPool) UpsertJob(ctx context.Context, j SyncableJob, pgRepoID int64, pgCommitID *int64) error

+ func (p *PgPool) UpsertReview(ctx context.Context, r SyncableReview) error

+ type PgPoolConfig struct

+ ConnectTimeout time.Duration

+ MaxConnIdleTime time.Duration

+ MaxConnLifetime time.Duration

+ MaxConns int32

+ MinConns int32

+ func DefaultPgPoolConfig() PgPoolConfig

+ type PulledJob struct

+ Agent string

+ Agentic bool

+ CommitAuthor string

+ CommitSHA string

+ CommitSubject string

+ CommitTimestamp time.Time

+ DiffContent *string

+ EnqueuedAt time.Time

+ Error string

+ FinishedAt *time.Time

+ GitRef string

+ Prompt string

+ Reasoning string

+ RepoIdentity string

+ SourceMachineID string

+ StartedAt *time.Time

+ Status string

+ UUID string

+ UpdatedAt time.Time

+ type PulledResponse struct

+ CreatedAt time.Time

+ JobUUID string

+ Responder string

+ Response string

+ SourceMachineID string

+ UUID string

+ type PulledReview struct

+ Addressed bool

+ Agent string

+ CreatedAt time.Time

+ JobUUID string

+ Output string

+ Prompt string

+ UUID string

+ UpdatedAt time.Time

+ UpdatedByMachineID string

+ type Repo struct

+ CreatedAt time.Time

+ ID int64

+ Identity string

+ Name string

+ RootPath string

+ type RepoStats struct

+ CompletedJobs int

+ FailedJobs int

+ FailedReviews int

+ PassedReviews int

+ QueuedJobs int

+ Repo *Repo

+ RunningJobs int

+ TotalJobs int

+ type RepoWithCount struct

+ Count int

+ Name string

+ RootPath string

+ type Response struct

+ CommitID *int64

+ CreatedAt time.Time

+ ID int64

+ JobID *int64

+ Responder string

+ Response string

+ SourceMachineID string

+ SyncedAt *time.Time

+ UUID string

+ type Review struct

+ Addressed bool

+ Agent string

+ CreatedAt time.Time

+ ID int64

+ Job *ReviewJob

+ JobID int64

+ Output string

+ Prompt string

+ SyncedAt *time.Time

+ UUID string

+ UpdatedAt *time.Time

+ UpdatedByMachineID string

+ type ReviewJob struct

+ Addressed *bool

+ Agent string

+ Agentic bool

+ CommitID *int64

+ CommitSubject string

+ DiffContent *string

+ EnqueuedAt time.Time

+ Error string

+ FinishedAt *time.Time

+ GitRef string

+ ID int64

+ Prompt string

+ Reasoning string

+ RepoID int64

+ RepoName string

+ RepoPath string

+ RetryCount int

+ SourceMachineID string

+ StartedAt *time.Time

+ Status JobStatus

+ SyncedAt *time.Time

+ UUID string

+ UpdatedAt *time.Time

+ Verdict *string

+ WorkerID string

+ type SyncProgress struct

+ BatchJobs int

+ BatchNum int

+ BatchResps int

+ BatchRevs int

+ Phase string

+ TotalJobs int

+ TotalResps int

+ TotalRevs int

+ type SyncStats struct

+ PulledJobs int

+ PulledResponses int

+ PulledReviews int

+ PushedJobs int

+ PushedResponses int

+ PushedReviews int

+ type SyncWorker struct

+ func NewSyncWorker(db *DB, cfg config.SyncConfig) *SyncWorker

+ func (w *SyncWorker) FinalPush() error

+ func (w *SyncWorker) HealthCheck() (healthy bool, message string)

+ func (w *SyncWorker) Start() error

+ func (w *SyncWorker) Stop()

+ func (w *SyncWorker) SyncNow() (*SyncStats, error)

+ func (w *SyncWorker) SyncNowWithProgress(progressFn func(SyncProgress)) (*SyncStats, error)

+ type SyncableJob struct

+ Agent string

+ Agentic bool

+ CommitAuthor string

+ CommitID *int64

+ CommitSHA string

+ CommitSubject string

+ CommitTimestamp time.Time

+ DiffContent *string

+ EnqueuedAt time.Time

+ Error string

+ FinishedAt *time.Time

+ GitRef string

+ ID int64

+ Prompt string

+ Reasoning string

+ RepoID int64

+ RepoIdentity string

+ SourceMachineID string

+ StartedAt *time.Time

+ Status string

+ UUID string

+ UpdatedAt time.Time

+ type SyncableResponse struct

+ CreatedAt time.Time

+ ID int64

+ JobID int64

+ JobUUID string

+ Responder string

+ Response string

+ SourceMachineID string

+ UUID string

+ type SyncableReview struct

+ Addressed bool

+ Agent string

+ CreatedAt time.Time

+ ID int64

+ JobID int64

+ JobUUID string

+ Output string

+ Prompt string

+ UUID string

+ UpdatedAt time.Time

+ UpdatedByMachineID string