state

package

Go to main page

Versions in this module

v1

v1.5.0

Mar 13, 2026

v0

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