Versions in this module Expand all Collapse all v1 v1.4.0 Mar 7, 2022 v1.3.0 Mar 7, 2022 Changes in this version + var File_pkg_sdb_protobuf_bitset_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_bloom_filter_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_data_type_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_geo_hash_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_hyper_log_log_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_index_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_list_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_log_entry_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_map_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_page_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_pub_sub_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_row_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_sdb_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_set_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_sorted_set_proto protoreflect.FileDescriptor + var File_pkg_sdb_protobuf_string_proto protoreflect.FileDescriptor v1.2.0 Mar 6, 2022 Changes in this version + var DataType_name = map[int32]string + var DataType_value = map[string]int32 + var File_pkg_protobuf_spec_bitset_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_bloom_filter_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_data_type_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_geo_hash_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_hyper_log_log_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_index_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_list_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_log_entry_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_map_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_page_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_pub_sub_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_row_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_sdb_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_set_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_sorted_set_proto protoreflect.FileDescriptor + var File_pkg_protobuf_spec_string_proto protoreflect.FileDescriptor + var SDB_ServiceDesc = grpc.ServiceDesc + func RegisterSDBHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterSDBHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SDBClient) error + func RegisterSDBHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterSDBHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SDBServer) error + func RegisterSDBServer(s grpc.ServiceRegistrar, srv SDBServer) + type BFAddRequest struct + Key []byte + Values [][]byte + func (*BFAddRequest) Descriptor() ([]byte, []int) + func (*BFAddRequest) ProtoMessage() + func (x *BFAddRequest) GetKey() []byte + func (x *BFAddRequest) GetValues() [][]byte + func (x *BFAddRequest) ProtoReflect() protoreflect.Message + func (x *BFAddRequest) Reset() + func (x *BFAddRequest) String() string + type BFAddResponse struct + Success bool + func (*BFAddResponse) Descriptor() ([]byte, []int) + func (*BFAddResponse) ProtoMessage() + func (x *BFAddResponse) GetSuccess() bool + func (x *BFAddResponse) ProtoReflect() protoreflect.Message + func (x *BFAddResponse) Reset() + func (x *BFAddResponse) String() string + type BFCreateRequest struct + Key []byte + N uint32 + P float64 + func (*BFCreateRequest) Descriptor() ([]byte, []int) + func (*BFCreateRequest) ProtoMessage() + func (x *BFCreateRequest) GetKey() []byte + func (x *BFCreateRequest) GetN() uint32 + func (x *BFCreateRequest) GetP() float64 + func (x *BFCreateRequest) ProtoReflect() protoreflect.Message + func (x *BFCreateRequest) Reset() + func (x *BFCreateRequest) String() string + type BFCreateResponse struct + Success bool + func (*BFCreateResponse) Descriptor() ([]byte, []int) + func (*BFCreateResponse) ProtoMessage() + func (x *BFCreateResponse) GetSuccess() bool + func (x *BFCreateResponse) ProtoReflect() protoreflect.Message + func (x *BFCreateResponse) Reset() + func (x *BFCreateResponse) String() string + type BFDelRequest struct + Key []byte + func (*BFDelRequest) Descriptor() ([]byte, []int) + func (*BFDelRequest) ProtoMessage() + func (x *BFDelRequest) GetKey() []byte + func (x *BFDelRequest) ProtoReflect() protoreflect.Message + func (x *BFDelRequest) Reset() + func (x *BFDelRequest) String() string + type BFDelResponse struct + Success bool + func (*BFDelResponse) Descriptor() ([]byte, []int) + func (*BFDelResponse) ProtoMessage() + func (x *BFDelResponse) GetSuccess() bool + func (x *BFDelResponse) ProtoReflect() protoreflect.Message + func (x *BFDelResponse) Reset() + func (x *BFDelResponse) String() string + type BFExistRequest struct + Key []byte + Values [][]byte + func (*BFExistRequest) Descriptor() ([]byte, []int) + func (*BFExistRequest) ProtoMessage() + func (x *BFExistRequest) GetKey() []byte + func (x *BFExistRequest) GetValues() [][]byte + func (x *BFExistRequest) ProtoReflect() protoreflect.Message + func (x *BFExistRequest) Reset() + func (x *BFExistRequest) String() string + type BFExistResponse struct + Exists []bool + func (*BFExistResponse) Descriptor() ([]byte, []int) + func (*BFExistResponse) ProtoMessage() + func (x *BFExistResponse) GetExists() []bool + func (x *BFExistResponse) ProtoReflect() protoreflect.Message + func (x *BFExistResponse) Reset() + func (x *BFExistResponse) String() string + type BSCountRangeRequest struct + End uint32 + Key []byte + Start uint32 + func (*BSCountRangeRequest) Descriptor() ([]byte, []int) + func (*BSCountRangeRequest) ProtoMessage() + func (x *BSCountRangeRequest) GetEnd() uint32 + func (x *BSCountRangeRequest) GetKey() []byte + func (x *BSCountRangeRequest) GetStart() uint32 + func (x *BSCountRangeRequest) ProtoReflect() protoreflect.Message + func (x *BSCountRangeRequest) Reset() + func (x *BSCountRangeRequest) String() string + type BSCountRangeResponse struct + Count uint32 + func (*BSCountRangeResponse) Descriptor() ([]byte, []int) + func (*BSCountRangeResponse) ProtoMessage() + func (x *BSCountRangeResponse) GetCount() uint32 + func (x *BSCountRangeResponse) ProtoReflect() protoreflect.Message + func (x *BSCountRangeResponse) Reset() + func (x *BSCountRangeResponse) String() string + type BSCountRequest struct + Key []byte + func (*BSCountRequest) Descriptor() ([]byte, []int) + func (*BSCountRequest) ProtoMessage() + func (x *BSCountRequest) GetKey() []byte + func (x *BSCountRequest) ProtoReflect() protoreflect.Message + func (x *BSCountRequest) Reset() + func (x *BSCountRequest) String() string + type BSCountResponse struct + Count uint32 + func (*BSCountResponse) Descriptor() ([]byte, []int) + func (*BSCountResponse) ProtoMessage() + func (x *BSCountResponse) GetCount() uint32 + func (x *BSCountResponse) ProtoReflect() protoreflect.Message + func (x *BSCountResponse) Reset() + func (x *BSCountResponse) String() string + type BSCreateRequest struct + Key []byte + Size uint32 + func (*BSCreateRequest) Descriptor() ([]byte, []int) + func (*BSCreateRequest) ProtoMessage() + func (x *BSCreateRequest) GetKey() []byte + func (x *BSCreateRequest) GetSize() uint32 + func (x *BSCreateRequest) ProtoReflect() protoreflect.Message + func (x *BSCreateRequest) Reset() + func (x *BSCreateRequest) String() string + type BSCreateResponse struct + Success bool + func (*BSCreateResponse) Descriptor() ([]byte, []int) + func (*BSCreateResponse) ProtoMessage() + func (x *BSCreateResponse) GetSuccess() bool + func (x *BSCreateResponse) ProtoReflect() protoreflect.Message + func (x *BSCreateResponse) Reset() + func (x *BSCreateResponse) String() string + type BSDelRequest struct + Key []byte + func (*BSDelRequest) Descriptor() ([]byte, []int) + func (*BSDelRequest) ProtoMessage() + func (x *BSDelRequest) GetKey() []byte + func (x *BSDelRequest) ProtoReflect() protoreflect.Message + func (x *BSDelRequest) Reset() + func (x *BSDelRequest) String() string + type BSDelResponse struct + Success bool + func (*BSDelResponse) Descriptor() ([]byte, []int) + func (*BSDelResponse) ProtoMessage() + func (x *BSDelResponse) GetSuccess() bool + func (x *BSDelResponse) ProtoReflect() protoreflect.Message + func (x *BSDelResponse) Reset() + func (x *BSDelResponse) String() string + type BSGetRangeRequest struct + End uint32 + Key []byte + Start uint32 + func (*BSGetRangeRequest) Descriptor() ([]byte, []int) + func (*BSGetRangeRequest) ProtoMessage() + func (x *BSGetRangeRequest) GetEnd() uint32 + func (x *BSGetRangeRequest) GetKey() []byte + func (x *BSGetRangeRequest) GetStart() uint32 + func (x *BSGetRangeRequest) ProtoReflect() protoreflect.Message + func (x *BSGetRangeRequest) Reset() + func (x *BSGetRangeRequest) String() string + type BSGetRangeResponse struct + Values []bool + func (*BSGetRangeResponse) Descriptor() ([]byte, []int) + func (*BSGetRangeResponse) ProtoMessage() + func (x *BSGetRangeResponse) GetValues() []bool + func (x *BSGetRangeResponse) ProtoReflect() protoreflect.Message + func (x *BSGetRangeResponse) Reset() + func (x *BSGetRangeResponse) String() string + type BSMGetRequest struct + Bits []uint32 + Key []byte + func (*BSMGetRequest) Descriptor() ([]byte, []int) + func (*BSMGetRequest) ProtoMessage() + func (x *BSMGetRequest) GetBits() []uint32 + func (x *BSMGetRequest) GetKey() []byte + func (x *BSMGetRequest) ProtoReflect() protoreflect.Message + func (x *BSMGetRequest) Reset() + func (x *BSMGetRequest) String() string + type BSMGetResponse struct + Values []bool + func (*BSMGetResponse) Descriptor() ([]byte, []int) + func (*BSMGetResponse) ProtoMessage() + func (x *BSMGetResponse) GetValues() []bool + func (x *BSMGetResponse) ProtoReflect() protoreflect.Message + func (x *BSMGetResponse) Reset() + func (x *BSMGetResponse) String() string + type BSMSetRequest struct + Bits []uint32 + Key []byte + Value bool + func (*BSMSetRequest) Descriptor() ([]byte, []int) + func (*BSMSetRequest) ProtoMessage() + func (x *BSMSetRequest) GetBits() []uint32 + func (x *BSMSetRequest) GetKey() []byte + func (x *BSMSetRequest) GetValue() bool + func (x *BSMSetRequest) ProtoReflect() protoreflect.Message + func (x *BSMSetRequest) Reset() + func (x *BSMSetRequest) String() string + type BSMSetResponse struct + Success bool + func (*BSMSetResponse) Descriptor() ([]byte, []int) + func (*BSMSetResponse) ProtoMessage() + func (x *BSMSetResponse) GetSuccess() bool + func (x *BSMSetResponse) ProtoReflect() protoreflect.Message + func (x *BSMSetResponse) Reset() + func (x *BSMSetResponse) String() string + type BSSetRangeRequest struct + End uint32 + Key []byte + Start uint32 + Value bool + func (*BSSetRangeRequest) Descriptor() ([]byte, []int) + func (*BSSetRangeRequest) ProtoMessage() + func (x *BSSetRangeRequest) GetEnd() uint32 + func (x *BSSetRangeRequest) GetKey() []byte + func (x *BSSetRangeRequest) GetStart() uint32 + func (x *BSSetRangeRequest) GetValue() bool + func (x *BSSetRangeRequest) ProtoReflect() protoreflect.Message + func (x *BSSetRangeRequest) Reset() + func (x *BSSetRangeRequest) String() string + type BSSetRangeResponse struct + Success bool + func (*BSSetRangeResponse) Descriptor() ([]byte, []int) + func (*BSSetRangeResponse) ProtoMessage() + func (x *BSSetRangeResponse) GetSuccess() bool + func (x *BSSetRangeResponse) ProtoReflect() protoreflect.Message + func (x *BSSetRangeResponse) Reset() + func (x *BSSetRangeResponse) String() string + type DataType int32 + const DataType_BITSET + const DataType_BLOOM_FILTER + const DataType_GEO_HASH + const DataType_HYPER_LOG_LOG + const DataType_LIST + const DataType_MAP + const DataType_PAGE + const DataType_SET + const DataType_SORTED_SET + const DataType_STRING + func (DataType) Descriptor() protoreflect.EnumDescriptor + func (DataType) EnumDescriptor() ([]byte, []int) + func (DataType) Type() protoreflect.EnumType + func (x DataType) Enum() *DataType + func (x DataType) Number() protoreflect.EnumNumber + func (x DataType) String() string + type DelRequest struct + Key []byte + func (*DelRequest) Descriptor() ([]byte, []int) + func (*DelRequest) ProtoMessage() + func (x *DelRequest) GetKey() []byte + func (x *DelRequest) ProtoReflect() protoreflect.Message + func (x *DelRequest) Reset() + func (x *DelRequest) String() string + type DelResponse struct + Success bool + func (*DelResponse) Descriptor() ([]byte, []int) + func (*DelResponse) ProtoMessage() + func (x *DelResponse) GetSuccess() bool + func (x *DelResponse) ProtoReflect() protoreflect.Message + func (x *DelResponse) Reset() + func (x *DelResponse) String() string + type GHAddRequest struct + Key []byte + Points []*Point + func (*GHAddRequest) Descriptor() ([]byte, []int) + func (*GHAddRequest) ProtoMessage() + func (x *GHAddRequest) GetKey() []byte + func (x *GHAddRequest) GetPoints() []*Point + func (x *GHAddRequest) ProtoReflect() protoreflect.Message + func (x *GHAddRequest) Reset() + func (x *GHAddRequest) String() string + type GHAddResponse struct + Success bool + func (*GHAddResponse) Descriptor() ([]byte, []int) + func (*GHAddResponse) ProtoMessage() + func (x *GHAddResponse) GetSuccess() bool + func (x *GHAddResponse) ProtoReflect() protoreflect.Message + func (x *GHAddResponse) Reset() + func (x *GHAddResponse) String() string + type GHCountRequest struct + Key []byte + func (*GHCountRequest) Descriptor() ([]byte, []int) + func (*GHCountRequest) ProtoMessage() + func (x *GHCountRequest) GetKey() []byte + func (x *GHCountRequest) ProtoReflect() protoreflect.Message + func (x *GHCountRequest) Reset() + func (x *GHCountRequest) String() string + type GHCountResponse struct + Count uint32 + func (*GHCountResponse) Descriptor() ([]byte, []int) + func (*GHCountResponse) ProtoMessage() + func (x *GHCountResponse) GetCount() uint32 + func (x *GHCountResponse) ProtoReflect() protoreflect.Message + func (x *GHCountResponse) Reset() + func (x *GHCountResponse) String() string + type GHCreateRequest struct + Key []byte + Precision int32 + func (*GHCreateRequest) Descriptor() ([]byte, []int) + func (*GHCreateRequest) ProtoMessage() + func (x *GHCreateRequest) GetKey() []byte + func (x *GHCreateRequest) GetPrecision() int32 + func (x *GHCreateRequest) ProtoReflect() protoreflect.Message + func (x *GHCreateRequest) Reset() + func (x *GHCreateRequest) String() string + type GHCreateResponse struct + Success bool + func (*GHCreateResponse) Descriptor() ([]byte, []int) + func (*GHCreateResponse) ProtoMessage() + func (x *GHCreateResponse) GetSuccess() bool + func (x *GHCreateResponse) ProtoReflect() protoreflect.Message + func (x *GHCreateResponse) Reset() + func (x *GHCreateResponse) String() string + type GHDelRequest struct + Key []byte + func (*GHDelRequest) Descriptor() ([]byte, []int) + func (*GHDelRequest) ProtoMessage() + func (x *GHDelRequest) GetKey() []byte + func (x *GHDelRequest) ProtoReflect() protoreflect.Message + func (x *GHDelRequest) Reset() + func (x *GHDelRequest) String() string + type GHDelResponse struct + Success bool + func (*GHDelResponse) Descriptor() ([]byte, []int) + func (*GHDelResponse) ProtoMessage() + func (x *GHDelResponse) GetSuccess() bool + func (x *GHDelResponse) ProtoReflect() protoreflect.Message + func (x *GHDelResponse) Reset() + func (x *GHDelResponse) String() string + type GHGetBoxesRequest struct + Key []byte + Latitude float64 + Longitude float64 + func (*GHGetBoxesRequest) Descriptor() ([]byte, []int) + func (*GHGetBoxesRequest) ProtoMessage() + func (x *GHGetBoxesRequest) GetKey() []byte + func (x *GHGetBoxesRequest) GetLatitude() float64 + func (x *GHGetBoxesRequest) GetLongitude() float64 + func (x *GHGetBoxesRequest) ProtoReflect() protoreflect.Message + func (x *GHGetBoxesRequest) Reset() + func (x *GHGetBoxesRequest) String() string + type GHGetBoxesResponse struct + Points []*Point + func (*GHGetBoxesResponse) Descriptor() ([]byte, []int) + func (*GHGetBoxesResponse) ProtoMessage() + func (x *GHGetBoxesResponse) GetPoints() []*Point + func (x *GHGetBoxesResponse) ProtoReflect() protoreflect.Message + func (x *GHGetBoxesResponse) Reset() + func (x *GHGetBoxesResponse) String() string + type GHGetNeighborsRequest struct + Key []byte + Latitude float64 + Longitude float64 + func (*GHGetNeighborsRequest) Descriptor() ([]byte, []int) + func (*GHGetNeighborsRequest) ProtoMessage() + func (x *GHGetNeighborsRequest) GetKey() []byte + func (x *GHGetNeighborsRequest) GetLatitude() float64 + func (x *GHGetNeighborsRequest) GetLongitude() float64 + func (x *GHGetNeighborsRequest) ProtoReflect() protoreflect.Message + func (x *GHGetNeighborsRequest) Reset() + func (x *GHGetNeighborsRequest) String() string + type GHGetNeighborsResponse struct + Points []*Point + func (*GHGetNeighborsResponse) Descriptor() ([]byte, []int) + func (*GHGetNeighborsResponse) ProtoMessage() + func (x *GHGetNeighborsResponse) GetPoints() []*Point + func (x *GHGetNeighborsResponse) ProtoReflect() protoreflect.Message + func (x *GHGetNeighborsResponse) Reset() + func (x *GHGetNeighborsResponse) String() string + type GHMembersRequest struct + Key []byte + func (*GHMembersRequest) Descriptor() ([]byte, []int) + func (*GHMembersRequest) ProtoMessage() + func (x *GHMembersRequest) GetKey() []byte + func (x *GHMembersRequest) ProtoReflect() protoreflect.Message + func (x *GHMembersRequest) Reset() + func (x *GHMembersRequest) String() string + type GHMembersResponse struct + Points []*Point + func (*GHMembersResponse) Descriptor() ([]byte, []int) + func (*GHMembersResponse) ProtoMessage() + func (x *GHMembersResponse) GetPoints() []*Point + func (x *GHMembersResponse) ProtoReflect() protoreflect.Message + func (x *GHMembersResponse) Reset() + func (x *GHMembersResponse) String() string + type GHPopRequest struct + Ids [][]byte + Key []byte + func (*GHPopRequest) Descriptor() ([]byte, []int) + func (*GHPopRequest) ProtoMessage() + func (x *GHPopRequest) GetIds() [][]byte + func (x *GHPopRequest) GetKey() []byte + func (x *GHPopRequest) ProtoReflect() protoreflect.Message + func (x *GHPopRequest) Reset() + func (x *GHPopRequest) String() string + type GHPopResponse struct + Success bool + func (*GHPopResponse) Descriptor() ([]byte, []int) + func (*GHPopResponse) ProtoMessage() + func (x *GHPopResponse) GetSuccess() bool + func (x *GHPopResponse) ProtoReflect() protoreflect.Message + func (x *GHPopResponse) Reset() + func (x *GHPopResponse) String() string + type GetRequest struct + Key []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (x *GetRequest) GetKey() []byte + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type GetResponse struct + Value []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (x *GetResponse) GetValue() []byte + func (x *GetResponse) ProtoReflect() protoreflect.Message + func (x *GetResponse) Reset() + func (x *GetResponse) String() string + type HLLAddRequest struct + Key []byte + Values [][]byte + func (*HLLAddRequest) Descriptor() ([]byte, []int) + func (*HLLAddRequest) ProtoMessage() + func (x *HLLAddRequest) GetKey() []byte + func (x *HLLAddRequest) GetValues() [][]byte + func (x *HLLAddRequest) ProtoReflect() protoreflect.Message + func (x *HLLAddRequest) Reset() + func (x *HLLAddRequest) String() string + type HLLAddResponse struct + Success bool + func (*HLLAddResponse) Descriptor() ([]byte, []int) + func (*HLLAddResponse) ProtoMessage() + func (x *HLLAddResponse) GetSuccess() bool + func (x *HLLAddResponse) ProtoReflect() protoreflect.Message + func (x *HLLAddResponse) Reset() + func (x *HLLAddResponse) String() string + type HLLCountRequest struct + Key []byte + func (*HLLCountRequest) Descriptor() ([]byte, []int) + func (*HLLCountRequest) ProtoMessage() + func (x *HLLCountRequest) GetKey() []byte + func (x *HLLCountRequest) ProtoReflect() protoreflect.Message + func (x *HLLCountRequest) Reset() + func (x *HLLCountRequest) String() string + type HLLCountResponse struct + Count uint32 + func (*HLLCountResponse) Descriptor() ([]byte, []int) + func (*HLLCountResponse) ProtoMessage() + func (x *HLLCountResponse) GetCount() uint32 + func (x *HLLCountResponse) ProtoReflect() protoreflect.Message + func (x *HLLCountResponse) Reset() + func (x *HLLCountResponse) String() string + type HLLCreateRequest struct + Key []byte + func (*HLLCreateRequest) Descriptor() ([]byte, []int) + func (*HLLCreateRequest) ProtoMessage() + func (x *HLLCreateRequest) GetKey() []byte + func (x *HLLCreateRequest) ProtoReflect() protoreflect.Message + func (x *HLLCreateRequest) Reset() + func (x *HLLCreateRequest) String() string + type HLLCreateResponse struct + Success bool + func (*HLLCreateResponse) Descriptor() ([]byte, []int) + func (*HLLCreateResponse) ProtoMessage() + func (x *HLLCreateResponse) GetSuccess() bool + func (x *HLLCreateResponse) ProtoReflect() protoreflect.Message + func (x *HLLCreateResponse) Reset() + func (x *HLLCreateResponse) String() string + type HLLDelRequest struct + Key []byte + func (*HLLDelRequest) Descriptor() ([]byte, []int) + func (*HLLDelRequest) ProtoMessage() + func (x *HLLDelRequest) GetKey() []byte + func (x *HLLDelRequest) ProtoReflect() protoreflect.Message + func (x *HLLDelRequest) Reset() + func (x *HLLDelRequest) String() string + type HLLDelResponse struct + Success bool + func (*HLLDelResponse) Descriptor() ([]byte, []int) + func (*HLLDelResponse) ProtoMessage() + func (x *HLLDelResponse) GetSuccess() bool + func (x *HLLDelResponse) ProtoReflect() protoreflect.Message + func (x *HLLDelResponse) Reset() + func (x *HLLDelResponse) String() string + type IncrRequest struct + Delta int32 + Key []byte + func (*IncrRequest) Descriptor() ([]byte, []int) + func (*IncrRequest) ProtoMessage() + func (x *IncrRequest) GetDelta() int32 + func (x *IncrRequest) GetKey() []byte + func (x *IncrRequest) ProtoReflect() protoreflect.Message + func (x *IncrRequest) Reset() + func (x *IncrRequest) String() string + type IncrResponse struct + Success bool + func (*IncrResponse) Descriptor() ([]byte, []int) + func (*IncrResponse) ProtoMessage() + func (x *IncrResponse) GetSuccess() bool + func (x *IncrResponse) ProtoReflect() protoreflect.Message + func (x *IncrResponse) Reset() + func (x *IncrResponse) String() string + type Index struct + Name []byte + Value []byte + func (*Index) Descriptor() ([]byte, []int) + func (*Index) ProtoMessage() + func (x *Index) GetName() []byte + func (x *Index) GetValue() []byte + func (x *Index) ProtoReflect() protoreflect.Message + func (x *Index) Reset() + func (x *Index) String() string + type LCountRequest struct + Key []byte + func (*LCountRequest) Descriptor() ([]byte, []int) + func (*LCountRequest) ProtoMessage() + func (x *LCountRequest) GetKey() []byte + func (x *LCountRequest) ProtoReflect() protoreflect.Message + func (x *LCountRequest) Reset() + func (x *LCountRequest) String() string + type LCountResponse struct + Count uint32 + func (*LCountResponse) Descriptor() ([]byte, []int) + func (*LCountResponse) ProtoMessage() + func (x *LCountResponse) GetCount() uint32 + func (x *LCountResponse) ProtoReflect() protoreflect.Message + func (x *LCountResponse) Reset() + func (x *LCountResponse) String() string + type LDelRequest struct + Key []byte + func (*LDelRequest) Descriptor() ([]byte, []int) + func (*LDelRequest) ProtoMessage() + func (x *LDelRequest) GetKey() []byte + func (x *LDelRequest) ProtoReflect() protoreflect.Message + func (x *LDelRequest) Reset() + func (x *LDelRequest) String() string + type LDelResponse struct + Success bool + func (*LDelResponse) Descriptor() ([]byte, []int) + func (*LDelResponse) ProtoMessage() + func (x *LDelResponse) GetSuccess() bool + func (x *LDelResponse) ProtoReflect() protoreflect.Message + func (x *LDelResponse) Reset() + func (x *LDelResponse) String() string + type LExistRequest struct + Key []byte + Values [][]byte + func (*LExistRequest) Descriptor() ([]byte, []int) + func (*LExistRequest) ProtoMessage() + func (x *LExistRequest) GetKey() []byte + func (x *LExistRequest) GetValues() [][]byte + func (x *LExistRequest) ProtoReflect() protoreflect.Message + func (x *LExistRequest) Reset() + func (x *LExistRequest) String() string + type LExistResponse struct + Exists []bool + func (*LExistResponse) Descriptor() ([]byte, []int) + func (*LExistResponse) ProtoMessage() + func (x *LExistResponse) GetExists() []bool + func (x *LExistResponse) ProtoReflect() protoreflect.Message + func (x *LExistResponse) Reset() + func (x *LExistResponse) String() string + type LLPushRequest struct + Key []byte + Values [][]byte + func (*LLPushRequest) Descriptor() ([]byte, []int) + func (*LLPushRequest) ProtoMessage() + func (x *LLPushRequest) GetKey() []byte + func (x *LLPushRequest) GetValues() [][]byte + func (x *LLPushRequest) ProtoReflect() protoreflect.Message + func (x *LLPushRequest) Reset() + func (x *LLPushRequest) String() string + type LLPushResponse struct + Success bool + func (*LLPushResponse) Descriptor() ([]byte, []int) + func (*LLPushResponse) ProtoMessage() + func (x *LLPushResponse) GetSuccess() bool + func (x *LLPushResponse) ProtoReflect() protoreflect.Message + func (x *LLPushResponse) Reset() + func (x *LLPushResponse) String() string + type LMembersRequest struct + Key []byte + func (*LMembersRequest) Descriptor() ([]byte, []int) + func (*LMembersRequest) ProtoMessage() + func (x *LMembersRequest) GetKey() []byte + func (x *LMembersRequest) ProtoReflect() protoreflect.Message + func (x *LMembersRequest) Reset() + func (x *LMembersRequest) String() string + type LMembersResponse struct + Values [][]byte + func (*LMembersResponse) Descriptor() ([]byte, []int) + func (*LMembersResponse) ProtoMessage() + func (x *LMembersResponse) GetValues() [][]byte + func (x *LMembersResponse) ProtoReflect() protoreflect.Message + func (x *LMembersResponse) Reset() + func (x *LMembersResponse) String() string + type LPopRequest struct + Key []byte + Values [][]byte + func (*LPopRequest) Descriptor() ([]byte, []int) + func (*LPopRequest) ProtoMessage() + func (x *LPopRequest) GetKey() []byte + func (x *LPopRequest) GetValues() [][]byte + func (x *LPopRequest) ProtoReflect() protoreflect.Message + func (x *LPopRequest) Reset() + func (x *LPopRequest) String() string + type LPopResponse struct + Success bool + func (*LPopResponse) Descriptor() ([]byte, []int) + func (*LPopResponse) ProtoMessage() + func (x *LPopResponse) GetSuccess() bool + func (x *LPopResponse) ProtoReflect() protoreflect.Message + func (x *LPopResponse) Reset() + func (x *LPopResponse) String() string + type LRPushRequest struct + Key []byte + Values [][]byte + func (*LRPushRequest) Descriptor() ([]byte, []int) + func (*LRPushRequest) ProtoMessage() + func (x *LRPushRequest) GetKey() []byte + func (x *LRPushRequest) GetValues() [][]byte + func (x *LRPushRequest) ProtoReflect() protoreflect.Message + func (x *LRPushRequest) Reset() + func (x *LRPushRequest) String() string + type LRPushResponse struct + Success bool + func (*LRPushResponse) Descriptor() ([]byte, []int) + func (*LRPushResponse) ProtoMessage() + func (x *LRPushResponse) GetSuccess() bool + func (x *LRPushResponse) ProtoReflect() protoreflect.Message + func (x *LRPushResponse) Reset() + func (x *LRPushResponse) String() string + type LRangeRequest struct + Key []byte + Limit uint32 + Offset int32 + func (*LRangeRequest) Descriptor() ([]byte, []int) + func (*LRangeRequest) ProtoMessage() + func (x *LRangeRequest) GetKey() []byte + func (x *LRangeRequest) GetLimit() uint32 + func (x *LRangeRequest) GetOffset() int32 + func (x *LRangeRequest) ProtoReflect() protoreflect.Message + func (x *LRangeRequest) Reset() + func (x *LRangeRequest) String() string + type LRangeResponse struct + Values [][]byte + func (*LRangeResponse) Descriptor() ([]byte, []int) + func (*LRangeResponse) ProtoMessage() + func (x *LRangeResponse) GetValues() [][]byte + func (x *LRangeResponse) ProtoReflect() protoreflect.Message + func (x *LRangeResponse) Reset() + func (x *LRangeResponse) String() string + type LogEntry struct + MethodName string + RequestBytes []byte + func (*LogEntry) Descriptor() ([]byte, []int) + func (*LogEntry) ProtoMessage() + func (x *LogEntry) GetMethodName() string + func (x *LogEntry) GetRequestBytes() []byte + func (x *LogEntry) ProtoReflect() protoreflect.Message + func (x *LogEntry) Reset() + func (x *LogEntry) String() string + type MCountRequest struct + Key []byte + func (*MCountRequest) Descriptor() ([]byte, []int) + func (*MCountRequest) ProtoMessage() + func (x *MCountRequest) GetKey() []byte + func (x *MCountRequest) ProtoReflect() protoreflect.Message + func (x *MCountRequest) Reset() + func (x *MCountRequest) String() string + type MCountResponse struct + Count uint32 + func (*MCountResponse) Descriptor() ([]byte, []int) + func (*MCountResponse) ProtoMessage() + func (x *MCountResponse) GetCount() uint32 + func (x *MCountResponse) ProtoReflect() protoreflect.Message + func (x *MCountResponse) Reset() + func (x *MCountResponse) String() string + type MDelRequest struct + Key []byte + func (*MDelRequest) Descriptor() ([]byte, []int) + func (*MDelRequest) ProtoMessage() + func (x *MDelRequest) GetKey() []byte + func (x *MDelRequest) ProtoReflect() protoreflect.Message + func (x *MDelRequest) Reset() + func (x *MDelRequest) String() string + type MDelResponse struct + Success bool + func (*MDelResponse) Descriptor() ([]byte, []int) + func (*MDelResponse) ProtoMessage() + func (x *MDelResponse) GetSuccess() bool + func (x *MDelResponse) ProtoReflect() protoreflect.Message + func (x *MDelResponse) Reset() + func (x *MDelResponse) String() string + type MExistRequest struct + Key []byte + Keys [][]byte + func (*MExistRequest) Descriptor() ([]byte, []int) + func (*MExistRequest) ProtoMessage() + func (x *MExistRequest) GetKey() []byte + func (x *MExistRequest) GetKeys() [][]byte + func (x *MExistRequest) ProtoReflect() protoreflect.Message + func (x *MExistRequest) Reset() + func (x *MExistRequest) String() string + type MExistResponse struct + Exists []bool + func (*MExistResponse) Descriptor() ([]byte, []int) + func (*MExistResponse) ProtoMessage() + func (x *MExistResponse) GetExists() []bool + func (x *MExistResponse) ProtoReflect() protoreflect.Message + func (x *MExistResponse) Reset() + func (x *MExistResponse) String() string + type MGetRequest struct + Keys [][]byte + func (*MGetRequest) Descriptor() ([]byte, []int) + func (*MGetRequest) ProtoMessage() + func (x *MGetRequest) GetKeys() [][]byte + func (x *MGetRequest) ProtoReflect() protoreflect.Message + func (x *MGetRequest) Reset() + func (x *MGetRequest) String() string + type MGetResponse struct + Values [][]byte + func (*MGetResponse) Descriptor() ([]byte, []int) + func (*MGetResponse) ProtoMessage() + func (x *MGetResponse) GetValues() [][]byte + func (x *MGetResponse) ProtoReflect() protoreflect.Message + func (x *MGetResponse) Reset() + func (x *MGetResponse) String() string + type MMembersRequest struct + Key []byte + func (*MMembersRequest) Descriptor() ([]byte, []int) + func (*MMembersRequest) ProtoMessage() + func (x *MMembersRequest) GetKey() []byte + func (x *MMembersRequest) ProtoReflect() protoreflect.Message + func (x *MMembersRequest) Reset() + func (x *MMembersRequest) String() string + type MMembersResponse struct + Pairs []*Pair + func (*MMembersResponse) Descriptor() ([]byte, []int) + func (*MMembersResponse) ProtoMessage() + func (x *MMembersResponse) GetPairs() []*Pair + func (x *MMembersResponse) ProtoReflect() protoreflect.Message + func (x *MMembersResponse) Reset() + func (x *MMembersResponse) String() string + type MPopRequest struct + Key []byte + Keys [][]byte + func (*MPopRequest) Descriptor() ([]byte, []int) + func (*MPopRequest) ProtoMessage() + func (x *MPopRequest) GetKey() []byte + func (x *MPopRequest) GetKeys() [][]byte + func (x *MPopRequest) ProtoReflect() protoreflect.Message + func (x *MPopRequest) Reset() + func (x *MPopRequest) String() string + type MPopResponse struct + Success bool + func (*MPopResponse) Descriptor() ([]byte, []int) + func (*MPopResponse) ProtoMessage() + func (x *MPopResponse) GetSuccess() bool + func (x *MPopResponse) ProtoReflect() protoreflect.Message + func (x *MPopResponse) Reset() + func (x *MPopResponse) String() string + type MPushRequest struct + Key []byte + Pairs []*Pair + func (*MPushRequest) Descriptor() ([]byte, []int) + func (*MPushRequest) ProtoMessage() + func (x *MPushRequest) GetKey() []byte + func (x *MPushRequest) GetPairs() []*Pair + func (x *MPushRequest) ProtoReflect() protoreflect.Message + func (x *MPushRequest) Reset() + func (x *MPushRequest) String() string + type MPushResponse struct + Success bool + func (*MPushResponse) Descriptor() ([]byte, []int) + func (*MPushResponse) ProtoMessage() + func (x *MPushResponse) GetSuccess() bool + func (x *MPushResponse) ProtoReflect() protoreflect.Message + func (x *MPushResponse) Reset() + func (x *MPushResponse) String() string + type MSetRequest struct + Keys [][]byte + Values [][]byte + func (*MSetRequest) Descriptor() ([]byte, []int) + func (*MSetRequest) ProtoMessage() + func (x *MSetRequest) GetKeys() [][]byte + func (x *MSetRequest) GetValues() [][]byte + func (x *MSetRequest) ProtoReflect() protoreflect.Message + func (x *MSetRequest) Reset() + func (x *MSetRequest) String() string + type MSetResponse struct + Success bool + func (*MSetResponse) Descriptor() ([]byte, []int) + func (*MSetResponse) ProtoMessage() + func (x *MSetResponse) GetSuccess() bool + func (x *MSetResponse) ProtoReflect() protoreflect.Message + func (x *MSetResponse) Reset() + func (x *MSetResponse) String() string + type Message struct + Payload []byte + Topic []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetPayload() []byte + func (x *Message) GetTopic() []byte + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type PListRequest struct + DataType DataType + Key []byte + Limit uint32 + Offset int32 + func (*PListRequest) Descriptor() ([]byte, []int) + func (*PListRequest) ProtoMessage() + func (x *PListRequest) GetDataType() DataType + func (x *PListRequest) GetKey() []byte + func (x *PListRequest) GetLimit() uint32 + func (x *PListRequest) GetOffset() int32 + func (x *PListRequest) ProtoReflect() protoreflect.Message + func (x *PListRequest) Reset() + func (x *PListRequest) String() string + type PListResponse struct + Keys [][]byte + func (*PListResponse) Descriptor() ([]byte, []int) + func (*PListResponse) ProtoMessage() + func (x *PListResponse) GetKeys() [][]byte + func (x *PListResponse) ProtoReflect() protoreflect.Message + func (x *PListResponse) Reset() + func (x *PListResponse) String() string + type Pair struct + Key []byte + Value []byte + func (*Pair) Descriptor() ([]byte, []int) + func (*Pair) ProtoMessage() + func (x *Pair) GetKey() []byte + func (x *Pair) GetValue() []byte + func (x *Pair) ProtoReflect() protoreflect.Message + func (x *Pair) Reset() + func (x *Pair) String() string + type Point struct + Distance uint64 + Id []byte + Latitude float64 + Longitude float64 + func (*Point) Descriptor() ([]byte, []int) + func (*Point) ProtoMessage() + func (x *Point) GetDistance() uint64 + func (x *Point) GetId() []byte + func (x *Point) GetLatitude() float64 + func (x *Point) GetLongitude() float64 + func (x *Point) ProtoReflect() protoreflect.Message + func (x *Point) Reset() + func (x *Point) String() string + type PublishRequest struct + Payload []byte + Topic []byte + func (*PublishRequest) Descriptor() ([]byte, []int) + func (*PublishRequest) ProtoMessage() + func (x *PublishRequest) GetPayload() []byte + func (x *PublishRequest) GetTopic() []byte + func (x *PublishRequest) ProtoReflect() protoreflect.Message + func (x *PublishRequest) Reset() + func (x *PublishRequest) String() string + type PublishResponse struct + Success bool + func (*PublishResponse) Descriptor() ([]byte, []int) + func (*PublishResponse) ProtoMessage() + func (x *PublishResponse) GetSuccess() bool + func (x *PublishResponse) ProtoReflect() protoreflect.Message + func (x *PublishResponse) Reset() + func (x *PublishResponse) String() string + type Row struct + DataType DataType + Id []byte + Indexes []*Index + Key []byte + Value []byte + func (*Row) Descriptor() ([]byte, []int) + func (*Row) ProtoMessage() + func (x *Row) GetDataType() DataType + func (x *Row) GetId() []byte + func (x *Row) GetIndexes() []*Index + func (x *Row) GetKey() []byte + func (x *Row) GetValue() []byte + func (x *Row) ProtoReflect() protoreflect.Message + func (x *Row) Reset() + func (x *Row) String() string + type SCountRequest struct + Key []byte + func (*SCountRequest) Descriptor() ([]byte, []int) + func (*SCountRequest) ProtoMessage() + func (x *SCountRequest) GetKey() []byte + func (x *SCountRequest) ProtoReflect() protoreflect.Message + func (x *SCountRequest) Reset() + func (x *SCountRequest) String() string + type SCountResponse struct + Count uint32 + func (*SCountResponse) Descriptor() ([]byte, []int) + func (*SCountResponse) ProtoMessage() + func (x *SCountResponse) GetCount() uint32 + func (x *SCountResponse) ProtoReflect() protoreflect.Message + func (x *SCountResponse) Reset() + func (x *SCountResponse) String() string + type SDBClient interface + BFAdd func(ctx context.Context, in *BFAddRequest, opts ...grpc.CallOption) (*BFAddResponse, error) + BFCreate func(ctx context.Context, in *BFCreateRequest, opts ...grpc.CallOption) (*BFCreateResponse, error) + BFDel func(ctx context.Context, in *BFDelRequest, opts ...grpc.CallOption) (*BFDelResponse, error) + BFExist func(ctx context.Context, in *BFExistRequest, opts ...grpc.CallOption) (*BFExistResponse, error) + BSCount func(ctx context.Context, in *BSCountRequest, opts ...grpc.CallOption) (*BSCountResponse, error) + BSCountRange func(ctx context.Context, in *BSCountRangeRequest, opts ...grpc.CallOption) (*BSCountRangeResponse, error) + BSCreate func(ctx context.Context, in *BSCreateRequest, opts ...grpc.CallOption) (*BSCreateResponse, error) + BSDel func(ctx context.Context, in *BSDelRequest, opts ...grpc.CallOption) (*BSDelResponse, error) + BSGetRange func(ctx context.Context, in *BSGetRangeRequest, opts ...grpc.CallOption) (*BSGetRangeResponse, error) + BSMGet func(ctx context.Context, in *BSMGetRequest, opts ...grpc.CallOption) (*BSMGetResponse, error) + BSMSet func(ctx context.Context, in *BSMSetRequest, opts ...grpc.CallOption) (*BSMSetResponse, error) + BSSetRange func(ctx context.Context, in *BSSetRangeRequest, opts ...grpc.CallOption) (*BSSetRangeResponse, error) + Del func(ctx context.Context, in *DelRequest, opts ...grpc.CallOption) (*DelResponse, error) + GHAdd func(ctx context.Context, in *GHAddRequest, opts ...grpc.CallOption) (*GHAddResponse, error) + GHCount func(ctx context.Context, in *GHCountRequest, opts ...grpc.CallOption) (*GHCountResponse, error) + GHCreate func(ctx context.Context, in *GHCreateRequest, opts ...grpc.CallOption) (*GHCreateResponse, error) + GHDel func(ctx context.Context, in *GHDelRequest, opts ...grpc.CallOption) (*GHDelResponse, error) + GHGetBoxes func(ctx context.Context, in *GHGetBoxesRequest, opts ...grpc.CallOption) (*GHGetBoxesResponse, error) + GHGetNeighbors func(ctx context.Context, in *GHGetNeighborsRequest, opts ...grpc.CallOption) (*GHGetNeighborsResponse, error) + GHMembers func(ctx context.Context, in *GHMembersRequest, opts ...grpc.CallOption) (*GHMembersResponse, error) + GHPop func(ctx context.Context, in *GHPopRequest, opts ...grpc.CallOption) (*GHPopResponse, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + HLLAdd func(ctx context.Context, in *HLLAddRequest, opts ...grpc.CallOption) (*HLLAddResponse, error) + HLLCount func(ctx context.Context, in *HLLCountRequest, opts ...grpc.CallOption) (*HLLCountResponse, error) + HLLCreate func(ctx context.Context, in *HLLCreateRequest, opts ...grpc.CallOption) (*HLLCreateResponse, error) + HLLDel func(ctx context.Context, in *HLLDelRequest, opts ...grpc.CallOption) (*HLLDelResponse, error) + Incr func(ctx context.Context, in *IncrRequest, opts ...grpc.CallOption) (*IncrResponse, error) + LCount func(ctx context.Context, in *LCountRequest, opts ...grpc.CallOption) (*LCountResponse, error) + LDel func(ctx context.Context, in *LDelRequest, opts ...grpc.CallOption) (*LDelResponse, error) + LExist func(ctx context.Context, in *LExistRequest, opts ...grpc.CallOption) (*LExistResponse, error) + LLPush func(ctx context.Context, in *LLPushRequest, opts ...grpc.CallOption) (*LLPushResponse, error) + LMembers func(ctx context.Context, in *LMembersRequest, opts ...grpc.CallOption) (*LMembersResponse, error) + LPop func(ctx context.Context, in *LPopRequest, opts ...grpc.CallOption) (*LPopResponse, error) + LRPush func(ctx context.Context, in *LRPushRequest, opts ...grpc.CallOption) (*LRPushResponse, error) + LRange func(ctx context.Context, in *LRangeRequest, opts ...grpc.CallOption) (*LRangeResponse, error) + MCount func(ctx context.Context, in *MCountRequest, opts ...grpc.CallOption) (*MCountResponse, error) + MDel func(ctx context.Context, in *MDelRequest, opts ...grpc.CallOption) (*MDelResponse, error) + MExist func(ctx context.Context, in *MExistRequest, opts ...grpc.CallOption) (*MExistResponse, error) + MGet func(ctx context.Context, in *MGetRequest, opts ...grpc.CallOption) (*MGetResponse, error) + MMembers func(ctx context.Context, in *MMembersRequest, opts ...grpc.CallOption) (*MMembersResponse, error) + MPop func(ctx context.Context, in *MPopRequest, opts ...grpc.CallOption) (*MPopResponse, error) + MPush func(ctx context.Context, in *MPushRequest, opts ...grpc.CallOption) (*MPushResponse, error) + MSet func(ctx context.Context, in *MSetRequest, opts ...grpc.CallOption) (*MSetResponse, error) + PList func(ctx context.Context, in *PListRequest, opts ...grpc.CallOption) (*PListResponse, error) + Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) + SCount func(ctx context.Context, in *SCountRequest, opts ...grpc.CallOption) (*SCountResponse, error) + SDel func(ctx context.Context, in *SDelRequest, opts ...grpc.CallOption) (*SDelResponse, error) + SExist func(ctx context.Context, in *SExistRequest, opts ...grpc.CallOption) (*SExistResponse, error) + SMembers func(ctx context.Context, in *SMembersRequest, opts ...grpc.CallOption) (*SMembersResponse, error) + SPop func(ctx context.Context, in *SPopRequest, opts ...grpc.CallOption) (*SPopResponse, error) + SPush func(ctx context.Context, in *SPushRequest, opts ...grpc.CallOption) (*SPushResponse, error) + Set func(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) + SetNX func(ctx context.Context, in *SetNXRequest, opts ...grpc.CallOption) (*SetNXResponse, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (SDB_SubscribeClient, error) + ZCount func(ctx context.Context, in *ZCountRequest, opts ...grpc.CallOption) (*ZCountResponse, error) + ZDel func(ctx context.Context, in *ZDelRequest, opts ...grpc.CallOption) (*ZDelResponse, error) + ZExist func(ctx context.Context, in *ZExistRequest, opts ...grpc.CallOption) (*ZExistResponse, error) + ZMembers func(ctx context.Context, in *ZMembersRequest, opts ...grpc.CallOption) (*ZMembersResponse, error) + ZPop func(ctx context.Context, in *ZPopRequest, opts ...grpc.CallOption) (*ZPopResponse, error) + ZPush func(ctx context.Context, in *ZPushRequest, opts ...grpc.CallOption) (*ZPushResponse, error) + ZRange func(ctx context.Context, in *ZRangeRequest, opts ...grpc.CallOption) (*ZRangeResponse, error) + func NewSDBClient(cc grpc.ClientConnInterface) SDBClient + type SDBServer interface + BFAdd func(context.Context, *BFAddRequest) (*BFAddResponse, error) + BFCreate func(context.Context, *BFCreateRequest) (*BFCreateResponse, error) + BFDel func(context.Context, *BFDelRequest) (*BFDelResponse, error) + BFExist func(context.Context, *BFExistRequest) (*BFExistResponse, error) + BSCount func(context.Context, *BSCountRequest) (*BSCountResponse, error) + BSCountRange func(context.Context, *BSCountRangeRequest) (*BSCountRangeResponse, error) + BSCreate func(context.Context, *BSCreateRequest) (*BSCreateResponse, error) + BSDel func(context.Context, *BSDelRequest) (*BSDelResponse, error) + BSGetRange func(context.Context, *BSGetRangeRequest) (*BSGetRangeResponse, error) + BSMGet func(context.Context, *BSMGetRequest) (*BSMGetResponse, error) + BSMSet func(context.Context, *BSMSetRequest) (*BSMSetResponse, error) + BSSetRange func(context.Context, *BSSetRangeRequest) (*BSSetRangeResponse, error) + Del func(context.Context, *DelRequest) (*DelResponse, error) + GHAdd func(context.Context, *GHAddRequest) (*GHAddResponse, error) + GHCount func(context.Context, *GHCountRequest) (*GHCountResponse, error) + GHCreate func(context.Context, *GHCreateRequest) (*GHCreateResponse, error) + GHDel func(context.Context, *GHDelRequest) (*GHDelResponse, error) + GHGetBoxes func(context.Context, *GHGetBoxesRequest) (*GHGetBoxesResponse, error) + GHGetNeighbors func(context.Context, *GHGetNeighborsRequest) (*GHGetNeighborsResponse, error) + GHMembers func(context.Context, *GHMembersRequest) (*GHMembersResponse, error) + GHPop func(context.Context, *GHPopRequest) (*GHPopResponse, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + HLLAdd func(context.Context, *HLLAddRequest) (*HLLAddResponse, error) + HLLCount func(context.Context, *HLLCountRequest) (*HLLCountResponse, error) + HLLCreate func(context.Context, *HLLCreateRequest) (*HLLCreateResponse, error) + HLLDel func(context.Context, *HLLDelRequest) (*HLLDelResponse, error) + Incr func(context.Context, *IncrRequest) (*IncrResponse, error) + LCount func(context.Context, *LCountRequest) (*LCountResponse, error) + LDel func(context.Context, *LDelRequest) (*LDelResponse, error) + LExist func(context.Context, *LExistRequest) (*LExistResponse, error) + LLPush func(context.Context, *LLPushRequest) (*LLPushResponse, error) + LMembers func(context.Context, *LMembersRequest) (*LMembersResponse, error) + LPop func(context.Context, *LPopRequest) (*LPopResponse, error) + LRPush func(context.Context, *LRPushRequest) (*LRPushResponse, error) + LRange func(context.Context, *LRangeRequest) (*LRangeResponse, error) + MCount func(context.Context, *MCountRequest) (*MCountResponse, error) + MDel func(context.Context, *MDelRequest) (*MDelResponse, error) + MExist func(context.Context, *MExistRequest) (*MExistResponse, error) + MGet func(context.Context, *MGetRequest) (*MGetResponse, error) + MMembers func(context.Context, *MMembersRequest) (*MMembersResponse, error) + MPop func(context.Context, *MPopRequest) (*MPopResponse, error) + MPush func(context.Context, *MPushRequest) (*MPushResponse, error) + MSet func(context.Context, *MSetRequest) (*MSetResponse, error) + PList func(context.Context, *PListRequest) (*PListResponse, error) + Publish func(context.Context, *PublishRequest) (*PublishResponse, error) + SCount func(context.Context, *SCountRequest) (*SCountResponse, error) + SDel func(context.Context, *SDelRequest) (*SDelResponse, error) + SExist func(context.Context, *SExistRequest) (*SExistResponse, error) + SMembers func(context.Context, *SMembersRequest) (*SMembersResponse, error) + SPop func(context.Context, *SPopRequest) (*SPopResponse, error) + SPush func(context.Context, *SPushRequest) (*SPushResponse, error) + Set func(context.Context, *SetRequest) (*SetResponse, error) + SetNX func(context.Context, *SetNXRequest) (*SetNXResponse, error) + Subscribe func(*SubscribeRequest, SDB_SubscribeServer) error + ZCount func(context.Context, *ZCountRequest) (*ZCountResponse, error) + ZDel func(context.Context, *ZDelRequest) (*ZDelResponse, error) + ZExist func(context.Context, *ZExistRequest) (*ZExistResponse, error) + ZMembers func(context.Context, *ZMembersRequest) (*ZMembersResponse, error) + ZPop func(context.Context, *ZPopRequest) (*ZPopResponse, error) + ZPush func(context.Context, *ZPushRequest) (*ZPushResponse, error) + ZRange func(context.Context, *ZRangeRequest) (*ZRangeResponse, error) + type SDB_SubscribeClient interface + Recv func() (*Message, error) + type SDB_SubscribeServer interface + Send func(*Message) error + type SDelRequest struct + Key []byte + func (*SDelRequest) Descriptor() ([]byte, []int) + func (*SDelRequest) ProtoMessage() + func (x *SDelRequest) GetKey() []byte + func (x *SDelRequest) ProtoReflect() protoreflect.Message + func (x *SDelRequest) Reset() + func (x *SDelRequest) String() string + type SDelResponse struct + Success bool + func (*SDelResponse) Descriptor() ([]byte, []int) + func (*SDelResponse) ProtoMessage() + func (x *SDelResponse) GetSuccess() bool + func (x *SDelResponse) ProtoReflect() protoreflect.Message + func (x *SDelResponse) Reset() + func (x *SDelResponse) String() string + type SExistRequest struct + Key []byte + Values [][]byte + func (*SExistRequest) Descriptor() ([]byte, []int) + func (*SExistRequest) ProtoMessage() + func (x *SExistRequest) GetKey() []byte + func (x *SExistRequest) GetValues() [][]byte + func (x *SExistRequest) ProtoReflect() protoreflect.Message + func (x *SExistRequest) Reset() + func (x *SExistRequest) String() string + type SExistResponse struct + Exists []bool + func (*SExistResponse) Descriptor() ([]byte, []int) + func (*SExistResponse) ProtoMessage() + func (x *SExistResponse) GetExists() []bool + func (x *SExistResponse) ProtoReflect() protoreflect.Message + func (x *SExistResponse) Reset() + func (x *SExistResponse) String() string + type SMembersRequest struct + Key []byte + func (*SMembersRequest) Descriptor() ([]byte, []int) + func (*SMembersRequest) ProtoMessage() + func (x *SMembersRequest) GetKey() []byte + func (x *SMembersRequest) ProtoReflect() protoreflect.Message + func (x *SMembersRequest) Reset() + func (x *SMembersRequest) String() string + type SMembersResponse struct + Values [][]byte + func (*SMembersResponse) Descriptor() ([]byte, []int) + func (*SMembersResponse) ProtoMessage() + func (x *SMembersResponse) GetValues() [][]byte + func (x *SMembersResponse) ProtoReflect() protoreflect.Message + func (x *SMembersResponse) Reset() + func (x *SMembersResponse) String() string + type SPopRequest struct + Key []byte + Values [][]byte + func (*SPopRequest) Descriptor() ([]byte, []int) + func (*SPopRequest) ProtoMessage() + func (x *SPopRequest) GetKey() []byte + func (x *SPopRequest) GetValues() [][]byte + func (x *SPopRequest) ProtoReflect() protoreflect.Message + func (x *SPopRequest) Reset() + func (x *SPopRequest) String() string + type SPopResponse struct + Success bool + func (*SPopResponse) Descriptor() ([]byte, []int) + func (*SPopResponse) ProtoMessage() + func (x *SPopResponse) GetSuccess() bool + func (x *SPopResponse) ProtoReflect() protoreflect.Message + func (x *SPopResponse) Reset() + func (x *SPopResponse) String() string + type SPushRequest struct + Key []byte + Values [][]byte + func (*SPushRequest) Descriptor() ([]byte, []int) + func (*SPushRequest) ProtoMessage() + func (x *SPushRequest) GetKey() []byte + func (x *SPushRequest) GetValues() [][]byte + func (x *SPushRequest) ProtoReflect() protoreflect.Message + func (x *SPushRequest) Reset() + func (x *SPushRequest) String() string + type SPushResponse struct + Success bool + func (*SPushResponse) Descriptor() ([]byte, []int) + func (*SPushResponse) ProtoMessage() + func (x *SPushResponse) GetSuccess() bool + func (x *SPushResponse) ProtoReflect() protoreflect.Message + func (x *SPushResponse) Reset() + func (x *SPushResponse) String() string + type SetNXRequest struct + Key []byte + Value []byte + func (*SetNXRequest) Descriptor() ([]byte, []int) + func (*SetNXRequest) ProtoMessage() + func (x *SetNXRequest) GetKey() []byte + func (x *SetNXRequest) GetValue() []byte + func (x *SetNXRequest) ProtoReflect() protoreflect.Message + func (x *SetNXRequest) Reset() + func (x *SetNXRequest) String() string + type SetNXResponse struct + Success bool + func (*SetNXResponse) Descriptor() ([]byte, []int) + func (*SetNXResponse) ProtoMessage() + func (x *SetNXResponse) GetSuccess() bool + func (x *SetNXResponse) ProtoReflect() protoreflect.Message + func (x *SetNXResponse) Reset() + func (x *SetNXResponse) String() string + type SetRequest struct + Key []byte + Value []byte + func (*SetRequest) Descriptor() ([]byte, []int) + func (*SetRequest) ProtoMessage() + func (x *SetRequest) GetKey() []byte + func (x *SetRequest) GetValue() []byte + func (x *SetRequest) ProtoReflect() protoreflect.Message + func (x *SetRequest) Reset() + func (x *SetRequest) String() string + type SetResponse struct + Success bool + func (*SetResponse) Descriptor() ([]byte, []int) + func (*SetResponse) ProtoMessage() + func (x *SetResponse) GetSuccess() bool + func (x *SetResponse) ProtoReflect() protoreflect.Message + func (x *SetResponse) Reset() + func (x *SetResponse) String() string + type SubscribeRequest struct + Topic []byte + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (x *SubscribeRequest) GetTopic() []byte + func (x *SubscribeRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRequest) Reset() + func (x *SubscribeRequest) String() string + type Tuple struct + Score float64 + Value []byte + func (*Tuple) Descriptor() ([]byte, []int) + func (*Tuple) ProtoMessage() + func (x *Tuple) GetScore() float64 + func (x *Tuple) GetValue() []byte + func (x *Tuple) ProtoReflect() protoreflect.Message + func (x *Tuple) Reset() + func (x *Tuple) String() string + type UnimplementedSDBServer struct + func (UnimplementedSDBServer) BFAdd(context.Context, *BFAddRequest) (*BFAddResponse, error) + func (UnimplementedSDBServer) BFCreate(context.Context, *BFCreateRequest) (*BFCreateResponse, error) + func (UnimplementedSDBServer) BFDel(context.Context, *BFDelRequest) (*BFDelResponse, error) + func (UnimplementedSDBServer) BFExist(context.Context, *BFExistRequest) (*BFExistResponse, error) + func (UnimplementedSDBServer) BSCount(context.Context, *BSCountRequest) (*BSCountResponse, error) + func (UnimplementedSDBServer) BSCountRange(context.Context, *BSCountRangeRequest) (*BSCountRangeResponse, error) + func (UnimplementedSDBServer) BSCreate(context.Context, *BSCreateRequest) (*BSCreateResponse, error) + func (UnimplementedSDBServer) BSDel(context.Context, *BSDelRequest) (*BSDelResponse, error) + func (UnimplementedSDBServer) BSGetRange(context.Context, *BSGetRangeRequest) (*BSGetRangeResponse, error) + func (UnimplementedSDBServer) BSMGet(context.Context, *BSMGetRequest) (*BSMGetResponse, error) + func (UnimplementedSDBServer) BSMSet(context.Context, *BSMSetRequest) (*BSMSetResponse, error) + func (UnimplementedSDBServer) BSSetRange(context.Context, *BSSetRangeRequest) (*BSSetRangeResponse, error) + func (UnimplementedSDBServer) Del(context.Context, *DelRequest) (*DelResponse, error) + func (UnimplementedSDBServer) GHAdd(context.Context, *GHAddRequest) (*GHAddResponse, error) + func (UnimplementedSDBServer) GHCount(context.Context, *GHCountRequest) (*GHCountResponse, error) + func (UnimplementedSDBServer) GHCreate(context.Context, *GHCreateRequest) (*GHCreateResponse, error) + func (UnimplementedSDBServer) GHDel(context.Context, *GHDelRequest) (*GHDelResponse, error) + func (UnimplementedSDBServer) GHGetBoxes(context.Context, *GHGetBoxesRequest) (*GHGetBoxesResponse, error) + func (UnimplementedSDBServer) GHGetNeighbors(context.Context, *GHGetNeighborsRequest) (*GHGetNeighborsResponse, error) + func (UnimplementedSDBServer) GHMembers(context.Context, *GHMembersRequest) (*GHMembersResponse, error) + func (UnimplementedSDBServer) GHPop(context.Context, *GHPopRequest) (*GHPopResponse, error) + func (UnimplementedSDBServer) Get(context.Context, *GetRequest) (*GetResponse, error) + func (UnimplementedSDBServer) HLLAdd(context.Context, *HLLAddRequest) (*HLLAddResponse, error) + func (UnimplementedSDBServer) HLLCount(context.Context, *HLLCountRequest) (*HLLCountResponse, error) + func (UnimplementedSDBServer) HLLCreate(context.Context, *HLLCreateRequest) (*HLLCreateResponse, error) + func (UnimplementedSDBServer) HLLDel(context.Context, *HLLDelRequest) (*HLLDelResponse, error) + func (UnimplementedSDBServer) Incr(context.Context, *IncrRequest) (*IncrResponse, error) + func (UnimplementedSDBServer) LCount(context.Context, *LCountRequest) (*LCountResponse, error) + func (UnimplementedSDBServer) LDel(context.Context, *LDelRequest) (*LDelResponse, error) + func (UnimplementedSDBServer) LExist(context.Context, *LExistRequest) (*LExistResponse, error) + func (UnimplementedSDBServer) LLPush(context.Context, *LLPushRequest) (*LLPushResponse, error) + func (UnimplementedSDBServer) LMembers(context.Context, *LMembersRequest) (*LMembersResponse, error) + func (UnimplementedSDBServer) LPop(context.Context, *LPopRequest) (*LPopResponse, error) + func (UnimplementedSDBServer) LRPush(context.Context, *LRPushRequest) (*LRPushResponse, error) + func (UnimplementedSDBServer) LRange(context.Context, *LRangeRequest) (*LRangeResponse, error) + func (UnimplementedSDBServer) MCount(context.Context, *MCountRequest) (*MCountResponse, error) + func (UnimplementedSDBServer) MDel(context.Context, *MDelRequest) (*MDelResponse, error) + func (UnimplementedSDBServer) MExist(context.Context, *MExistRequest) (*MExistResponse, error) + func (UnimplementedSDBServer) MGet(context.Context, *MGetRequest) (*MGetResponse, error) + func (UnimplementedSDBServer) MMembers(context.Context, *MMembersRequest) (*MMembersResponse, error) + func (UnimplementedSDBServer) MPop(context.Context, *MPopRequest) (*MPopResponse, error) + func (UnimplementedSDBServer) MPush(context.Context, *MPushRequest) (*MPushResponse, error) + func (UnimplementedSDBServer) MSet(context.Context, *MSetRequest) (*MSetResponse, error) + func (UnimplementedSDBServer) PList(context.Context, *PListRequest) (*PListResponse, error) + func (UnimplementedSDBServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error) + func (UnimplementedSDBServer) SCount(context.Context, *SCountRequest) (*SCountResponse, error) + func (UnimplementedSDBServer) SDel(context.Context, *SDelRequest) (*SDelResponse, error) + func (UnimplementedSDBServer) SExist(context.Context, *SExistRequest) (*SExistResponse, error) + func (UnimplementedSDBServer) SMembers(context.Context, *SMembersRequest) (*SMembersResponse, error) + func (UnimplementedSDBServer) SPop(context.Context, *SPopRequest) (*SPopResponse, error) + func (UnimplementedSDBServer) SPush(context.Context, *SPushRequest) (*SPushResponse, error) + func (UnimplementedSDBServer) Set(context.Context, *SetRequest) (*SetResponse, error) + func (UnimplementedSDBServer) SetNX(context.Context, *SetNXRequest) (*SetNXResponse, error) + func (UnimplementedSDBServer) Subscribe(*SubscribeRequest, SDB_SubscribeServer) error + func (UnimplementedSDBServer) ZCount(context.Context, *ZCountRequest) (*ZCountResponse, error) + func (UnimplementedSDBServer) ZDel(context.Context, *ZDelRequest) (*ZDelResponse, error) + func (UnimplementedSDBServer) ZExist(context.Context, *ZExistRequest) (*ZExistResponse, error) + func (UnimplementedSDBServer) ZMembers(context.Context, *ZMembersRequest) (*ZMembersResponse, error) + func (UnimplementedSDBServer) ZPop(context.Context, *ZPopRequest) (*ZPopResponse, error) + func (UnimplementedSDBServer) ZPush(context.Context, *ZPushRequest) (*ZPushResponse, error) + func (UnimplementedSDBServer) ZRange(context.Context, *ZRangeRequest) (*ZRangeResponse, error) + type UnsafeSDBServer interface + type ZCountRequest struct + Key []byte + func (*ZCountRequest) Descriptor() ([]byte, []int) + func (*ZCountRequest) ProtoMessage() + func (x *ZCountRequest) GetKey() []byte + func (x *ZCountRequest) ProtoReflect() protoreflect.Message + func (x *ZCountRequest) Reset() + func (x *ZCountRequest) String() string + type ZCountResponse struct + Count uint32 + func (*ZCountResponse) Descriptor() ([]byte, []int) + func (*ZCountResponse) ProtoMessage() + func (x *ZCountResponse) GetCount() uint32 + func (x *ZCountResponse) ProtoReflect() protoreflect.Message + func (x *ZCountResponse) Reset() + func (x *ZCountResponse) String() string + type ZDelRequest struct + Key []byte + func (*ZDelRequest) Descriptor() ([]byte, []int) + func (*ZDelRequest) ProtoMessage() + func (x *ZDelRequest) GetKey() []byte + func (x *ZDelRequest) ProtoReflect() protoreflect.Message + func (x *ZDelRequest) Reset() + func (x *ZDelRequest) String() string + type ZDelResponse struct + Success bool + func (*ZDelResponse) Descriptor() ([]byte, []int) + func (*ZDelResponse) ProtoMessage() + func (x *ZDelResponse) GetSuccess() bool + func (x *ZDelResponse) ProtoReflect() protoreflect.Message + func (x *ZDelResponse) Reset() + func (x *ZDelResponse) String() string + type ZExistRequest struct + Key []byte + Values [][]byte + func (*ZExistRequest) Descriptor() ([]byte, []int) + func (*ZExistRequest) ProtoMessage() + func (x *ZExistRequest) GetKey() []byte + func (x *ZExistRequest) GetValues() [][]byte + func (x *ZExistRequest) ProtoReflect() protoreflect.Message + func (x *ZExistRequest) Reset() + func (x *ZExistRequest) String() string + type ZExistResponse struct + Exists []bool + func (*ZExistResponse) Descriptor() ([]byte, []int) + func (*ZExistResponse) ProtoMessage() + func (x *ZExistResponse) GetExists() []bool + func (x *ZExistResponse) ProtoReflect() protoreflect.Message + func (x *ZExistResponse) Reset() + func (x *ZExistResponse) String() string + type ZMembersRequest struct + Key []byte + func (*ZMembersRequest) Descriptor() ([]byte, []int) + func (*ZMembersRequest) ProtoMessage() + func (x *ZMembersRequest) GetKey() []byte + func (x *ZMembersRequest) ProtoReflect() protoreflect.Message + func (x *ZMembersRequest) Reset() + func (x *ZMembersRequest) String() string + type ZMembersResponse struct + Tuples []*Tuple + func (*ZMembersResponse) Descriptor() ([]byte, []int) + func (*ZMembersResponse) ProtoMessage() + func (x *ZMembersResponse) GetTuples() []*Tuple + func (x *ZMembersResponse) ProtoReflect() protoreflect.Message + func (x *ZMembersResponse) Reset() + func (x *ZMembersResponse) String() string + type ZPopRequest struct + Key []byte + Values [][]byte + func (*ZPopRequest) Descriptor() ([]byte, []int) + func (*ZPopRequest) ProtoMessage() + func (x *ZPopRequest) GetKey() []byte + func (x *ZPopRequest) GetValues() [][]byte + func (x *ZPopRequest) ProtoReflect() protoreflect.Message + func (x *ZPopRequest) Reset() + func (x *ZPopRequest) String() string + type ZPopResponse struct + Success bool + func (*ZPopResponse) Descriptor() ([]byte, []int) + func (*ZPopResponse) ProtoMessage() + func (x *ZPopResponse) GetSuccess() bool + func (x *ZPopResponse) ProtoReflect() protoreflect.Message + func (x *ZPopResponse) Reset() + func (x *ZPopResponse) String() string + type ZPushRequest struct + Key []byte + Tuples []*Tuple + func (*ZPushRequest) Descriptor() ([]byte, []int) + func (*ZPushRequest) ProtoMessage() + func (x *ZPushRequest) GetKey() []byte + func (x *ZPushRequest) GetTuples() []*Tuple + func (x *ZPushRequest) ProtoReflect() protoreflect.Message + func (x *ZPushRequest) Reset() + func (x *ZPushRequest) String() string + type ZPushResponse struct + Success bool + func (*ZPushResponse) Descriptor() ([]byte, []int) + func (*ZPushResponse) ProtoMessage() + func (x *ZPushResponse) GetSuccess() bool + func (x *ZPushResponse) ProtoReflect() protoreflect.Message + func (x *ZPushResponse) Reset() + func (x *ZPushResponse) String() string + type ZRangeRequest struct + Key []byte + Limit uint32 + Offset int32 + func (*ZRangeRequest) Descriptor() ([]byte, []int) + func (*ZRangeRequest) ProtoMessage() + func (x *ZRangeRequest) GetKey() []byte + func (x *ZRangeRequest) GetLimit() uint32 + func (x *ZRangeRequest) GetOffset() int32 + func (x *ZRangeRequest) ProtoReflect() protoreflect.Message + func (x *ZRangeRequest) Reset() + func (x *ZRangeRequest) String() string + type ZRangeResponse struct + Tuples []*Tuple + func (*ZRangeResponse) Descriptor() ([]byte, []int) + func (*ZRangeResponse) ProtoMessage() + func (x *ZRangeResponse) GetTuples() []*Tuple + func (x *ZRangeResponse) ProtoReflect() protoreflect.Message + func (x *ZRangeResponse) Reset() + func (x *ZRangeResponse) String() string
Go to main page