state

package

Go to main page

Versions in this module

v1

v1.5.0

Mar 13, 2026

v0

v0.22.0

Jun 19, 2026

Changes in this version

type DB

+ func (db *DB) AssayWorkerInFlight(anvil string, prNumber int) (bool, error)

+ func (db *DB) RecoveredStalledWorkers(staleThreshold time.Duration) ([]Worker, error)

+ func (db *DB) UnstallWorker(id string) error

type EventType

+ const EventWorkerRecovered

v0.21.0

Jun 15, 2026

Changes in this version

type DB

+ func (db *DB) CountAssayRuns(anvil string, prNumber int) (int, error)

+ func (db *DB) RecentEventsMatching(pattern string, n int, excludeTypes []EventType) ([]Event, error)

type EventType

+ const EventDispatchPaused

+ const EventDispatchResumed

+ const EventPRCreateRecovered

v0.20.0

Jun 4, 2026

Changes in this version

+ type AssayRun struct

+ Anvil string

+ CostUSD float64

+ DurationMs int64

+ Error string

+ FindingsCount int

+ FinishedAt *time.Time

+ HeadSHA string

+ ID int

+ PRNumber int

+ PostedCount int

+ ShadowMode bool

+ SkippedReason string

+ StartedAt time.Time

type DB

+ func (db *DB) ActiveFindings(anvil string, prNumber int) ([]Finding, error)

+ func (db *DB) AssayCostUSDSince(since time.Time) (float64, error)

+ func (db *DB) IncrementConsecutiveMiss(findingHash string) error

+ func (db *DB) InsertFinding(f Finding) error

+ func (db *DB) LastAssayRunAt(anvil string, prNumber int) (time.Time, error)

+ func (db *DB) LastReviewedSHA(anvil string, prNumber int) (string, error)

+ func (db *DB) MarkFindingPosted(findingHash string, ghCommentID int64) error

+ func (db *DB) MarkResolved(findingHash string) error

+ func (db *DB) OpenPostedFindings(anvil string, prNumber int) ([]Finding, error)

+ func (db *DB) PostedFindingHashes(anvil string, prNumber int) (map[string]bool, error)

+ func (db *DB) RecordAssayRun(r *AssayRun) error

+ func (db *DB) ResetConsecutiveMiss(findingHash string) error

+ func (db *DB) SetFindingThreadID(findingHash, threadID string) error

type EventType

+ const EventDispatchRecoveredStrandedBranch

+ const EventPRReviewNeeded

+ type Finding struct

+ Anchor string

+ Anvil string

+ Body string

+ Category string

+ ConsecutiveMisses int

+ CreatedAt time.Time

+ Evidence string

+ File string

+ FindingHash string

+ GHCommentID int64

+ GHThreadID string

+ HeadSHA string

+ ID int

+ PRNumber int

+ Posted bool

+ ResolvedAt *time.Time

+ Severity string

+ SourcePass string

+ Title string

v0.19.0

May 29, 2026

Changes in this version

type DB

+ func (db *DB) EventsByBead(beadID, anvil string, limit int) ([]Event, error)

v0.18.1

May 26, 2026

v0.18.0

May 22, 2026

v0.17.0

May 22, 2026

v0.16.0

May 21, 2026

Changes in this version

+ const ForgeMessageKindAnswer

+ const ForgeMessageKindBeadsCreated

+ const ForgeMessageKindPlan

+ const ForgeMessageKindQuestion

+ const ForgeMessageKindStatus

+ const ForgeMessageKindText

+ const ForgeMessageRoleAssistant

+ const ForgeMessageRoleSystem

+ const ForgeMessageRoleUser

+ const ForgeSessionStatusArchived

+ const ForgeSessionStatusDraft

+ const ForgeStageDrafting

+ const ForgeStageGrilling

+ const ForgeStageReady

+ var ErrForgeSessionNotFound = errors.New("forge session not found")

type DB

+ func (db *DB) AppendForgeSessionMessage(m ForgeSessionMessage) (ForgeSessionMessage, error)

+ func (db *DB) AppendForgeSessionMessageRaw(sessionID int64, role, kind, content, metadata string) (ForgeSessionMessage, error)

+ func (db *DB) ClearNeedsAttention(beadID, anvil string) error

+ func (db *DB) CountForgeSessionMessages(sessionID int64) (int, error)

+ func (db *DB) CreateForgeSession(s ForgeSession) (ForgeSession, error)

