typed

type Event[T any, PT message[T]] interface {
	Type() protodb.EventType
	Old() PT
	New() PT
	Err() error
}

type Reader[T any, PT message[T]] interface {
	Get(ctx context.Context, m PT, opts ...protodb.GetOption) ([]PT, *protodb.PagingInfo, error)
}

type Store[T any, PT message[T]] interface {
	Reader[T, PT]
	Writer[T, PT]
	Watcher[T, PT]
	TxProvider[T, PT]

	Register(ctx context.Context) error

	Raw() client.Client
}

type Tx[T any, PT message[T]] interface {
	protodb.Committer
	Reader[T, PT]
	Writer[T, PT]
	Raw() protodb.Tx
}

type TxProvider[T any, PT message[T]] interface {
	Tx(ctx context.Context) (Tx[T, PT], error)
}

type Watcher[T any, PT message[T]] interface {
	Watch(ctx context.Context, m PT, opts ...protodb.GetOption) (<-chan Event[T, PT], error)
}

type Writer[T any, PT message[T]] interface {
	Set(ctx context.Context, m PT, opts ...protodb.SetOption) (PT, error)
	Delete(ctx context.Context, m PT) error
}