protobuf

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 7, 2022 License: BSD-2-Clause Imports: 15 Imported by: 0

Documentation

Overview

Package protobuf is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	DataType_name = map[int32]string{
		0:   "STRING",
		1:   "LIST",
		2:   "SET",
		3:   "SORTED_SET",
		4:   "BLOOM_FILTER",
		5:   "HYPER_LOG_LOG",
		6:   "BITSET",
		7:   "MAP",
		8:   "GEO_HASH",
		100: "PAGE",
	}
	DataType_value = map[string]int32{
		"STRING":        0,
		"LIST":          1,
		"SET":           2,
		"SORTED_SET":    3,
		"BLOOM_FILTER":  4,
		"HYPER_LOG_LOG": 5,
		"BITSET":        6,
		"MAP":           7,
		"GEO_HASH":      8,
		"PAGE":          100,
	}
)

Enum value maps for DataType.

View Source 
var File_pkg_sdb_protobuf_bitset_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_bloom_filter_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_data_type_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_geo_hash_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_hyper_log_log_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_index_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_list_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_log_entry_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_map_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_page_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_pub_sub_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_row_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_sdb_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_set_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_sorted_set_proto protoreflect.FileDescriptor
View Source 
var File_pkg_sdb_protobuf_string_proto protoreflect.FileDescriptor
View Source 
var SDB_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.SDB",
	HandlerType: (*SDBServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Set",
			Handler:    _SDB_Set_Handler,
		},
		{
			MethodName: "MSet",
			Handler:    _SDB_MSet_Handler,
		},
		{
			MethodName: "SetNX",
			Handler:    _SDB_SetNX_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _SDB_Get_Handler,
		},
		{
			MethodName: "MGet",
			Handler:    _SDB_MGet_Handler,
		},
		{
			MethodName: "Del",
			Handler:    _SDB_Del_Handler,
		},
		{
			MethodName: "Incr",
			Handler:    _SDB_Incr_Handler,
		},
		{
			MethodName: "LRPush",
			Handler:    _SDB_LRPush_Handler,
		},
		{
			MethodName: "LLPush",
			Handler:    _SDB_LLPush_Handler,
		},
		{
			MethodName: "LPop",
			Handler:    _SDB_LPop_Handler,
		},
		{
			MethodName: "LRange",
			Handler:    _SDB_LRange_Handler,
		},
		{
			MethodName: "LExist",
			Handler:    _SDB_LExist_Handler,
		},
		{
			MethodName: "LDel",
			Handler:    _SDB_LDel_Handler,
		},
		{
			MethodName: "LCount",
			Handler:    _SDB_LCount_Handler,
		},
		{
			MethodName: "LMembers",
			Handler:    _SDB_LMembers_Handler,
		},
		{
			MethodName: "SPush",
			Handler:    _SDB_SPush_Handler,
		},
		{
			MethodName: "SPop",
			Handler:    _SDB_SPop_Handler,
		},
		{
			MethodName: "SExist",
			Handler:    _SDB_SExist_Handler,
		},
		{
			MethodName: "SDel",
			Handler:    _SDB_SDel_Handler,
		},
		{
			MethodName: "SCount",
			Handler:    _SDB_SCount_Handler,
		},
		{
			MethodName: "SMembers",
			Handler:    _SDB_SMembers_Handler,
		},
		{
			MethodName: "ZPush",
			Handler:    _SDB_ZPush_Handler,
		},
		{
			MethodName: "ZPop",
			Handler:    _SDB_ZPop_Handler,
		},
		{
			MethodName: "ZRange",
			Handler:    _SDB_ZRange_Handler,
		},
		{
			MethodName: "ZExist",
			Handler:    _SDB_ZExist_Handler,
		},
		{
			MethodName: "ZDel",
			Handler:    _SDB_ZDel_Handler,
		},
		{
			MethodName: "ZCount",
			Handler:    _SDB_ZCount_Handler,
		},
		{
			MethodName: "ZMembers",
			Handler:    _SDB_ZMembers_Handler,
		},
		{
			MethodName: "BFCreate",
			Handler:    _SDB_BFCreate_Handler,
		},
		{
			MethodName: "BFDel",
			Handler:    _SDB_BFDel_Handler,
		},
		{
			MethodName: "BFAdd",
			Handler:    _SDB_BFAdd_Handler,
		},
		{
			MethodName: "BFExist",
			Handler:    _SDB_BFExist_Handler,
		},
		{
			MethodName: "HLLCreate",
			Handler:    _SDB_HLLCreate_Handler,
		},
		{
			MethodName: "HLLDel",
			Handler:    _SDB_HLLDel_Handler,
		},
		{
			MethodName: "HLLAdd",
			Handler:    _SDB_HLLAdd_Handler,
		},
		{
			MethodName: "HLLCount",
			Handler:    _SDB_HLLCount_Handler,
		},
		{
			MethodName: "BSCreate",
			Handler:    _SDB_BSCreate_Handler,
		},
		{
			MethodName: "BSDel",
			Handler:    _SDB_BSDel_Handler,
		},
		{
			MethodName: "BSSetRange",
			Handler:    _SDB_BSSetRange_Handler,
		},
		{
			MethodName: "BSMSet",
			Handler:    _SDB_BSMSet_Handler,
		},
		{
			MethodName: "BSGetRange",
			Handler:    _SDB_BSGetRange_Handler,
		},
		{
			MethodName: "BSMGet",
			Handler:    _SDB_BSMGet_Handler,
		},
		{
			MethodName: "BSCount",
			Handler:    _SDB_BSCount_Handler,
		},
		{
			MethodName: "BSCountRange",
			Handler:    _SDB_BSCountRange_Handler,
		},
		{
			MethodName: "MPush",
			Handler:    _SDB_MPush_Handler,
		},
		{
			MethodName: "MPop",
			Handler:    _SDB_MPop_Handler,
		},
		{
			MethodName: "MExist",
			Handler:    _SDB_MExist_Handler,
		},
		{
			MethodName: "MDel",
			Handler:    _SDB_MDel_Handler,
		},
		{
			MethodName: "MCount",
			Handler:    _SDB_MCount_Handler,
		},
		{
			MethodName: "MMembers",
			Handler:    _SDB_MMembers_Handler,
		},
		{
			MethodName: "GHCreate",
			Handler:    _SDB_GHCreate_Handler,
		},
		{
			MethodName: "GHDel",
			Handler:    _SDB_GHDel_Handler,
		},
		{
			MethodName: "GHAdd",
			Handler:    _SDB_GHAdd_Handler,
		},
		{
			MethodName: "GHPop",
			Handler:    _SDB_GHPop_Handler,
		},
		{
			MethodName: "GHGetBoxes",
			Handler:    _SDB_GHGetBoxes_Handler,
		},
		{
			MethodName: "GHGetNeighbors",
			Handler:    _SDB_GHGetNeighbors_Handler,
		},
		{
			MethodName: "GHCount",
			Handler:    _SDB_GHCount_Handler,
		},
		{
			MethodName: "GHMembers",
			Handler:    _SDB_GHMembers_Handler,
		},
		{
			MethodName: "PList",
			Handler:    _SDB_PList_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _SDB_Publish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _SDB_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/sdb-protobuf/sdb.proto",
}

SDB_ServiceDesc is the grpc.ServiceDesc for SDB service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSDBHandler 

func RegisterSDBHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSDBHandler registers the http handlers for service SDB to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSDBHandlerClient 

func RegisterSDBHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SDBClient) error

RegisterSDBHandlerClient registers the http handlers for service SDB to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SDBClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SDBClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SDBClient" to call the correct interceptors.

func RegisterSDBHandlerFromEndpoint 

func RegisterSDBHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSDBHandlerFromEndpoint is same as RegisterSDBHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSDBHandlerServer 

func RegisterSDBHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SDBServer) error

RegisterSDBHandlerServer registers the http handlers for service SDB to "mux". UnaryRPC :call SDBServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSDBHandlerFromEndpoint instead.

func RegisterSDBServer 

func RegisterSDBServer(s grpc.ServiceRegistrar, srv SDBServer)

Types

type BFAddRequest 

type BFAddRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BFAddRequest) Descriptor deprecated 

func (*BFAddRequest) Descriptor() ([]byte, []int)

Deprecated: Use BFAddRequest.ProtoReflect.Descriptor instead.

func (*BFAddRequest) GetKey 

func (x *BFAddRequest) GetKey() []byte

func (*BFAddRequest) GetValues 

func (x *BFAddRequest) GetValues() [][]byte

func (*BFAddRequest) ProtoMessage 

func (*BFAddRequest) ProtoMessage()

func (*BFAddRequest) ProtoReflect 

func (x *BFAddRequest) ProtoReflect() protoreflect.Message

func (*BFAddRequest) Reset 

func (x *BFAddRequest) Reset()

func (*BFAddRequest) String 

func (x *BFAddRequest) String() string

type BFAddResponse 

type BFAddResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*BFAddResponse) Descriptor deprecated 

func (*BFAddResponse) Descriptor() ([]byte, []int)

Deprecated: Use BFAddResponse.ProtoReflect.Descriptor instead.

func (*BFAddResponse) GetSuccess 

func (x *BFAddResponse) GetSuccess() bool

func (*BFAddResponse) ProtoMessage 

func (*BFAddResponse) ProtoMessage()

func (*BFAddResponse) ProtoReflect 

func (x *BFAddResponse) ProtoReflect() protoreflect.Message

func (*BFAddResponse) Reset 

func (x *BFAddResponse) Reset()

func (*BFAddResponse) String 

func (x *BFAddResponse) String() string

type BFCreateRequest 

type BFCreateRequest struct {
	Key []byte  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	N   uint32  `protobuf:"varint,2,opt,name=n,proto3" json:"n,omitempty"`
	P   float64 `protobuf:"fixed64,3,opt,name=p,proto3" json:"p,omitempty"`
	// contains filtered or unexported fields
}

func (*BFCreateRequest) Descriptor deprecated 

func (*BFCreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use BFCreateRequest.ProtoReflect.Descriptor instead.

func (*BFCreateRequest) GetKey 

func (x *BFCreateRequest) GetKey() []byte

func (*BFCreateRequest) GetN 

func (x *BFCreateRequest) GetN() uint32

func (*BFCreateRequest) GetP 

func (x *BFCreateRequest) GetP() float64

func (*BFCreateRequest) ProtoMessage 

func (*BFCreateRequest) ProtoMessage()

func (*BFCreateRequest) ProtoReflect 

func (x *BFCreateRequest) ProtoReflect() protoreflect.Message

func (*BFCreateRequest) Reset 

func (x *BFCreateRequest) Reset()

func (*BFCreateRequest) String 

func (x *BFCreateRequest) String() string

type BFCreateResponse 

type BFCreateResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*BFCreateResponse) Descriptor deprecated 

func (*BFCreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use BFCreateResponse.ProtoReflect.Descriptor instead.

func (*BFCreateResponse) GetSuccess 

func (x *BFCreateResponse) GetSuccess() bool

func (*BFCreateResponse) ProtoMessage 

func (*BFCreateResponse) ProtoMessage()

func (*BFCreateResponse) ProtoReflect 

func (x *BFCreateResponse) ProtoReflect() protoreflect.Message

func (*BFCreateResponse) Reset 

func (x *BFCreateResponse) Reset()

func (*BFCreateResponse) String 

func (x *BFCreateResponse) String() string

type BFDelRequest 

type BFDelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*BFDelRequest) Descriptor deprecated 

func (*BFDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use BFDelRequest.ProtoReflect.Descriptor instead.

func (*BFDelRequest) GetKey 

func (x *BFDelRequest) GetKey() []byte

func (*BFDelRequest) ProtoMessage 

func (*BFDelRequest) ProtoMessage()

func (*BFDelRequest) ProtoReflect 

func (x *BFDelRequest) ProtoReflect() protoreflect.Message

func (*BFDelRequest) Reset 

func (x *BFDelRequest) Reset()

func (*BFDelRequest) String 

func (x *BFDelRequest) String() string

type BFDelResponse 

type BFDelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*BFDelResponse) Descriptor deprecated 

func (*BFDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use BFDelResponse.ProtoReflect.Descriptor instead.

func (*BFDelResponse) GetSuccess 

func (x *BFDelResponse) GetSuccess() bool

func (*BFDelResponse) ProtoMessage 

func (*BFDelResponse) ProtoMessage()

func (*BFDelResponse) ProtoReflect 

func (x *BFDelResponse) ProtoReflect() protoreflect.Message

func (*BFDelResponse) Reset 

func (x *BFDelResponse) Reset()

func (*BFDelResponse) String 

func (x *BFDelResponse) String() string

type BFExistRequest 

type BFExistRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BFExistRequest) Descriptor deprecated 

func (*BFExistRequest) Descriptor() ([]byte, []int)

Deprecated: Use BFExistRequest.ProtoReflect.Descriptor instead.

func (*BFExistRequest) GetKey 

func (x *BFExistRequest) GetKey() []byte

func (*BFExistRequest) GetValues 

func (x *BFExistRequest) GetValues() [][]byte

func (*BFExistRequest) ProtoMessage 

func (*BFExistRequest) ProtoMessage()

func (*BFExistRequest) ProtoReflect 

func (x *BFExistRequest) ProtoReflect() protoreflect.Message

func (*BFExistRequest) Reset 

func (x *BFExistRequest) Reset()

func (*BFExistRequest) String 

func (x *BFExistRequest) String() string

type BFExistResponse 

