protodb

type Committer interface {
	Commit(ctx context.Context) error
	Close()
}

type DB interface {
	Registerer
	Resolverer
	Reader
	Writer
	Watcher
	TxProvider
	Leader
	io.Closer
}

type Event interface {
	Type() EventType
	Old() proto.Message
	New() proto.Message
	Err() error
}

type EventType = pb.WatchEventType

type Filter = filters.FieldFilterer

type FilterExpr = filters.Expression

type GetOption func(o *GetOpts)

type GetOpts struct {
	Paging    *Paging
	Filter    Filter
	FieldMask *fieldmaskpb.FieldMask
	Reverse   bool
}

type Leader interface {
	IsLeader() bool
	Leader() string
	LeaderChanges() <-chan string
}

type Logger interface {
	Errorf(string, ...interface{})
	Warningf(string, ...interface{})
	Infof(string, ...interface{})
	Debugf(string, ...interface{})
	Tracef(string, ...interface{})
}

type Paging = pb.Paging

type PagingInfo = pb.PagingInfo

type Reader interface {
	Get(ctx context.Context, m proto.Message, opts ...GetOption) ([]proto.Message, *PagingInfo, error)
}

type Registerer interface {
	RegisterProto(ctx context.Context, file *descriptorpb.FileDescriptorProto) error
	Register(ctx context.Context, file protoreflect.FileDescriptor) error
	Descriptors(ctx context.Context) ([]*descriptorpb.DescriptorProto, error)
	FileDescriptors(ctx context.Context) ([]*descriptorpb.FileDescriptorProto, error)
}

type Resolverer interface {
	Resolver() protodesc.Resolver
}

type SetOption func(o *SetOpts)

type SetOpts struct {
	TTL       time.Duration
	FieldMask *fieldmaskpb.FieldMask
}

type Tx interface {
	Reader
	Writer
	Committer
}

type TxOption func(o *TxOpts)

type TxOpts struct {
	ReadOnly bool
}

type TxProvider interface {
	Tx(ctx context.Context, opts ...TxOption) (Tx, error)
}

type Watcher interface {
	Watch(ctx context.Context, m proto.Message, opts ...GetOption) (<-chan Event, error)
}

type Writer interface {
	Set(ctx context.Context, m proto.Message, opts ...SetOption) (proto.Message, error)
	Delete(ctx context.Context, m proto.Message) error
}