+ func (db *DB) CreateWebSession(s WebSession) error

+ func (db *DB) DeleteForgeSession(id int64) error

+ func (db *DB) DeleteWebSession(tokenHash string) error

+ func (db *DB) EventsSince(lastID, limit int) ([]Event, error)

+ func (db *DB) GetForgeSession(id int64) (*ForgeSession, error)

+ func (db *DB) GetWebSession(tokenHash string) (*WebSession, error)

+ func (db *DB) ListForgeSessionMessages(sessionID int64) ([]ForgeSessionMessage, error)

+ func (db *DB) ListForgeSessions(createdBy string, limit int) ([]ForgeSession, error)

+ func (db *DB) ListForgeSessionsMissingAnvil() ([]ForgeSession, error)

+ func (db *DB) ListForgeSessionsWithCounts(createdBy string, limit int) ([]ForgeSessionWithCount, error)

+ func (db *DB) OrphanedMonitoringBellowsWorkers() ([]OrphanedWorkerInfo, error)

+ func (db *DB) PurgeExpiredWebSessions() (int64, error)

+ func (db *DB) TouchForgeSession(id int64) error

+ func (db *DB) TouchWebSession(tokenHash string, ttl time.Duration) (time.Time, error)

+ func (db *DB) UpdateForgeSession(id int64, title, status *string) error

+ func (db *DB) UpdateForgeSessionAnvil(id int64, anvil string) error

+ func (db *DB) UpdateForgeSessionStageAndPlan(id int64, stage, plan *string) (*ForgeSession, error)

+ func (db *DB) UpdatePRBellowsAssignment(id int, managed, manuallyAssigned bool) error

+ func (db *DB) WorkersByBead(beadID, anvil string, limit int) ([]Worker, error)

type EventType

+ const EventDispatchBlockedStrandedBranch

+ const EventRetryCleared

+ const EventSmithRecheck

+ type ForgeSession struct

+ Anvil string

+ CreatedAt time.Time

+ CreatedBy string

+ ID int64

+ Plan string

+ Stage string

+ Status string

+ Title string

+ UpdatedAt time.Time

+ type ForgeSessionMessage struct

+ Content string

+ CreatedAt time.Time

+ ID int64

+ Kind string

+ Metadata string

+ Role string

+ SessionID int64

+ type ForgeSessionWithCount struct

+ MessageCount int

+ type OrphanedWorkerInfo struct

+ PRStatus string

+ WorkerID string

type PR

+ BellowsManuallyAssigned bool

+ type WebSession struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ LastSeen time.Time

+ TokenHash string

+ Username string

v0.15.1

Apr 21, 2026

v0.15.0

Apr 17, 2026

v0.14.0

Apr 15, 2026

Changes in this version

type DB

+ func (db *DB) IncrementRecoveryFailures(beadID, anvil, reason string) (int, bool, error)

+ func (db *DB) ResetRecoveryFailures(beadID, anvil string) error

type EventType

+ const EventRecoveryCircuitBreak

type NeedsAttentionBead

+ FailureCount int

type RetryRecord

+ FirstRecoveryFailure *time.Time

+ RecoveryFailures int

v0.13.0

Apr 11, 2026

Changes in this version

type DB

+ func (db *DB) GetWorker(id string) (*Worker, error)

type EventType

+ const EventBurnishFailed

+ const EventBurnishSmithError

+ const EventBurnishStarted

+ const EventBurnishSuccess

+ const EventBurnishTemperFailed

+ const EventHookFailed

+ const EventQuenchFailed

+ const EventQuenchStarted

+ const EventQuenchSuccess

v0.12.0

Apr 4, 2026

Changes in this version

type DB

+ func (db *DB) LastEventTime(eventType EventType) (time.Time, bool, error)

+ func (db *DB) LastPollAllAnvils() ([]AnvilPollStatus, error)

+ func (db *DB) UpdateWorkerTitle(id string, title string) error

type EventType

+ const EventSmelterCycleDone

type Worker

+ StaleTimeout time.Duration

v0.11.2

Mar 27, 2026

v0.11.1

Mar 26, 2026

Changes in this version

type DB

+ func (db *DB) HasEventWithin(eventType EventType, d time.Duration) (bool, error)

+ func (db *DB) LogEventAt(typ EventType, message, beadID, anvil string, at time.Time) error

type EventType

+ const EventVulnScanCycleDone

v0.11.0

Mar 25, 2026

Changes in this version

type DB

