collector

type Input struct {
	Plan *planner.RunPlan
	// Sources is the populated source-plugin registry.
	Sources *registry.Registry[core.SourcePlugin]
	// EvidenceTypes is the registered evidence-type catalog. The
	// collector validates every emitted record's payload against its
	// type's schema before signing — a schema mismatch is treated as a
	// collection error and tagged on the policy. When nil (legacy
	// callers, tests that don't exercise validation), validation is
	// skipped.
	EvidenceTypes *registry.Registry[core.EvidenceType]
	// Vault is where envelopes land.
	Vault core.Vault
	// RunRoot is the framework-prefixed root inside the vault for this
	// run, e.g. "soc2/2026-Q1/run_20260215T140000Z_a3f8b2c1".
	RunRoot string
	// SlotParamsExtras is appended to each binding's SlotParams before
	// invoking Collect. The orchestrator uses this to inject period_id,
	// period_start, period_end, now — values the planner knows but the
	// project config does not.
	SlotParamsExtras map[string]any
	// Now is the run's reference time for envelope ProducedAt.
	Now time.Time
	// RetryPolicy controls per-slot retry behavior. Zero value (or
	// MaxAttempts <= 1) is the legacy no-retry behavior. The
	// orchestrator selects a mode-appropriate policy (PR=generous,
	// Scheduled=fast-fail, Manual=none) and threads it through here.
	RetryPolicy RetryPolicy
}

type Output struct {
	// RecordsByPolicy[policyID][slotName] holds the union of all bound
	// sources' records for that slot.
	RecordsByPolicy map[string]map[string][]core.EvidenceRecord
	// EnvelopesByPolicy[policyID] holds the relative vault paths of the
	// envelopes written for that policy. Used by the evaluator to
	// populate PolicyResult.EvidenceEnvelopes.
	EnvelopesByPolicy map[string][]string
	// CollectErrorsByPolicy[policyID] is set when at least one bound
	// source returned an error. The evaluator turns this into a
	// status=error result.
	CollectErrorsByPolicy map[string]error
}

type RetryPolicy struct {
	MaxAttempts int
	Backoff     []time.Duration
}