Documentation
¶
Overview ¶
Package sweep is the continuation-store janitor: a single periodic background pass that fails abandoned/expired runs, fails runs whose resumer crashed mid-resume, and purges long-dead runs. It only ever reads the store and writes create-if-absent terminal docs (FailRun) or deletes whole finished runs (PurgeRun) — it never re-enters the processor and never mutates a live run.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SweeperController ¶
type SweeperController struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(ctx context.Context, pu *processor.Unit) *SweeperController
func (*SweeperController) Start ¶
func (sc *SweeperController) Start()
func (*SweeperController) Stop ¶
func (sc *SweeperController) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.