+ func (db *DB) CountWicketIssues(opts ListWicketIssuesOpts) (int, error)

+ func (db *DB) GetWicketIssue(repo string, number int) (*WicketIssue, error)

+ func (db *DB) GetWicketIssueByBeadID(beadID string) (*WicketIssue, error)

+ func (db *DB) GetWicketSummary() ([]WicketAnvilSummary, error)

+ func (db *DB) InsertWicketIssue(issue WicketIssue) error

+ func (db *DB) IsIssueTracked(repo string, number int) (bool, error)

+ func (db *DB) LastWicketScanAt() (*time.Time, error)

+ func (db *DB) ListWicketIssues(opts ListWicketIssuesOpts) ([]WicketIssue, error)

+ func (db *DB) UpdateWicketIssue(issue WicketIssue) error

type EventType

+ const EventWicketBeadCreated

+ const EventWicketClarification

+ const EventWicketDispatchConfirm

+ const EventWicketError

+ const EventWicketFlaggedHuman

+ const EventWicketIssueClosed

+ const EventWicketIssueStaleClose

+ const EventWicketIssueTriage

+ const EventWicketPRLinked

+ const EventWicketRejected

+ const EventWicketScanDone

+ type ListWicketIssuesOpts struct

+ Limit int

+ Repo string

+ State string

+ type WicketAnvilSummary struct

+ NeedsHumanCount int

+ OpenCount int

+ Repo string

+ type WicketIssue struct

+ Author string

+ AuthorRepliedAt *time.Time

+ BeadID string

+ Body string

+ CommentCount int

+ CreatedAt time.Time

+ ID int

+ IssueNumber int

+ PRNumber int

+ PRUrl string

+ ProcessedAt *time.Time

+ Repo string

+ State string

+ Title string

+ TriageAction string

+ TriageReason string

+ UpdatedAt time.Time

v0.10.0

Mar 23, 2026

Changes in this version

type DB

+ func (db *DB) DeletePendingRules(ids []int) error

+ func (db *DB) InsertPendingRule(anvil, ruleYAML, sourcePR string) error

+ func (db *DB) QueryPendingRulesByAnvil() (map[string][]PendingRule, error)

type EventType

+ const EventDepupdateCompleted

+ const EventDepupdateFailed

+ const EventDepupdateStarted

+ const EventSmelterFailed

+ const EventSmelterFlushed

+ const EventSmelterStarted

+ type PendingRule struct

+ Anvil string

+ CreatedAt time.Time

+ ID int

+ RuleYAML string

+ SourcePR string

v0.9.0

Mar 20, 2026

Changes in this version

type EventType

+ const EventAdventurerFailed

+ const EventAdventurerPassed

+ const EventAdventurerStarted

+ const EventDispatchFailed

+ const EventPRAlreadyExists

+ const EventPRCreationFailed

+ const EventQuestgiverScanDone

+ const EventTestBeadCreated

v0.8.0

Mar 16, 2026

Changes in this version

type DB

+ func (db *DB) DeletePipelineBellowsWorker(beadID, anvil string) error

+ func (db *DB) InsertWorkerIfMissing(w *Worker) error

+ func (db *DB) LatestWardenRejectMessage(beadID string) string

+ func (db *DB) MergedPRs() ([]PR, error)

type EventType

+ const EventApproveAsIs

+ const EventBeadAutoClosed

+ const EventForceSmith

+ const EventNoChangesNeeded

+ const EventPRAutoMerged

+ const EventWardenRerun

v0.7.1

Mar 14, 2026

v0.7.0

Mar 14, 2026

Changes in this version

type DB

+ func (db *DB) MarkNeedsHuman(beadID, anvil, reason string) error

+ func (db *DB) UpdatePRBellowsManaged(id int, managed bool) error

+ func (db *DB) UpdatePRTitle(id int, title string) error

type EventType

+ const EventRateLimited

type OpenPRDetail

+ BellowsManaged bool

+ IsExternal bool

type PR

+ BellowsManaged bool

+ Title string

+ func (p *PR) IsExternal() bool

v0.6.0

Mar 13, 2026

v0.5.1

Mar 13, 2026

v0.5.0

Mar 13, 2026

Changes in this version

+ type AnvilPollStatus struct

+ Anvil string

+ Message string

+ OK bool

+ Timestamp time.Time

type DB

+ func (db *DB) LastPollPerAnvil(anvilNames []string) ([]AnvilPollStatus, error)