type BFExistResponse struct {
	Exists []bool `protobuf:"varint,1,rep,packed,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*BFExistResponse) Descriptor deprecated 

func (*BFExistResponse) Descriptor() ([]byte, []int)

Deprecated: Use BFExistResponse.ProtoReflect.Descriptor instead.

func (*BFExistResponse) GetExists 

func (x *BFExistResponse) GetExists() []bool

func (*BFExistResponse) ProtoMessage 

func (*BFExistResponse) ProtoMessage()

func (*BFExistResponse) ProtoReflect 

func (x *BFExistResponse) ProtoReflect() protoreflect.Message

func (*BFExistResponse) Reset 

func (x *BFExistResponse) Reset()

func (*BFExistResponse) String 

func (x *BFExistResponse) String() string

type BSCountRangeRequest 

type BSCountRangeRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Start uint32 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End   uint32 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*BSCountRangeRequest) Descriptor deprecated 

func (*BSCountRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use BSCountRangeRequest.ProtoReflect.Descriptor instead.

func (*BSCountRangeRequest) GetEnd 

func (x *BSCountRangeRequest) GetEnd() uint32

func (*BSCountRangeRequest) GetKey 

func (x *BSCountRangeRequest) GetKey() []byte

func (*BSCountRangeRequest) GetStart 

func (x *BSCountRangeRequest) GetStart() uint32

func (*BSCountRangeRequest) ProtoMessage 

func (*BSCountRangeRequest) ProtoMessage()

func (*BSCountRangeRequest) ProtoReflect 

func (x *BSCountRangeRequest) ProtoReflect() protoreflect.Message

func (*BSCountRangeRequest) Reset 

func (x *BSCountRangeRequest) Reset()

func (*BSCountRangeRequest) String 

func (x *BSCountRangeRequest) String() string

type BSCountRangeResponse 

type BSCountRangeResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*BSCountRangeResponse) Descriptor deprecated 

func (*BSCountRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use BSCountRangeResponse.ProtoReflect.Descriptor instead.

func (*BSCountRangeResponse) GetCount 

func (x *BSCountRangeResponse) GetCount() uint32

func (*BSCountRangeResponse) ProtoMessage 

func (*BSCountRangeResponse) ProtoMessage()

func (*BSCountRangeResponse) ProtoReflect 

func (x *BSCountRangeResponse) ProtoReflect() protoreflect.Message

func (*BSCountRangeResponse) Reset 

func (x *BSCountRangeResponse) Reset()

func (*BSCountRangeResponse) String 

func (x *BSCountRangeResponse) String() string

type BSCountRequest 

type BSCountRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*BSCountRequest) Descriptor deprecated 

func (*BSCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use BSCountRequest.ProtoReflect.Descriptor instead.

func (*BSCountRequest) GetKey 

func (x *BSCountRequest) GetKey() []byte

func (*BSCountRequest) ProtoMessage 

func (*BSCountRequest) ProtoMessage()

func (*BSCountRequest) ProtoReflect 

func (x *BSCountRequest) ProtoReflect() protoreflect.Message

func (*BSCountRequest) Reset 

func (x *BSCountRequest) Reset()

func (*BSCountRequest) String 

func (x *BSCountRequest) String() string

type BSCountResponse 

type BSCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*BSCountResponse) Descriptor deprecated 

func (*BSCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use BSCountResponse.ProtoReflect.Descriptor instead.

func (*BSCountResponse) GetCount 

func (x *BSCountResponse) GetCount() uint32

func (*BSCountResponse) ProtoMessage 

func (*BSCountResponse) ProtoMessage()

func (*BSCountResponse) ProtoReflect 

func (x *BSCountResponse) ProtoReflect() protoreflect.Message

func (*BSCountResponse) Reset 

func (x *BSCountResponse) Reset()

func (*BSCountResponse) String 

func (x *BSCountResponse) String() string

type BSCreateRequest 

type BSCreateRequest struct {
	Key  []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Size uint32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*BSCreateRequest) Descriptor deprecated 

func (*BSCreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use BSCreateRequest.ProtoReflect.Descriptor instead.

func (*BSCreateRequest) GetKey 

func (x *BSCreateRequest) GetKey() []byte

func (*BSCreateRequest) GetSize 

func (x *BSCreateRequest) GetSize() uint32

func (*BSCreateRequest) ProtoMessage 

func (*BSCreateRequest) ProtoMessage()

func (*BSCreateRequest) ProtoReflect 

func (x *BSCreateRequest) ProtoReflect() protoreflect.Message

func (*BSCreateRequest) Reset 

func (x *BSCreateRequest) Reset()

func (*BSCreateRequest) String 

func (x *BSCreateRequest) String() string

type BSCreateResponse 

type BSCreateResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*BSCreateResponse) Descriptor deprecated 

func (*BSCreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use BSCreateResponse.ProtoReflect.Descriptor instead.

func (*BSCreateResponse) GetSuccess 

func (x *BSCreateResponse) GetSuccess() bool

func (*BSCreateResponse) ProtoMessage 

func (*BSCreateResponse) ProtoMessage()

func (*BSCreateResponse) ProtoReflect 

func (x *BSCreateResponse) ProtoReflect() protoreflect.Message

func (*BSCreateResponse) Reset 

func (x *BSCreateResponse) Reset()

func (*BSCreateResponse) String 

func (x *BSCreateResponse) String() string

type BSDelRequest 

type BSDelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*BSDelRequest) Descriptor deprecated 

func (*BSDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use BSDelRequest.ProtoReflect.Descriptor instead.

func (*BSDelRequest) GetKey 

func (x *BSDelRequest) GetKey() []byte

func (*BSDelRequest) ProtoMessage 

func (*BSDelRequest) ProtoMessage()

func (*BSDelRequest) ProtoReflect 

func (x *BSDelRequest) ProtoReflect() protoreflect.Message

func (*BSDelRequest) Reset 

func (x *BSDelRequest) Reset()

func (*BSDelRequest) String 

func (x *BSDelRequest) String() string

type BSDelResponse 

type BSDelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*BSDelResponse) Descriptor deprecated 

func (*BSDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use BSDelResponse.ProtoReflect.Descriptor instead.

func (*BSDelResponse) GetSuccess 

func (x *BSDelResponse) GetSuccess() bool

func (*BSDelResponse) ProtoMessage 

func (*BSDelResponse) ProtoMessage()

func (*BSDelResponse) ProtoReflect 

func (x *BSDelResponse) ProtoReflect() protoreflect.Message

func (*BSDelResponse) Reset 

func (x *BSDelResponse) Reset()

func (*BSDelResponse) String 

func (x *BSDelResponse) String() string

type BSGetRangeRequest 

type BSGetRangeRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Start uint32 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End   uint32 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*BSGetRangeRequest) Descriptor deprecated 

func (*BSGetRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use BSGetRangeRequest.ProtoReflect.Descriptor instead.

func (*BSGetRangeRequest) GetEnd 

func (x *BSGetRangeRequest) GetEnd() uint32

func (*BSGetRangeRequest) GetKey 

func (x *BSGetRangeRequest) GetKey() []byte

func (*BSGetRangeRequest) GetStart 

func (x *BSGetRangeRequest) GetStart() uint32

func (*BSGetRangeRequest) ProtoMessage 

func (*BSGetRangeRequest) ProtoMessage()

func (*BSGetRangeRequest) ProtoReflect 

func (x *BSGetRangeRequest) ProtoReflect() protoreflect.Message

func (*BSGetRangeRequest) Reset 

func (x *BSGetRangeRequest) Reset()

func (*BSGetRangeRequest) String 

func (x *BSGetRangeRequest) String() string

type BSGetRangeResponse 

type BSGetRangeResponse struct {
	Values []bool `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BSGetRangeResponse) Descriptor deprecated 

