Documentation ¶
Index ¶
- Constants
- Variables
- func DataPrefix(m proto.Message) (key []byte, field string, value string, err error)
- func DescriptorPrefix(d *descriptorpb.FileDescriptorProto) []byte
- func KeyFor(m proto.Message) (key string, field string, err error)
- func KeyFromOpts(m proto.Message) (key string, field string, ok bool)
- type Committer
- type DB
- type Event
- type EventType
- type Filter
- type FilterExpr
- type GetOption
- type GetOpts
- type Leader
- type Logger
- type Paging
- type PagingInfo
- type Reader
- type Registerer
- type Resolverer
- type SetOption
- type SetOpts
- type Tx
- type TxOption
- type TxOpts
- type TxProvider
- type Watcher
- type Writer
Constants ¶
View Source
const ( Data = "_data" Index = "_index" Descriptors = "_schema" Internal = "_internal" )
View Source
const ( EventTypeUnknown = pb.WatchEventUnknown EventTypeEnter = pb.WatchEventEnter EventTypeLeave = pb.WatchEventLeave EventTypeUpdate = pb.WatchEventUpdate )
Variables ¶
View Source
var ( ErrNotLeader = errors.New("current node is not leader") ErrNoLeaderConn = errors.New("no leader connection") )
Functions ¶
func DataPrefix ¶
func DescriptorPrefix ¶
func DescriptorPrefix(d *descriptorpb.FileDescriptorProto) []byte
Types ¶
type DB ¶
type DB interface { Registerer Resolverer Reader Writer Watcher TxProvider Leader io.Closer }
type EventType ¶
type EventType = pb.WatchEventType
type Filter ¶
type Filter = filters.FieldFilterer
type FilterExpr ¶
type FilterExpr = filters.Expression
type GetOption ¶
type GetOption func(o *GetOpts)
func WithFilter ¶
func WithPaging ¶
func WithReadFieldMask ¶
func WithReadFieldMask(fieldMask *fieldmaskpb.FieldMask) GetOption
func WithReadFieldMaskPaths ¶
func WithReverse ¶
func WithReverse() GetOption
type GetOpts ¶
type GetOpts struct { Paging *Paging Filter Filter FieldMask *fieldmaskpb.FieldMask Reverse bool }
type PagingInfo ¶
type PagingInfo = pb.PagingInfo
type Registerer ¶
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 ¶
type SetOption ¶
type SetOption func(o *SetOpts)
func WithWriteFieldMask ¶
func WithWriteFieldMask(fieldMask *fieldmaskpb.FieldMask) SetOption
func WithWriteFieldMaskPaths ¶
type TxProvider ¶
Click to show internal directories.
Click to hide internal directories.