clean

type AncestorProtection struct {
	AncestorRunID           string           `json:"ancestor_run_id"`
	RetainedDescendantRunID string           `json:"retained_descendant_run_id"`
	LineageEdgeRefs         []LineageEdgeRef `json:"lineage_edge_refs"`
}

type ApplyIdentity struct {
	DryRunPlanHash            string     `json:"dry_run_plan_hash"`
	ExpectedStoreEpoch        StoreEpoch `json:"expected_store_epoch"`
	ExpectedInputPolicySHA256 string     `json:"expected_input_policy_sha256"`
}

type ApplyStore interface {
	Observe(context.Context) (RetentionSnapshot, error)
	WithCleanupTransaction(context.Context, func(CleanupTransaction) error) error
}

type ByteAccounting struct {
	InitialRegularFileBytes   int64 `json:"initial_regular_file_bytes"`
	AgeDeleteBytes            int64 `json:"age_delete_bytes"`
	SizeDeleteBytes           int64 `json:"size_delete_bytes"`
	PlannedDeleteBytes        int64 `json:"planned_delete_bytes"`
	ProjectedRegularFileBytes int64 `json:"projected_regular_file_bytes"`
	TargetBytes               int64 `json:"target_bytes"`
	TargetReached             bool  `json:"target_reached"`
}

type CleanPlan struct {
	SchemaVersion       string              `json:"schema_version"`
	Mode                string              `json:"mode"`
	Now                 string              `json:"now"`
	StoreEpoch          StoreEpoch          `json:"store_epoch"`
	InputPolicySHA256   string              `json:"input_policy_sha256"`
	Policy              Policy              `json:"policy"`
	RetentionProtection RetentionProtection `json:"retention_protection"`
	RunDecisions        []RunDecision       `json:"run_decisions"`
	DeleteSets          DeleteSets          `json:"delete_sets"`
	OrderedActions      []OrderedAction     `json:"ordered_actions"`
	ByteAccounting      ByteAccounting      `json:"byte_accounting"`
	OutcomeReasons      []Reason            `json:"outcome_reasons"`
	PlanHash            string              `json:"plan_hash"`
	ApplyIdentity       *ApplyIdentity      `json:"apply_identity"`
}

type CleanupTransaction interface {
	Snapshot(context.Context) (RetentionSnapshot, error)
	DryRunPlan(context.Context, string) (CleanPlan, error)
	PersistDryRunPlan(context.Context, CleanPlan) error
	ClearDryRunPlans(context.Context) error
	Tombstones(context.Context) ([]Tombstone, error)
	Tombstone(context.Context, Tombstone) error
	DeleteTombstoned(context.Context, Tombstone) error
}

type DeleteSetEntry struct {
	RunID            string `json:"run_id"`
	CompletedAt      string `json:"completed_at"`
	RegularFileBytes int64  `json:"regular_file_bytes"`
	Reason           Reason `json:"reason"`
}

type DeleteSets struct {
	AgeDeleteSet  []DeleteSetEntry `json:"age_delete_set"`
	SizeDeleteSet []DeleteSetEntry `json:"size_delete_set"`
}

type Failure struct {
	Kind    FailureKind
	Message string
	Cause   error
}

type FailureKind string

type GraphAnomalyComponent struct {
	AffectedRunIDs  []string         `json:"affected_run_ids"`
	LineageEdgeRefs []LineageEdgeRef `json:"lineage_edge_refs"`
}

type LineageEdgeObservation struct {
	LineageEdgeRef
	// Valid is false when the edge record is malformed or fails its integrity checks.
	Valid bool
}

type LineageEdgeRef struct {
	ParentRunID string `json:"parent_run_id"`
	ChildRunID  string `json:"child_run_id"`
	EdgePath    string `json:"edge_path"`
	SHA256      string `json:"sha256"`
}

type OrderedAction struct {
	Sequence      int    `json:"sequence"`
	Phase         string `json:"phase"`
	Action        string `json:"action"`
	RunID         string `json:"run_id"`
	Reason        Reason `json:"reason"`
	BytesReleased int64  `json:"bytes_released"`
}

type Policy struct {
	RetentionAgeSeconds  int64    `json:"retention_age_seconds"`
	MinAgeForSizeSeconds int64    `json:"min_age_for_size_seconds"`
	TargetBytes          int64    `json:"target_bytes"`
	ExplicitKeepRunIDs   []string `json:"explicit_keep_run_ids"`
}

type Reason string

type Request struct {
	OlderThanDays int64
	All           bool
	DryRun        bool
}

type Result struct {
	Plan             CleanPlan
	DryRun           bool
	AffectedRunCount int
	AffectedBytes    int64
}

type RetentionProtection struct {
	RetainedSeedRunIDs           []string                `json:"retained_seed_run_ids"`
	TransitiveAncestorProtection []AncestorProtection    `json:"transitive_ancestor_protection"`
	GraphAnomalyComponents       []GraphAnomalyComponent `json:"graph_anomaly_components"`
}

type RetentionSnapshot struct {
	Now                       time.Time
	StoreEpoch                StoreEpoch
	InputPolicySHA256         string
	Policy                    Policy
	Runs                      []RunObservation
	Edges                     []LineageEdgeObservation
	ProtectedRegularFileBytes int64
}

type RunDecision struct {
	RunID    string   `json:"run_id"`
	Decision string   `json:"decision"`
	Reasons  []Reason `json:"reasons"`
}

type RunKind string

type RunObservation struct {
	RunID               string
	SessionID           string
	Kind                RunKind
	Completed           bool
	CompletedAt         *time.Time
	Active              bool
	Committed           bool
	Corrupt             bool
	DiagnosticProtected bool
	RegularFileBytes    int64
}

type SchemaValidator interface {
	Validate(context.Context, ports.AssetID, []byte) error
}

type Service struct {
	// contains filtered or unexported fields
}

type StoreEpoch struct {
	Value  int64  `json:"value"`
	SHA256 string `json:"sha256"`
}

type Tombstone struct {
	RunID    string
	PlanHash string
}