func (*BSGetRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use BSGetRangeResponse.ProtoReflect.Descriptor instead.

func (*BSGetRangeResponse) GetValues 

func (x *BSGetRangeResponse) GetValues() []bool

func (*BSGetRangeResponse) ProtoMessage 

func (*BSGetRangeResponse) ProtoMessage()

func (*BSGetRangeResponse) ProtoReflect 

func (x *BSGetRangeResponse) ProtoReflect() protoreflect.Message

func (*BSGetRangeResponse) Reset 

func (x *BSGetRangeResponse) Reset()

func (*BSGetRangeResponse) String 

func (x *BSGetRangeResponse) String() string

type BSMGetRequest 

type BSMGetRequest struct {
	Key  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Bits []uint32 `protobuf:"varint,2,rep,packed,name=bits,proto3" json:"bits,omitempty"`
	// contains filtered or unexported fields
}

func (*BSMGetRequest) Descriptor deprecated 

func (*BSMGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use BSMGetRequest.ProtoReflect.Descriptor instead.

func (*BSMGetRequest) GetBits 

func (x *BSMGetRequest) GetBits() []uint32

func (*BSMGetRequest) GetKey 

func (x *BSMGetRequest) GetKey() []byte

func (*BSMGetRequest) ProtoMessage 

func (*BSMGetRequest) ProtoMessage()

func (*BSMGetRequest) ProtoReflect 

func (x *BSMGetRequest) ProtoReflect() protoreflect.Message

func (*BSMGetRequest) Reset 

func (x *BSMGetRequest) Reset()

func (*BSMGetRequest) String 

func (x *BSMGetRequest) String() string

type BSMGetResponse 

type BSMGetResponse struct {
	Values []bool `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BSMGetResponse) Descriptor deprecated 

func (*BSMGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use BSMGetResponse.ProtoReflect.Descriptor instead.

func (*BSMGetResponse) GetValues 

func (x *BSMGetResponse) GetValues() []bool

func (*BSMGetResponse) ProtoMessage 

func (*BSMGetResponse) ProtoMessage()

func (*BSMGetResponse) ProtoReflect 

func (x *BSMGetResponse) ProtoReflect() protoreflect.Message

func (*BSMGetResponse) Reset 

func (x *BSMGetResponse) Reset()

func (*BSMGetResponse) String 

func (x *BSMGetResponse) String() string

type BSMSetRequest 

type BSMSetRequest struct {
	Key   []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Bits  []uint32 `protobuf:"varint,2,rep,packed,name=bits,proto3" json:"bits,omitempty"`
	Value bool     `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BSMSetRequest) Descriptor deprecated 

func (*BSMSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use BSMSetRequest.ProtoReflect.Descriptor instead.

func (*BSMSetRequest) GetBits 

func (x *BSMSetRequest) GetBits() []uint32

func (*BSMSetRequest) GetKey 

func (x *BSMSetRequest) GetKey() []byte

func (*BSMSetRequest) GetValue 

func (x *BSMSetRequest) GetValue() bool

func (*BSMSetRequest) ProtoMessage 

func (*BSMSetRequest) ProtoMessage()

func (*BSMSetRequest) ProtoReflect 

func (x *BSMSetRequest) ProtoReflect() protoreflect.Message

func (*BSMSetRequest) Reset 

func (x *BSMSetRequest) Reset()

func (*BSMSetRequest) String 

func (x *BSMSetRequest) String() string

type BSMSetResponse 

type BSMSetResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*BSMSetResponse) Descriptor deprecated 

func (*BSMSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use BSMSetResponse.ProtoReflect.Descriptor instead.

func (*BSMSetResponse) GetSuccess 

func (x *BSMSetResponse) GetSuccess() bool

func (*BSMSetResponse) ProtoMessage 

func (*BSMSetResponse) ProtoMessage()

func (*BSMSetResponse) ProtoReflect 

func (x *BSMSetResponse) ProtoReflect() protoreflect.Message

func (*BSMSetResponse) Reset 

func (x *BSMSetResponse) Reset()

func (*BSMSetResponse) String 

func (x *BSMSetResponse) String() string

type BSSetRangeRequest 

type BSSetRangeRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Start uint32 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End   uint32 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	Value bool   `protobuf:"varint,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BSSetRangeRequest) Descriptor deprecated 

func (*BSSetRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use BSSetRangeRequest.ProtoReflect.Descriptor instead.

func (*BSSetRangeRequest) GetEnd 

func (x *BSSetRangeRequest) GetEnd() uint32

func (*BSSetRangeRequest) GetKey 

func (x *BSSetRangeRequest) GetKey() []byte

func (*BSSetRangeRequest) GetStart 

func (x *BSSetRangeRequest) GetStart() uint32

func (*BSSetRangeRequest) GetValue 

func (x *BSSetRangeRequest) GetValue() bool

func (*BSSetRangeRequest) ProtoMessage 

func (*BSSetRangeRequest) ProtoMessage()

func (*BSSetRangeRequest) ProtoReflect 

func (x *BSSetRangeRequest) ProtoReflect() protoreflect.Message

func (*BSSetRangeRequest) Reset 

func (x *BSSetRangeRequest) Reset()

func (*BSSetRangeRequest) String 

func (x *BSSetRangeRequest) String() string

type BSSetRangeResponse 

type BSSetRangeResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*BSSetRangeResponse) Descriptor deprecated 

func (*BSSetRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use BSSetRangeResponse.ProtoReflect.Descriptor instead.

func (*BSSetRangeResponse) GetSuccess 

func (x *BSSetRangeResponse) GetSuccess() bool

func (*BSSetRangeResponse) ProtoMessage 

func (*BSSetRangeResponse) ProtoMessage()

func (*BSSetRangeResponse) ProtoReflect 

func (x *BSSetRangeResponse) ProtoReflect() protoreflect.Message

func (*BSSetRangeResponse) Reset 

func (x *BSSetRangeResponse) Reset()

func (*BSSetRangeResponse) String 

func (x *BSSetRangeResponse) String() string

type DataType 

type DataType int32
const (
	DataType_STRING        DataType = 0
	DataType_LIST          DataType = 1
	DataType_SET           DataType = 2
	DataType_SORTED_SET    DataType = 3
	DataType_BLOOM_FILTER  DataType = 4
	DataType_HYPER_LOG_LOG DataType = 5
	DataType_BITSET        DataType = 6
	DataType_MAP           DataType = 7
	DataType_GEO_HASH      DataType = 8
	DataType_PAGE          DataType = 100
)

func (DataType) Descriptor 

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum 

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated 

func (DataType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number 

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String 

func (x DataType) String() string

func (DataType) Type 

func (DataType) Type() protoreflect.EnumType

type DelRequest 

type DelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DelRequest) Descriptor deprecated 

func (*DelRequest) Descriptor() ([]byte, []int)

Deprecated: Use DelRequest.ProtoReflect.Descriptor instead.

func (*DelRequest) GetKey 

func (x *DelRequest) GetKey() []byte

func (*DelRequest) ProtoMessage 

func (*DelRequest) ProtoMessage()

func (*DelRequest) ProtoReflect 

func (x *DelRequest) ProtoReflect() protoreflect.Message

func (*DelRequest) Reset 

func (x *DelRequest) Reset()

func (*DelRequest) String 

func (x *DelRequest) String() string

type DelResponse 

type DelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*DelResponse) Descriptor deprecated 

func (*DelResponse) Descriptor() ([]byte, []int)

Deprecated: Use DelResponse.ProtoReflect.Descriptor instead.

func (*DelResponse) GetSuccess 

func (x *DelResponse) GetSuccess() bool

func (*DelResponse) ProtoMessage 

func (*DelResponse) ProtoMessage()

func (*DelResponse) ProtoReflect 

func (x *DelResponse) ProtoReflect() protoreflect.Message

func (*DelResponse) Reset 

func (x *DelResponse) Reset()

func (*DelResponse) String 

func (x *DelResponse) String() string

type GHAddRequest 

type GHAddRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Points []*Point `protobuf:"bytes,2,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

func (*GHAddRequest) Descriptor deprecated 

func (*GHAddRequest) Descriptor() ([]byte, []int)

Deprecated: Use GHAddRequest.ProtoReflect.Descriptor instead.

func (*GHAddRequest) GetKey 

func (x *GHAddRequest) GetKey() []byte

func (*GHAddRequest) GetPoints 

func (x *GHAddRequest) GetPoints() []*Point

func (*GHAddRequest) ProtoMessage 

func (*GHAddRequest) ProtoMessage()

func (*GHAddRequest) ProtoReflect 

func (x *GHAddRequest) ProtoReflect() protoreflect.Message

func (*GHAddRequest) Reset 

func (x *GHAddRequest) Reset()

func (*GHAddRequest) String 

func (x *GHAddRequest) String() string

type GHAddResponse 

type GHAddResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*GHAddResponse) Descriptor deprecated 

func (*GHAddResponse) Descriptor() ([]byte, []int)

Deprecated: Use GHAddResponse.ProtoReflect.Descriptor instead.

func (*GHAddResponse) GetSuccess 

func (x *GHAddResponse) GetSuccess() bool

func (*GHAddResponse) ProtoMessage 

func (*GHAddResponse) ProtoMessage()

func (*GHAddResponse) ProtoReflect 

func (x *GHAddResponse) ProtoReflect() protoreflect.Message

func (*GHAddResponse) Reset 

func (x *GHAddResponse) Reset()

func (*GHAddResponse) String 

func (x *GHAddResponse) String() string

type GHCountRequest 

type GHCountRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GHCountRequest) Descriptor deprecated 

func (*GHCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use GHCountRequest.ProtoReflect.Descriptor instead.

func (*GHCountRequest) GetKey 

func (x *GHCountRequest) GetKey() []byte

func (*GHCountRequest) ProtoMessage 

func (*GHCountRequest) ProtoMessage()

func (*GHCountRequest) ProtoReflect 

func (x *GHCountRequest) ProtoReflect() protoreflect.Message

func (*GHCountRequest) Reset 

func (x *GHCountRequest) Reset()

func (*GHCountRequest) String 

func (x *GHCountRequest) String() string

type GHCountResponse 

type GHCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*GHCountResponse) Descriptor deprecated 

func (*GHCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use GHCountResponse.ProtoReflect.Descriptor instead.

func (*GHCountResponse) GetCount 

func (x *GHCountResponse) GetCount() uint32

func (*GHCountResponse) ProtoMessage 

func (*GHCountResponse) ProtoMessage()

func (*GHCountResponse) ProtoReflect 

func (x *GHCountResponse) ProtoReflect() protoreflect.Message

func (*GHCountResponse) Reset 

func (x *GHCountResponse) Reset()

func (*GHCountResponse) String 

func (x *GHCountResponse) String() string

type GHCreateRequest 

type GHCreateRequest struct {
	Key       []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Precision int32  `protobuf:"varint,2,opt,name=precision,proto3" json:"precision,omitempty"`
	// contains filtered or unexported fields
}

func (*GHCreateRequest) Descriptor deprecated 

func (*GHCreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use GHCreateRequest.ProtoReflect.Descriptor instead.

func (*GHCreateRequest) GetKey 

func (x *GHCreateRequest) GetKey() []byte

func (*GHCreateRequest) GetPrecision 

func (x *GHCreateRequest) GetPrecision() int32

func (*GHCreateRequest) ProtoMessage 

func (*GHCreateRequest) ProtoMessage()

func (*GHCreateRequest) ProtoReflect 

func (x *GHCreateRequest) ProtoReflect() protoreflect.Message

func (*GHCreateRequest) Reset 

func (x *GHCreateRequest) Reset()

func (*GHCreateRequest) String 

func (x *GHCreateRequest) String() string

type GHCreateResponse 

type GHCreateResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*GHCreateResponse) Descriptor deprecated 

func (*GHCreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use GHCreateResponse.ProtoReflect.Descriptor instead.

func (*GHCreateResponse) GetSuccess 

func (x *GHCreateResponse) GetSuccess() bool

func (*GHCreateResponse) ProtoMessage 

func (*GHCreateResponse) ProtoMessage()

func (*GHCreateResponse) ProtoReflect 

func (x *GHCreateResponse) ProtoReflect() protoreflect.Message

func (*GHCreateResponse) Reset 

func (x *GHCreateResponse) Reset()

func (*GHCreateResponse) String 

func (x *GHCreateResponse) String() string

type GHDelRequest 

type GHDelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GHDelRequest) Descriptor deprecated 

func (*GHDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use GHDelRequest.ProtoReflect.Descriptor instead.

func (*GHDelRequest) GetKey 

func (x *GHDelRequest) GetKey() []byte

func (*GHDelRequest) ProtoMessage 

func (*GHDelRequest) ProtoMessage()

func (*GHDelRequest) ProtoReflect 

func (x *GHDelRequest) ProtoReflect() protoreflect.Message

func (*GHDelRequest) Reset 

func (x *GHDelRequest) Reset()

func (*GHDelRequest) String 

func (x *GHDelRequest) String() string

type GHDelResponse 

type GHDelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*GHDelResponse) Descriptor deprecated 

func (*GHDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use GHDelResponse.ProtoReflect.Descriptor instead.

func (*GHDelResponse) GetSuccess 

func (x *GHDelResponse) GetSuccess() bool

func (*GHDelResponse) ProtoMessage 

func (*GHDelResponse) ProtoMessage()

func (*GHDelResponse) ProtoReflect 

func (x *GHDelResponse) ProtoReflect() protoreflect.Message

func (*GHDelResponse) Reset 

func (x *GHDelResponse) Reset()

func (*GHDelResponse) String 

func (x *GHDelResponse) String() string

type GHGetBoxesRequest 

type GHGetBoxesRequest struct {
	Key       []byte  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Latitude  float64 `protobuf:"fixed64,2,opt,name=latitude,proto3" json:"latitude,omitempty"`
	Longitude float64 `protobuf:"fixed64,3,opt,name=longitude,proto3" json:"longitude,omitempty"`
	// contains filtered or unexported fields
}

func (*GHGetBoxesRequest) Descriptor deprecated 

func (*GHGetBoxesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GHGetBoxesRequest.ProtoReflect.Descriptor instead.

func (*GHGetBoxesRequest) GetKey 

func (x *GHGetBoxesRequest) GetKey() []byte

func (*GHGetBoxesRequest) GetLatitude 

func (x *GHGetBoxesRequest) GetLatitude() float64

func (*GHGetBoxesRequest) GetLongitude 

func (x *GHGetBoxesRequest) GetLongitude() float64

func (*GHGetBoxesRequest) ProtoMessage 

func (*GHGetBoxesRequest) ProtoMessage()

func (*GHGetBoxesRequest) ProtoReflect 

func (x *GHGetBoxesRequest) ProtoReflect() protoreflect.Message

func (*GHGetBoxesRequest) Reset 

func (x *GHGetBoxesRequest) Reset()

func (*GHGetBoxesRequest) String 

func (x *GHGetBoxesRequest) String() string

type GHGetBoxesResponse 

type GHGetBoxesResponse struct {
	Points []*Point `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

func (*GHGetBoxesResponse) Descriptor deprecated 

func (*GHGetBoxesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GHGetBoxesResponse.ProtoReflect.Descriptor instead.

func (*GHGetBoxesResponse) GetPoints 

func (x *GHGetBoxesResponse) GetPoints() []*Point

func (*GHGetBoxesResponse) ProtoMessage 

func (*GHGetBoxesResponse) ProtoMessage()

func (*GHGetBoxesResponse) ProtoReflect 

func (x *GHGetBoxesResponse) ProtoReflect() protoreflect.Message

func (*GHGetBoxesResponse) Reset 

func (x *GHGetBoxesResponse) Reset()

func (*GHGetBoxesResponse) String 

func (x *GHGetBoxesResponse) String() string

type GHGetNeighborsRequest 

type GHGetNeighborsRequest struct {
	Key       []byte  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Latitude  float64 `protobuf:"fixed64,2,opt,name=latitude,proto3" json:"latitude,omitempty"`
	Longitude float64 `protobuf:"fixed64,3,opt,name=longitude,proto3" json:"longitude,omitempty"`
	// contains filtered or unexported fields
}

func (*GHGetNeighborsRequest) Descriptor deprecated 

func (*GHGetNeighborsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GHGetNeighborsRequest.ProtoReflect.Descriptor instead.

func (*GHGetNeighborsRequest) GetKey 

func (x *GHGetNeighborsRequest) GetKey() []byte

func (*GHGetNeighborsRequest) GetLatitude 

func (x *GHGetNeighborsRequest) GetLatitude() float64

func (*GHGetNeighborsRequest) GetLongitude 

func (x *GHGetNeighborsRequest) GetLongitude() float64

func (*GHGetNeighborsRequest) ProtoMessage 

func (*GHGetNeighborsRequest) ProtoMessage()

func (*GHGetNeighborsRequest) ProtoReflect 

func (x *GHGetNeighborsRequest) ProtoReflect() protoreflect.Message

func (*GHGetNeighborsRequest) Reset 

func (x *GHGetNeighborsRequest) Reset()

func (*GHGetNeighborsRequest) String 

func (x *GHGetNeighborsRequest) String() string

type GHGetNeighborsResponse 

type GHGetNeighborsResponse struct {
	Points []*Point `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

func (*GHGetNeighborsResponse) Descriptor deprecated 

func (*GHGetNeighborsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GHGetNeighborsResponse.ProtoReflect.Descriptor instead.

func (*GHGetNeighborsResponse) GetPoints 

func (x *GHGetNeighborsResponse) GetPoints() []*Point

func (*GHGetNeighborsResponse) ProtoMessage 

func (*GHGetNeighborsResponse) ProtoMessage()

func (*GHGetNeighborsResponse) ProtoReflect 

func (x *GHGetNeighborsResponse) ProtoReflect() protoreflect.Message

func (*GHGetNeighborsResponse) Reset 

func (x *GHGetNeighborsResponse) Reset()

func (*GHGetNeighborsResponse) String 

func (x *GHGetNeighborsResponse) String() string

type GHMembersRequest 

type GHMembersRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GHMembersRequest) Descriptor deprecated 

func (*GHMembersRequest) Descriptor() ([]byte, []int)

Deprecated: Use GHMembersRequest.ProtoReflect.Descriptor instead.

func (*GHMembersRequest) GetKey 

func (x *GHMembersRequest) GetKey() []byte

func (*GHMembersRequest) ProtoMessage 

func (*GHMembersRequest) ProtoMessage()

func (*GHMembersRequest) ProtoReflect 

func (x *GHMembersRequest) ProtoReflect() protoreflect.Message

func (*GHMembersRequest) Reset 

func (x *GHMembersRequest) Reset()

func (*GHMembersRequest) String 

func (x *GHMembersRequest) String() string

type GHMembersResponse 

type GHMembersResponse struct {
	Points []*Point `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

func (*GHMembersResponse) Descriptor deprecated 

func (*GHMembersResponse) Descriptor() ([]byte, []int)

Deprecated: Use GHMembersResponse.ProtoReflect.Descriptor instead.

func (*GHMembersResponse) GetPoints 

func (x *GHMembersResponse) GetPoints() []*Point

func (*GHMembersResponse) ProtoMessage 

func (*GHMembersResponse) ProtoMessage()

func (*GHMembersResponse) ProtoReflect 

func (x *GHMembersResponse) ProtoReflect() protoreflect.Message

func (*GHMembersResponse) Reset 

func (x *GHMembersResponse) Reset()

func (*GHMembersResponse) String 

func (x *GHMembersResponse) String() string

type GHPopRequest 

type GHPopRequest struct {
	Key []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Ids [][]byte `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GHPopRequest) Descriptor deprecated 

func (*GHPopRequest) Descriptor() ([]byte, []int)

Deprecated: Use GHPopRequest.ProtoReflect.Descriptor instead.

func (*GHPopRequest) GetIds 

func (x *GHPopRequest) GetIds() [][]byte

func (*GHPopRequest) GetKey 

func (x *GHPopRequest) GetKey() []byte

func (*GHPopRequest) ProtoMessage 

func (*GHPopRequest) ProtoMessage()

func (*GHPopRequest) ProtoReflect 

func (x *GHPopRequest) ProtoReflect() protoreflect.Message

func (*GHPopRequest) Reset 

func (x *GHPopRequest) Reset()

func (*GHPopRequest) String 

func (x *GHPopRequest) String() string

type GHPopResponse 

type GHPopResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*GHPopResponse) Descriptor deprecated 

func (*GHPopResponse) Descriptor() ([]byte, []int)

Deprecated: Use GHPopResponse.ProtoReflect.Descriptor instead.

func (*GHPopResponse) GetSuccess 

func (x *GHPopResponse) GetSuccess() bool

func (*GHPopResponse) ProtoMessage 

func (*GHPopResponse) ProtoMessage()

func (*GHPopResponse) ProtoReflect 

func (x *GHPopResponse) ProtoReflect() protoreflect.Message

func (*GHPopResponse) Reset 

func (x *GHPopResponse) Reset()

func (*GHPopResponse) String 

func (x *GHPopResponse) String() string

type GetRequest 

type GetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() []byte

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

func (*GetResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetValue 

func (x *GetResponse) GetValue() []byte

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type HLLAddRequest 

type HLLAddRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*HLLAddRequest) Descriptor deprecated 

func (*HLLAddRequest) Descriptor() ([]byte, []int)

Deprecated: Use HLLAddRequest.ProtoReflect.Descriptor instead.

func (*HLLAddRequest) GetKey 

func (x *HLLAddRequest) GetKey() []byte

func (*HLLAddRequest) GetValues 

func (x *HLLAddRequest) GetValues() [][]byte

func (*HLLAddRequest) ProtoMessage 

func (*HLLAddRequest) ProtoMessage()

func (*HLLAddRequest) ProtoReflect 

func (x *HLLAddRequest) ProtoReflect() protoreflect.Message

func (*HLLAddRequest) Reset 

func (x *HLLAddRequest) Reset()

func (*HLLAddRequest) String 

func (x *HLLAddRequest) String() string

type HLLAddResponse 

type HLLAddResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*HLLAddResponse) Descriptor deprecated 

func (*HLLAddResponse) Descriptor() ([]byte, []int)

Deprecated: Use HLLAddResponse.ProtoReflect.Descriptor instead.

func (*HLLAddResponse) GetSuccess 

func (x *HLLAddResponse) GetSuccess() bool

func (*HLLAddResponse) ProtoMessage 

func (*HLLAddResponse) ProtoMessage()

func (*HLLAddResponse) ProtoReflect 

func (x *HLLAddResponse) ProtoReflect() protoreflect.Message

func (*HLLAddResponse) Reset 

func (x *HLLAddResponse) Reset()

func (*HLLAddResponse) String 

func (x *HLLAddResponse) String() string

type HLLCountRequest 

type HLLCountRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*HLLCountRequest) Descriptor deprecated 

func (*HLLCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use HLLCountRequest.ProtoReflect.Descriptor instead.

func (*HLLCountRequest) GetKey 

func (x *HLLCountRequest) GetKey() []byte

func (*HLLCountRequest) ProtoMessage 

func (*HLLCountRequest) ProtoMessage()

func (*HLLCountRequest) ProtoReflect 

func (x *HLLCountRequest) ProtoReflect() protoreflect.Message

func (*HLLCountRequest) Reset 

func (x *HLLCountRequest) Reset()

func (*HLLCountRequest) String 

func (x *HLLCountRequest) String() string

type HLLCountResponse 

type HLLCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*HLLCountResponse) Descriptor deprecated 

func (*HLLCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use HLLCountResponse.ProtoReflect.Descriptor instead.

func (*HLLCountResponse) GetCount 

func (x *HLLCountResponse) GetCount() uint32

func (*HLLCountResponse) ProtoMessage 

func (*HLLCountResponse) ProtoMessage()

func (*HLLCountResponse) ProtoReflect 

func (x *HLLCountResponse) ProtoReflect() protoreflect.Message

func (*HLLCountResponse) Reset 

func (x *HLLCountResponse) Reset()

func (*HLLCountResponse) String 

func (x *HLLCountResponse) String() string

type HLLCreateRequest 

type HLLCreateRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*HLLCreateRequest) Descriptor deprecated 

func (*HLLCreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use HLLCreateRequest.ProtoReflect.Descriptor instead.

func (*HLLCreateRequest) GetKey 

func (x *HLLCreateRequest) GetKey() []byte

func (*HLLCreateRequest) ProtoMessage 

func (*HLLCreateRequest) ProtoMessage()

func (*HLLCreateRequest) ProtoReflect 

func (x *HLLCreateRequest) ProtoReflect() protoreflect.Message

func (*HLLCreateRequest) Reset 

func (x *HLLCreateRequest) Reset()

func (*HLLCreateRequest) String 

func (x *HLLCreateRequest) String() string

type HLLCreateResponse 

type HLLCreateResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*HLLCreateResponse) Descriptor deprecated 

func (*HLLCreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use HLLCreateResponse.ProtoReflect.Descriptor instead.

func (*HLLCreateResponse) GetSuccess 

func (x *HLLCreateResponse) GetSuccess() bool

func (*HLLCreateResponse) ProtoMessage 

func (*HLLCreateResponse) ProtoMessage()

func (*HLLCreateResponse) ProtoReflect 

func (x *HLLCreateResponse) ProtoReflect() protoreflect.Message

func (*HLLCreateResponse) Reset 

func (x *HLLCreateResponse) Reset()

func (*HLLCreateResponse) String 

func (x *HLLCreateResponse) String() string

type HLLDelRequest 

type HLLDelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*HLLDelRequest) Descriptor deprecated 

func (*HLLDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use HLLDelRequest.ProtoReflect.Descriptor instead.

func (*HLLDelRequest) GetKey 

func (x *HLLDelRequest) GetKey() []byte

func (*HLLDelRequest) ProtoMessage 

func (*HLLDelRequest) ProtoMessage()

func (*HLLDelRequest) ProtoReflect 

func (x *HLLDelRequest) ProtoReflect() protoreflect.Message

func (*HLLDelRequest) Reset 

func (x *HLLDelRequest) Reset()

func (*HLLDelRequest) String 

func (x *HLLDelRequest) String() string

type HLLDelResponse 

type HLLDelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*HLLDelResponse) Descriptor deprecated 

func (*HLLDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use HLLDelResponse.ProtoReflect.Descriptor instead.

func (*HLLDelResponse) GetSuccess 

func (x *HLLDelResponse) GetSuccess() bool

func (*HLLDelResponse) ProtoMessage 

func (*HLLDelResponse) ProtoMessage()

func (*HLLDelResponse) ProtoReflect 

func (x *HLLDelResponse) ProtoReflect() protoreflect.Message

func (*HLLDelResponse) Reset 

func (x *HLLDelResponse) Reset()

func (*HLLDelResponse) String 

func (x *HLLDelResponse) String() string

type IncrRequest 

type IncrRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Delta int32  `protobuf:"varint,2,opt,name=delta,proto3" json:"delta,omitempty"`
	// contains filtered or unexported fields
}

func (*IncrRequest) Descriptor deprecated 

func (*IncrRequest) Descriptor() ([]byte, []int)

Deprecated: Use IncrRequest.ProtoReflect.Descriptor instead.

func (*IncrRequest) GetDelta 

func (x *IncrRequest) GetDelta() int32

func (*IncrRequest) GetKey 

func (x *IncrRequest) GetKey() []byte

func (*IncrRequest) ProtoMessage 

func (*IncrRequest) ProtoMessage()

func (*IncrRequest) ProtoReflect 

func (x *IncrRequest) ProtoReflect() protoreflect.Message

func (*IncrRequest) Reset 

func (x *IncrRequest) Reset()

func (*IncrRequest) String 

func (x *IncrRequest) String() string

type IncrResponse 

type IncrResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*IncrResponse) Descriptor deprecated 

func (*IncrResponse) Descriptor() ([]byte, []int)

Deprecated: Use IncrResponse.ProtoReflect.Descriptor instead.

func (*IncrResponse) GetSuccess 

func (x *IncrResponse) GetSuccess() bool

func (*IncrResponse) ProtoMessage 

func (*IncrResponse) ProtoMessage()

func (*IncrResponse) ProtoReflect 

func (x *IncrResponse) ProtoReflect() protoreflect.Message

func (*IncrResponse) Reset 

func (x *IncrResponse) Reset()

func (*IncrResponse) String 

func (x *IncrResponse) String() string

type Index 

type Index struct {
	Name  []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Index) Descriptor deprecated 

func (*Index) Descriptor() ([]byte, []int)

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetName 

func (x *Index) GetName() []byte

func (*Index) GetValue 

func (x *Index) GetValue() []byte

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) ProtoReflect 

