Documentation
¶
Overview ¶
Package sweep is the store janitor: a single periodic background pass per store. For the continuation store it 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. For the drive store (where the `webdav` head runs) it reclaims unreferenced objects and hard-deletes old tombstones (drive.Store.Sweep).
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, driveStore *drive.Store) *SweeperController
NewController constructs the sweeper. driveStore may be nil; the drive arm runs only where the `webdav` head runs (the node that serves a collection is the one that pays for its housekeeping).
func (*SweeperController) Start ¶
func (sc *SweeperController) Start()
func (*SweeperController) Stop ¶
func (sc *SweeperController) Stop()
Source Files