Versions in this module Expand all Collapse all v0 v0.31.5 Apr 16, 2019 Changes in this version + var Operation_Type_name = map[int32]string + var Operation_Type_value = map[string]int32 + func RegisterDBServer(s *grpc.Server, srv DBServer) + type Batch struct + Ops []*Operation + func (*Batch) Descriptor() ([]byte, []int) + func (*Batch) ProtoMessage() + func (m *Batch) GetOps() []*Operation + func (m *Batch) Reset() + func (m *Batch) String() string + type DBClient interface + BatchWrite func(ctx context.Context, in *Batch, opts ...grpc.CallOption) (*Nothing, error) + BatchWriteSync func(ctx context.Context, in *Batch, opts ...grpc.CallOption) (*Nothing, error) + Delete func(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Nothing, error) + DeleteSync func(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Nothing, error) + Get func(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Entity, error) + GetStream func(ctx context.Context, opts ...grpc.CallOption) (DB_GetStreamClient, error) + Has func(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Entity, error) + Init func(ctx context.Context, in *Init, opts ...grpc.CallOption) (*Entity, error) + Iterator func(ctx context.Context, in *Entity, opts ...grpc.CallOption) (DB_IteratorClient, error) + ReverseIterator func(ctx context.Context, in *Entity, opts ...grpc.CallOption) (DB_ReverseIteratorClient, error) + Set func(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Nothing, error) + SetSync func(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Nothing, error) + Stats func(ctx context.Context, in *Nothing, opts ...grpc.CallOption) (*Stats, error) + func NewDBClient(cc *grpc.ClientConn) DBClient + type DBServer interface + BatchWrite func(context.Context, *Batch) (*Nothing, error) + BatchWriteSync func(context.Context, *Batch) (*Nothing, error) + Delete func(context.Context, *Entity) (*Nothing, error) + DeleteSync func(context.Context, *Entity) (*Nothing, error) + Get func(context.Context, *Entity) (*Entity, error) + GetStream func(DB_GetStreamServer) error + Has func(context.Context, *Entity) (*Entity, error) + Init func(context.Context, *Init) (*Entity, error) + Iterator func(*Entity, DB_IteratorServer) error + ReverseIterator func(*Entity, DB_ReverseIteratorServer) error + Set func(context.Context, *Entity) (*Nothing, error) + SetSync func(context.Context, *Entity) (*Nothing, error) + Stats func(context.Context, *Nothing) (*Stats, error) + type DB_GetStreamClient interface + Recv func() (*Entity, error) + Send func(*Entity) error + type DB_GetStreamServer interface + Recv func() (*Entity, error) + Send func(*Entity) error + type DB_IteratorClient interface + Recv func() (*Iterator, error) + type DB_IteratorServer interface + Send func(*Iterator) error + type DB_ReverseIteratorClient interface + Recv func() (*Iterator, error) + type DB_ReverseIteratorServer interface + Send func(*Iterator) error + type Domain struct + End []byte + Start []byte + func (*Domain) Descriptor() ([]byte, []int) + func (*Domain) ProtoMessage() + func (m *Domain) GetEnd() []byte + func (m *Domain) GetStart() []byte + func (m *Domain) Reset() + func (m *Domain) String() string + type Entity struct + CreatedAt int64 + End []byte + Err string + Exists bool + Id int32 + Key []byte + Start []byte + Value []byte + func (*Entity) Descriptor() ([]byte, []int) + func (*Entity) ProtoMessage() + func (m *Entity) GetCreatedAt() int64 + func (m *Entity) GetEnd() []byte + func (m *Entity) GetErr() string + func (m *Entity) GetExists() bool + func (m *Entity) GetId() int32 + func (m *Entity) GetKey() []byte + func (m *Entity) GetStart() []byte + func (m *Entity) GetValue() []byte + func (m *Entity) Reset() + func (m *Entity) String() string + type Init struct + Dir string + Name string + Type string + func (*Init) Descriptor() ([]byte, []int) + func (*Init) ProtoMessage() + func (m *Init) GetDir() string + func (m *Init) GetName() string + func (m *Init) GetType() string + func (m *Init) Reset() + func (m *Init) String() string + type Iterator struct + Domain *Domain + Key []byte + Valid bool + Value []byte + func (*Iterator) Descriptor() ([]byte, []int) + func (*Iterator) ProtoMessage() + func (m *Iterator) GetDomain() *Domain + func (m *Iterator) GetKey() []byte + func (m *Iterator) GetValid() bool + func (m *Iterator) GetValue() []byte + func (m *Iterator) Reset() + func (m *Iterator) String() string + type Nothing struct + func (*Nothing) Descriptor() ([]byte, []int) + func (*Nothing) ProtoMessage() + func (m *Nothing) Reset() + func (m *Nothing) String() string + type Operation struct + Entity *Entity + Type Operation_Type + func (*Operation) Descriptor() ([]byte, []int) + func (*Operation) ProtoMessage() + func (m *Operation) GetEntity() *Entity + func (m *Operation) GetType() Operation_Type + func (m *Operation) Reset() + func (m *Operation) String() string + type Operation_Type int32 + const Operation_DELETE + const Operation_SET + func (Operation_Type) EnumDescriptor() ([]byte, []int) + func (x Operation_Type) String() string + type Stats struct + Data map[string]string + TimeAt int64 + func (*Stats) Descriptor() ([]byte, []int) + func (*Stats) ProtoMessage() + func (m *Stats) GetData() map[string]string + func (m *Stats) GetTimeAt() int64 + func (m *Stats) Reset() + func (m *Stats) String() string
Go to main page