func (x *Index) ProtoReflect() protoreflect.Message

func (*Index) Reset 

func (x *Index) Reset()

func (*Index) String 

func (x *Index) String() string

type LCountRequest 

type LCountRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*LCountRequest) Descriptor deprecated 

func (*LCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use LCountRequest.ProtoReflect.Descriptor instead.

func (*LCountRequest) GetKey 

func (x *LCountRequest) GetKey() []byte

func (*LCountRequest) ProtoMessage 

func (*LCountRequest) ProtoMessage()

func (*LCountRequest) ProtoReflect 

func (x *LCountRequest) ProtoReflect() protoreflect.Message

func (*LCountRequest) Reset 

func (x *LCountRequest) Reset()

func (*LCountRequest) String 

func (x *LCountRequest) String() string

type LCountResponse 

type LCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*LCountResponse) Descriptor deprecated 

func (*LCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use LCountResponse.ProtoReflect.Descriptor instead.

func (*LCountResponse) GetCount 

func (x *LCountResponse) GetCount() uint32

func (*LCountResponse) ProtoMessage 

func (*LCountResponse) ProtoMessage()

func (*LCountResponse) ProtoReflect 

func (x *LCountResponse) ProtoReflect() protoreflect.Message

func (*LCountResponse) Reset 

func (x *LCountResponse) Reset()

func (*LCountResponse) String 

func (x *LCountResponse) String() string

type LDelRequest 

type LDelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*LDelRequest) Descriptor deprecated 

func (*LDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use LDelRequest.ProtoReflect.Descriptor instead.

func (*LDelRequest) GetKey 

func (x *LDelRequest) GetKey() []byte

func (*LDelRequest) ProtoMessage 

func (*LDelRequest) ProtoMessage()

func (*LDelRequest) ProtoReflect 

func (x *LDelRequest) ProtoReflect() protoreflect.Message

func (*LDelRequest) Reset 

func (x *LDelRequest) Reset()

func (*LDelRequest) String 

func (x *LDelRequest) String() string

type LDelResponse 

type LDelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*LDelResponse) Descriptor deprecated 

func (*LDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use LDelResponse.ProtoReflect.Descriptor instead.

func (*LDelResponse) GetSuccess 

func (x *LDelResponse) GetSuccess() bool

func (*LDelResponse) ProtoMessage 

func (*LDelResponse) ProtoMessage()

func (*LDelResponse) ProtoReflect 

func (x *LDelResponse) ProtoReflect() protoreflect.Message

func (*LDelResponse) Reset 

func (x *LDelResponse) Reset()

func (*LDelResponse) String 

func (x *LDelResponse) String() string

type LExistRequest 

type LExistRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LExistRequest) Descriptor deprecated 

func (*LExistRequest) Descriptor() ([]byte, []int)

Deprecated: Use LExistRequest.ProtoReflect.Descriptor instead.

func (*LExistRequest) GetKey 

func (x *LExistRequest) GetKey() []byte

func (*LExistRequest) GetValues 

func (x *LExistRequest) GetValues() [][]byte

func (*LExistRequest) ProtoMessage 

func (*LExistRequest) ProtoMessage()

func (*LExistRequest) ProtoReflect 

func (x *LExistRequest) ProtoReflect() protoreflect.Message

func (*LExistRequest) Reset 

func (x *LExistRequest) Reset()

func (*LExistRequest) String 

func (x *LExistRequest) String() string

type LExistResponse 

type LExistResponse struct {
	Exists []bool `protobuf:"varint,1,rep,packed,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*LExistResponse) Descriptor deprecated 

func (*LExistResponse) Descriptor() ([]byte, []int)

Deprecated: Use LExistResponse.ProtoReflect.Descriptor instead.

func (*LExistResponse) GetExists 

func (x *LExistResponse) GetExists() []bool

func (*LExistResponse) ProtoMessage 

func (*LExistResponse) ProtoMessage()

func (*LExistResponse) ProtoReflect 

func (x *LExistResponse) ProtoReflect() protoreflect.Message

func (*LExistResponse) Reset 

func (x *LExistResponse) Reset()

func (*LExistResponse) String 

func (x *LExistResponse) String() string

type LLPushRequest 

type LLPushRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LLPushRequest) Descriptor deprecated 

func (*LLPushRequest) Descriptor() ([]byte, []int)

Deprecated: Use LLPushRequest.ProtoReflect.Descriptor instead.

func (*LLPushRequest) GetKey 

func (x *LLPushRequest) GetKey() []byte

func (*LLPushRequest) GetValues 

func (x *LLPushRequest) GetValues() [][]byte

func (*LLPushRequest) ProtoMessage 

func (*LLPushRequest) ProtoMessage()

func (*LLPushRequest) ProtoReflect 

func (x *LLPushRequest) ProtoReflect() protoreflect.Message

func (*LLPushRequest) Reset 

func (x *LLPushRequest) Reset()

func (*LLPushRequest) String 

func (x *LLPushRequest) String() string

type LLPushResponse 

type LLPushResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*LLPushResponse) Descriptor deprecated 

func (*LLPushResponse) Descriptor() ([]byte, []int)

Deprecated: Use LLPushResponse.ProtoReflect.Descriptor instead.

func (*LLPushResponse) GetSuccess 

func (x *LLPushResponse) GetSuccess() bool

func (*LLPushResponse) ProtoMessage 

func (*LLPushResponse) ProtoMessage()

func (*LLPushResponse) ProtoReflect 

func (x *LLPushResponse) ProtoReflect() protoreflect.Message

func (*LLPushResponse) Reset 

func (x *LLPushResponse) Reset()

func (*LLPushResponse) String 

func (x *LLPushResponse) String() string

type LMembersRequest 

type LMembersRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*LMembersRequest) Descriptor deprecated 

func (*LMembersRequest) Descriptor() ([]byte, []int)

Deprecated: Use LMembersRequest.ProtoReflect.Descriptor instead.

func (*LMembersRequest) GetKey 

func (x *LMembersRequest) GetKey() []byte

func (*LMembersRequest) ProtoMessage 

func (*LMembersRequest) ProtoMessage()

func (*LMembersRequest) ProtoReflect 

func (x *LMembersRequest) ProtoReflect() protoreflect.Message

func (*LMembersRequest) Reset 

func (x *LMembersRequest) Reset()

func (*LMembersRequest) String 

func (x *LMembersRequest) String() string

type LMembersResponse 

type LMembersResponse struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LMembersResponse) Descriptor deprecated 

func (*LMembersResponse) Descriptor() ([]byte, []int)

Deprecated: Use LMembersResponse.ProtoReflect.Descriptor instead.

func (*LMembersResponse) GetValues 

func (x *LMembersResponse) GetValues() [][]byte

func (*LMembersResponse) ProtoMessage 

func (*LMembersResponse) ProtoMessage()

func (*LMembersResponse) ProtoReflect 

func (x *LMembersResponse) ProtoReflect() protoreflect.Message

func (*LMembersResponse) Reset 

func (x *LMembersResponse) Reset()

func (*LMembersResponse) String 

func (x *LMembersResponse) String() string

type LPopRequest 

type LPopRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LPopRequest) Descriptor deprecated 

func (*LPopRequest) Descriptor() ([]byte, []int)

Deprecated: Use LPopRequest.ProtoReflect.Descriptor instead.

func (*LPopRequest) GetKey 

func (x *LPopRequest) GetKey() []byte

func (*LPopRequest) GetValues 

func (x *LPopRequest) GetValues() [][]byte

func (*LPopRequest) ProtoMessage 

func (*LPopRequest) ProtoMessage()

func (*LPopRequest) ProtoReflect 

func (x *LPopRequest) ProtoReflect() protoreflect.Message

func (*LPopRequest) Reset 

func (x *LPopRequest) Reset()

func (*LPopRequest) String 

func (x *LPopRequest) String() string

type LPopResponse 

type LPopResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*LPopResponse) Descriptor deprecated 

func (*LPopResponse) Descriptor() ([]byte, []int)

Deprecated: Use LPopResponse.ProtoReflect.Descriptor instead.

func (*LPopResponse) GetSuccess 

func (x *LPopResponse) GetSuccess() bool

func (*LPopResponse) ProtoMessage 

func (*LPopResponse) ProtoMessage()

func (*LPopResponse) ProtoReflect 

func (x *LPopResponse) ProtoReflect() protoreflect.Message

func (*LPopResponse) Reset 

func (x *LPopResponse) Reset()

func (*LPopResponse) String 

func (x *LPopResponse) String() string

type LRPushRequest 

type LRPushRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LRPushRequest) Descriptor deprecated 

func (*LRPushRequest) Descriptor() ([]byte, []int)

Deprecated: Use LRPushRequest.ProtoReflect.Descriptor instead.

func (*LRPushRequest) GetKey 

func (x *LRPushRequest) GetKey() []byte

func (*LRPushRequest) GetValues 

func (x *LRPushRequest) GetValues() [][]byte

func (*LRPushRequest) ProtoMessage 

func (*LRPushRequest) ProtoMessage()

func (*LRPushRequest) ProtoReflect 

func (x *LRPushRequest) ProtoReflect() protoreflect.Message

func (*LRPushRequest) Reset 

func (x *LRPushRequest) Reset()

func (*LRPushRequest) String 

func (x *LRPushRequest) String() string

type LRPushResponse 

type LRPushResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*LRPushResponse) Descriptor deprecated 

func (*LRPushResponse) Descriptor() ([]byte, []int)

Deprecated: Use LRPushResponse.ProtoReflect.Descriptor instead.

func (*LRPushResponse) GetSuccess 

func (x *LRPushResponse) GetSuccess() bool

func (*LRPushResponse) ProtoMessage 

func (*LRPushResponse) ProtoMessage()

func (*LRPushResponse) ProtoReflect 

func (x *LRPushResponse) ProtoReflect() protoreflect.Message

func (*LRPushResponse) Reset 

func (x *LRPushResponse) Reset()

func (*LRPushResponse) String 

func (x *LRPushResponse) String() string

type LRangeRequest 

type LRangeRequest struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Offset int32  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit  uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*LRangeRequest) Descriptor deprecated 

func (*LRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use LRangeRequest.ProtoReflect.Descriptor instead.

func (*LRangeRequest) GetKey 

func (x *LRangeRequest) GetKey() []byte

func (*LRangeRequest) GetLimit 

func (x *LRangeRequest) GetLimit() uint32

func (*LRangeRequest) GetOffset 

func (x *LRangeRequest) GetOffset() int32

func (*LRangeRequest) ProtoMessage 

func (*LRangeRequest) ProtoMessage()

func (*LRangeRequest) ProtoReflect 

func (x *LRangeRequest) ProtoReflect() protoreflect.Message

func (*LRangeRequest) Reset 

func (x *LRangeRequest) Reset()

func (*LRangeRequest) String 

func (x *LRangeRequest) String() string

type LRangeResponse 

type LRangeResponse struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LRangeResponse) Descriptor deprecated 

func (*LRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use LRangeResponse.ProtoReflect.Descriptor instead.

func (*LRangeResponse) GetValues 

func (x *LRangeResponse) GetValues() [][]byte

func (*LRangeResponse) ProtoMessage 

func (*LRangeResponse) ProtoMessage()

func (*LRangeResponse) ProtoReflect 

func (x *LRangeResponse) ProtoReflect() protoreflect.Message

func (*LRangeResponse) Reset 

func (x *LRangeResponse) Reset()

func (*LRangeResponse) String 

func (x *LRangeResponse) String() string

type LogEntry 

type LogEntry struct {
	MethodName   string `protobuf:"bytes,1,opt,name=methodName,proto3" json:"methodName,omitempty"`
	RequestBytes []byte `protobuf:"bytes,2,opt,name=requestBytes,proto3" json:"requestBytes,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated 

func (*LogEntry) Descriptor() ([]byte, []int)

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetMethodName 

func (x *LogEntry) GetMethodName() string

func (*LogEntry) GetRequestBytes 

func (x *LogEntry) GetRequestBytes() []byte

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

func (x *LogEntry) ProtoReflect() protoreflect.Message

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type MCountRequest 

type MCountRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*MCountRequest) Descriptor deprecated 

