Versions in this module Expand all Collapse all v0 v0.0.5 May 27, 2021 v0.0.4 May 26, 2021 v0.0.2 May 24, 2021 v0.0.1 May 27, 2021 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedBatch(r randyDefs, easy bool) *Batch + func (*Batch) Descriptor() ([]byte, []int) + func (*Batch) ProtoMessage() + func (m *Batch) GetOps() []*Operation + func (m *Batch) Reset() + func (m *Batch) String() string + func (m *Batch) XXX_DiscardUnknown() + func (m *Batch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Batch) XXX_Merge(src proto.Message) + func (m *Batch) XXX_Size() int + func (m *Batch) XXX_Unmarshal(b []byte) error + func (this *Batch) Equal(that interface{}) bool + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedDomain(r randyDefs, easy bool) *Domain + 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 + func (m *Domain) XXX_DiscardUnknown() + func (m *Domain) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Domain) XXX_Merge(src proto.Message) + func (m *Domain) XXX_Size() int + func (m *Domain) XXX_Unmarshal(b []byte) error + func (this *Domain) Equal(that interface{}) bool + type Entity struct + CreatedAt int64 + End []byte + Err string + Exists bool + Id int32 + Key []byte + Start []byte + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedEntity(r randyDefs, easy bool) *Entity + 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 + func (m *Entity) XXX_DiscardUnknown() + func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Entity) XXX_Merge(src proto.Message) + func (m *Entity) XXX_Size() int + func (m *Entity) XXX_Unmarshal(b []byte) error + func (this *Entity) Equal(that interface{}) bool + type Init struct + Dir string + Name string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedInit(r randyDefs, easy bool) *Init + 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 + func (m *Init) XXX_DiscardUnknown() + func (m *Init) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Init) XXX_Merge(src proto.Message) + func (m *Init) XXX_Size() int + func (m *Init) XXX_Unmarshal(b []byte) error + func (this *Init) Equal(that interface{}) bool + type Iterator struct + Domain *Domain + Key []byte + Valid bool + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedIterator(r randyDefs, easy bool) *Iterator + 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 + func (m *Iterator) XXX_DiscardUnknown() + func (m *Iterator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Iterator) XXX_Merge(src proto.Message) + func (m *Iterator) XXX_Size() int + func (m *Iterator) XXX_Unmarshal(b []byte) error + func (this *Iterator) Equal(that interface{}) bool + type Nothing struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedNothing(r randyDefs, easy bool) *Nothing + func (*Nothing) Descriptor() ([]byte, []int) + func (*Nothing) ProtoMessage() + func (m *Nothing) Reset() + func (m *Nothing) String() string + func (m *Nothing) XXX_DiscardUnknown() + func (m *Nothing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Nothing) XXX_Merge(src proto.Message) + func (m *Nothing) XXX_Size() int + func (m *Nothing) XXX_Unmarshal(b []byte) error + func (this *Nothing) Equal(that interface{}) bool + type Operation struct + Entity *Entity + Type Operation_Type + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedOperation(r randyDefs, easy bool) *Operation + 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 + func (m *Operation) XXX_DiscardUnknown() + func (m *Operation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Operation) XXX_Merge(src proto.Message) + func (m *Operation) XXX_Size() int + func (m *Operation) XXX_Unmarshal(b []byte) error + func (this *Operation) Equal(that interface{}) bool + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedStats(r randyDefs, easy bool) *Stats + 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 + func (m *Stats) XXX_DiscardUnknown() + func (m *Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Stats) XXX_Merge(src proto.Message) + func (m *Stats) XXX_Size() int + func (m *Stats) XXX_Unmarshal(b []byte) error + func (this *Stats) Equal(that interface{}) bool + type UnimplementedDBServer struct + func (*UnimplementedDBServer) BatchWrite(ctx context.Context, req *Batch) (*Nothing, error) + func (*UnimplementedDBServer) BatchWriteSync(ctx context.Context, req *Batch) (*Nothing, error) + func (*UnimplementedDBServer) Delete(ctx context.Context, req *Entity) (*Nothing, error) + func (*UnimplementedDBServer) DeleteSync(ctx context.Context, req *Entity) (*Nothing, error) + func (*UnimplementedDBServer) Get(ctx context.Context, req *Entity) (*Entity, error) + func (*UnimplementedDBServer) GetStream(srv DB_GetStreamServer) error + func (*UnimplementedDBServer) Has(ctx context.Context, req *Entity) (*Entity, error) + func (*UnimplementedDBServer) Init(ctx context.Context, req *Init) (*Entity, error) + func (*UnimplementedDBServer) Iterator(req *Entity, srv DB_IteratorServer) error + func (*UnimplementedDBServer) ReverseIterator(req *Entity, srv DB_ReverseIteratorServer) error + func (*UnimplementedDBServer) Set(ctx context.Context, req *Entity) (*Nothing, error) + func (*UnimplementedDBServer) SetSync(ctx context.Context, req *Entity) (*Nothing, error) + func (*UnimplementedDBServer) Stats(ctx context.Context, req *Nothing) (*Stats, error)
Go to main page