objectstore

type Config struct {
	Reader config.Reader
}

type Constructor func(Config) (Store, error)

type Info struct {
	Size      int64
	ETag      string
	VersionID string
	// SHA256 is the content hash recorded at Put time (object metadata), ""
	// when the object predates keryx or the backend can't echo it.
	SHA256 string
}

type PutResult struct {
	VersionID string
	ETag      string
}

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

type Store interface {
	// Put uploads r (size bytes, content sha256Hex) to key, returning the new
	// object version.
	Put(ctx context.Context, key string, r io.Reader, size int64, sha256Hex string) (PutResult, error)
	// Get streams the object at key; versionID "" means latest.
	Get(ctx context.Context, key, versionID string) (io.ReadCloser, error)
	// Head describes the object at key without fetching it; versionID "" means
	// latest.
	Head(ctx context.Context, key, versionID string) (Info, error)
	// Verify checks the backing store is reachable — the doctor check
	// (R-STO-10). It never creates or configures anything.
	Verify(ctx context.Context) error
	// List returns every key under prefix (used by `media gc` to find blobs no
	// manifest or ledger references).
	List(ctx context.Context, prefix string) ([]string, error)
	// Delete removes one object. keryx only ever calls this from the explicit,
	// opt-in `media gc` prune — never from push/pull (R-STO-6).
	Delete(ctx context.Context, key string) error
}