func (*MCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use MCountRequest.ProtoReflect.Descriptor instead.

func (*MCountRequest) GetKey 

func (x *MCountRequest) GetKey() []byte

func (*MCountRequest) ProtoMessage 

func (*MCountRequest) ProtoMessage()

func (*MCountRequest) ProtoReflect 

func (x *MCountRequest) ProtoReflect() protoreflect.Message

func (*MCountRequest) Reset 

func (x *MCountRequest) Reset()

func (*MCountRequest) String 

func (x *MCountRequest) String() string

type MCountResponse 

type MCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*MCountResponse) Descriptor deprecated 

func (*MCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use MCountResponse.ProtoReflect.Descriptor instead.

func (*MCountResponse) GetCount 

func (x *MCountResponse) GetCount() uint32

func (*MCountResponse) ProtoMessage 

func (*MCountResponse) ProtoMessage()

func (*MCountResponse) ProtoReflect 

func (x *MCountResponse) ProtoReflect() protoreflect.Message

func (*MCountResponse) Reset 

func (x *MCountResponse) Reset()

func (*MCountResponse) String 

func (x *MCountResponse) String() string

type MDelRequest 

type MDelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*MDelRequest) Descriptor deprecated 

func (*MDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use MDelRequest.ProtoReflect.Descriptor instead.

func (*MDelRequest) GetKey 

func (x *MDelRequest) GetKey() []byte

func (*MDelRequest) ProtoMessage 

func (*MDelRequest) ProtoMessage()

func (*MDelRequest) ProtoReflect 

func (x *MDelRequest) ProtoReflect() protoreflect.Message

func (*MDelRequest) Reset 

func (x *MDelRequest) Reset()

func (*MDelRequest) String 

func (x *MDelRequest) String() string

type MDelResponse 

type MDelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*MDelResponse) Descriptor deprecated 

