Struct recordingSender

weed/worker/tasks/s3_lifecycle/handler_test.go:23–30

Tests cover the worker-handler surface that runs without a live filer or S3 server: pure helpers (clusterS3Endpoints, readString), Capability/Descriptor sanity, and the Detect input-validation / skip-activity / proposal paths driven by a recorder sender. recordingSender captures everything the handl

// recordingSender captures everything the handler sends so each Detect
// case can assert on activities, proposals, and completion.
type recordingSender struct {
	proposals  []*plugin_pb.DetectionProposals
	completes  []*plugin_pb.DetectionComplete
	activities []*plugin_pb.ActivityEvent
	// errOn forces the named send to fail; lets tests cover the
	// SendComplete error-propagation path without a full transport stub.
	errOn map[string]error
}

func (r *recordingSender) SendProposals(p *plugin_pb.DetectionProposals) error {
	if err := r.errOn["proposals"]; err != nil {