+ func (db *DB) OpenPRsWithDetail() ([]OpenPRDetail, error)

+ func (db *DB) RecentEventsExcluding(n int, excludeTypes []EventType) ([]Event, error)

type EventType

+ const EventBeadStopped

+ type OpenPRDetail struct

+ Anvil string

+ BeadID string

+ Branch string

+ CIFixCount int

+ CIPassing bool

+ HasApproval bool

+ HasPendingReviews bool

+ HasUnresolvedThreads bool

+ ID int

+ IsConflicting bool

+ Number int

+ RebaseCount int

+ ReviewFixCount int

+ Status PRStatus

+ Title string

v0.4.0

Mar 12, 2026

Changes in this version

type DB

+ func (db *DB) AddPendingOrphan(beadID, anvil, title, branch string) error

+ func (db *DB) HasEventForDate(eventType EventType, date string) (bool, error)

+ func (db *DB) IsPendingOrphan(beadID, anvil string) (bool, error)

+ func (db *DB) LastWorkerBranchForBead(beadID, anvil string) (string, error)

+ func (db *DB) ListPendingOrphans() ([]PendingOrphan, error)

+ func (db *DB) RemovePendingOrphan(beadID, anvil string) error

type EventType

+ const EventPRReadyToMerge

+ const EventWardenHardReject

type NeedsAttentionBead

+ Description string

type PR

+ HasApproval bool

+ type PendingOrphan struct

+ Anvil string

+ BeadID string

+ Branch string

+ CreatedAt time.Time

+ Title string

v0.3.1

Mar 11, 2026

v0.3.0

Mar 11, 2026

Changes in this version

type DB

+ func (db *DB) NeedsHumanBeadIDSet() (map[string]struct{}, error)

type EventType

+ const EventAutoLearnSkipped

type ReadyToMergePR

+ Title string

v0.2.0

Mar 10, 2026

Changes in this version

type DB

+ func (db *DB) AddCopilotRequest(date string, multiplier float64) error

+ func (db *DB) AddProviderDailyCost(date, prov string, input, output, cacheRead, cacheWrite int, cost float64) error

+ func (db *DB) GetCopilotRequestsOn(date string) (float64, error)

+ func (db *DB) GetProviderDailyCosts(date string) ([]ProviderDailyCost, error)

+ func (db *DB) GetTodayCopilotRequests() (float64, error)

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

type EventType

+ const EventDepcheckDedup

+ type ProviderDailyCost struct

+ CacheRead int

+ CacheWrite int

+ EstimatedCost float64

+ InputTokens int

+ OutputTokens int

+ Provider string

v0.1.0

Mar 9, 2026

Changes in this version

+ const DefaultMaxCIFixAttempts

+ const DefaultMaxRebaseAttempts

+ const DefaultMaxReviewFixAttempts

+ func DefaultPath() (string, error)

+ type DB struct

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

+ func (db *DB) ActiveDispatchWorkers() ([]Worker, error)

+ func (db *DB) ActiveDispatchWorkersByAnvil(anvil string) ([]Worker, error)

+ func (db *DB) ActiveWorkerByBead(beadID string) (*Worker, error)

+ func (db *DB) ActiveWorkerByBeadAndAnvil(beadID, anvil string) (*Worker, error)

+ func (db *DB) ActiveWorkers() ([]Worker, error)

+ func (db *DB) AddBeadCost(beadID, anvil string, input, output, cacheRead, cacheWrite int, cost float64) error

+ func (db *DB) AddDailyCost(date string, input, output, cacheRead, cacheWrite int, cost float64) error

+ func (db *DB) AllWorkers(limit int) ([]Worker, error)

+ func (db *DB) BeadTitle(beadID, anvil string) string

+ func (db *DB) ClarificationNeededBeadIDSet() (map[string]struct{}, error)

+ func (db *DB) ClarificationNeededBeads() ([]RetryRecord, error)

+ func (db *DB) ClearRetry(beadID, anvil string) error

+ func (db *DB) Close() error

+ func (db *DB) CompleteWorkersByBead(beadID string) error

+ func (db *DB) CompletedWorkers(limit int) ([]Worker, error)

+ func (db *DB) Conn() *sql.DB

+ func (db *DB) DismissExhaustedPR(id int) error

+ func (db *DB) DismissRetry(beadID, anvil string) error

+ func (db *DB) DispatchCircuitBrokenBeadIDSet() (map[string]struct{}, error)