func (*MDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use MDelResponse.ProtoReflect.Descriptor instead.

func (*MDelResponse) GetSuccess 

func (x *MDelResponse) GetSuccess() bool

func (*MDelResponse) ProtoMessage 

func (*MDelResponse) ProtoMessage()

func (*MDelResponse) ProtoReflect 

func (x *MDelResponse) ProtoReflect() protoreflect.Message

func (*MDelResponse) Reset 

func (x *MDelResponse) Reset()

func (*MDelResponse) String 

func (x *MDelResponse) String() string

type MExistRequest 

type MExistRequest struct {
	Key  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Keys [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*MExistRequest) Descriptor deprecated 

func (*MExistRequest) Descriptor() ([]byte, []int)

Deprecated: Use MExistRequest.ProtoReflect.Descriptor instead.

func (*MExistRequest) GetKey 

func (x *MExistRequest) GetKey() []byte

func (*MExistRequest) GetKeys 

func (x *MExistRequest) GetKeys() [][]byte

func (*MExistRequest) ProtoMessage 

func (*MExistRequest) ProtoMessage()

func (*MExistRequest) ProtoReflect 

func (x *MExistRequest) ProtoReflect() protoreflect.Message

func (*MExistRequest) Reset 

func (x *MExistRequest) Reset()

func (*MExistRequest) String 

func (x *MExistRequest) String() string

type MExistResponse 

type MExistResponse struct {
	Exists []bool `protobuf:"varint,1,rep,packed,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*MExistResponse) Descriptor deprecated 

func (*MExistResponse) Descriptor() ([]byte, []int)

Deprecated: Use MExistResponse.ProtoReflect.Descriptor instead.

func (*MExistResponse) GetExists 

func (x *MExistResponse) GetExists() []bool

func (*MExistResponse) ProtoMessage 

func (*MExistResponse) ProtoMessage()

func (*MExistResponse) ProtoReflect 

func (x *MExistResponse) ProtoReflect() protoreflect.Message

func (*MExistResponse) Reset 

func (x *MExistResponse) Reset()

func (*MExistResponse) String 

func (x *MExistResponse) String() string

type MGetRequest 

type MGetRequest struct {
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*MGetRequest) Descriptor deprecated 

func (*MGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use MGetRequest.ProtoReflect.Descriptor instead.

func (*MGetRequest) GetKeys 

func (x *MGetRequest) GetKeys() [][]byte

func (*MGetRequest) ProtoMessage 

func (*MGetRequest) ProtoMessage()

func (*MGetRequest) ProtoReflect 

func (x *MGetRequest) ProtoReflect() protoreflect.Message

func (*MGetRequest) Reset 

func (x *MGetRequest) Reset()

func (*MGetRequest) String 

func (x *MGetRequest) String() string

type MGetResponse 

type MGetResponse struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*MGetResponse) Descriptor deprecated 

func (*MGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use MGetResponse.ProtoReflect.Descriptor instead.

func (*MGetResponse) GetValues 

func (x *MGetResponse) GetValues() [][]byte

func (*MGetResponse) ProtoMessage 

func (*MGetResponse) ProtoMessage()

func (*MGetResponse) ProtoReflect 

func (x *MGetResponse) ProtoReflect() protoreflect.Message

func (*MGetResponse) Reset 

func (x *MGetResponse) Reset()

func (*MGetResponse) String 

func (x *MGetResponse) String() string

type MMembersRequest 

type MMembersRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*MMembersRequest) Descriptor deprecated 

func (*MMembersRequest) Descriptor() ([]byte, []int)

Deprecated: Use MMembersRequest.ProtoReflect.Descriptor instead.

func (*MMembersRequest) GetKey 

func (x *MMembersRequest) GetKey() []byte

func (*MMembersRequest) ProtoMessage 

func (*MMembersRequest) ProtoMessage()

func (*MMembersRequest) ProtoReflect 

func (x *MMembersRequest) ProtoReflect() protoreflect.Message

func (*MMembersRequest) Reset 

func (x *MMembersRequest) Reset()

func (*MMembersRequest) String 

func (x *MMembersRequest) String() string

type MMembersResponse 

type MMembersResponse struct {
	Pairs []*Pair `protobuf:"bytes,1,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*MMembersResponse) Descriptor deprecated 

func (*MMembersResponse) Descriptor() ([]byte, []int)

Deprecated: Use MMembersResponse.ProtoReflect.Descriptor instead.

func (*MMembersResponse) GetPairs 

func (x *MMembersResponse) GetPairs() []*Pair

func (*MMembersResponse) ProtoMessage 

func (*MMembersResponse) ProtoMessage()

func (*MMembersResponse) ProtoReflect 

func (x *MMembersResponse) ProtoReflect() protoreflect.Message

func (*MMembersResponse) Reset 

func (x *MMembersResponse) Reset()

func (*MMembersResponse) String 

func (x *MMembersResponse) String() string

type MPopRequest 

type MPopRequest struct {
	Key  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Keys [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*MPopRequest) Descriptor deprecated 

func (*MPopRequest) Descriptor() ([]byte, []int)

Deprecated: Use MPopRequest.ProtoReflect.Descriptor instead.

func (*MPopRequest) GetKey 

func (x *MPopRequest) GetKey() []byte

func (*MPopRequest) GetKeys 

func (x *MPopRequest) GetKeys() [][]byte

func (*MPopRequest) ProtoMessage 

func (*MPopRequest) ProtoMessage()

func (*MPopRequest) ProtoReflect 

func (x *MPopRequest) ProtoReflect() protoreflect.Message

func (*MPopRequest) Reset 

func (x *MPopRequest) Reset()

func (*MPopRequest) String 

func (x *MPopRequest) String() string

type MPopResponse 

type MPopResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*MPopResponse) Descriptor deprecated 

func (*MPopResponse) Descriptor() ([]byte, []int)

Deprecated: Use MPopResponse.ProtoReflect.Descriptor instead.

func (*MPopResponse) GetSuccess 

func (x *MPopResponse) GetSuccess() bool

func (*MPopResponse) ProtoMessage 

func (*MPopResponse) ProtoMessage()

func (*MPopResponse) ProtoReflect 

func (x *MPopResponse) ProtoReflect() protoreflect.Message

func (*MPopResponse) Reset 

func (x *MPopResponse) Reset()

func (*MPopResponse) String 

func (x *MPopResponse) String() string

type MPushRequest 

type MPushRequest struct {
	Key   []byte  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Pairs []*Pair `protobuf:"bytes,2,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*MPushRequest) Descriptor deprecated 

func (*MPushRequest) Descriptor() ([]byte, []int)

Deprecated: Use MPushRequest.ProtoReflect.Descriptor instead.

func (*MPushRequest) GetKey 

func (x *MPushRequest) GetKey() []byte

func (*MPushRequest) GetPairs 

func (x *MPushRequest) GetPairs() []*Pair

func (*MPushRequest) ProtoMessage 

func (*MPushRequest) ProtoMessage()

func (*MPushRequest) ProtoReflect 

func (x *MPushRequest) ProtoReflect() protoreflect.Message

func (*MPushRequest) Reset 

func (x *MPushRequest) Reset()

func (*MPushRequest) String 

func (x *MPushRequest) String() string

type MPushResponse 

type MPushResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*MPushResponse) Descriptor deprecated 

func (*MPushResponse) Descriptor() ([]byte, []int)

Deprecated: Use MPushResponse.ProtoReflect.Descriptor instead.

func (*MPushResponse) GetSuccess 

func (x *MPushResponse) GetSuccess() bool

func (*MPushResponse) ProtoMessage 

func (*MPushResponse) ProtoMessage()

func (*MPushResponse) ProtoReflect 

func (x *MPushResponse) ProtoReflect() protoreflect.Message

func (*MPushResponse) Reset 

func (x *MPushResponse) Reset()

func (*MPushResponse) String 

func (x *MPushResponse) String() string

type MSetRequest 

type MSetRequest struct {
	Keys   [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*MSetRequest) Descriptor deprecated 

func (*MSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use MSetRequest.ProtoReflect.Descriptor instead.

func (*MSetRequest) GetKeys 

func (x *MSetRequest) GetKeys() [][]byte

func (*MSetRequest) GetValues 

func (x *MSetRequest) GetValues() [][]byte

func (*MSetRequest) ProtoMessage 

func (*MSetRequest) ProtoMessage()

func (*MSetRequest) ProtoReflect 

func (x *MSetRequest) ProtoReflect() protoreflect.Message

func (*MSetRequest) Reset 

func (x *MSetRequest) Reset()

func (*MSetRequest) String 

func (x *MSetRequest) String() string

type MSetResponse 

type MSetResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*MSetResponse) Descriptor deprecated 

func (*MSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use MSetResponse.ProtoReflect.Descriptor instead.

func (*MSetResponse) GetSuccess 

func (x *MSetResponse) GetSuccess() bool

func (*MSetResponse) ProtoMessage 

func (*MSetResponse) ProtoMessage()

func (*MSetResponse) ProtoReflect 

func (x *MSetResponse) ProtoReflect() protoreflect.Message

func (*MSetResponse) Reset 

func (x *MSetResponse) Reset()

func (*MSetResponse) String 

func (x *MSetResponse) String() string

type Message 

type Message struct {
	Topic   []byte `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

func (*Message) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetPayload 

func (x *Message) GetPayload() []byte

func (*Message) GetTopic 

func (x *Message) GetTopic() []byte

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type PListRequest 

type PListRequest struct {
	DataType DataType `protobuf:"varint,1,opt,name=dataType,proto3,enum=proto.DataType" json:"dataType,omitempty"`
	Key      []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Offset   int32    `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit    uint32   `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*PListRequest) Descriptor deprecated 

func (*PListRequest) Descriptor() ([]byte, []int)

Deprecated: Use PListRequest.ProtoReflect.Descriptor instead.

func (*PListRequest) GetDataType 

func (x *PListRequest) GetDataType() DataType

func (*PListRequest) GetKey 

func (x *PListRequest) GetKey() []byte

func (*PListRequest) GetLimit 

func (x *PListRequest) GetLimit() uint32

func (*PListRequest) GetOffset 

func (x *PListRequest) GetOffset() int32

func (*PListRequest) ProtoMessage 

func (*PListRequest) ProtoMessage()

func (*PListRequest) ProtoReflect 

func (x *PListRequest) ProtoReflect() protoreflect.Message

func (*PListRequest) Reset 

func (x *PListRequest) Reset()

func (*PListRequest) String 

func (x *PListRequest) String() string

type PListResponse 

type PListResponse struct {
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*PListResponse) Descriptor deprecated 

func (*PListResponse) Descriptor() ([]byte, []int)

Deprecated: Use PListResponse.ProtoReflect.Descriptor instead.

func (*PListResponse) GetKeys 

func (x *PListResponse) GetKeys() [][]byte

func (*PListResponse) ProtoMessage 

func (*PListResponse) ProtoMessage()

func (*PListResponse) ProtoReflect 

func (x *PListResponse) ProtoReflect() protoreflect.Message

func (*PListResponse) Reset 

func (x *PListResponse) Reset()

func (*PListResponse) String 

func (x *PListResponse) String() string

type Pair 

type Pair struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Pair) Descriptor deprecated 

func (*Pair) Descriptor() ([]byte, []int)

Deprecated: Use Pair.ProtoReflect.Descriptor instead.

func (*Pair) GetKey 

func (x *Pair) GetKey() []byte

func (*Pair) GetValue 

func (x *Pair) GetValue() []byte

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) ProtoReflect 

func (x *Pair) ProtoReflect() protoreflect.Message

func (*Pair) Reset 

func (x *Pair) Reset()

func (*Pair) String 

func (x *Pair) String() string

type Point 

type Point struct {
	Id        []byte  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Latitude  float64 `protobuf:"fixed64,2,opt,name=latitude,proto3" json:"latitude,omitempty"`
	Longitude float64 `protobuf:"fixed64,3,opt,name=longitude,proto3" json:"longitude,omitempty"`
	Distance  uint64  `protobuf:"varint,4,opt,name=distance,proto3" json:"distance,omitempty"`
	// contains filtered or unexported fields
}

func (*Point) Descriptor deprecated 

func (*Point) Descriptor() ([]byte, []int)

Deprecated: Use Point.ProtoReflect.Descriptor instead.

func (*Point) GetDistance 

func (x *Point) GetDistance() uint64

func (*Point) GetId 

func (x *Point) GetId() []byte

func (*Point) GetLatitude 

func (x *Point) GetLatitude() float64

func (*Point) GetLongitude 

func (x *Point) GetLongitude() float64

func (*Point) ProtoMessage 

func (*Point) ProtoMessage()

func (*Point) ProtoReflect 

func (x *Point) ProtoReflect() protoreflect.Message

func (*Point) Reset 

func (x *Point) Reset()

func (*Point) String 

func (x *Point) String() string

type PublishRequest 

type PublishRequest struct {
	Topic   []byte `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated 

func (*PublishRequest) Descriptor() ([]byte, []int)

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetPayload 

func (x *PublishRequest) GetPayload() []byte

func (*PublishRequest) GetTopic 

func (x *PublishRequest) GetTopic() []byte

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

func (x *PublishRequest) ProtoReflect() protoreflect.Message

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishResponse 

type PublishResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResponse) Descriptor deprecated 

func (*PublishResponse) Descriptor() ([]byte, []int)

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetSuccess 

func (x *PublishResponse) GetSuccess() bool

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

func (x *PublishResponse) ProtoReflect() protoreflect.Message

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type Row 

type Row struct {
	DataType DataType `protobuf:"varint,1,opt,name=dataType,proto3,enum=proto.DataType" json:"dataType,omitempty"`
	Key      []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Id       []byte   `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Indexes  []*Index `protobuf:"bytes,4,rep,name=indexes,proto3" json:"indexes,omitempty"`
	Value    []byte   `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Row) Descriptor deprecated 

func (*Row) Descriptor() ([]byte, []int)

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetDataType 

func (x *Row) GetDataType() DataType

func (*Row) GetId 

func (x *Row) GetId() []byte

func (*Row) GetIndexes 

func (x *Row) GetIndexes() []*Index

func (*Row) GetKey 

func (x *Row) GetKey() []byte

func (*Row) GetValue 

func (x *Row) GetValue() []byte

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect 

func (x *Row) ProtoReflect() protoreflect.Message

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) String 

func (x *Row) String() string

type SCountRequest 

type SCountRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*SCountRequest) Descriptor deprecated 

func (*SCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use SCountRequest.ProtoReflect.Descriptor instead.

func (*SCountRequest) GetKey 

func (x *SCountRequest) GetKey() []byte

func (*SCountRequest) ProtoMessage 

func (*SCountRequest) ProtoMessage()

func (*SCountRequest) ProtoReflect 

func (x *SCountRequest) ProtoReflect() protoreflect.Message

func (*SCountRequest) Reset 

func (x *SCountRequest) Reset()

func (*SCountRequest) String 

func (x *SCountRequest) String() string

type SCountResponse 

type SCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*SCountResponse) Descriptor deprecated 

func (*SCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use SCountResponse.ProtoReflect.Descriptor instead.

func (*SCountResponse) GetCount 

func (x *SCountResponse) GetCount() uint32

func (*SCountResponse) ProtoMessage 

func (*SCountResponse) ProtoMessage()

func (*SCountResponse) ProtoReflect 

func (x *SCountResponse) ProtoReflect() protoreflect.Message

func (*SCountResponse) Reset 

func (x *SCountResponse) Reset()

func (*SCountResponse) String 

func (x *SCountResponse) String() string

type SDBClient 

type SDBClient interface {
	// string 类型的存储
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	MSet(ctx context.Context, in *MSetRequest, opts ...grpc.CallOption) (*MSetResponse, error)
	SetNX(ctx context.Context, in *SetNXRequest, opts ...grpc.CallOption) (*SetNXResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	MGet(ctx context.Context, in *MGetRequest, opts ...grpc.CallOption) (*MGetResponse, error)
	Del(ctx context.Context, in *DelRequest, opts ...grpc.CallOption) (*DelResponse, error)
	Incr(ctx context.Context, in *IncrRequest, opts ...grpc.CallOption) (*IncrResponse, error)
	// list 类型的存储
	LRPush(ctx context.Context, in *LRPushRequest, opts ...grpc.CallOption) (*LRPushResponse, error)
	LLPush(ctx context.Context, in *LLPushRequest, opts ...grpc.CallOption) (*LLPushResponse, error)
	LPop(ctx context.Context, in *LPopRequest, opts ...grpc.CallOption) (*LPopResponse, error)
	LRange(ctx context.Context, in *LRangeRequest, opts ...grpc.CallOption) (*LRangeResponse, error)
	LExist(ctx context.Context, in *LExistRequest, opts ...grpc.CallOption) (*LExistResponse, error)
	LDel(ctx context.Context, in *LDelRequest, opts ...grpc.CallOption) (*LDelResponse, error)
	LCount(ctx context.Context, in *LCountRequest, opts ...grpc.CallOption) (*LCountResponse, error)
	LMembers(ctx context.Context, in *LMembersRequest, opts ...grpc.CallOption) (*LMembersResponse, error)
	// set 类型的存储
	SPush(ctx context.Context, in *SPushRequest, opts ...grpc.CallOption) (*SPushResponse, error)
	SPop(ctx context.Context, in *SPopRequest, opts ...grpc.CallOption) (*SPopResponse, error)
	SExist(ctx context.Context, in *SExistRequest, opts ...grpc.CallOption) (*SExistResponse, error)
	SDel(ctx context.Context, in *SDelRequest, opts ...grpc.CallOption) (*SDelResponse, error)
	SCount(ctx context.Context, in *SCountRequest, opts ...grpc.CallOption) (*SCountResponse, error)
	SMembers(ctx context.Context, in *SMembersRequest, opts ...grpc.CallOption) (*SMembersResponse, error)
	// sorted set 类型的存储
	ZPush(ctx context.Context, in *ZPushRequest, opts ...grpc.CallOption) (*ZPushResponse, error)
	ZPop(ctx context.Context, in *ZPopRequest, opts ...grpc.CallOption) (*ZPopResponse, error)
	ZRange(ctx context.Context, in *ZRangeRequest, opts ...grpc.CallOption) (*ZRangeResponse, error)
	ZExist(ctx context.Context, in *ZExistRequest, opts ...grpc.CallOption) (*ZExistResponse, error)
	ZDel(ctx context.Context, in *ZDelRequest, opts ...grpc.CallOption) (*ZDelResponse, error)
	ZCount(ctx context.Context, in *ZCountRequest, opts ...grpc.CallOption) (*ZCountResponse, error)
	ZMembers(ctx context.Context, in *ZMembersRequest, opts ...grpc.CallOption) (*ZMembersResponse, error)
	// bloom filter 类型的存储
	BFCreate(ctx context.Context, in *BFCreateRequest, opts ...grpc.CallOption) (*BFCreateResponse, error)
	BFDel(ctx context.Context, in *BFDelRequest, opts ...grpc.CallOption) (*BFDelResponse, error)
	BFAdd(ctx context.Context, in *BFAddRequest, opts ...grpc.CallOption) (*BFAddResponse, error)
	BFExist(ctx context.Context, in *BFExistRequest, opts ...grpc.CallOption) (*BFExistResponse, error)
	// hyper log log 类型的存储
	HLLCreate(ctx context.Context, in *HLLCreateRequest, opts ...grpc.CallOption) (*HLLCreateResponse, error)
	HLLDel(ctx context.Context, in *HLLDelRequest, opts ...grpc.CallOption) (*HLLDelResponse, error)
	HLLAdd(ctx context.Context, in *HLLAddRequest, opts ...grpc.CallOption) (*HLLAddResponse, error)
	HLLCount(ctx context.Context, in *HLLCountRequest, opts ...grpc.CallOption) (*HLLCountResponse, error)
	// bitset 类型的存储
	BSCreate(ctx context.Context, in *BSCreateRequest, opts ...grpc.CallOption) (*BSCreateResponse, error)
	BSDel(ctx context.Context, in *BSDelRequest, opts ...grpc.CallOption) (*BSDelResponse, error)
	BSSetRange(ctx context.Context, in *BSSetRangeRequest, opts ...grpc.CallOption) (*BSSetRangeResponse, error)
	BSMSet(ctx context.Context, in *BSMSetRequest, opts ...grpc.CallOption) (*BSMSetResponse, error)
	BSGetRange(ctx context.Context, in *BSGetRangeRequest, opts ...grpc.CallOption) (*BSGetRangeResponse, error)
	BSMGet(ctx context.Context, in *BSMGetRequest, opts ...grpc.CallOption) (*BSMGetResponse, error)
	BSCount(ctx context.Context, in *BSCountRequest, opts ...grpc.CallOption) (*BSCountResponse, error)
	BSCountRange(ctx context.Context, in *BSCountRangeRequest, opts ...grpc.CallOption) (*BSCountRangeResponse, error)
	// map 类型的存储
	MPush(ctx context.Context, in *MPushRequest, opts ...grpc.CallOption) (*MPushResponse, error)
	MPop(ctx context.Context, in *MPopRequest, opts ...grpc.CallOption) (*MPopResponse, error)
	MExist(ctx context.Context, in *MExistRequest, opts ...grpc.CallOption) (*MExistResponse, error)
	MDel(ctx context.Context, in *MDelRequest, opts ...grpc.CallOption) (*MDelResponse, error)
	MCount(ctx context.Context, in *MCountRequest, opts ...grpc.CallOption) (*MCountResponse, error)
	MMembers(ctx context.Context, in *MMembersRequest, opts ...grpc.CallOption) (*MMembersResponse, error)
	// geo hash 类型的存储
	GHCreate(ctx context.Context, in *GHCreateRequest, opts ...grpc.CallOption) (*GHCreateResponse, error)
	GHDel(ctx context.Context, in *GHDelRequest, opts ...grpc.CallOption) (*GHDelResponse, error)
	GHAdd(ctx context.Context, in *GHAddRequest, opts ...grpc.CallOption) (*GHAddResponse, error)
	GHPop(ctx context.Context, in *GHPopRequest, opts ...grpc.CallOption) (*GHPopResponse, error)
	GHGetBoxes(ctx context.Context, in *GHGetBoxesRequest, opts ...grpc.CallOption) (*GHGetBoxesResponse, error)
	GHGetNeighbors(ctx context.Context, in *GHGetNeighborsRequest, opts ...grpc.CallOption) (*GHGetNeighborsResponse, error)
	GHCount(ctx context.Context, in *GHCountRequest, opts ...grpc.CallOption) (*GHCountResponse, error)
	GHMembers(ctx context.Context, in *GHMembersRequest, opts ...grpc.CallOption) (*GHMembersResponse, error)
	// page 类型的存储
	PList(ctx context.Context, in *PListRequest, opts ...grpc.CallOption) (*PListResponse, error)
	// pub/sub
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (SDB_SubscribeClient, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
}

SDBClient is the client API for SDB service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSDBClient 

func NewSDBClient(cc grpc.ClientConnInterface) SDBClient

type SDBServer 

type SDBServer interface {
	// string 类型的存储
	Set(context.Context, *SetRequest) (*SetResponse, error)
	MSet(context.Context, *MSetRequest) (*MSetResponse, error)
	SetNX(context.Context, *SetNXRequest) (*SetNXResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	MGet(context.Context, *MGetRequest) (*MGetResponse, error)
	Del(context.Context, *DelRequest) (*DelResponse, error)
	Incr(context.Context, *IncrRequest) (*IncrResponse, error)
	// list 类型的存储
	LRPush(context.Context, *LRPushRequest) (*LRPushResponse, error)
	LLPush(context.Context, *LLPushRequest) (*LLPushResponse, error)
	LPop(context.Context, *LPopRequest) (*LPopResponse, error)
	LRange(context.Context, *LRangeRequest) (*LRangeResponse, error)
	LExist(context.Context, *LExistRequest) (*LExistResponse, error)
	LDel(context.Context, *LDelRequest) (*LDelResponse, error)
	LCount(context.Context, *LCountRequest) (*LCountResponse, error)
	LMembers(context.Context, *LMembersRequest) (*LMembersResponse, error)
	// set 类型的存储
	SPush(context.Context, *SPushRequest) (*SPushResponse, error)
	SPop(context.Context, *SPopRequest) (*SPopResponse, error)
	SExist(context.Context, *SExistRequest) (*SExistResponse, error)
	SDel(context.Context, *SDelRequest) (*SDelResponse, error)
	SCount(context.Context, *SCountRequest) (*SCountResponse, error)
	SMembers(context.Context, *SMembersRequest) (*SMembersResponse, error)
	// sorted set 类型的存储
	ZPush(context.Context, *ZPushRequest) (*ZPushResponse, error)
	ZPop(context.Context, *ZPopRequest) (*ZPopResponse, error)
	ZRange(context.Context, *ZRangeRequest) (*ZRangeResponse, error)
	ZExist(context.Context, *ZExistRequest) (*ZExistResponse, error)
	ZDel(context.Context, *ZDelRequest) (*ZDelResponse, error)
	ZCount(context.Context, *ZCountRequest) (*ZCountResponse, error)
	ZMembers(context.Context, *ZMembersRequest) (*ZMembersResponse, error)
	// bloom filter 类型的存储
	BFCreate(context.Context, *BFCreateRequest) (*BFCreateResponse, error)
	BFDel(context.Context, *BFDelRequest) (*BFDelResponse, error)
	BFAdd(context.Context, *BFAddRequest) (*BFAddResponse, error)
	BFExist(context.Context, *BFExistRequest) (*BFExistResponse, error)
	// hyper log log 类型的存储
	HLLCreate(context.Context, *HLLCreateRequest) (*HLLCreateResponse, error)
	HLLDel(context.Context, *HLLDelRequest) (*HLLDelResponse, error)
	HLLAdd(context.Context, *HLLAddRequest) (*HLLAddResponse, error)
	HLLCount(context.Context, *HLLCountRequest) (*HLLCountResponse, error)
	// bitset 类型的存储
	BSCreate(context.Context, *BSCreateRequest) (*BSCreateResponse, error)
	BSDel(context.Context, *BSDelRequest) (*BSDelResponse, error)
	BSSetRange(context.Context, *BSSetRangeRequest) (*BSSetRangeResponse, error)
	BSMSet(context.Context, *BSMSetRequest) (*BSMSetResponse, error)
	BSGetRange(context.Context, *BSGetRangeRequest) (*BSGetRangeResponse, error)
	BSMGet(context.Context, *BSMGetRequest) (*BSMGetResponse, error)
	BSCount(context.Context, *BSCountRequest) (*BSCountResponse, error)
	BSCountRange(context.Context, *BSCountRangeRequest) (*BSCountRangeResponse, error)
	// map 类型的存储
	MPush(context.Context, *MPushRequest) (*MPushResponse, error)
	MPop(context.Context, *MPopRequest) (*MPopResponse, error)
	MExist(context.Context, *MExistRequest) (*MExistResponse, error)
	MDel(context.Context, *MDelRequest) (*MDelResponse, error)
	MCount(context.Context, *MCountRequest) (*MCountResponse, error)
	MMembers(context.Context, *MMembersRequest) (*MMembersResponse, error)
	// geo hash 类型的存储
	GHCreate(context.Context, *GHCreateRequest) (*GHCreateResponse, error)
	GHDel(context.Context, *GHDelRequest) (*GHDelResponse, error)
	GHAdd(context.Context, *GHAddRequest) (*GHAddResponse, error)
	GHPop(context.Context, *GHPopRequest) (*GHPopResponse, error)
	GHGetBoxes(context.Context, *GHGetBoxesRequest) (*GHGetBoxesResponse, error)
	GHGetNeighbors(context.Context, *GHGetNeighborsRequest) (*GHGetNeighborsResponse, error)
	GHCount(context.Context, *GHCountRequest) (*GHCountResponse, error)
	GHMembers(context.Context, *GHMembersRequest) (*GHMembersResponse, error)
	// page 类型的存储
	PList(context.Context, *PListRequest) (*PListResponse, error)
	// pub/sub
	Subscribe(*SubscribeRequest, SDB_SubscribeServer) error
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
}

SDBServer is the server API for SDB service. All implementations should embed UnimplementedSDBServer for forward compatibility

type SDB_SubscribeClient 

type SDB_SubscribeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type SDB_SubscribeServer 

type SDB_SubscribeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type SDelRequest 

type SDelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*SDelRequest) Descriptor deprecated 

func (*SDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use SDelRequest.ProtoReflect.Descriptor instead.

func (*SDelRequest) GetKey 

func (x *SDelRequest) GetKey() []byte

func (*SDelRequest) ProtoMessage 

func (*SDelRequest) ProtoMessage()

func (*SDelRequest) ProtoReflect 

func (x *SDelRequest) ProtoReflect() protoreflect.Message

func (*SDelRequest) Reset 

func (x *SDelRequest) Reset()

func (*SDelRequest) String 

func (x *SDelRequest) String() string

type SDelResponse 

type SDelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*SDelResponse) Descriptor deprecated 

func (*SDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use SDelResponse.ProtoReflect.Descriptor instead.

func (*SDelResponse) GetSuccess 

func (x *SDelResponse) GetSuccess() bool

func (*SDelResponse) ProtoMessage 

func (*SDelResponse) ProtoMessage()

func (*SDelResponse) ProtoReflect 

func (x *SDelResponse) ProtoReflect() protoreflect.Message

func (*SDelResponse) Reset 

func (x *SDelResponse) Reset()

func (*SDelResponse) String 

func (x *SDelResponse) String() string

type SExistRequest 

type SExistRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*SExistRequest) Descriptor deprecated 

func (*SExistRequest) Descriptor() ([]byte, []int)

Deprecated: Use SExistRequest.ProtoReflect.Descriptor instead.

func (*SExistRequest) GetKey 

func (x *SExistRequest) GetKey() []byte

func (*SExistRequest) GetValues 

func (x *SExistRequest) GetValues() [][]byte

func (*SExistRequest) ProtoMessage 

func (*SExistRequest) ProtoMessage()

func (*SExistRequest) ProtoReflect 

func (x *SExistRequest) ProtoReflect() protoreflect.Message

func (*SExistRequest) Reset 

func (x *SExistRequest) Reset()

func (*SExistRequest) String 

func (x *SExistRequest) String() string

type SExistResponse 

type SExistResponse struct {
	Exists []bool `protobuf:"varint,1,rep,packed,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*SExistResponse) Descriptor deprecated 

func (*SExistResponse) Descriptor() ([]byte, []int)

Deprecated: Use SExistResponse.ProtoReflect.Descriptor instead.

func (*SExistResponse) GetExists 

func (x *SExistResponse) GetExists() []bool

func (*SExistResponse) ProtoMessage 

func (*SExistResponse) ProtoMessage()

func (*SExistResponse) ProtoReflect 

func (x *SExistResponse) ProtoReflect() protoreflect.Message

func (*SExistResponse) Reset 

func (x *SExistResponse) Reset()

func (*SExistResponse) String 

func (x *SExistResponse) String() string

type SMembersRequest 

type SMembersRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*SMembersRequest) Descriptor deprecated 

func (*SMembersRequest) Descriptor() ([]byte, []int)

Deprecated: Use SMembersRequest.ProtoReflect.Descriptor instead.

func (*SMembersRequest) GetKey 

func (x *SMembersRequest) GetKey() []byte

func (*SMembersRequest) ProtoMessage 

func (*SMembersRequest) ProtoMessage()

func (*SMembersRequest) ProtoReflect 

func (x *SMembersRequest) ProtoReflect() protoreflect.Message

func (*SMembersRequest) Reset 

func (x *SMembersRequest) Reset()

func (*SMembersRequest) String 

func (x *SMembersRequest) String() string

type SMembersResponse 

type SMembersResponse struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*SMembersResponse) Descriptor deprecated 

func (*SMembersResponse) Descriptor() ([]byte, []int)

Deprecated: Use SMembersResponse.ProtoReflect.Descriptor instead.

func (*SMembersResponse) GetValues 

func (x *SMembersResponse) GetValues() [][]byte

func (*SMembersResponse) ProtoMessage 

func (*SMembersResponse) ProtoMessage()

func (*SMembersResponse) ProtoReflect 

func (x *SMembersResponse) ProtoReflect() protoreflect.Message

func (*SMembersResponse) Reset 

func (x *SMembersResponse) Reset()

func (*SMembersResponse) String 

func (x *SMembersResponse) String() string

type SPopRequest 

type SPopRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*SPopRequest) Descriptor deprecated 

