storeseed

type Materializer interface {
	// Kind is the pack kind this materializer owns (KindVector | KindKV).
	Kind() string

	// Shared reports whether the backing store is shared across fleet nodes
	// (pgvector, redis) rather than per-node (sqlite-vec, boltdb). A shared
	// store is reconciled exactly ONCE — on the activation origin (the control
	// plane) — so concurrent data-plane appliers don't race the delete-missing
	// pass. A per-node store is reconciled on every node from its CAS-resolved
	// pack. The wiring layer that picks the backend declares this.
	Shared() bool

	// Reconcile makes the store match packs — the full set of this kind's packs
	// in this version. Each pack owns its collection/namespace (managed scope):
	// upsert the pack's items + delete managed items absent from it. A pack with
	// zero items empties (but does not necessarily drop) its target. Whole-
	// collection drop (a pack removed entirely between versions) is the
	// Reconciler's job (P4 prior-version diff), not the Materializer's.
	Reconcile(ctx context.Context, scope Scope, packs []RawPack) error
}

type RawPack struct {
	Path  string // e.g. "VECTORS/books.jsonl", "BLOBS/faqs/house-01.doc"
	Kind  string // KindVector | KindKV | KindBlob
	Name  string // collection / namespace / blob name the pack owns
	Bytes []byte // raw NDJSON (nil for a blob row)
	Hash  string // sha256 hex of the row's bytes (blob rows: the CAS key)
}

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

type Scope struct {
	Tenant  string
	Stack   string
	Version int64
	// Force is the `txco data apply --force` signal: the tree WINS over
	// runtime drift — a materializer re-asserts every seeded item and drops
	// the ones the tree no longer ships, even where it would otherwise leave
	// a runtime edit alone (blobseed). The caller also reconciles every pack,
	// not just the changed ones.
	Force bool
}