+ func (db *DB) ExhaustedPRs(maxCI, maxRev, maxRebase int) ([]ExhaustedPR, error)

+ func (db *DB) GetAllProviderQuotas() (map[string]provider.Quota, error)

+ func (db *DB) GetDailyCost(date string) (inputTokens, outputTokens, cacheRead, cacheWrite int, cost, limit float64, ...)

+ func (db *DB) GetPRByID(id int) (*PR, error)

+ func (db *DB) GetPRByNumber(anvil string, number int) (*PR, error)

+ func (db *DB) GetProviderQuota(pv string) (*provider.Quota, error)

+ func (db *DB) GetRetry(beadID, anvil string) (*RetryRecord, error)

+ func (db *DB) GetTodayCost() (float64, error)

+ func (db *DB) GetTodayCostOn(date string) (float64, error)

+ func (db *DB) HasOpenPRForBead(beadID, anvil string) (bool, error)

+ func (db *DB) HasWorkerRecord(beadID, anvil string) (bool, error)

+ func (db *DB) IncrementDispatchFailures(beadID, anvil string, maxFailures int, reason string) (int, bool, error)

+ func (db *DB) InsertPR(pr *PR) error

+ func (db *DB) InsertWorker(w *Worker) error

+ func (db *DB) IsPRReadyToMerge(id int) (bool, error)

+ func (db *DB) LastWorkerLogPath(beadID string) (string, error)

+ func (db *DB) LogEvent(typ EventType, message, beadID, anvil string) error

+ func (db *DB) MarkWorkerStalled(id string) error

+ func (db *DB) NeedsAttentionBeads(maxCI, maxRev, maxRebase int) ([]NeedsAttentionBead, error)

+ func (db *DB) NeedsHumanBeads() ([]RetryRecord, error)

+ func (db *DB) OpenPRs() ([]PR, error)

+ func (db *DB) PRByNumber(number int) (*PR, error)

+ func (db *DB) Path() string

+ func (db *DB) PendingRetries() ([]RetryRecord, error)

+ func (db *DB) QueueCache() ([]QueueItem, error)

+ func (db *DB) ReadyToMergePRs() ([]ReadyToMergePR, error)

+ func (db *DB) RecentDailyCosts(n int) ([]struct{ ... }, error)

+ func (db *DB) RecentEvents(n int) ([]Event, error)

+ func (db *DB) ReplaceQueueCacheForAnvils(anvils []string, items []QueueItem) error

+ func (db *DB) ResetDispatchFailures(beadID, anvil string) error

+ func (db *DB) ResetPRFixCounts(id int) error

+ func (db *DB) ResetRetry(beadID, anvil string) error

+ func (db *DB) SetClarificationNeeded(beadID, anvil string, needed bool, reason string) error

+ func (db *DB) SetDailyCostLimit(date string, limit float64) error

+ func (db *DB) StalledWorkers(staleThreshold time.Duration) ([]Worker, error)

+ func (db *DB) TotalCostSince(sinceDate string) (float64, error)

+ func (db *DB) UpdatePRLifecycle(id int, ciFixCount, reviewFixCount, rebaseCount int, ciPassing bool) error

+ func (db *DB) UpdatePRMergeability(id int, isConflicting, hasUnresolvedThreads, hasPendingReviews bool) error

+ func (db *DB) UpdatePRStatus(id int, status PRStatus) error

+ func (db *DB) UpdatePRStatusIfNeedsFix(id int, status PRStatus) error

+ func (db *DB) UpdateWorkerLogPath(id string, logPath string) error

+ func (db *DB) UpdateWorkerPID(id string, pid int) error

+ func (db *DB) UpdateWorkerPhase(id string, phase string) error

+ func (db *DB) UpdateWorkerStatus(id string, status WorkerStatus) error

+ func (db *DB) UpsertProviderQuota(pv string, q *provider.Quota) error

+ func (db *DB) UpsertRetry(r *RetryRecord) error

+ func (db *DB) WorkersByAnvil(anvil string) ([]Worker, error)

+ type Event struct

+ Anvil string

+ BeadID string

+ ID int

+ Message string

+ Timestamp time.Time

+ Type EventType

+ type EventType string

+ const EventAutoLearnError

+ const EventAutoLearnRules

+ const EventBeadClaimed

+ const EventBeadClosed

+ const EventBeadDismissed

+ const EventBeadRecovered

+ const EventBeadTagged

+ const EventBellowsStarted