func (*SPopRequest) Descriptor() ([]byte, []int)

Deprecated: Use SPopRequest.ProtoReflect.Descriptor instead.

func (*SPopRequest) GetKey 

func (x *SPopRequest) GetKey() []byte

func (*SPopRequest) GetValues 

func (x *SPopRequest) GetValues() [][]byte

func (*SPopRequest) ProtoMessage 

func (*SPopRequest) ProtoMessage()

func (*SPopRequest) ProtoReflect 

func (x *SPopRequest) ProtoReflect() protoreflect.Message

func (*SPopRequest) Reset 

func (x *SPopRequest) Reset()

func (*SPopRequest) String 

func (x *SPopRequest) String() string

type SPopResponse 

type SPopResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*SPopResponse) Descriptor deprecated 

func (*SPopResponse) Descriptor() ([]byte, []int)

Deprecated: Use SPopResponse.ProtoReflect.Descriptor instead.

func (*SPopResponse) GetSuccess 

func (x *SPopResponse) GetSuccess() bool

func (*SPopResponse) ProtoMessage 

func (*SPopResponse) ProtoMessage()

func (*SPopResponse) ProtoReflect 

func (x *SPopResponse) ProtoReflect() protoreflect.Message

func (*SPopResponse) Reset 

func (x *SPopResponse) Reset()

func (*SPopResponse) String 

func (x *SPopResponse) String() string

type SPushRequest 

type SPushRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*SPushRequest) Descriptor deprecated 

func (*SPushRequest) Descriptor() ([]byte, []int)

Deprecated: Use SPushRequest.ProtoReflect.Descriptor instead.

func (*SPushRequest) GetKey 

func (x *SPushRequest) GetKey() []byte

func (*SPushRequest) GetValues 

func (x *SPushRequest) GetValues() [][]byte

func (*SPushRequest) ProtoMessage 

func (*SPushRequest) ProtoMessage()

func (*SPushRequest) ProtoReflect 

func (x *SPushRequest) ProtoReflect() protoreflect.Message

func (*SPushRequest) Reset 

func (x *SPushRequest) Reset()

func (*SPushRequest) String 

func (x *SPushRequest) String() string

type SPushResponse 

type SPushResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*SPushResponse) Descriptor deprecated 

func (*SPushResponse) Descriptor() ([]byte, []int)

Deprecated: Use SPushResponse.ProtoReflect.Descriptor instead.

func (*SPushResponse) GetSuccess 

func (x *SPushResponse) GetSuccess() bool

func (*SPushResponse) ProtoMessage 

func (*SPushResponse) ProtoMessage()

func (*SPushResponse) ProtoReflect 

func (x *SPushResponse) ProtoReflect() protoreflect.Message

func (*SPushResponse) Reset 

func (x *SPushResponse) Reset()

func (*SPushResponse) String 

func (x *SPushResponse) String() string

type SetNXRequest 

type SetNXRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetNXRequest) Descriptor deprecated 

func (*SetNXRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetNXRequest.ProtoReflect.Descriptor instead.

func (*SetNXRequest) GetKey 

func (x *SetNXRequest) GetKey() []byte

func (*SetNXRequest) GetValue 

func (x *SetNXRequest) GetValue() []byte

func (*SetNXRequest) ProtoMessage 

func (*SetNXRequest) ProtoMessage()

func (*SetNXRequest) ProtoReflect 

func (x *SetNXRequest) ProtoReflect() protoreflect.Message

func (*SetNXRequest) Reset 

func (x *SetNXRequest) Reset()

func (*SetNXRequest) String 

func (x *SetNXRequest) String() string

type SetNXResponse 

type SetNXResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*SetNXResponse) Descriptor deprecated 

func (*SetNXResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetNXResponse.ProtoReflect.Descriptor instead.

func (*SetNXResponse) GetSuccess 

func (x *SetNXResponse) GetSuccess() bool

func (*SetNXResponse) ProtoMessage 

func (*SetNXResponse) ProtoMessage()

func (*SetNXResponse) ProtoReflect 

func (x *SetNXResponse) ProtoReflect() protoreflect.Message

func (*SetNXResponse) Reset 

func (x *SetNXResponse) Reset()

func (*SetNXResponse) String 

func (x *SetNXResponse) String() string

type SetRequest 

type SetRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequest) Descriptor deprecated 

func (*SetRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetKey 

func (x *SetRequest) GetKey() []byte

func (*SetRequest) GetValue 

func (x *SetRequest) GetValue() []byte

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect 

func (x *SetRequest) ProtoReflect() protoreflect.Message

func (*SetRequest) Reset 

func (x *SetRequest) Reset()

func (*SetRequest) String 

func (x *SetRequest) String() string

type SetResponse 

type SetResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*SetResponse) Descriptor deprecated 

