store

type Cache interface {
	CacheGet(Key, func(sb.Stream) error) error

	// CachePut must save tokens as encoded form
	CachePut(Key, sb.Tokens, ...CachePutOption) error
}

type CachePutOption interface {
	IsCachePutOption()
}

type Def struct{}

type EncodedLen int

type Hash = key.Hash

type ID string

type Key = key.Key

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

type NewMemCache func(
	maxKeys int,
	maxSize int,
) (*MemCache, error)

type Scrub func(
	ctx context.Context,
	store Store,
	options ...ScrubOption,
) error

type ScrubOption interface {
	IsScrubOption()
}

type Store interface {
	ID() (ID, error)
	Name() string

	Write(
		key.Namespace,
		sb.Stream,
		...WriteOption,
	) (
		WriteResult,
		error,
	)

	Read(
		Key,
		func(sb.Stream) error,
	) error

	Exists(
		Key,
	) (bool, error)

	IterKeys(
		key.Namespace,
		func(Key) error,
	) error

	IterAllKeys(
		fn func(Key) error,
	) error

	Delete(
		[]Key,
	) error
}

type TapWriteResult func(WriteResult)

type TestStore func(
	ctx context.Context,
	withStore func(
		fn func(Store),
		provides ...any,
	),
	t *testing.T,
)

type WriteOption interface {
	IsWriteOption()
}

type WriteResult struct {
	Key          Key
	Written      bool
	BytesWritten int64
}