+ const EventCIFailed

+ const EventCIFixFailed

+ const EventCIFixStarted

+ const EventCIFixSuccess

+ const EventClarificationCleared

+ const EventClarificationNeeded

+ const EventConfigReload

+ const EventCostLimitHit

+ const EventCrucibleChildDispatched

+ const EventCrucibleChildFailed

+ const EventCrucibleChildMerged

+ const EventCrucibleChildPRCreated

+ const EventCrucibleComplete

+ const EventCrucibleFinalPR

+ const EventCruciblePaused

+ const EventCrucibleStarted

+ const EventDaemonStarted

+ const EventDaemonStopped

+ const EventDepcheckBeadCreated

+ const EventDepcheckFailed

+ const EventDepcheckFound

+ const EventDepcheckPassed

+ const EventDepcheckStarted

+ const EventDispatchCircuitBreak

+ const EventError

+ const EventLifecycleExhausted

+ const EventOrphanCleanup

+ const EventPRClosed

+ const EventPRConflicting

+ const EventPRCreated

+ const EventPRMergeFailed

+ const EventPRMergeRequested

+ const EventPRMerged

+ const EventPRNeedsFix

+ const EventPoll

+ const EventPollError

+ const EventRebaseFailed

+ const EventRebaseStarted

+ const EventRebaseSuccess

+ const EventRetryReset

+ const EventReviewChanges

+ const EventReviewFixFailed

+ const EventReviewFixSmithError

+ const EventReviewFixStarted

+ const EventReviewFixSuccess

+ const EventReviewThreadResolved

+ const EventSchematicDone

+ const EventSchematicSkipped

+ const EventSchematicStarted

+ const EventSchematicSubBead

+ const EventSmithDone

+ const EventSmithFailed

+ const EventSmithStarted

+ const EventSmithStats

+ const EventTemperFailed

+ const EventTemperPassed

+ const EventTemperStarted

+ const EventVulnBeadCreated

+ const EventVulnScanDone

+ const EventVulnScanFailed

+ const EventVulnScanStarted

+ const EventWardenPass

+ const EventWardenReject

+ const EventWardenRuleLearned

+ const EventWardenStarted

+ const EventWorkerStalled

+ type ExhaustedPR struct

+ Anvil string

+ BeadID string

+ CIFixCount int

+ ID int

+ Number int

+ Reason string

+ RebaseCount int

+ ReviewFixCount int

+ type NeedsAttentionBead struct

+ Anvil string

+ BeadID string

+ ClarificationNeeded bool

+ NeedsHuman bool

+ PRID int

+ PRNumber int

+ Reason string

+ Title string

+ type PR struct

+ Anvil string

+ BaseBranch string

+ BeadID string

+ Branch string

+ CIFixCount int

+ CIPassing bool

+ CreatedAt time.Time

+ HasPendingReviews bool

+ HasUnresolvedThreads bool

+ ID int

+ IsConflicting bool

+ LastChecked *time.Time

+ Number int

+ RebaseCount int

+ ReviewFixCount int

+ Status PRStatus

+ type PRStatus string

+ const PRApproved

+ const PRClosed

+ const PRMerged

+ const PRNeedsFix

+ const PROpen

+ type QueueItem struct

+ Anvil string

+ Assignee string

+ BeadID string

+ Description string

+ Labels string

+ Priority int

+ Section QueueSection

+ Status string

+ Title string

+ type QueueSection string

+ const QueueSectionInProgress

+ const QueueSectionReady

+ const QueueSectionUnlabeled

+ type ReadyToMergePR struct

+ Anvil string

+ BeadID string

+ Branch string

+ ID int

+ Number int

+ type RetryRecord struct

+ Anvil string

+ BeadID string

+ ClarificationNeeded bool

+ DispatchFailures int

+ LastError string

+ NeedsHuman bool

+ NextRetry *time.Time

+ RetryCount int

+ UpdatedAt time.Time

+ type Worker struct

+ Anvil string

+ BeadID string

+ Branch string

+ CompletedAt *time.Time

+ ID string

+ LogPath string

+ PID int

+ PRNumber int

+ Phase string

+ StartedAt time.Time

+ Status WorkerStatus

+ Title string

+ type WorkerStatus string

+ const WorkerDone

+ const WorkerFailed

+ const WorkerMonitoring

+ const WorkerPending

+ const WorkerReviewing

+ const WorkerRunning

+ const WorkerStalled

+ const WorkerTimeout

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