storage

type Config struct {
	// DataDir is the absolute root passed through to walkAndStat
	// and FileID.{CanonicalPath,MediaSubtree,FSExists}. Required.
	DataDir string

	// Initial retention values. After New, callers mutate these via
	// UpdateConfig — the in-memory atomic.Pointer is the live source
	// of truth, not the Config struct.
	MaxBytes      int64
	MaxAgeDays    int
	WarnAtPercent int

	// TickInterval is the monitor cadence. Default 1 hour.
	TickInterval time.Duration

	// EvictionCapPerTick bounds work per tick for both eviction and
	// orphan reconciliation. Default 1000 files.
	EvictionCapPerTick int

	// IdleEvictionLag is the grace period: files modified within
	// this window are NOT evicted. Default 5 minutes. Gives
	// just-rotated or just-released files breathing room.
	IdleEvictionLag time.Duration
}

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

type Counters interface {
	AddEvictedTraces(n int64)
	AddEvictedBytes(n int64)
}

type FileID struct {
	// DataDir is the absolute root configured via storage.data_dir.
	// Kept on FileID so MediaSubtree, CanonicalPath, and FSExists
	// don't need it threaded as a separate argument.
	DataDir string

	// Date is the UTC date the writer used at bucket-creation time,
	// formatted as YYYY-MM-DD. Source-of-truth is the JSONL file's
	// parent directory name, not the trace's TsStart (those can
	// differ when finalize crosses a day boundary).
	Date string

	// KeyHash8 is the first 8 hex characters of the SHA-256 of the
	// client's Authorization / x-api-key, computed by
	// internal/ids.KeyHashShort. 8 hex chars ≈ 32 bits, sufficient
	// to keep per-tenant files separate at every realistic scale
	// (collision probability is ~1.2e-5 at 1000 tenants).
	KeyHash8 string
}

type FileInfo struct {
	FileID    FileID
	FSPath    string    // most recently scanned on-disk form
	SizeBytes int64     // total across .jsonl + .jsonl.gz (sums during rotation)
	ModTime   time.Time // latest mtime across forms; zero if no JSONL on disk
	MediaSize int64     // recursive bytes under MediaSubtree()
}

type Inventory struct {
	Files      []FileInfo
	TotalBytes int64 // sum of SizeBytes + MediaSize over Files (the retention-managed footprint)
}

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

type RetentionConfig struct {
	MaxBytes      int64
	MaxAgeDays    int
	WarnAtPercent int
}

type Status struct {
	// DataDirBytes is the current retention-managed footprint
	// (sum of JSONL + media across all (date, keyhash) buckets).
	DataDirBytes int64

	// MaxBytes mirrors the active RetentionConfig.MaxBytes for ops
	// visibility; 0 when byte cap is disabled.
	MaxBytes int64

	// MaxAgeDays mirrors the active RetentionConfig.MaxAgeDays; 0
	// when age cap is disabled.
	MaxAgeDays int

	// UsagePct = 100 * DataDirBytes / MaxBytes, clamped to [0, 100+].
	// 0 when MaxBytes == 0 (no byte cap, so the percentage is
	// meaningless). The value can exceed 100 briefly between writer
	// activity and the next eviction tick.
	UsagePct int

	// State summarizes the storage situation in one word so the
	// Landing OPS strip can color-code without doing arithmetic:
	//
	//   "disabled" — both knobs are 0; monitor still runs but no
	//                eviction can fire.
	//   "ok"       — under thresholds.
	//   "warning"  — usage at or above warn_at_percent of max_bytes.
	//   "critical" — usage at or above 100% of max_bytes.
	//   "pending"  — monitor hasn't ticked yet; Status() returns
	//                this when atomic.Pointer is still nil at first
	//                load.
	State string

	// LastEvictionTs is the wall-clock time of the most recent
	// eviction tick that actually deleted something. Zero value
	// (time.Time{}) means "no eviction has run yet OR no files
	// were eligible at last tick".
	LastEvictionTs time.Time

	// LastEvictedBytes is the byte total deleted by the most recent
	// eviction tick. Zero when LastEvictionTs is zero.
	LastEvictedBytes int64

	// EvictionCapHit is true when the most recent tick exhausted the
	// per-tick eviction cap (default 1000 files) with more eligible
	// files remaining. Operator-facing signal that another tick is
	// needed to fully catch up — useful during the first-enable
	// migration.
	EvictionCapHit bool

	// NextEvictionEst is a best-effort projection of when the byte
	// cap would be hit at the current growth rate. Always zero in
	// v0.1.1; v0.2 may populate it from inventory deltas.
	NextEvictionEst time.Time

	// EngineRunning is true when monitor.Start has been called and
	// the goroutine is alive. Distinguishes "monitor hasn't started
	// yet" (e.g. unit test instantiation without Start) from
	// "monitor is up but hasn't ticked yet".
	EngineRunning bool
}

type Store interface {
	// ListDistinctJSONLPaths returns every distinct jsonl_path
	// stored in the traces table, in unspecified order. Backed by
	// the idx_jsonl_path index added by B2's schema migration.
	ListDistinctJSONLPaths(ctx context.Context) ([]string, error)

	// DeleteByJSONLPath removes all trace rows referencing the
	// given canonical path. Returns affected row count.
	DeleteByJSONLPath(ctx context.Context, jsonlPath string) (int64, error)
}