Documentation
¶
Overview ¶
Package runnerhealthcheckbackfill holds the shared constants and payload types for the runner-healthcheck-emitter backfill workflow, so the ctl-api service (which starts and queries the workflow) and the runners worker (which implements it) can share them without an import cycle.
Index ¶
Constants ¶
View Source
const ( // WorkflowName must match the registered workflow function name. WorkflowName = "BackfillRunnerHealthcheckEmitters" // WorkflowID is fixed so a re-triggered backfill reuses the running one // rather than starting a duplicate. WorkflowID = "runners-healthcheck-emitter-backfill" ProgressQueryType = "progress" // DefaultBatchSize is how many runners each activity call processes. Kept // small so each batch holds little in memory and starts few emitter // workflows at once. DefaultBatchSize = 10 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Progress ¶
type Progress struct {
RunnersProcessed int `json:"runners_processed"`
EmittersCreated int `json:"emitters_created"`
AlreadyPresent int `json:"already_present"`
Errors int `json:"errors"`
CursorCreatedAt time.Time `json:"cursor_created_at"`
CursorID string `json:"cursor_id"`
Done bool `json:"done"`
}
Progress is the live snapshot returned by the workflow's progress query.
type Request ¶
type Request struct {
// CursorCreatedAt / CursorID form a keyset cursor ordered by
// (created_at, id) ascending, so the fleet is processed oldest-first. The
// id is a tiebreaker for runners sharing a created_at. Zero values start
// from the beginning.
CursorCreatedAt time.Time `json:"cursor_created_at"`
CursorID string `json:"cursor_id"`
// BatchSize overrides DefaultBatchSize when non-zero.
BatchSize int `json:"batch_size"`
RunnersProcessed int `json:"runners_processed"`
EmittersCreated int `json:"emitters_created"`
AlreadyPresent int `json:"already_present"`
Errors int `json:"errors"`
}
Request is the orchestrator input. Callers leave it zero; the workflow fills in the cursor and running totals and carries them across continue-as-new.
Source Files
Click to show internal directories.
Click to hide internal directories.