Documentation ¶
Index ¶
- Variables
- func RegisterIndexServiceServer(s *grpc.Server, srv IndexServiceServer)
- type AddItemReq
- func (*AddItemReq) Descriptor() ([]byte, []int)deprecated
- func (x *AddItemReq) GetItem() []*Item
- func (x *AddItemReq) GetMainKey() string
- func (x *AddItemReq) GetOpType() OpType
- func (x *AddItemReq) GetVersion() string
- func (*AddItemReq) ProtoMessage()
- func (x *AddItemReq) ProtoReflect() protoreflect.Message
- func (x *AddItemReq) Reset()
- func (x *AddItemReq) String() string
- type AddItemRsp
- func (*AddItemRsp) Descriptor() ([]byte, []int)deprecated
- func (x *AddItemRsp) GetId() string
- func (x *AddItemRsp) GetItemCount() int32
- func (x *AddItemRsp) GetMsg() string
- func (x *AddItemRsp) GetRet() int32
- func (*AddItemRsp) ProtoMessage()
- func (x *AddItemRsp) ProtoReflect() protoreflect.Message
- func (x *AddItemRsp) Reset()
- func (x *AddItemRsp) String() string
- type BloomFilterValueData
- func (*BloomFilterValueData) Descriptor() ([]byte, []int)deprecated
- func (x *BloomFilterValueData) GetBloomFilters() []byte
- func (*BloomFilterValueData) ProtoMessage()
- func (x *BloomFilterValueData) ProtoReflect() protoreflect.Message
- func (x *BloomFilterValueData) Reset()
- func (x *BloomFilterValueData) String() string
- type DeleteKeyReq
- type DeleteKeyRsp
- type IndexServiceClient
- type IndexServiceServer
- type IndexValueData
- type Item
- func (*Item) Descriptor() ([]byte, []int)deprecated
- func (x *Item) GetId() string
- func (x *Item) GetInvalidSortValue() bool
- func (x *Item) GetInvalidTime() bool
- func (x *Item) GetSortValue() float64
- func (x *Item) GetTime() int64
- func (*Item) ProtoMessage()
- func (x *Item) ProtoReflect() protoreflect.Message
- func (x *Item) Reset()
- func (x *Item) String() string
- type OpType
- type ReadBloomFilterReq
- func (*ReadBloomFilterReq) Descriptor() ([]byte, []int)deprecated
- func (x *ReadBloomFilterReq) GetUserID() string
- func (*ReadBloomFilterReq) ProtoMessage()
- func (x *ReadBloomFilterReq) ProtoReflect() protoreflect.Message
- func (x *ReadBloomFilterReq) Reset()
- func (x *ReadBloomFilterReq) String() string
- type ReadBloomFilterRsp
- func (*ReadBloomFilterRsp) Descriptor() ([]byte, []int)deprecated
- func (x *ReadBloomFilterRsp) GetBloomFilters() [][]byte
- func (x *ReadBloomFilterRsp) GetMsg() string
- func (x *ReadBloomFilterRsp) GetRet() int32
- func (*ReadBloomFilterRsp) ProtoMessage()
- func (x *ReadBloomFilterRsp) ProtoReflect() protoreflect.Message
- func (x *ReadBloomFilterRsp) Reset()
- func (x *ReadBloomFilterRsp) String() string
- type ReadItemsReq
- func (*ReadItemsReq) Descriptor() ([]byte, []int)deprecated
- func (x *ReadItemsReq) GetBloomFilter() [][]byte
- func (x *ReadItemsReq) GetItemCount() int32
- func (x *ReadItemsReq) GetMainKey() string
- func (x *ReadItemsReq) GetVersion() string
- func (*ReadItemsReq) ProtoMessage()
- func (x *ReadItemsReq) ProtoReflect() protoreflect.Message
- func (x *ReadItemsReq) Reset()
- func (x *ReadItemsReq) String() string
- type ReadItemsRsp
- func (*ReadItemsRsp) Descriptor() ([]byte, []int)deprecated
- func (x *ReadItemsRsp) GetItem() []*Item
- func (x *ReadItemsRsp) GetMsg() string
- func (x *ReadItemsRsp) GetRet() int32
- func (*ReadItemsRsp) ProtoMessage()
- func (x *ReadItemsRsp) ProtoReflect() protoreflect.Message
- func (x *ReadItemsRsp) Reset()
- func (x *ReadItemsRsp) String() string
- type RemoveItemReq
- func (*RemoveItemReq) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveItemReq) GetId() []string
- func (x *RemoveItemReq) GetMainKey() string
- func (x *RemoveItemReq) GetVersion() string
- func (*RemoveItemReq) ProtoMessage()
- func (x *RemoveItemReq) ProtoReflect() protoreflect.Message
- func (x *RemoveItemReq) Reset()
- func (x *RemoveItemReq) String() string
- type RemoveItemRsp
- func (*RemoveItemRsp) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveItemRsp) GetChangeCount() int32
- func (x *RemoveItemRsp) GetItemCount() int32
- func (x *RemoveItemRsp) GetMsg() string
- func (x *RemoveItemRsp) GetRet() int32
- func (*RemoveItemRsp) ProtoMessage()
- func (x *RemoveItemRsp) ProtoReflect() protoreflect.Message
- func (x *RemoveItemRsp) Reset()
- func (x *RemoveItemRsp) String() string
- type UnimplementedIndexServiceServer
- func (*UnimplementedIndexServiceServer) AddItem(context.Context, *AddItemReq) (*AddItemRsp, error)
- func (*UnimplementedIndexServiceServer) DeleteKey(context.Context, *DeleteKeyReq) (*DeleteKeyRsp, error)
- func (*UnimplementedIndexServiceServer) ReadBloomFilter(context.Context, *ReadBloomFilterReq) (*ReadBloomFilterRsp, error)
- func (*UnimplementedIndexServiceServer) ReadItems(context.Context, *ReadItemsReq) (*ReadItemsRsp, error)
- func (*UnimplementedIndexServiceServer) RemoveItem(context.Context, *RemoveItemReq) (*RemoveItemRsp, error)
- func (*UnimplementedIndexServiceServer) WriteBloomFilter(context.Context, *WriteBloomFilterReq) (*WriteBloomFilterRsp, error)
- type WriteBloomFilterReq
- func (*WriteBloomFilterReq) Descriptor() ([]byte, []int)deprecated
- func (x *WriteBloomFilterReq) GetItemIds() []string
- func (x *WriteBloomFilterReq) GetUserID() string
- func (*WriteBloomFilterReq) ProtoMessage()
- func (x *WriteBloomFilterReq) ProtoReflect() protoreflect.Message
- func (x *WriteBloomFilterReq) Reset()
- func (x *WriteBloomFilterReq) String() string
- type WriteBloomFilterRsp
- func (*WriteBloomFilterRsp) Descriptor() ([]byte, []int)deprecated
- func (x *WriteBloomFilterRsp) GetMsg() string
- func (x *WriteBloomFilterRsp) GetRet() int32
- func (*WriteBloomFilterRsp) ProtoMessage()
- func (x *WriteBloomFilterRsp) ProtoReflect() protoreflect.Message
- func (x *WriteBloomFilterRsp) Reset()
- func (x *WriteBloomFilterRsp) String() string
Constants ¶
This section is empty.
Variables ¶
var ( OpType_name = map[int32]string{ 0: "Upsert", 1: "Update", } OpType_value = map[string]int32{ "Upsert": 0, "Update": 1, } )
Enum value maps for OpType.
var File_index_proto protoreflect.FileDescriptor
Functions ¶
func RegisterIndexServiceServer ¶
func RegisterIndexServiceServer(s *grpc.Server, srv IndexServiceServer)
Types ¶
type AddItemReq ¶
type AddItemReq struct { Item []*Item `protobuf:"bytes,1,rep,name=Item,proto3" json:"Item,omitempty"` //items MainKey string `protobuf:"bytes,2,opt,name=MainKey,proto3" json:"MainKey,omitempty"` //主key OpType OpType `protobuf:"varint,3,opt,name=OpType,proto3,enum=OpType" json:"OpType,omitempty"` //操作类型 Version string `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"` //版本号 // contains filtered or unexported fields }
AddItem Request
func (*AddItemReq) Descriptor
deprecated
func (*AddItemReq) Descriptor() ([]byte, []int)
Deprecated: Use AddItemReq.ProtoReflect.Descriptor instead.
func (*AddItemReq) GetItem ¶
func (x *AddItemReq) GetItem() []*Item
func (*AddItemReq) GetMainKey ¶
func (x *AddItemReq) GetMainKey() string
func (*AddItemReq) GetOpType ¶
func (x *AddItemReq) GetOpType() OpType
func (*AddItemReq) GetVersion ¶
func (x *AddItemReq) GetVersion() string
func (*AddItemReq) ProtoMessage ¶
func (*AddItemReq) ProtoMessage()
func (*AddItemReq) ProtoReflect ¶
func (x *AddItemReq) ProtoReflect() protoreflect.Message
func (*AddItemReq) Reset ¶
func (x *AddItemReq) Reset()
func (*AddItemReq) String ¶
func (x *AddItemReq) String() string
type AddItemRsp ¶
type AddItemRsp struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` //item id ItemCount int32 `protobuf:"varint,2,opt,name=ItemCount,proto3" json:"ItemCount,omitempty"` //item count in bucket Msg string `protobuf:"bytes,3,opt,name=Msg,proto3" json:"Msg,omitempty"` //return msg Ret int32 `protobuf:"varint,4,opt,name=Ret,proto3" json:"Ret,omitempty"` //返回值return code // contains filtered or unexported fields }
AddItem Response
func (*AddItemRsp) Descriptor
deprecated
func (*AddItemRsp) Descriptor() ([]byte, []int)
Deprecated: Use AddItemRsp.ProtoReflect.Descriptor instead.
func (*AddItemRsp) GetId ¶
func (x *AddItemRsp) GetId() string
func (*AddItemRsp) GetItemCount ¶
func (x *AddItemRsp) GetItemCount() int32
func (*AddItemRsp) GetMsg ¶
func (x *AddItemRsp) GetMsg() string
func (*AddItemRsp) GetRet ¶
func (x *AddItemRsp) GetRet() int32
func (*AddItemRsp) ProtoMessage ¶
func (*AddItemRsp) ProtoMessage()
func (*AddItemRsp) ProtoReflect ¶
func (x *AddItemRsp) ProtoReflect() protoreflect.Message
func (*AddItemRsp) Reset ¶
func (x *AddItemRsp) Reset()
func (*AddItemRsp) String ¶
func (x *AddItemRsp) String() string
type BloomFilterValueData ¶
type BloomFilterValueData struct { BloomFilters []byte `protobuf:"bytes,1,opt,name=BloomFilters,proto3" json:"BloomFilters,omitempty"` // contains filtered or unexported fields }
布隆过滤器编解码存储value类型
func (*BloomFilterValueData) Descriptor
deprecated
func (*BloomFilterValueData) Descriptor() ([]byte, []int)
Deprecated: Use BloomFilterValueData.ProtoReflect.Descriptor instead.
func (*BloomFilterValueData) GetBloomFilters ¶
func (x *BloomFilterValueData) GetBloomFilters() []byte
func (*BloomFilterValueData) ProtoMessage ¶
func (*BloomFilterValueData) ProtoMessage()
func (*BloomFilterValueData) ProtoReflect ¶
func (x *BloomFilterValueData) ProtoReflect() protoreflect.Message
func (*BloomFilterValueData) Reset ¶
func (x *BloomFilterValueData) Reset()
func (*BloomFilterValueData) String ¶
func (x *BloomFilterValueData) String() string
type DeleteKeyReq ¶
type DeleteKeyReq struct { MainKey string `protobuf:"bytes,1,opt,name=MainKey,proto3" json:"MainKey,omitempty"` // contains filtered or unexported fields }
DeleteKey Request
func (*DeleteKeyReq) Descriptor
deprecated
func (*DeleteKeyReq) Descriptor() ([]byte, []int)
Deprecated: Use DeleteKeyReq.ProtoReflect.Descriptor instead.
func (*DeleteKeyReq) GetMainKey ¶
func (x *DeleteKeyReq) GetMainKey() string
func (*DeleteKeyReq) ProtoMessage ¶
func (*DeleteKeyReq) ProtoMessage()
func (*DeleteKeyReq) ProtoReflect ¶
func (x *DeleteKeyReq) ProtoReflect() protoreflect.Message
func (*DeleteKeyReq) Reset ¶
func (x *DeleteKeyReq) Reset()
func (*DeleteKeyReq) String ¶
func (x *DeleteKeyReq) String() string
type DeleteKeyRsp ¶
type DeleteKeyRsp struct { Ret int32 `protobuf:"varint,1,opt,name=Ret,proto3" json:"Ret,omitempty"` //return code // contains filtered or unexported fields }
DeleteKey Response
func (*DeleteKeyRsp) Descriptor
deprecated
func (*DeleteKeyRsp) Descriptor() ([]byte, []int)
Deprecated: Use DeleteKeyRsp.ProtoReflect.Descriptor instead.
func (*DeleteKeyRsp) GetRet ¶
func (x *DeleteKeyRsp) GetRet() int32
func (*DeleteKeyRsp) ProtoMessage ¶
func (*DeleteKeyRsp) ProtoMessage()
func (*DeleteKeyRsp) ProtoReflect ¶
func (x *DeleteKeyRsp) ProtoReflect() protoreflect.Message
func (*DeleteKeyRsp) Reset ¶
func (x *DeleteKeyRsp) Reset()
func (*DeleteKeyRsp) String ¶
func (x *DeleteKeyRsp) String() string
type IndexServiceClient ¶
type IndexServiceClient interface { //add item 添加Item,同个主key可一次添加多个Item AddItem(ctx context.Context, in *AddItemReq, opts ...grpc.CallOption) (*AddItemRsp, error) //delete item 删除Item,同个主Key可一次删除多个Item RemoveItem(ctx context.Context, in *RemoveItemReq, opts ...grpc.CallOption) (*RemoveItemRsp, error) //read items 读取Item列表 ReadItems(ctx context.Context, in *ReadItemsReq, opts ...grpc.CallOption) (*ReadItemsRsp, error) //delete MainKey 删除主Key DeleteKey(ctx context.Context, in *DeleteKeyReq, opts ...grpc.CallOption) (*DeleteKeyRsp, error) //布隆过滤器:写入 WriteBloomFilter(ctx context.Context, in *WriteBloomFilterReq, opts ...grpc.CallOption) (*WriteBloomFilterRsp, error) //布隆过滤器:读出 ReadBloomFilter(ctx context.Context, in *ReadBloomFilterReq, opts ...grpc.CallOption) (*ReadBloomFilterRsp, error) }
IndexServiceClient is the client API for IndexService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewIndexServiceClient ¶
func NewIndexServiceClient(cc grpc.ClientConnInterface) IndexServiceClient
type IndexServiceServer ¶
type IndexServiceServer interface { //add item 添加Item,同个主key可一次添加多个Item AddItem(context.Context, *AddItemReq) (*AddItemRsp, error) //delete item 删除Item,同个主Key可一次删除多个Item RemoveItem(context.Context, *RemoveItemReq) (*RemoveItemRsp, error) //read items 读取Item列表 ReadItems(context.Context, *ReadItemsReq) (*ReadItemsRsp, error) //delete MainKey 删除主Key DeleteKey(context.Context, *DeleteKeyReq) (*DeleteKeyRsp, error) //布隆过滤器:写入 WriteBloomFilter(context.Context, *WriteBloomFilterReq) (*WriteBloomFilterRsp, error) //布隆过滤器:读出 ReadBloomFilter(context.Context, *ReadBloomFilterReq) (*ReadBloomFilterRsp, error) }
IndexServiceServer is the server API for IndexService service.
type IndexValueData ¶
type IndexValueData struct { Items []*Item `protobuf:"bytes,1,rep,name=Items,proto3" json:"Items,omitempty"` // contains filtered or unexported fields }
索引存储value类型
func (*IndexValueData) Descriptor
deprecated
func (*IndexValueData) Descriptor() ([]byte, []int)
Deprecated: Use IndexValueData.ProtoReflect.Descriptor instead.
func (*IndexValueData) GetItems ¶
func (x *IndexValueData) GetItems() []*Item
func (*IndexValueData) ProtoMessage ¶
func (*IndexValueData) ProtoMessage()
func (*IndexValueData) ProtoReflect ¶
func (x *IndexValueData) ProtoReflect() protoreflect.Message
func (*IndexValueData) Reset ¶
func (x *IndexValueData) Reset()
func (*IndexValueData) String ¶
func (x *IndexValueData) String() string
type Item ¶
type Item struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` //唯一ID,一般对应ProductID SortValue float64 `protobuf:"fixed64,2,opt,name=SortValue,proto3" json:"SortValue,omitempty"` //打分值 Time int64 `protobuf:"varint,3,opt,name=Time,proto3" json:"Time,omitempty"` //时间戳 InvalidSortValue bool `protobuf:"varint,4,opt,name=InvalidSortValue,proto3" json:"InvalidSortValue,omitempty"` //打分值是否无效,默认false更新 InvalidTime bool `protobuf:"varint,5,opt,name=InvalidTime,proto3" json:"InvalidTime,omitempty"` //时间戳是否无效,默认false更新 // contains filtered or unexported fields }
Item
func (*Item) Descriptor
deprecated
func (*Item) GetInvalidSortValue ¶
func (*Item) GetInvalidTime ¶
func (*Item) GetSortValue ¶
func (*Item) ProtoMessage ¶
func (*Item) ProtoMessage()
func (*Item) ProtoReflect ¶
func (x *Item) ProtoReflect() protoreflect.Message
type OpType ¶
type OpType int32
操作类型
func (OpType) Descriptor ¶
func (OpType) Descriptor() protoreflect.EnumDescriptor
func (OpType) EnumDescriptor
deprecated
func (OpType) Number ¶
func (x OpType) Number() protoreflect.EnumNumber
func (OpType) Type ¶
func (OpType) Type() protoreflect.EnumType
type ReadBloomFilterReq ¶
type ReadBloomFilterReq struct { UserID string `protobuf:"bytes,1,opt,name=UserID,proto3" json:"UserID,omitempty"` // contains filtered or unexported fields }
Read BloomFilter Request
func (*ReadBloomFilterReq) Descriptor
deprecated
func (*ReadBloomFilterReq) Descriptor() ([]byte, []int)
Deprecated: Use ReadBloomFilterReq.ProtoReflect.Descriptor instead.
func (*ReadBloomFilterReq) GetUserID ¶
func (x *ReadBloomFilterReq) GetUserID() string
func (*ReadBloomFilterReq) ProtoMessage ¶
func (*ReadBloomFilterReq) ProtoMessage()
func (*ReadBloomFilterReq) ProtoReflect ¶
func (x *ReadBloomFilterReq) ProtoReflect() protoreflect.Message
func (*ReadBloomFilterReq) Reset ¶
func (x *ReadBloomFilterReq) Reset()
func (*ReadBloomFilterReq) String ¶
func (x *ReadBloomFilterReq) String() string
type ReadBloomFilterRsp ¶
type ReadBloomFilterRsp struct { BloomFilters [][]byte `protobuf:"bytes,1,rep,name=BloomFilters,proto3" json:"BloomFilters,omitempty"` //布隆过滤器 Ret int32 `protobuf:"varint,2,opt,name=Ret,proto3" json:"Ret,omitempty"` Msg string `protobuf:"bytes,3,opt,name=Msg,proto3" json:"Msg,omitempty"` // contains filtered or unexported fields }
Read BloomFilter Response
func (*ReadBloomFilterRsp) Descriptor
deprecated
func (*ReadBloomFilterRsp) Descriptor() ([]byte, []int)
Deprecated: Use ReadBloomFilterRsp.ProtoReflect.Descriptor instead.
func (*ReadBloomFilterRsp) GetBloomFilters ¶
func (x *ReadBloomFilterRsp) GetBloomFilters() [][]byte
func (*ReadBloomFilterRsp) GetMsg ¶
func (x *ReadBloomFilterRsp) GetMsg() string
func (*ReadBloomFilterRsp) GetRet ¶
func (x *ReadBloomFilterRsp) GetRet() int32
func (*ReadBloomFilterRsp) ProtoMessage ¶
func (*ReadBloomFilterRsp) ProtoMessage()
func (*ReadBloomFilterRsp) ProtoReflect ¶
func (x *ReadBloomFilterRsp) ProtoReflect() protoreflect.Message
func (*ReadBloomFilterRsp) Reset ¶
func (x *ReadBloomFilterRsp) Reset()
func (*ReadBloomFilterRsp) String ¶
func (x *ReadBloomFilterRsp) String() string
type ReadItemsReq ¶
type ReadItemsReq struct { MainKey string `protobuf:"bytes,1,opt,name=MainKey,proto3" json:"MainKey,omitempty"` //主key ItemCount int32 `protobuf:"varint,2,opt,name=ItemCount,proto3" json:"ItemCount,omitempty"` //限制长度 BloomFilter [][]byte `protobuf:"bytes,3,rep,name=BloomFilter,proto3" json:"BloomFilter,omitempty"` //布隆过滤器 Version string `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"` //版本号 // contains filtered or unexported fields }
ReadItems Request
func (*ReadItemsReq) Descriptor
deprecated
func (*ReadItemsReq) Descriptor() ([]byte, []int)
Deprecated: Use ReadItemsReq.ProtoReflect.Descriptor instead.
func (*ReadItemsReq) GetBloomFilter ¶
func (x *ReadItemsReq) GetBloomFilter() [][]byte
func (*ReadItemsReq) GetItemCount ¶
func (x *ReadItemsReq) GetItemCount() int32
func (*ReadItemsReq) GetMainKey ¶
func (x *ReadItemsReq) GetMainKey() string
func (*ReadItemsReq) GetVersion ¶
func (x *ReadItemsReq) GetVersion() string
func (*ReadItemsReq) ProtoMessage ¶
func (*ReadItemsReq) ProtoMessage()
func (*ReadItemsReq) ProtoReflect ¶
func (x *ReadItemsReq) ProtoReflect() protoreflect.Message
func (*ReadItemsReq) Reset ¶
func (x *ReadItemsReq) Reset()
func (*ReadItemsReq) String ¶
func (x *ReadItemsReq) String() string
type ReadItemsRsp ¶
type ReadItemsRsp struct { Item []*Item `protobuf:"bytes,1,rep,name=item,proto3" json:"item,omitempty"` //items Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"` //return msg Ret int32 `protobuf:"varint,3,opt,name=Ret,proto3" json:"Ret,omitempty"` //return code // contains filtered or unexported fields }
ReadItems Response
func (*ReadItemsRsp) Descriptor
deprecated
func (*ReadItemsRsp) Descriptor() ([]byte, []int)
Deprecated: Use ReadItemsRsp.ProtoReflect.Descriptor instead.
func (*ReadItemsRsp) GetItem ¶
func (x *ReadItemsRsp) GetItem() []*Item
func (*ReadItemsRsp) GetMsg ¶
func (x *ReadItemsRsp) GetMsg() string
func (*ReadItemsRsp) GetRet ¶
func (x *ReadItemsRsp) GetRet() int32
func (*ReadItemsRsp) ProtoMessage ¶
func (*ReadItemsRsp) ProtoMessage()
func (*ReadItemsRsp) ProtoReflect ¶
func (x *ReadItemsRsp) ProtoReflect() protoreflect.Message
func (*ReadItemsRsp) Reset ¶
func (x *ReadItemsRsp) Reset()
func (*ReadItemsRsp) String ¶
func (x *ReadItemsRsp) String() string
type RemoveItemReq ¶
type RemoveItemReq struct { Id []string `protobuf:"bytes,1,rep,name=Id,proto3" json:"Id,omitempty"` //items id MainKey string `protobuf:"bytes,2,opt,name=MainKey,proto3" json:"MainKey,omitempty"` //主key Version string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"` //版本号 // contains filtered or unexported fields }
RemoveItem Request
func (*RemoveItemReq) Descriptor
deprecated
func (*RemoveItemReq) Descriptor() ([]byte, []int)
Deprecated: Use RemoveItemReq.ProtoReflect.Descriptor instead.
func (*RemoveItemReq) GetId ¶
func (x *RemoveItemReq) GetId() []string
func (*RemoveItemReq) GetMainKey ¶
func (x *RemoveItemReq) GetMainKey() string
func (*RemoveItemReq) GetVersion ¶
func (x *RemoveItemReq) GetVersion() string
func (*RemoveItemReq) ProtoMessage ¶
func (*RemoveItemReq) ProtoMessage()
func (*RemoveItemReq) ProtoReflect ¶
func (x *RemoveItemReq) ProtoReflect() protoreflect.Message
func (*RemoveItemReq) Reset ¶
func (x *RemoveItemReq) Reset()
func (*RemoveItemReq) String ¶
func (x *RemoveItemReq) String() string
type RemoveItemRsp ¶
type RemoveItemRsp struct { ChangeCount int32 `protobuf:"varint,1,opt,name=ChangeCount,proto3" json:"ChangeCount,omitempty"` //发生变更的个数 ItemCount int32 `protobuf:"varint,2,opt,name=ItemCount,proto3" json:"ItemCount,omitempty"` //item count in bucket Msg string `protobuf:"bytes,3,opt,name=Msg,proto3" json:"Msg,omitempty"` //return msg Ret int32 `protobuf:"varint,4,opt,name=Ret,proto3" json:"Ret,omitempty"` //return code // contains filtered or unexported fields }
RemoveItem Response
func (*RemoveItemRsp) Descriptor
deprecated
func (*RemoveItemRsp) Descriptor() ([]byte, []int)
Deprecated: Use RemoveItemRsp.ProtoReflect.Descriptor instead.
func (*RemoveItemRsp) GetChangeCount ¶
func (x *RemoveItemRsp) GetChangeCount() int32
func (*RemoveItemRsp) GetItemCount ¶
func (x *RemoveItemRsp) GetItemCount() int32
func (*RemoveItemRsp) GetMsg ¶
func (x *RemoveItemRsp) GetMsg() string
func (*RemoveItemRsp) GetRet ¶
func (x *RemoveItemRsp) GetRet() int32
func (*RemoveItemRsp) ProtoMessage ¶
func (*RemoveItemRsp) ProtoMessage()
func (*RemoveItemRsp) ProtoReflect ¶
func (x *RemoveItemRsp) ProtoReflect() protoreflect.Message
func (*RemoveItemRsp) Reset ¶
func (x *RemoveItemRsp) Reset()
func (*RemoveItemRsp) String ¶
func (x *RemoveItemRsp) String() string
type UnimplementedIndexServiceServer ¶
type UnimplementedIndexServiceServer struct { }
UnimplementedIndexServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedIndexServiceServer) AddItem ¶
func (*UnimplementedIndexServiceServer) AddItem(context.Context, *AddItemReq) (*AddItemRsp, error)
func (*UnimplementedIndexServiceServer) DeleteKey ¶
func (*UnimplementedIndexServiceServer) DeleteKey(context.Context, *DeleteKeyReq) (*DeleteKeyRsp, error)
func (*UnimplementedIndexServiceServer) ReadBloomFilter ¶
func (*UnimplementedIndexServiceServer) ReadBloomFilter(context.Context, *ReadBloomFilterReq) (*ReadBloomFilterRsp, error)
func (*UnimplementedIndexServiceServer) ReadItems ¶
func (*UnimplementedIndexServiceServer) ReadItems(context.Context, *ReadItemsReq) (*ReadItemsRsp, error)
func (*UnimplementedIndexServiceServer) RemoveItem ¶
func (*UnimplementedIndexServiceServer) RemoveItem(context.Context, *RemoveItemReq) (*RemoveItemRsp, error)
func (*UnimplementedIndexServiceServer) WriteBloomFilter ¶
func (*UnimplementedIndexServiceServer) WriteBloomFilter(context.Context, *WriteBloomFilterReq) (*WriteBloomFilterRsp, error)
type WriteBloomFilterReq ¶
type WriteBloomFilterReq struct { UserID string `protobuf:"bytes,1,opt,name=UserID,proto3" json:"UserID,omitempty"` //user id ItemIds []string `protobuf:"bytes,2,rep,name=ItemIds,proto3" json:"ItemIds,omitempty"` //item id list // contains filtered or unexported fields }
Write BloomFilter Request
func (*WriteBloomFilterReq) Descriptor
deprecated
func (*WriteBloomFilterReq) Descriptor() ([]byte, []int)
Deprecated: Use WriteBloomFilterReq.ProtoReflect.Descriptor instead.
func (*WriteBloomFilterReq) GetItemIds ¶
func (x *WriteBloomFilterReq) GetItemIds() []string
func (*WriteBloomFilterReq) GetUserID ¶
func (x *WriteBloomFilterReq) GetUserID() string
func (*WriteBloomFilterReq) ProtoMessage ¶
func (*WriteBloomFilterReq) ProtoMessage()
func (*WriteBloomFilterReq) ProtoReflect ¶
func (x *WriteBloomFilterReq) ProtoReflect() protoreflect.Message
func (*WriteBloomFilterReq) Reset ¶
func (x *WriteBloomFilterReq) Reset()
func (*WriteBloomFilterReq) String ¶
func (x *WriteBloomFilterReq) String() string
type WriteBloomFilterRsp ¶
type WriteBloomFilterRsp struct { Ret int32 `protobuf:"varint,1,opt,name=Ret,proto3" json:"Ret,omitempty"` Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"` // contains filtered or unexported fields }
Write BloomFilter Response
func (*WriteBloomFilterRsp) Descriptor
deprecated
func (*WriteBloomFilterRsp) Descriptor() ([]byte, []int)
Deprecated: Use WriteBloomFilterRsp.ProtoReflect.Descriptor instead.
func (*WriteBloomFilterRsp) GetMsg ¶
func (x *WriteBloomFilterRsp) GetMsg() string
func (*WriteBloomFilterRsp) GetRet ¶
func (x *WriteBloomFilterRsp) GetRet() int32
func (*WriteBloomFilterRsp) ProtoMessage ¶
func (*WriteBloomFilterRsp) ProtoMessage()
func (*WriteBloomFilterRsp) ProtoReflect ¶
func (x *WriteBloomFilterRsp) ProtoReflect() protoreflect.Message
func (*WriteBloomFilterRsp) Reset ¶
func (x *WriteBloomFilterRsp) Reset()
func (*WriteBloomFilterRsp) String ¶
func (x *WriteBloomFilterRsp) String() string