schema

type Change struct {
	Prev, Next Value
}

type Constructor = func(params json.RawMessage, mkSchema Factory) (Schema, error)

type Exists interface {
	Exists(ctx context.Context, cids []blobcache.CID, dst []bool) error
}

type Factory = func(blobcache.SchemaSpec) (Schema, error)

type Initializer interface {
	Init(ctx context.Context, s bcsdk.WO) ([]byte, error)
}

type KV[K, V any] interface {
	Put(ctx context.Context, s bcsdk.RW, root []byte, key K, value V) ([]byte, error)
	Get(ctx context.Context, s bcsdk.RO, root []byte, key K, dst *V) (bool, error)
	Delete(ctx context.Context, s bcsdk.RW, root []byte, key K) ([]byte, error)
}

type Link struct {
	// Target is the OID of the volume being referenced.
	Target blobcache.OID
	// Rights are the set of actions on the target, which are granted to the caller.
	Rights blobcache.ActionSet
}

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

type NSClient struct {
	Service blobcache.Service
	Schema  Namespace
}

type NSEntry struct {
	// Name is the key for this entry within the namespace.
	Name string `json:"name"`
	// Target is the OID of the entry.
	Target blobcache.OID `json:"target"`
	// Rights is the set of rights for the entry.
	Rights blobcache.ActionSet `json:"rights"`
}

type Namespace interface {
	NSList(ctx context.Context, s bcsdk.RO, root []byte) ([]NSEntry, error)
	// NSGet retrieves the entry at the given name.
	// If the entry exists, it is returned in dst and true is returned.
	// If the entry does not exist, dst is not modified and false is returned.
	NSGet(ctx context.Context, s bcsdk.RO, root []byte, name string, dst *NSEntry) (bool, error)
	// Delete deletes the entry at the given name.
	// Delete is idempotent, and does not fail if the entry does not exist.
	NSDelete(ctx context.Context, s bcsdk.RW, root []byte, name string) ([]byte, error)
	// Put performs an idempotent create or replace operation.
	NSPut(ctx context.Context, s bcsdk.RW, root []byte, ent NSEntry) ([]byte, error)
}

type None struct{}

type Opener interface {
	Schema

	OpenAs(ctx context.Context, s bcsdk.RO, root []byte, peer blobcache.PeerID) (blobcache.ActionSet, error)
}

type RO = bcsdk.RO

type RW = bcsdk.RW

type Schema interface {
	// ValidateChange returns nil if the state transition is valid.
	ValidateChange(ctx context.Context, change Change) error
}

type Spec = blobcache.SchemaSpec

type Syncer interface {
	// Sync ensures that all data transitively reachable from rootData
	// has been copied from rs to ws.
	Sync(ctx context.Context, rs bcsdk.RO, ws bcsdk.WO, rootData []byte) error
}

type Value struct {
	Cell  []byte
	Store bcsdk.RO
}

type VisitAll interface {
	VisitAll(ctx context.Context, s bcsdk.RO, root []byte, visit func(cids []blobcache.CID, links []blobcache.OID) error) error
}

type WO = bcsdk.WO