Versions in this module Expand all Collapse all v0 v0.1.0 May 23, 2022 v0.0.4 Aug 4, 2021 Changes in this version + var ErrCode_name = map[int32]string + var ErrCode_value = map[string]int32 + var File_store_proto protoreflect.FileDescriptor + var KVStore_ServiceDesc = grpc.ServiceDesc + func RegisterKVStoreServer(s grpc.ServiceRegistrar, srv KVStoreServer) + type CommonReply struct + Code ErrCode + Msg string + Size int64 + Success bool + Value []byte + func (*CommonReply) Descriptor() ([]byte, []int) + func (*CommonReply) ProtoMessage() + func (x *CommonReply) GetCode() ErrCode + func (x *CommonReply) GetMsg() string + func (x *CommonReply) GetSize() int64 + func (x *CommonReply) GetSuccess() bool + func (x *CommonReply) GetValue() []byte + func (x *CommonReply) ProtoReflect() protoreflect.Message + func (x *CommonReply) Reset() + func (x *CommonReply) String() string + type CommonRequest struct + Key string + Value []byte + func (*CommonRequest) Descriptor() ([]byte, []int) + func (*CommonRequest) ProtoMessage() + func (x *CommonRequest) GetKey() string + func (x *CommonRequest) GetValue() []byte + func (x *CommonRequest) ProtoReflect() protoreflect.Message + func (x *CommonRequest) Reset() + func (x *CommonRequest) String() string + type DataStore struct + func NewDataStore(client KVStoreClient) (*DataStore, error) + func (d *DataStore) Batch() (ds.Batch, error) + func (d *DataStore) Close() error + func (d *DataStore) Delete(k ds.Key) error + func (d *DataStore) Get(k ds.Key) ([]byte, error) + func (d *DataStore) GetSize(k ds.Key) (int, error) + func (d *DataStore) Has(k ds.Key) (bool, error) + func (d *DataStore) Put(k ds.Key, value []byte) error + func (d *DataStore) Query(q dsq.Query) (dsq.Results, error) + func (d *DataStore) Sync(ds.Key) error + type ErrCode int32 + const ErrCode_ErrNotFound + const ErrCode_None + const ErrCode_Others + func (ErrCode) Descriptor() protoreflect.EnumDescriptor + func (ErrCode) EnumDescriptor() ([]byte, []int) + func (ErrCode) Type() protoreflect.EnumType + func (x ErrCode) Enum() *ErrCode + func (x ErrCode) Number() protoreflect.EnumNumber + func (x ErrCode) String() string + type KVStoreClient interface + Delete func(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error) + Get func(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error) + GetSize func(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error) + Has func(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error) + Put func(ctx context.Context, in *CommonRequest, opts ...grpc.CallOption) (*CommonReply, error) + Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (KVStore_QueryClient, error) + func NewKVStoreClient(cc grpc.ClientConnInterface) KVStoreClient + type KVStoreServer interface + Delete func(context.Context, *CommonRequest) (*CommonReply, error) + Get func(context.Context, *CommonRequest) (*CommonReply, error) + GetSize func(context.Context, *CommonRequest) (*CommonReply, error) + Has func(context.Context, *CommonRequest) (*CommonReply, error) + Put func(context.Context, *CommonRequest) (*CommonReply, error) + Query func(*QueryRequest, KVStore_QueryServer) error + type KVStore_QueryClient interface + Recv func() (*QueryReply, error) + type KVStore_QueryServer interface + Send func(*QueryReply) error + type QueryReply struct + Code ErrCode + Msg string + Res []byte + func (*QueryReply) Descriptor() ([]byte, []int) + func (*QueryReply) ProtoMessage() + func (x *QueryReply) GetCode() ErrCode + func (x *QueryReply) GetMsg() string + func (x *QueryReply) GetRes() []byte + func (x *QueryReply) ProtoReflect() protoreflect.Message + func (x *QueryReply) Reset() + func (x *QueryReply) String() string + type QueryRequest struct + Q []byte + func (*QueryRequest) Descriptor() ([]byte, []int) + func (*QueryRequest) ProtoMessage() + func (x *QueryRequest) GetQ() []byte + func (x *QueryRequest) ProtoReflect() protoreflect.Message + func (x *QueryRequest) Reset() + func (x *QueryRequest) String() string + type UnimplementedKVStoreServer struct + func (UnimplementedKVStoreServer) Delete(context.Context, *CommonRequest) (*CommonReply, error) + func (UnimplementedKVStoreServer) Get(context.Context, *CommonRequest) (*CommonReply, error) + func (UnimplementedKVStoreServer) GetSize(context.Context, *CommonRequest) (*CommonReply, error) + func (UnimplementedKVStoreServer) Has(context.Context, *CommonRequest) (*CommonReply, error) + func (UnimplementedKVStoreServer) Put(context.Context, *CommonRequest) (*CommonReply, error) + func (UnimplementedKVStoreServer) Query(*QueryRequest, KVStore_QueryServer) error + type UnsafeKVStoreServer interface v0.0.3 Aug 4, 2021 v0.0.2 Aug 4, 2021 v0.0.1 Aug 2, 2021
Go to main page