func (*SetResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.

func (*SetResponse) GetSuccess 

func (x *SetResponse) GetSuccess() bool

func (*SetResponse) ProtoMessage 

func (*SetResponse) ProtoMessage()

func (*SetResponse) ProtoReflect 

func (x *SetResponse) ProtoReflect() protoreflect.Message

func (*SetResponse) Reset 

func (x *SetResponse) Reset()

func (*SetResponse) String 

func (x *SetResponse) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	Topic []byte `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

func (*SubscribeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetTopic 

func (x *SubscribeRequest) GetTopic() []byte

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type Tuple 

type Tuple struct {
	Value []byte  `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Score float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

func (*Tuple) Descriptor deprecated 

func (*Tuple) Descriptor() ([]byte, []int)

Deprecated: Use Tuple.ProtoReflect.Descriptor instead.

func (*Tuple) GetScore 

func (x *Tuple) GetScore() float64

func (*Tuple) GetValue 

func (x *Tuple) GetValue() []byte

func (*Tuple) ProtoMessage 

func (*Tuple) ProtoMessage()

func (*Tuple) ProtoReflect 

func (x *Tuple) ProtoReflect() protoreflect.Message

func (*Tuple) Reset 

func (x *Tuple) Reset()

func (*Tuple) String 

func (x *Tuple) String() string

type UnimplementedSDBServer 

type UnimplementedSDBServer struct {
}

UnimplementedSDBServer should be embedded to have forward compatible implementations.

func (UnimplementedSDBServer) BFAdd 

func (UnimplementedSDBServer) BFAdd(context.Context, *BFAddRequest) (*BFAddResponse, error)

func (UnimplementedSDBServer) BFCreate 

func (UnimplementedSDBServer) BFCreate(context.Context, *BFCreateRequest) (*BFCreateResponse, error)

func (UnimplementedSDBServer) BFDel 

func (UnimplementedSDBServer) BFDel(context.Context, *BFDelRequest) (*BFDelResponse, error)

func (UnimplementedSDBServer) BFExist 

func (UnimplementedSDBServer) BFExist(context.Context, *BFExistRequest) (*BFExistResponse, error)

func (UnimplementedSDBServer) BSCount 

func (UnimplementedSDBServer) BSCount(context.Context, *BSCountRequest) (*BSCountResponse, error)

func (UnimplementedSDBServer) BSCountRange 

func (UnimplementedSDBServer) BSCountRange(context.Context, *BSCountRangeRequest) (*BSCountRangeResponse, error)

func (UnimplementedSDBServer) BSCreate 

func (UnimplementedSDBServer) BSCreate(context.Context, *BSCreateRequest) (*BSCreateResponse, error)

func (UnimplementedSDBServer) BSDel 

func (UnimplementedSDBServer) BSDel(context.Context, *BSDelRequest) (*BSDelResponse, error)

func (UnimplementedSDBServer) BSGetRange 

func (UnimplementedSDBServer) BSGetRange(context.Context, *BSGetRangeRequest) (*BSGetRangeResponse, error)

func (UnimplementedSDBServer) BSMGet 

func (UnimplementedSDBServer) BSMGet(context.Context, *BSMGetRequest) (*BSMGetResponse, error)

func (UnimplementedSDBServer) BSMSet 

func (UnimplementedSDBServer) BSMSet(context.Context, *BSMSetRequest) (*BSMSetResponse, error)

func (UnimplementedSDBServer) BSSetRange 

func (UnimplementedSDBServer) BSSetRange(context.Context, *BSSetRangeRequest) (*BSSetRangeResponse, error)

func (UnimplementedSDBServer) Del 

func (UnimplementedSDBServer) Del(context.Context, *DelRequest) (*DelResponse, error)

func (UnimplementedSDBServer) GHAdd 

func (UnimplementedSDBServer) GHAdd(context.Context, *GHAddRequest) (*GHAddResponse, error)

func (UnimplementedSDBServer) GHCount 

func (UnimplementedSDBServer) GHCount(context.Context, *GHCountRequest) (*GHCountResponse, error)

func (UnimplementedSDBServer) GHCreate 

func (UnimplementedSDBServer) GHCreate(context.Context, *GHCreateRequest) (*GHCreateResponse, error)

func (UnimplementedSDBServer) GHDel 

func (UnimplementedSDBServer) GHDel(context.Context, *GHDelRequest) (*GHDelResponse, error)

func (UnimplementedSDBServer) GHGetBoxes 

func (UnimplementedSDBServer) GHGetBoxes(context.Context, *GHGetBoxesRequest) (*GHGetBoxesResponse, error)

func (UnimplementedSDBServer) GHGetNeighbors 

func (UnimplementedSDBServer) GHGetNeighbors(context.Context, *GHGetNeighborsRequest) (*GHGetNeighborsResponse, error)

func (UnimplementedSDBServer) GHMembers 

func (UnimplementedSDBServer) GHMembers(context.Context, *GHMembersRequest) (*GHMembersResponse, error)

func (UnimplementedSDBServer) GHPop 

func (UnimplementedSDBServer) GHPop(context.Context, *GHPopRequest) (*GHPopResponse, error)

func (UnimplementedSDBServer) Get 

func (UnimplementedSDBServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedSDBServer) HLLAdd 

func (UnimplementedSDBServer) HLLAdd(context.Context, *HLLAddRequest) (*HLLAddResponse, error)

func (UnimplementedSDBServer) HLLCount 

func (UnimplementedSDBServer) HLLCount(context.Context, *HLLCountRequest) (*HLLCountResponse, error)

func (UnimplementedSDBServer) HLLCreate 

func (UnimplementedSDBServer) HLLCreate(context.Context, *HLLCreateRequest) (*HLLCreateResponse, error)

func (UnimplementedSDBServer) HLLDel 

func (UnimplementedSDBServer) HLLDel(context.Context, *HLLDelRequest) (*HLLDelResponse, error)

func (UnimplementedSDBServer) Incr 

func (UnimplementedSDBServer) Incr(context.Context, *IncrRequest) (*IncrResponse, error)

func (UnimplementedSDBServer) LCount 

func (UnimplementedSDBServer) LCount(context.Context, *LCountRequest) (*LCountResponse, error)

func (UnimplementedSDBServer) LDel 

func (UnimplementedSDBServer) LDel(context.Context, *LDelRequest) (*LDelResponse, error)

func (UnimplementedSDBServer) LExist 

func (UnimplementedSDBServer) LExist(context.Context, *LExistRequest) (*LExistResponse, error)

func (UnimplementedSDBServer) LLPush 

func (UnimplementedSDBServer) LLPush(context.Context, *LLPushRequest) (*LLPushResponse, error)

func (UnimplementedSDBServer) LMembers 

func (UnimplementedSDBServer) LMembers(context.Context, *LMembersRequest) (*LMembersResponse, error)

func (UnimplementedSDBServer) LPop 

func (UnimplementedSDBServer) LPop(context.Context, *LPopRequest) (*LPopResponse, error)

func (UnimplementedSDBServer) LRPush 

func (UnimplementedSDBServer) LRPush(context.Context, *LRPushRequest) (*LRPushResponse, error)

func (UnimplementedSDBServer) LRange 

func (UnimplementedSDBServer) LRange(context.Context, *LRangeRequest) (*LRangeResponse, error)

func (UnimplementedSDBServer) MCount 

func (UnimplementedSDBServer) MCount(context.Context, *MCountRequest) (*MCountResponse, error)

func (UnimplementedSDBServer) MDel 

func (UnimplementedSDBServer) MDel(context.Context, *MDelRequest) (*MDelResponse, error)

func (UnimplementedSDBServer) MExist 

func (UnimplementedSDBServer) MExist(context.Context, *MExistRequest) (*MExistResponse, error)

func (UnimplementedSDBServer) MGet 

func (UnimplementedSDBServer) MGet(context.Context, *MGetRequest) (*MGetResponse, error)

func (UnimplementedSDBServer) MMembers 

func (UnimplementedSDBServer) MMembers(context.Context, *MMembersRequest) (*MMembersResponse, error)

func (UnimplementedSDBServer) MPop 

func (UnimplementedSDBServer) MPop(context.Context, *MPopRequest) (*MPopResponse, error)

func (UnimplementedSDBServer) MPush 

func (UnimplementedSDBServer) MPush(context.Context, *MPushRequest) (*MPushResponse, error)

func (UnimplementedSDBServer) MSet 

func (UnimplementedSDBServer) MSet(context.Context, *MSetRequest) (*MSetResponse, error)

func (UnimplementedSDBServer) PList 

func (UnimplementedSDBServer) PList(context.Context, *PListRequest) (*PListResponse, error)

func (UnimplementedSDBServer) Publish 

func (UnimplementedSDBServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

func (UnimplementedSDBServer) SCount 

func (UnimplementedSDBServer) SCount(context.Context, *SCountRequest) (*SCountResponse, error)

func (UnimplementedSDBServer) SDel 

func (UnimplementedSDBServer) SDel(context.Context, *SDelRequest) (*SDelResponse, error)

func (UnimplementedSDBServer) SExist 

func (UnimplementedSDBServer) SExist(context.Context, *SExistRequest) (*SExistResponse, error)

func (UnimplementedSDBServer) SMembers 

func (UnimplementedSDBServer) SMembers(context.Context, *SMembersRequest) (*SMembersResponse, error)

func (UnimplementedSDBServer) SPop 

func (UnimplementedSDBServer) SPop(context.Context, *SPopRequest) (*SPopResponse, error)

func (UnimplementedSDBServer) SPush 

func (UnimplementedSDBServer) SPush(context.Context, *SPushRequest) (*SPushResponse, error)

func (UnimplementedSDBServer) Set 

func (UnimplementedSDBServer) Set(context.Context, *SetRequest) (*SetResponse, error)

func (UnimplementedSDBServer) SetNX 

func (UnimplementedSDBServer) SetNX(context.Context, *SetNXRequest) (*SetNXResponse, error)

func (UnimplementedSDBServer) Subscribe 

func (UnimplementedSDBServer) Subscribe(*SubscribeRequest, SDB_SubscribeServer) error

func (UnimplementedSDBServer) ZCount 

func (UnimplementedSDBServer) ZCount(context.Context, *ZCountRequest) (*ZCountResponse, error)

func (UnimplementedSDBServer) ZDel 

func (UnimplementedSDBServer) ZDel(context.Context, *ZDelRequest) (*ZDelResponse, error)

func (UnimplementedSDBServer) ZExist 

func (UnimplementedSDBServer) ZExist(context.Context, *ZExistRequest) (*ZExistResponse, error)

func (UnimplementedSDBServer) ZMembers 

func (UnimplementedSDBServer) ZMembers(context.Context, *ZMembersRequest) (*ZMembersResponse, error)

func (UnimplementedSDBServer) ZPop 

func (UnimplementedSDBServer) ZPop(context.Context, *ZPopRequest) (*ZPopResponse, error)

func (UnimplementedSDBServer) ZPush 

func (UnimplementedSDBServer) ZPush(context.Context, *ZPushRequest) (*ZPushResponse, error)

func (UnimplementedSDBServer) ZRange 

func (UnimplementedSDBServer) ZRange(context.Context, *ZRangeRequest) (*ZRangeResponse, error)

type UnsafeSDBServer 

type UnsafeSDBServer interface {
	// contains filtered or unexported methods
}

UnsafeSDBServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SDBServer will result in compilation errors.

type ZCountRequest 

type ZCountRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*ZCountRequest) Descriptor deprecated 

func (*ZCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use ZCountRequest.ProtoReflect.Descriptor instead.

func (*ZCountRequest) GetKey 

func (x *ZCountRequest) GetKey() []byte

func (*ZCountRequest) ProtoMessage 

func (*ZCountRequest) ProtoMessage()

func (*ZCountRequest) ProtoReflect 

func (x *ZCountRequest) ProtoReflect() protoreflect.Message

func (*ZCountRequest) Reset 

func (x *ZCountRequest) Reset()

func (*ZCountRequest) String 

func (x *ZCountRequest) String() string

type ZCountResponse 

type ZCountResponse struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ZCountResponse) Descriptor deprecated 

func (*ZCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use ZCountResponse.ProtoReflect.Descriptor instead.

func (*ZCountResponse) GetCount 

func (x *ZCountResponse) GetCount() uint32

func (*ZCountResponse) ProtoMessage 

func (*ZCountResponse) ProtoMessage()

func (*ZCountResponse) ProtoReflect 

func (x *ZCountResponse) ProtoReflect() protoreflect.Message

func (*ZCountResponse) Reset 

func (x *ZCountResponse) Reset()

func (*ZCountResponse) String 

func (x *ZCountResponse) String() string

type ZDelRequest 

type ZDelRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*ZDelRequest) Descriptor deprecated 

func (*ZDelRequest) Descriptor() ([]byte, []int)

Deprecated: Use ZDelRequest.ProtoReflect.Descriptor instead.

func (*ZDelRequest) GetKey 

func (x *ZDelRequest) GetKey() []byte

func (*ZDelRequest) ProtoMessage 

func (*ZDelRequest) ProtoMessage()

func (*ZDelRequest) ProtoReflect 

func (x *ZDelRequest) ProtoReflect() protoreflect.Message

func (*ZDelRequest) Reset 

func (x *ZDelRequest) Reset()

func (*ZDelRequest) String 

func (x *ZDelRequest) String() string

type ZDelResponse 

type ZDelResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*ZDelResponse) Descriptor deprecated 

func (*ZDelResponse) Descriptor() ([]byte, []int)

Deprecated: Use ZDelResponse.ProtoReflect.Descriptor instead.

func (*ZDelResponse) GetSuccess 

func (x *ZDelResponse) GetSuccess() bool

func (*ZDelResponse) ProtoMessage 

func (*ZDelResponse) ProtoMessage()

func (*ZDelResponse) ProtoReflect 

func (x *ZDelResponse) ProtoReflect() protoreflect.Message

func (*ZDelResponse) Reset 

func (x *ZDelResponse) Reset()

func (*ZDelResponse) String 

func (x *ZDelResponse) String() string

type ZExistRequest 

type ZExistRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ZExistRequest) Descriptor deprecated 

func (*ZExistRequest) Descriptor() ([]byte, []int)

Deprecated: Use ZExistRequest.ProtoReflect.Descriptor instead.

func (*ZExistRequest) GetKey 

func (x *ZExistRequest) GetKey() []byte

func (*ZExistRequest) GetValues 

func (x *ZExistRequest) GetValues() [][]byte

func (*ZExistRequest) ProtoMessage 

func (*ZExistRequest) ProtoMessage()

func (*ZExistRequest) ProtoReflect 

func (x *ZExistRequest) ProtoReflect() protoreflect.Message

func (*ZExistRequest) Reset 

func (x *ZExistRequest) Reset()

func (*ZExistRequest) String 

func (x *ZExistRequest) String() string

type ZExistResponse 

type ZExistResponse struct {
	Exists []bool `protobuf:"varint,1,rep,packed,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*ZExistResponse) Descriptor deprecated 

func (*ZExistResponse) Descriptor() ([]byte, []int)

Deprecated: Use ZExistResponse.ProtoReflect.Descriptor instead.

func (*ZExistResponse) GetExists 

func (x *ZExistResponse) GetExists() []bool

func (*ZExistResponse) ProtoMessage 

func (*ZExistResponse) ProtoMessage()

func (*ZExistResponse) ProtoReflect 

func (x *ZExistResponse) ProtoReflect() protoreflect.Message

func (*ZExistResponse) Reset 

func (x *ZExistResponse) Reset()

func (*ZExistResponse) String 

func (x *ZExistResponse) String() string

type ZMembersRequest 

type ZMembersRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*ZMembersRequest) Descriptor deprecated 

func (*ZMembersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ZMembersRequest.ProtoReflect.Descriptor instead.

func (*ZMembersRequest) GetKey 

func (x *ZMembersRequest) GetKey() []byte

func (*ZMembersRequest) ProtoMessage 

func (*ZMembersRequest) ProtoMessage()

func (*ZMembersRequest) ProtoReflect 

func (x *ZMembersRequest) ProtoReflect() protoreflect.Message

func (*ZMembersRequest) Reset 

func (x *ZMembersRequest) Reset()

func (*ZMembersRequest) String 

func (x *ZMembersRequest) String() string

type ZMembersResponse 

type ZMembersResponse struct {
	Tuples []*Tuple `protobuf:"bytes,1,rep,name=tuples,proto3" json:"tuples,omitempty"`
	// contains filtered or unexported fields
}

func (*ZMembersResponse) Descriptor deprecated 

func (*ZMembersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ZMembersResponse.ProtoReflect.Descriptor instead.

func (*ZMembersResponse) GetTuples 

func (x *ZMembersResponse) GetTuples() []*Tuple

func (*ZMembersResponse) ProtoMessage 

func (*ZMembersResponse) ProtoMessage()

func (*ZMembersResponse) ProtoReflect 

func (x *ZMembersResponse) ProtoReflect() protoreflect.Message

func (*ZMembersResponse) Reset 

func (x *ZMembersResponse) Reset()

func (*ZMembersResponse) String 

func (x *ZMembersResponse) String() string

type ZPopRequest 

type ZPopRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ZPopRequest) Descriptor deprecated 

func (*ZPopRequest) Descriptor() ([]byte, []int)

Deprecated: Use ZPopRequest.ProtoReflect.Descriptor instead.

func (*ZPopRequest) GetKey 

func (x *ZPopRequest) GetKey() []byte

func (*ZPopRequest) GetValues 

func (x *ZPopRequest) GetValues() [][]byte

func (*ZPopRequest) ProtoMessage 

func (*ZPopRequest) ProtoMessage()

func (*ZPopRequest) ProtoReflect 

func (x *ZPopRequest) ProtoReflect() protoreflect.Message

func (*ZPopRequest) Reset 

func (x *ZPopRequest) Reset()

func (*ZPopRequest) String 

func (x *ZPopRequest) String() string

type ZPopResponse 

type ZPopResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*ZPopResponse) Descriptor deprecated 

func (*ZPopResponse) Descriptor() ([]byte, []int)

Deprecated: Use ZPopResponse.ProtoReflect.Descriptor instead.

func (*ZPopResponse) GetSuccess 

func (x *ZPopResponse) GetSuccess() bool

func (*ZPopResponse) ProtoMessage 

func (*ZPopResponse) ProtoMessage()

func (*ZPopResponse) ProtoReflect 

func (x *ZPopResponse) ProtoReflect() protoreflect.Message

func (*ZPopResponse) Reset 

func (x *ZPopResponse) Reset()

func (*ZPopResponse) String 

func (x *ZPopResponse) String() string

type ZPushRequest 

type ZPushRequest struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Tuples []*Tuple `protobuf:"bytes,2,rep,name=tuples,proto3" json:"tuples,omitempty"`
	// contains filtered or unexported fields
}

func (*ZPushRequest) Descriptor deprecated 

func (*ZPushRequest) Descriptor() ([]byte, []int)

Deprecated: Use ZPushRequest.ProtoReflect.Descriptor instead.

func (*ZPushRequest) GetKey 

func (x *ZPushRequest) GetKey() []byte

func (*ZPushRequest) GetTuples 

func (x *ZPushRequest) GetTuples() []*Tuple

func (*ZPushRequest) ProtoMessage 

func (*ZPushRequest) ProtoMessage()

func (*ZPushRequest) ProtoReflect 

func (x *ZPushRequest) ProtoReflect() protoreflect.Message

func (*ZPushRequest) Reset 

func (x *ZPushRequest) Reset()

func (*ZPushRequest) String 

func (x *ZPushRequest) String() string

type ZPushResponse 

type ZPushResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*ZPushResponse) Descriptor deprecated 

func (*ZPushResponse) Descriptor() ([]byte, []int)

Deprecated: Use ZPushResponse.ProtoReflect.Descriptor instead.

func (*ZPushResponse) GetSuccess 

func (x *ZPushResponse) GetSuccess() bool

func (*ZPushResponse) ProtoMessage 

func (*ZPushResponse) ProtoMessage()

func (*ZPushResponse) ProtoReflect 

func (x *ZPushResponse) ProtoReflect() protoreflect.Message

func (*ZPushResponse) Reset 

func (x *ZPushResponse) Reset()

func (*ZPushResponse) String 

func (x *ZPushResponse) String() string

type ZRangeRequest 

type ZRangeRequest struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Offset int32  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit  uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ZRangeRequest) Descriptor deprecated 

func (*ZRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ZRangeRequest.ProtoReflect.Descriptor instead.

func (*ZRangeRequest) GetKey 

func (x *ZRangeRequest) GetKey() []byte

func (*ZRangeRequest) GetLimit 

func (x *ZRangeRequest) GetLimit() uint32

func (*ZRangeRequest) GetOffset 

func (x *ZRangeRequest) GetOffset() int32

func (*ZRangeRequest) ProtoMessage 

func (*ZRangeRequest) ProtoMessage()

func (*ZRangeRequest) ProtoReflect 

func (x *ZRangeRequest) ProtoReflect() protoreflect.Message

func (*ZRangeRequest) Reset 

func (x *ZRangeRequest) Reset()

func (*ZRangeRequest) String 

func (x *ZRangeRequest) String() string

type ZRangeResponse 

type ZRangeResponse struct {
	Tuples []*Tuple `protobuf:"bytes,1,rep,name=tuples,proto3" json:"tuples,omitempty"`
	// contains filtered or unexported fields
}

func (*ZRangeResponse) Descriptor deprecated 

func (*ZRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ZRangeResponse.ProtoReflect.Descriptor instead.

func (*ZRangeResponse) GetTuples 

func (x *ZRangeResponse) GetTuples() []*Tuple

func (*ZRangeResponse) ProtoMessage 

func (*ZRangeResponse) ProtoMessage()

func (*ZRangeResponse) ProtoReflect 

func (x *ZRangeResponse) ProtoReflect() protoreflect.Message

func (*ZRangeResponse) Reset 

func (x *ZRangeResponse) Reset()

func (*ZRangeResponse) String 

func (x *ZRangeResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.