pub
/
waymaker-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
waymaker-client/go/genpb/sketches/sketches.pb.go

3781 lines
113 KiB
Go
Raw Permalink Blame History

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.36.11
// protoc v7.34.1
// source: sketches.proto
package waymaker_sketches
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
unsafe "unsafe"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type ProbType int32
const (
ProbType_PROB_UNSPECIFIED ProbType = 0
ProbType_PROB_BLOOM ProbType = 1
ProbType_PROB_HLL ProbType = 2
ProbType_PROB_CMS ProbType = 3
ProbType_PROB_TOPK ProbType = 4
ProbType_PROB_TDIGEST ProbType = 5
)
// Enum value maps for ProbType.
var (
ProbType_name = map[int32]string{
0: "PROB_UNSPECIFIED",
1: "PROB_BLOOM",
2: "PROB_HLL",
3: "PROB_CMS",
4: "PROB_TOPK",
5: "PROB_TDIGEST",
}
ProbType_value = map[string]int32{
"PROB_UNSPECIFIED": 0,
"PROB_BLOOM": 1,
"PROB_HLL": 2,
"PROB_CMS": 3,
"PROB_TOPK": 4,
"PROB_TDIGEST": 5,
}
)
func (x ProbType) Enum() *ProbType {
p := new(ProbType)
*p = x
return p
}
func (x ProbType) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (ProbType) Descriptor() protoreflect.EnumDescriptor {
return file_sketches_proto_enumTypes[0].Descriptor()
}
func (ProbType) Type() protoreflect.EnumType {
return &file_sketches_proto_enumTypes[0]
}
func (x ProbType) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use ProbType.Descriptor instead.
func (ProbType) EnumDescriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{0}
}
type BloomReserveRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Capacity uint64 `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
ErrorRate float64 `protobuf:"fixed64,3,opt,name=error_rate,json=errorRate,proto3" json:"error_rate,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomReserveRequest) Reset() {
*x = BloomReserveRequest{}
mi := &file_sketches_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomReserveRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomReserveRequest) ProtoMessage() {}
func (x *BloomReserveRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[0]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomReserveRequest.ProtoReflect.Descriptor instead.
func (*BloomReserveRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{0}
}
func (x *BloomReserveRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *BloomReserveRequest) GetCapacity() uint64 {
if x != nil {
return x.Capacity
}
return 0
}
func (x *BloomReserveRequest) GetErrorRate() float64 {
if x != nil {
return x.ErrorRate
}
return 0
}
type BloomReserveResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomReserveResponse) Reset() {
*x = BloomReserveResponse{}
mi := &file_sketches_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomReserveResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomReserveResponse) ProtoMessage() {}
func (x *BloomReserveResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[1]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomReserveResponse.ProtoReflect.Descriptor instead.
func (*BloomReserveResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{1}
}
func (x *BloomReserveResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *BloomReserveResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *BloomReserveResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type BloomAddRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Item []byte `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomAddRequest) Reset() {
*x = BloomAddRequest{}
mi := &file_sketches_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomAddRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomAddRequest) ProtoMessage() {}
func (x *BloomAddRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[2]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomAddRequest.ProtoReflect.Descriptor instead.
func (*BloomAddRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{2}
}
func (x *BloomAddRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *BloomAddRequest) GetItem() []byte {
if x != nil {
return x.Item
}
return nil
}
type BloomAddResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomAddResponse) Reset() {
*x = BloomAddResponse{}
mi := &file_sketches_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomAddResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomAddResponse) ProtoMessage() {}
func (x *BloomAddResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[3]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomAddResponse.ProtoReflect.Descriptor instead.
func (*BloomAddResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{3}
}
func (x *BloomAddResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *BloomAddResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *BloomAddResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type BloomMultiAddRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Items [][]byte `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomMultiAddRequest) Reset() {
*x = BloomMultiAddRequest{}
mi := &file_sketches_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomMultiAddRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomMultiAddRequest) ProtoMessage() {}
func (x *BloomMultiAddRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[4]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomMultiAddRequest.ProtoReflect.Descriptor instead.
func (*BloomMultiAddRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{4}
}
func (x *BloomMultiAddRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *BloomMultiAddRequest) GetItems() [][]byte {
if x != nil {
return x.Items
}
return nil
}
type BloomMultiAddResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomMultiAddResponse) Reset() {
*x = BloomMultiAddResponse{}
mi := &file_sketches_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomMultiAddResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomMultiAddResponse) ProtoMessage() {}
func (x *BloomMultiAddResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[5]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomMultiAddResponse.ProtoReflect.Descriptor instead.
func (*BloomMultiAddResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{5}
}
func (x *BloomMultiAddResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *BloomMultiAddResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *BloomMultiAddResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type BloomExistsRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Item []byte `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomExistsRequest) Reset() {
*x = BloomExistsRequest{}
mi := &file_sketches_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomExistsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomExistsRequest) ProtoMessage() {}
func (x *BloomExistsRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[6]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomExistsRequest.ProtoReflect.Descriptor instead.
func (*BloomExistsRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{6}
}
func (x *BloomExistsRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *BloomExistsRequest) GetItem() []byte {
if x != nil {
return x.Item
}
return nil
}
type BloomExistsResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Exists bool `protobuf:"varint,4,opt,name=exists,proto3" json:"exists,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomExistsResponse) Reset() {
*x = BloomExistsResponse{}
mi := &file_sketches_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomExistsResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomExistsResponse) ProtoMessage() {}
func (x *BloomExistsResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[7]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomExistsResponse.ProtoReflect.Descriptor instead.
func (*BloomExistsResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{7}
}
func (x *BloomExistsResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *BloomExistsResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *BloomExistsResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *BloomExistsResponse) GetExists() bool {
if x != nil {
return x.Exists
}
return false
}
type BloomMultiExistsRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Items [][]byte `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomMultiExistsRequest) Reset() {
*x = BloomMultiExistsRequest{}
mi := &file_sketches_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomMultiExistsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomMultiExistsRequest) ProtoMessage() {}
func (x *BloomMultiExistsRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[8]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomMultiExistsRequest.ProtoReflect.Descriptor instead.
func (*BloomMultiExistsRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{8}
}
func (x *BloomMultiExistsRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *BloomMultiExistsRequest) GetItems() [][]byte {
if x != nil {
return x.Items
}
return nil
}
type BloomMultiExistsResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Exists []bool `protobuf:"varint,4,rep,packed,name=exists,proto3" json:"exists,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomMultiExistsResponse) Reset() {
*x = BloomMultiExistsResponse{}
mi := &file_sketches_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomMultiExistsResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomMultiExistsResponse) ProtoMessage() {}
func (x *BloomMultiExistsResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[9]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomMultiExistsResponse.ProtoReflect.Descriptor instead.
func (*BloomMultiExistsResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{9}
}
func (x *BloomMultiExistsResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *BloomMultiExistsResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *BloomMultiExistsResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *BloomMultiExistsResponse) GetExists() []bool {
if x != nil {
return x.Exists
}
return nil
}
type BloomInfoRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomInfoRequest) Reset() {
*x = BloomInfoRequest{}
mi := &file_sketches_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomInfoRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomInfoRequest) ProtoMessage() {}
func (x *BloomInfoRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[10]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomInfoRequest.ProtoReflect.Descriptor instead.
func (*BloomInfoRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{10}
}
func (x *BloomInfoRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type BloomInfoResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Capacity uint64 `protobuf:"varint,4,opt,name=capacity,proto3" json:"capacity,omitempty"`
ErrorRate float64 `protobuf:"fixed64,5,opt,name=error_rate,json=errorRate,proto3" json:"error_rate,omitempty"`
BitsSet uint64 `protobuf:"varint,6,opt,name=bits_set,json=bitsSet,proto3" json:"bits_set,omitempty"`
BitCount uint64 `protobuf:"varint,7,opt,name=bit_count,json=bitCount,proto3" json:"bit_count,omitempty"`
HashCount uint32 `protobuf:"varint,8,opt,name=hash_count,json=hashCount,proto3" json:"hash_count,omitempty"`
ItemsAdded uint64 `protobuf:"varint,9,opt,name=items_added,json=itemsAdded,proto3" json:"items_added,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomInfoResponse) Reset() {
*x = BloomInfoResponse{}
mi := &file_sketches_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomInfoResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomInfoResponse) ProtoMessage() {}
func (x *BloomInfoResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[11]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomInfoResponse.ProtoReflect.Descriptor instead.
func (*BloomInfoResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{11}
}
func (x *BloomInfoResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *BloomInfoResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *BloomInfoResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *BloomInfoResponse) GetCapacity() uint64 {
if x != nil {
return x.Capacity
}
return 0
}
func (x *BloomInfoResponse) GetErrorRate() float64 {
if x != nil {
return x.ErrorRate
}
return 0
}
func (x *BloomInfoResponse) GetBitsSet() uint64 {
if x != nil {
return x.BitsSet
}
return 0
}
func (x *BloomInfoResponse) GetBitCount() uint64 {
if x != nil {
return x.BitCount
}
return 0
}
func (x *BloomInfoResponse) GetHashCount() uint32 {
if x != nil {
return x.HashCount
}
return 0
}
func (x *BloomInfoResponse) GetItemsAdded() uint64 {
if x != nil {
return x.ItemsAdded
}
return 0
}
type BloomDeleteRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomDeleteRequest) Reset() {
*x = BloomDeleteRequest{}
mi := &file_sketches_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomDeleteRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomDeleteRequest) ProtoMessage() {}
func (x *BloomDeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[12]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomDeleteRequest.ProtoReflect.Descriptor instead.
func (*BloomDeleteRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{12}
}
func (x *BloomDeleteRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type BloomDeleteResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *BloomDeleteResponse) Reset() {
*x = BloomDeleteResponse{}
mi := &file_sketches_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *BloomDeleteResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*BloomDeleteResponse) ProtoMessage() {}
func (x *BloomDeleteResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[13]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use BloomDeleteResponse.ProtoReflect.Descriptor instead.
func (*BloomDeleteResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{13}
}
func (x *BloomDeleteResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *BloomDeleteResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *BloomDeleteResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type HllReserveRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Precision uint32 `protobuf:"varint,2,opt,name=precision,proto3" json:"precision,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllReserveRequest) Reset() {
*x = HllReserveRequest{}
mi := &file_sketches_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllReserveRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllReserveRequest) ProtoMessage() {}
func (x *HllReserveRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[14]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllReserveRequest.ProtoReflect.Descriptor instead.
func (*HllReserveRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{14}
}
func (x *HllReserveRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *HllReserveRequest) GetPrecision() uint32 {
if x != nil {
return x.Precision
}
return 0
}
type HllReserveResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllReserveResponse) Reset() {
*x = HllReserveResponse{}
mi := &file_sketches_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllReserveResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllReserveResponse) ProtoMessage() {}
func (x *HllReserveResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[15]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllReserveResponse.ProtoReflect.Descriptor instead.
func (*HllReserveResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{15}
}
func (x *HllReserveResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HllReserveResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HllReserveResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type HllAddRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Items [][]byte `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllAddRequest) Reset() {
*x = HllAddRequest{}
mi := &file_sketches_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllAddRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllAddRequest) ProtoMessage() {}
func (x *HllAddRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[16]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllAddRequest.ProtoReflect.Descriptor instead.
func (*HllAddRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{16}
}
func (x *HllAddRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *HllAddRequest) GetItems() [][]byte {
if x != nil {
return x.Items
}
return nil
}
type HllAddResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllAddResponse) Reset() {
*x = HllAddResponse{}
mi := &file_sketches_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllAddResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllAddResponse) ProtoMessage() {}
func (x *HllAddResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[17]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllAddResponse.ProtoReflect.Descriptor instead.
func (*HllAddResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{17}
}
func (x *HllAddResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HllAddResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HllAddResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type HllCountRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllCountRequest) Reset() {
*x = HllCountRequest{}
mi := &file_sketches_proto_msgTypes[18]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllCountRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllCountRequest) ProtoMessage() {}
func (x *HllCountRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[18]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllCountRequest.ProtoReflect.Descriptor instead.
func (*HllCountRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{18}
}
func (x *HllCountRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type HllCountResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Estimate uint64 `protobuf:"varint,4,opt,name=estimate,proto3" json:"estimate,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllCountResponse) Reset() {
*x = HllCountResponse{}
mi := &file_sketches_proto_msgTypes[19]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllCountResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllCountResponse) ProtoMessage() {}
func (x *HllCountResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[19]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllCountResponse.ProtoReflect.Descriptor instead.
func (*HllCountResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{19}
}
func (x *HllCountResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HllCountResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HllCountResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *HllCountResponse) GetEstimate() uint64 {
if x != nil {
return x.Estimate
}
return 0
}
type HllMergeRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllMergeRequest) Reset() {
*x = HllMergeRequest{}
mi := &file_sketches_proto_msgTypes[20]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllMergeRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllMergeRequest) ProtoMessage() {}
func (x *HllMergeRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[20]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllMergeRequest.ProtoReflect.Descriptor instead.
func (*HllMergeRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{20}
}
func (x *HllMergeRequest) GetDestination() string {
if x != nil {
return x.Destination
}
return ""
}
func (x *HllMergeRequest) GetSources() []string {
if x != nil {
return x.Sources
}
return nil
}
type HllMergeResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllMergeResponse) Reset() {
*x = HllMergeResponse{}
mi := &file_sketches_proto_msgTypes[21]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllMergeResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllMergeResponse) ProtoMessage() {}
func (x *HllMergeResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[21]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllMergeResponse.ProtoReflect.Descriptor instead.
func (*HllMergeResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{21}
}
func (x *HllMergeResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HllMergeResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HllMergeResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type HllDeleteRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllDeleteRequest) Reset() {
*x = HllDeleteRequest{}
mi := &file_sketches_proto_msgTypes[22]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllDeleteRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllDeleteRequest) ProtoMessage() {}
func (x *HllDeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[22]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllDeleteRequest.ProtoReflect.Descriptor instead.
func (*HllDeleteRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{22}
}
func (x *HllDeleteRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type HllDeleteResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HllDeleteResponse) Reset() {
*x = HllDeleteResponse{}
mi := &file_sketches_proto_msgTypes[23]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HllDeleteResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HllDeleteResponse) ProtoMessage() {}
func (x *HllDeleteResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[23]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HllDeleteResponse.ProtoReflect.Descriptor instead.
func (*HllDeleteResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{23}
}
func (x *HllDeleteResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HllDeleteResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HllDeleteResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type CmsReserveRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Width uint64 `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
Depth uint64 `protobuf:"varint,3,opt,name=depth,proto3" json:"depth,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsReserveRequest) Reset() {
*x = CmsReserveRequest{}
mi := &file_sketches_proto_msgTypes[24]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsReserveRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsReserveRequest) ProtoMessage() {}
func (x *CmsReserveRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[24]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsReserveRequest.ProtoReflect.Descriptor instead.
func (*CmsReserveRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{24}
}
func (x *CmsReserveRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *CmsReserveRequest) GetWidth() uint64 {
if x != nil {
return x.Width
}
return 0
}
func (x *CmsReserveRequest) GetDepth() uint64 {
if x != nil {
return x.Depth
}
return 0
}
type CmsReserveResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsReserveResponse) Reset() {
*x = CmsReserveResponse{}
mi := &file_sketches_proto_msgTypes[25]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsReserveResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsReserveResponse) ProtoMessage() {}
func (x *CmsReserveResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[25]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsReserveResponse.ProtoReflect.Descriptor instead.
func (*CmsReserveResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{25}
}
func (x *CmsReserveResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *CmsReserveResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *CmsReserveResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type CmsIncrByItem struct {
state protoimpl.MessageState `protogen:"open.v1"`
Item []byte `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
Count uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsIncrByItem) Reset() {
*x = CmsIncrByItem{}
mi := &file_sketches_proto_msgTypes[26]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsIncrByItem) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsIncrByItem) ProtoMessage() {}
func (x *CmsIncrByItem) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[26]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsIncrByItem.ProtoReflect.Descriptor instead.
func (*CmsIncrByItem) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{26}
}
func (x *CmsIncrByItem) GetItem() []byte {
if x != nil {
return x.Item
}
return nil
}
func (x *CmsIncrByItem) GetCount() uint64 {
if x != nil {
return x.Count
}
return 0
}
type CmsIncrByRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Items []*CmsIncrByItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsIncrByRequest) Reset() {
*x = CmsIncrByRequest{}
mi := &file_sketches_proto_msgTypes[27]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsIncrByRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsIncrByRequest) ProtoMessage() {}
func (x *CmsIncrByRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[27]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsIncrByRequest.ProtoReflect.Descriptor instead.
func (*CmsIncrByRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{27}
}
func (x *CmsIncrByRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *CmsIncrByRequest) GetItems() []*CmsIncrByItem {
if x != nil {
return x.Items
}
return nil
}
type CmsIncrByResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Counts []uint64 `protobuf:"varint,4,rep,packed,name=counts,proto3" json:"counts,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsIncrByResponse) Reset() {
*x = CmsIncrByResponse{}
mi := &file_sketches_proto_msgTypes[28]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsIncrByResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsIncrByResponse) ProtoMessage() {}
func (x *CmsIncrByResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[28]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsIncrByResponse.ProtoReflect.Descriptor instead.
func (*CmsIncrByResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{28}
}
func (x *CmsIncrByResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *CmsIncrByResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *CmsIncrByResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *CmsIncrByResponse) GetCounts() []uint64 {
if x != nil {
return x.Counts
}
return nil
}
type CmsQueryRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Items [][]byte `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsQueryRequest) Reset() {
*x = CmsQueryRequest{}
mi := &file_sketches_proto_msgTypes[29]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsQueryRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsQueryRequest) ProtoMessage() {}
func (x *CmsQueryRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[29]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsQueryRequest.ProtoReflect.Descriptor instead.
func (*CmsQueryRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{29}
}
func (x *CmsQueryRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *CmsQueryRequest) GetItems() [][]byte {
if x != nil {
return x.Items
}
return nil
}
type CmsQueryResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Counts []uint64 `protobuf:"varint,4,rep,packed,name=counts,proto3" json:"counts,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsQueryResponse) Reset() {
*x = CmsQueryResponse{}
mi := &file_sketches_proto_msgTypes[30]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsQueryResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsQueryResponse) ProtoMessage() {}
func (x *CmsQueryResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[30]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsQueryResponse.ProtoReflect.Descriptor instead.
func (*CmsQueryResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{30}
}
func (x *CmsQueryResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *CmsQueryResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *CmsQueryResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *CmsQueryResponse) GetCounts() []uint64 {
if x != nil {
return x.Counts
}
return nil
}
type CmsDeleteRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsDeleteRequest) Reset() {
*x = CmsDeleteRequest{}
mi := &file_sketches_proto_msgTypes[31]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsDeleteRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsDeleteRequest) ProtoMessage() {}
func (x *CmsDeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[31]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsDeleteRequest.ProtoReflect.Descriptor instead.
func (*CmsDeleteRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{31}
}
func (x *CmsDeleteRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type CmsDeleteResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CmsDeleteResponse) Reset() {
*x = CmsDeleteResponse{}
mi := &file_sketches_proto_msgTypes[32]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CmsDeleteResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CmsDeleteResponse) ProtoMessage() {}
func (x *CmsDeleteResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[32]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CmsDeleteResponse.ProtoReflect.Descriptor instead.
func (*CmsDeleteResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{32}
}
func (x *CmsDeleteResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *CmsDeleteResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *CmsDeleteResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type TopKReserveRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
K uint32 `protobuf:"varint,2,opt,name=k,proto3" json:"k,omitempty"`
Width uint64 `protobuf:"varint,3,opt,name=width,proto3" json:"width,omitempty"`
Depth uint64 `protobuf:"varint,4,opt,name=depth,proto3" json:"depth,omitempty"`
Decay float64 `protobuf:"fixed64,5,opt,name=decay,proto3" json:"decay,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKReserveRequest) Reset() {
*x = TopKReserveRequest{}
mi := &file_sketches_proto_msgTypes[33]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKReserveRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKReserveRequest) ProtoMessage() {}
func (x *TopKReserveRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[33]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKReserveRequest.ProtoReflect.Descriptor instead.
func (*TopKReserveRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{33}
}
func (x *TopKReserveRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *TopKReserveRequest) GetK() uint32 {
if x != nil {
return x.K
}
return 0
}
func (x *TopKReserveRequest) GetWidth() uint64 {
if x != nil {
return x.Width
}
return 0
}
func (x *TopKReserveRequest) GetDepth() uint64 {
if x != nil {
return x.Depth
}
return 0
}
func (x *TopKReserveRequest) GetDecay() float64 {
if x != nil {
return x.Decay
}
return 0
}
type TopKReserveResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKReserveResponse) Reset() {
*x = TopKReserveResponse{}
mi := &file_sketches_proto_msgTypes[34]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKReserveResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKReserveResponse) ProtoMessage() {}
func (x *TopKReserveResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[34]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKReserveResponse.ProtoReflect.Descriptor instead.
func (*TopKReserveResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{34}
}
func (x *TopKReserveResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TopKReserveResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TopKReserveResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type TopKAddRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Items [][]byte `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKAddRequest) Reset() {
*x = TopKAddRequest{}
mi := &file_sketches_proto_msgTypes[35]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKAddRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKAddRequest) ProtoMessage() {}
func (x *TopKAddRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[35]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKAddRequest.ProtoReflect.Descriptor instead.
func (*TopKAddRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{35}
}
func (x *TopKAddRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *TopKAddRequest) GetItems() [][]byte {
if x != nil {
return x.Items
}
return nil
}
type TopKAddResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Evicted [][]byte `protobuf:"bytes,4,rep,name=evicted,proto3" json:"evicted,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKAddResponse) Reset() {
*x = TopKAddResponse{}
mi := &file_sketches_proto_msgTypes[36]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKAddResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKAddResponse) ProtoMessage() {}
func (x *TopKAddResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[36]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKAddResponse.ProtoReflect.Descriptor instead.
func (*TopKAddResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{36}
}
func (x *TopKAddResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TopKAddResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TopKAddResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *TopKAddResponse) GetEvicted() [][]byte {
if x != nil {
return x.Evicted
}
return nil
}
type TopKQueryRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Items [][]byte `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKQueryRequest) Reset() {
*x = TopKQueryRequest{}
mi := &file_sketches_proto_msgTypes[37]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKQueryRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKQueryRequest) ProtoMessage() {}
func (x *TopKQueryRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[37]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKQueryRequest.ProtoReflect.Descriptor instead.
func (*TopKQueryRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{37}
}
func (x *TopKQueryRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *TopKQueryRequest) GetItems() [][]byte {
if x != nil {
return x.Items
}
return nil
}
type TopKQueryResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
InTopK []bool `protobuf:"varint,4,rep,packed,name=in_top_k,json=inTopK,proto3" json:"in_top_k,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKQueryResponse) Reset() {
*x = TopKQueryResponse{}
mi := &file_sketches_proto_msgTypes[38]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKQueryResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKQueryResponse) ProtoMessage() {}
func (x *TopKQueryResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[38]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKQueryResponse.ProtoReflect.Descriptor instead.
func (*TopKQueryResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{38}
}
func (x *TopKQueryResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TopKQueryResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TopKQueryResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *TopKQueryResponse) GetInTopK() []bool {
if x != nil {
return x.InTopK
}
return nil
}
type TopKListRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKListRequest) Reset() {
*x = TopKListRequest{}
mi := &file_sketches_proto_msgTypes[39]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKListRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKListRequest) ProtoMessage() {}
func (x *TopKListRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[39]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKListRequest.ProtoReflect.Descriptor instead.
func (*TopKListRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{39}
}
func (x *TopKListRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type TopKListResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Entries []*TopKEntry `protobuf:"bytes,4,rep,name=entries,proto3" json:"entries,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKListResponse) Reset() {
*x = TopKListResponse{}
mi := &file_sketches_proto_msgTypes[40]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKListResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKListResponse) ProtoMessage() {}
func (x *TopKListResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[40]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKListResponse.ProtoReflect.Descriptor instead.
func (*TopKListResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{40}
}
func (x *TopKListResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TopKListResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TopKListResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *TopKListResponse) GetEntries() []*TopKEntry {
if x != nil {
return x.Entries
}
return nil
}
type TopKEntry struct {
state protoimpl.MessageState `protogen:"open.v1"`
Item []byte `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
Count uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKEntry) Reset() {
*x = TopKEntry{}
mi := &file_sketches_proto_msgTypes[41]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKEntry) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKEntry) ProtoMessage() {}
func (x *TopKEntry) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[41]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKEntry.ProtoReflect.Descriptor instead.
func (*TopKEntry) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{41}
}
func (x *TopKEntry) GetItem() []byte {
if x != nil {
return x.Item
}
return nil
}
func (x *TopKEntry) GetCount() uint64 {
if x != nil {
return x.Count
}
return 0
}
type TopKDeleteRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKDeleteRequest) Reset() {
*x = TopKDeleteRequest{}
mi := &file_sketches_proto_msgTypes[42]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKDeleteRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKDeleteRequest) ProtoMessage() {}
func (x *TopKDeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[42]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKDeleteRequest.ProtoReflect.Descriptor instead.
func (*TopKDeleteRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{42}
}
func (x *TopKDeleteRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type TopKDeleteResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TopKDeleteResponse) Reset() {
*x = TopKDeleteResponse{}
mi := &file_sketches_proto_msgTypes[43]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TopKDeleteResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TopKDeleteResponse) ProtoMessage() {}
func (x *TopKDeleteResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[43]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TopKDeleteResponse.ProtoReflect.Descriptor instead.
func (*TopKDeleteResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{43}
}
func (x *TopKDeleteResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TopKDeleteResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TopKDeleteResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type TDigestCreateRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Compression uint32 `protobuf:"varint,2,opt,name=compression,proto3" json:"compression,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestCreateRequest) Reset() {
*x = TDigestCreateRequest{}
mi := &file_sketches_proto_msgTypes[44]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestCreateRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestCreateRequest) ProtoMessage() {}
func (x *TDigestCreateRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[44]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestCreateRequest.ProtoReflect.Descriptor instead.
func (*TDigestCreateRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{44}
}
func (x *TDigestCreateRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *TDigestCreateRequest) GetCompression() uint32 {
if x != nil {
return x.Compression
}
return 0
}
type TDigestCreateResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestCreateResponse) Reset() {
*x = TDigestCreateResponse{}
mi := &file_sketches_proto_msgTypes[45]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestCreateResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestCreateResponse) ProtoMessage() {}
func (x *TDigestCreateResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[45]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestCreateResponse.ProtoReflect.Descriptor instead.
func (*TDigestCreateResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{45}
}
func (x *TDigestCreateResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TDigestCreateResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TDigestCreateResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type TDigestAddRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Values []float64 `protobuf:"fixed64,2,rep,packed,name=values,proto3" json:"values,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestAddRequest) Reset() {
*x = TDigestAddRequest{}
mi := &file_sketches_proto_msgTypes[46]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestAddRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestAddRequest) ProtoMessage() {}
func (x *TDigestAddRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[46]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestAddRequest.ProtoReflect.Descriptor instead.
func (*TDigestAddRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{46}
}
func (x *TDigestAddRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *TDigestAddRequest) GetValues() []float64 {
if x != nil {
return x.Values
}
return nil
}
type TDigestAddResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestAddResponse) Reset() {
*x = TDigestAddResponse{}
mi := &file_sketches_proto_msgTypes[47]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestAddResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestAddResponse) ProtoMessage() {}
func (x *TDigestAddResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[47]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestAddResponse.ProtoReflect.Descriptor instead.
func (*TDigestAddResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{47}
}
func (x *TDigestAddResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TDigestAddResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TDigestAddResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type TDigestQuantileRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Quantiles []float64 `protobuf:"fixed64,2,rep,packed,name=quantiles,proto3" json:"quantiles,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestQuantileRequest) Reset() {
*x = TDigestQuantileRequest{}
mi := &file_sketches_proto_msgTypes[48]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestQuantileRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestQuantileRequest) ProtoMessage() {}
func (x *TDigestQuantileRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[48]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestQuantileRequest.ProtoReflect.Descriptor instead.
func (*TDigestQuantileRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{48}
}
func (x *TDigestQuantileRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *TDigestQuantileRequest) GetQuantiles() []float64 {
if x != nil {
return x.Quantiles
}
return nil
}
type TDigestQuantileResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Values []float64 `protobuf:"fixed64,4,rep,packed,name=values,proto3" json:"values,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestQuantileResponse) Reset() {
*x = TDigestQuantileResponse{}
mi := &file_sketches_proto_msgTypes[49]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestQuantileResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestQuantileResponse) ProtoMessage() {}
func (x *TDigestQuantileResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[49]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestQuantileResponse.ProtoReflect.Descriptor instead.
func (*TDigestQuantileResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{49}
}
func (x *TDigestQuantileResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TDigestQuantileResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TDigestQuantileResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *TDigestQuantileResponse) GetValues() []float64 {
if x != nil {
return x.Values
}
return nil
}
type TDigestMinMaxRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestMinMaxRequest) Reset() {
*x = TDigestMinMaxRequest{}
mi := &file_sketches_proto_msgTypes[50]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestMinMaxRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestMinMaxRequest) ProtoMessage() {}
func (x *TDigestMinMaxRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[50]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestMinMaxRequest.ProtoReflect.Descriptor instead.
func (*TDigestMinMaxRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{50}
}
func (x *TDigestMinMaxRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type TDigestMinMaxResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Min float64 `protobuf:"fixed64,4,opt,name=min,proto3" json:"min,omitempty"`
Max float64 `protobuf:"fixed64,5,opt,name=max,proto3" json:"max,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestMinMaxResponse) Reset() {
*x = TDigestMinMaxResponse{}
mi := &file_sketches_proto_msgTypes[51]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestMinMaxResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestMinMaxResponse) ProtoMessage() {}
func (x *TDigestMinMaxResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[51]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestMinMaxResponse.ProtoReflect.Descriptor instead.
func (*TDigestMinMaxResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{51}
}
func (x *TDigestMinMaxResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TDigestMinMaxResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TDigestMinMaxResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *TDigestMinMaxResponse) GetMin() float64 {
if x != nil {
return x.Min
}
return 0
}
func (x *TDigestMinMaxResponse) GetMax() float64 {
if x != nil {
return x.Max
}
return 0
}
type TDigestDeleteRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestDeleteRequest) Reset() {
*x = TDigestDeleteRequest{}
mi := &file_sketches_proto_msgTypes[52]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestDeleteRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestDeleteRequest) ProtoMessage() {}
func (x *TDigestDeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[52]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestDeleteRequest.ProtoReflect.Descriptor instead.
func (*TDigestDeleteRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{52}
}
func (x *TDigestDeleteRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type TDigestDeleteResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *TDigestDeleteResponse) Reset() {
*x = TDigestDeleteResponse{}
mi := &file_sketches_proto_msgTypes[53]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *TDigestDeleteResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*TDigestDeleteResponse) ProtoMessage() {}
func (x *TDigestDeleteResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[53]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use TDigestDeleteResponse.ProtoReflect.Descriptor instead.
func (*TDigestDeleteResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{53}
}
func (x *TDigestDeleteResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *TDigestDeleteResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *TDigestDeleteResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type ReplicateProbStateRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Type ProbType `protobuf:"varint,1,opt,name=type,proto3,enum=waymaker.sketches.ProbType" json:"type,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// Opaque binary snapshot — see specs/WIRE_SPEC.md "Probabilistic
// subsystem" for the per-type byte layout.
Snapshot []byte `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
Version uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ReplicateProbStateRequest) Reset() {
*x = ReplicateProbStateRequest{}
mi := &file_sketches_proto_msgTypes[54]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ReplicateProbStateRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ReplicateProbStateRequest) ProtoMessage() {}
func (x *ReplicateProbStateRequest) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[54]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ReplicateProbStateRequest.ProtoReflect.Descriptor instead.
func (*ReplicateProbStateRequest) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{54}
}
func (x *ReplicateProbStateRequest) GetType() ProbType {
if x != nil {
return x.Type
}
return ProbType_PROB_UNSPECIFIED
}
func (x *ReplicateProbStateRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *ReplicateProbStateRequest) GetSnapshot() []byte {
if x != nil {
return x.Snapshot
}
return nil
}
func (x *ReplicateProbStateRequest) GetVersion() uint64 {
if x != nil {
return x.Version
}
return 0
}
type ReplicateProbStateResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
ResultCode string `protobuf:"bytes,2,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ReplicateProbStateResponse) Reset() {
*x = ReplicateProbStateResponse{}
mi := &file_sketches_proto_msgTypes[55]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ReplicateProbStateResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ReplicateProbStateResponse) ProtoMessage() {}
func (x *ReplicateProbStateResponse) ProtoReflect() protoreflect.Message {
mi := &file_sketches_proto_msgTypes[55]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ReplicateProbStateResponse.ProtoReflect.Descriptor instead.
func (*ReplicateProbStateResponse) Descriptor() ([]byte, []int) {
return file_sketches_proto_rawDescGZIP(), []int{55}
}
func (x *ReplicateProbStateResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *ReplicateProbStateResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *ReplicateProbStateResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
var File_sketches_proto protoreflect.FileDescriptor
const file_sketches_proto_rawDesc = "" +
"\n" +
"\x0esketches.proto\x12\x11waymaker.sketches\"d\n" +
"\x13BloomReserveRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x1a\n" +
"\bcapacity\x18\x02 \x01(\x04R\bcapacity\x12\x1d\n" +
"\n" +
"error_rate\x18\x03 \x01(\x01R\terrorRate\"k\n" +
"\x14BloomReserveResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"9\n" +
"\x0fBloomAddRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n" +
"\x04item\x18\x02 \x01(\fR\x04item\"g\n" +
"\x10BloomAddResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"@\n" +
"\x14BloomMultiAddRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
"\x05items\x18\x02 \x03(\fR\x05items\"l\n" +
"\x15BloomMultiAddResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"<\n" +
"\x12BloomExistsRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n" +
"\x04item\x18\x02 \x01(\fR\x04item\"\x82\x01\n" +
"\x13BloomExistsResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x16\n" +
"\x06exists\x18\x04 \x01(\bR\x06exists\"C\n" +
"\x17BloomMultiExistsRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
"\x05items\x18\x02 \x03(\fR\x05items\"\x87\x01\n" +
"\x18BloomMultiExistsResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x16\n" +
"\x06exists\x18\x04 \x03(\bR\x06exists\"&\n" +
"\x10BloomInfoRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"\x9b\x02\n" +
"\x11BloomInfoResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x1a\n" +
"\bcapacity\x18\x04 \x01(\x04R\bcapacity\x12\x1d\n" +
"\n" +
"error_rate\x18\x05 \x01(\x01R\terrorRate\x12\x19\n" +
"\bbits_set\x18\x06 \x01(\x04R\abitsSet\x12\x1b\n" +
"\tbit_count\x18\a \x01(\x04R\bbitCount\x12\x1d\n" +
"\n" +
"hash_count\x18\b \x01(\rR\thashCount\x12\x1f\n" +
"\vitems_added\x18\t \x01(\x04R\n" +
"itemsAdded\"(\n" +
"\x12BloomDeleteRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"j\n" +
"\x13BloomDeleteResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"E\n" +
"\x11HllReserveRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x1c\n" +
"\tprecision\x18\x02 \x01(\rR\tprecision\"i\n" +
"\x12HllReserveResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"9\n" +
"\rHllAddRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
"\x05items\x18\x02 \x03(\fR\x05items\"e\n" +
"\x0eHllAddResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"%\n" +
"\x0fHllCountRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"\x83\x01\n" +
"\x10HllCountResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x1a\n" +
"\bestimate\x18\x04 \x01(\x04R\bestimate\"M\n" +
"\x0fHllMergeRequest\x12 \n" +
"\vdestination\x18\x01 \x01(\tR\vdestination\x12\x18\n" +
"\asources\x18\x02 \x03(\tR\asources\"g\n" +
"\x10HllMergeResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"&\n" +
"\x10HllDeleteRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"h\n" +
"\x11HllDeleteResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"S\n" +
"\x11CmsReserveRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
"\x05width\x18\x02 \x01(\x04R\x05width\x12\x14\n" +
"\x05depth\x18\x03 \x01(\x04R\x05depth\"i\n" +
"\x12CmsReserveResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"9\n" +
"\rCmsIncrByItem\x12\x12\n" +
"\x04item\x18\x01 \x01(\fR\x04item\x12\x14\n" +
"\x05count\x18\x02 \x01(\x04R\x05count\"^\n" +
"\x10CmsIncrByRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x126\n" +
"\x05items\x18\x02 \x03(\v2 .waymaker.sketches.CmsIncrByItemR\x05items\"\x80\x01\n" +
"\x11CmsIncrByResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x16\n" +
"\x06counts\x18\x04 \x03(\x04R\x06counts\";\n" +
"\x0fCmsQueryRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
"\x05items\x18\x02 \x03(\fR\x05items\"\x7f\n" +
"\x10CmsQueryResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x16\n" +
"\x06counts\x18\x04 \x03(\x04R\x06counts\"&\n" +
"\x10CmsDeleteRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"h\n" +
"\x11CmsDeleteResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"x\n" +
"\x12TopKReserveRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\f\n" +
"\x01k\x18\x02 \x01(\rR\x01k\x12\x14\n" +
"\x05width\x18\x03 \x01(\x04R\x05width\x12\x14\n" +
"\x05depth\x18\x04 \x01(\x04R\x05depth\x12\x14\n" +
"\x05decay\x18\x05 \x01(\x01R\x05decay\"j\n" +
"\x13TopKReserveResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\":\n" +
"\x0eTopKAddRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
"\x05items\x18\x02 \x03(\fR\x05items\"\x80\x01\n" +
"\x0fTopKAddResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x18\n" +
"\aevicted\x18\x04 \x03(\fR\aevicted\"<\n" +
"\x10TopKQueryRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
"\x05items\x18\x02 \x03(\fR\x05items\"\x82\x01\n" +
"\x11TopKQueryResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x18\n" +
"\bin_top_k\x18\x04 \x03(\bR\x06inTopK\"%\n" +
"\x0fTopKListRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"\x9f\x01\n" +
"\x10TopKListResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x126\n" +
"\aentries\x18\x04 \x03(\v2\x1c.waymaker.sketches.TopKEntryR\aentries\"5\n" +
"\tTopKEntry\x12\x12\n" +
"\x04item\x18\x01 \x01(\fR\x04item\x12\x14\n" +
"\x05count\x18\x02 \x01(\x04R\x05count\"'\n" +
"\x11TopKDeleteRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"i\n" +
"\x12TopKDeleteResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"L\n" +
"\x14TDigestCreateRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12 \n" +
"\vcompression\x18\x02 \x01(\rR\vcompression\"l\n" +
"\x15TDigestCreateResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"?\n" +
"\x11TDigestAddRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x16\n" +
"\x06values\x18\x02 \x03(\x01R\x06values\"i\n" +
"\x12TDigestAddResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"J\n" +
"\x16TDigestQuantileRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x1c\n" +
"\tquantiles\x18\x02 \x03(\x01R\tquantiles\"\x86\x01\n" +
"\x17TDigestQuantileResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x16\n" +
"\x06values\x18\x04 \x03(\x01R\x06values\"*\n" +
"\x14TDigestMinMaxRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"\x90\x01\n" +
"\x15TDigestMinMaxResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12\x10\n" +
"\x03min\x18\x04 \x01(\x01R\x03min\x12\x10\n" +
"\x03max\x18\x05 \x01(\x01R\x03max\"*\n" +
"\x14TDigestDeleteRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"l\n" +
"\x15TDigestDeleteResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"\x96\x01\n" +
"\x19ReplicateProbStateRequest\x12/\n" +
"\x04type\x18\x01 \x01(\x0e2\x1b.waymaker.sketches.ProbTypeR\x04type\x12\x12\n" +
"\x04name\x18\x02 \x01(\tR\x04name\x12\x1a\n" +
"\bsnapshot\x18\x03 \x01(\fR\bsnapshot\x12\x18\n" +
"\aversion\x18\x04 \x01(\x04R\aversion\"q\n" +
"\x1aReplicateProbStateResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x1f\n" +
"\vresult_code\x18\x02 \x01(\tR\n" +
"resultCode\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage*m\n" +
"\bProbType\x12\x14\n" +
"\x10PROB_UNSPECIFIED\x10\x00\x12\x0e\n" +
"\n" +
"PROB_BLOOM\x10\x01\x12\f\n" +
"\bPROB_HLL\x10\x02\x12\f\n" +
"\bPROB_CMS\x10\x03\x12\r\n" +
"\tPROB_TOPK\x10\x04\x12\x10\n" +
"\fPROB_TDIGEST\x10\x052\xdc\x13\n" +
"\x17WaymakerSketchesService\x12_\n" +
"\fBloomReserve\x12&.waymaker.sketches.BloomReserveRequest\x1a'.waymaker.sketches.BloomReserveResponse\x12S\n" +
"\bBloomAdd\x12\".waymaker.sketches.BloomAddRequest\x1a#.waymaker.sketches.BloomAddResponse\x12b\n" +
"\rBloomMultiAdd\x12'.waymaker.sketches.BloomMultiAddRequest\x1a(.waymaker.sketches.BloomMultiAddResponse\x12\\\n" +
"\vBloomExists\x12%.waymaker.sketches.BloomExistsRequest\x1a&.waymaker.sketches.BloomExistsResponse\x12k\n" +
"\x10BloomMultiExists\x12*.waymaker.sketches.BloomMultiExistsRequest\x1a+.waymaker.sketches.BloomMultiExistsResponse\x12V\n" +
"\tBloomInfo\x12#.waymaker.sketches.BloomInfoRequest\x1a$.waymaker.sketches.BloomInfoResponse\x12\\\n" +
"\vBloomDelete\x12%.waymaker.sketches.BloomDeleteRequest\x1a&.waymaker.sketches.BloomDeleteResponse\x12Y\n" +
"\n" +
"HllReserve\x12$.waymaker.sketches.HllReserveRequest\x1a%.waymaker.sketches.HllReserveResponse\x12M\n" +
"\x06HllAdd\x12 .waymaker.sketches.HllAddRequest\x1a!.waymaker.sketches.HllAddResponse\x12S\n" +
"\bHllCount\x12\".waymaker.sketches.HllCountRequest\x1a#.waymaker.sketches.HllCountResponse\x12S\n" +
"\bHllMerge\x12\".waymaker.sketches.HllMergeRequest\x1a#.waymaker.sketches.HllMergeResponse\x12V\n" +
"\tHllDelete\x12#.waymaker.sketches.HllDeleteRequest\x1a$.waymaker.sketches.HllDeleteResponse\x12Y\n" +
"\n" +
"CmsReserve\x12$.waymaker.sketches.CmsReserveRequest\x1a%.waymaker.sketches.CmsReserveResponse\x12V\n" +
"\tCmsIncrBy\x12#.waymaker.sketches.CmsIncrByRequest\x1a$.waymaker.sketches.CmsIncrByResponse\x12S\n" +
"\bCmsQuery\x12\".waymaker.sketches.CmsQueryRequest\x1a#.waymaker.sketches.CmsQueryResponse\x12V\n" +
"\tCmsDelete\x12#.waymaker.sketches.CmsDeleteRequest\x1a$.waymaker.sketches.CmsDeleteResponse\x12\\\n" +
"\vTopKReserve\x12%.waymaker.sketches.TopKReserveRequest\x1a&.waymaker.sketches.TopKReserveResponse\x12P\n" +
"\aTopKAdd\x12!.waymaker.sketches.TopKAddRequest\x1a\".waymaker.sketches.TopKAddResponse\x12V\n" +
"\tTopKQuery\x12#.waymaker.sketches.TopKQueryRequest\x1a$.waymaker.sketches.TopKQueryResponse\x12S\n" +
"\bTopKList\x12\".waymaker.sketches.TopKListRequest\x1a#.waymaker.sketches.TopKListResponse\x12Y\n" +
"\n" +
"TopKDelete\x12$.waymaker.sketches.TopKDeleteRequest\x1a%.waymaker.sketches.TopKDeleteResponse\x12b\n" +
"\rTDigestCreate\x12'.waymaker.sketches.TDigestCreateRequest\x1a(.waymaker.sketches.TDigestCreateResponse\x12Y\n" +
"\n" +
"TDigestAdd\x12$.waymaker.sketches.TDigestAddRequest\x1a%.waymaker.sketches.TDigestAddResponse\x12h\n" +
"\x0fTDigestQuantile\x12).waymaker.sketches.TDigestQuantileRequest\x1a*.waymaker.sketches.TDigestQuantileResponse\x12b\n" +
"\rTDigestMinMax\x12'.waymaker.sketches.TDigestMinMaxRequest\x1a(.waymaker.sketches.TDigestMinMaxResponse\x12b\n" +
"\rTDigestDelete\x12'.waymaker.sketches.TDigestDeleteRequest\x1a(.waymaker.sketches.TDigestDeleteResponse\x12q\n" +
"\x12ReplicateProbState\x12,.waymaker.sketches.ReplicateProbStateRequest\x1a-.waymaker.sketches.ReplicateProbStateResponseB\x19Z\x17/apis/waymaker_sketchesb\x06proto3"
var (
file_sketches_proto_rawDescOnce sync.Once
file_sketches_proto_rawDescData []byte
)
func file_sketches_proto_rawDescGZIP() []byte {
file_sketches_proto_rawDescOnce.Do(func() {
file_sketches_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_sketches_proto_rawDesc), len(file_sketches_proto_rawDesc)))
})
return file_sketches_proto_rawDescData
}
var file_sketches_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_sketches_proto_msgTypes = make([]protoimpl.MessageInfo, 56)
var file_sketches_proto_goTypes = []any{
(ProbType)(0), // 0: waymaker.sketches.ProbType
(*BloomReserveRequest)(nil), // 1: waymaker.sketches.BloomReserveRequest
(*BloomReserveResponse)(nil), // 2: waymaker.sketches.BloomReserveResponse
(*BloomAddRequest)(nil), // 3: waymaker.sketches.BloomAddRequest
(*BloomAddResponse)(nil), // 4: waymaker.sketches.BloomAddResponse
(*BloomMultiAddRequest)(nil), // 5: waymaker.sketches.BloomMultiAddRequest
(*BloomMultiAddResponse)(nil), // 6: waymaker.sketches.BloomMultiAddResponse
(*BloomExistsRequest)(nil), // 7: waymaker.sketches.BloomExistsRequest
(*BloomExistsResponse)(nil), // 8: waymaker.sketches.BloomExistsResponse
(*BloomMultiExistsRequest)(nil), // 9: waymaker.sketches.BloomMultiExistsRequest
(*BloomMultiExistsResponse)(nil), // 10: waymaker.sketches.BloomMultiExistsResponse
(*BloomInfoRequest)(nil), // 11: waymaker.sketches.BloomInfoRequest
(*BloomInfoResponse)(nil), // 12: waymaker.sketches.BloomInfoResponse
(*BloomDeleteRequest)(nil), // 13: waymaker.sketches.BloomDeleteRequest
(*BloomDeleteResponse)(nil), // 14: waymaker.sketches.BloomDeleteResponse
(*HllReserveRequest)(nil), // 15: waymaker.sketches.HllReserveRequest
(*HllReserveResponse)(nil), // 16: waymaker.sketches.HllReserveResponse
(*HllAddRequest)(nil), // 17: waymaker.sketches.HllAddRequest
(*HllAddResponse)(nil), // 18: waymaker.sketches.HllAddResponse
(*HllCountRequest)(nil), // 19: waymaker.sketches.HllCountRequest
(*HllCountResponse)(nil), // 20: waymaker.sketches.HllCountResponse
(*HllMergeRequest)(nil), // 21: waymaker.sketches.HllMergeRequest
(*HllMergeResponse)(nil), // 22: waymaker.sketches.HllMergeResponse
(*HllDeleteRequest)(nil), // 23: waymaker.sketches.HllDeleteRequest
(*HllDeleteResponse)(nil), // 24: waymaker.sketches.HllDeleteResponse
(*CmsReserveRequest)(nil), // 25: waymaker.sketches.CmsReserveRequest
(*CmsReserveResponse)(nil), // 26: waymaker.sketches.CmsReserveResponse
(*CmsIncrByItem)(nil), // 27: waymaker.sketches.CmsIncrByItem
(*CmsIncrByRequest)(nil), // 28: waymaker.sketches.CmsIncrByRequest
(*CmsIncrByResponse)(nil), // 29: waymaker.sketches.CmsIncrByResponse
(*CmsQueryRequest)(nil), // 30: waymaker.sketches.CmsQueryRequest
(*CmsQueryResponse)(nil), // 31: waymaker.sketches.CmsQueryResponse
(*CmsDeleteRequest)(nil), // 32: waymaker.sketches.CmsDeleteRequest
(*CmsDeleteResponse)(nil), // 33: waymaker.sketches.CmsDeleteResponse
(*TopKReserveRequest)(nil), // 34: waymaker.sketches.TopKReserveRequest
(*TopKReserveResponse)(nil), // 35: waymaker.sketches.TopKReserveResponse
(*TopKAddRequest)(nil), // 36: waymaker.sketches.TopKAddRequest
(*TopKAddResponse)(nil), // 37: waymaker.sketches.TopKAddResponse
(*TopKQueryRequest)(nil), // 38: waymaker.sketches.TopKQueryRequest
(*TopKQueryResponse)(nil), // 39: waymaker.sketches.TopKQueryResponse
(*TopKListRequest)(nil), // 40: waymaker.sketches.TopKListRequest
(*TopKListResponse)(nil), // 41: waymaker.sketches.TopKListResponse
(*TopKEntry)(nil), // 42: waymaker.sketches.TopKEntry
(*TopKDeleteRequest)(nil), // 43: waymaker.sketches.TopKDeleteRequest
(*TopKDeleteResponse)(nil), // 44: waymaker.sketches.TopKDeleteResponse
(*TDigestCreateRequest)(nil), // 45: waymaker.sketches.TDigestCreateRequest
(*TDigestCreateResponse)(nil), // 46: waymaker.sketches.TDigestCreateResponse
(*TDigestAddRequest)(nil), // 47: waymaker.sketches.TDigestAddRequest
(*TDigestAddResponse)(nil), // 48: waymaker.sketches.TDigestAddResponse
(*TDigestQuantileRequest)(nil), // 49: waymaker.sketches.TDigestQuantileRequest
(*TDigestQuantileResponse)(nil), // 50: waymaker.sketches.TDigestQuantileResponse
(*TDigestMinMaxRequest)(nil), // 51: waymaker.sketches.TDigestMinMaxRequest
(*TDigestMinMaxResponse)(nil), // 52: waymaker.sketches.TDigestMinMaxResponse
(*TDigestDeleteRequest)(nil), // 53: waymaker.sketches.TDigestDeleteRequest
(*TDigestDeleteResponse)(nil), // 54: waymaker.sketches.TDigestDeleteResponse
(*ReplicateProbStateRequest)(nil), // 55: waymaker.sketches.ReplicateProbStateRequest
(*ReplicateProbStateResponse)(nil), // 56: waymaker.sketches.ReplicateProbStateResponse
}
var file_sketches_proto_depIdxs = []int32{
27, // 0: waymaker.sketches.CmsIncrByRequest.items:type_name -> waymaker.sketches.CmsIncrByItem
42, // 1: waymaker.sketches.TopKListResponse.entries:type_name -> waymaker.sketches.TopKEntry
0, // 2: waymaker.sketches.ReplicateProbStateRequest.type:type_name -> waymaker.sketches.ProbType
1, // 3: waymaker.sketches.WaymakerSketchesService.BloomReserve:input_type -> waymaker.sketches.BloomReserveRequest
3, // 4: waymaker.sketches.WaymakerSketchesService.BloomAdd:input_type -> waymaker.sketches.BloomAddRequest
5, // 5: waymaker.sketches.WaymakerSketchesService.BloomMultiAdd:input_type -> waymaker.sketches.BloomMultiAddRequest
7, // 6: waymaker.sketches.WaymakerSketchesService.BloomExists:input_type -> waymaker.sketches.BloomExistsRequest
9, // 7: waymaker.sketches.WaymakerSketchesService.BloomMultiExists:input_type -> waymaker.sketches.BloomMultiExistsRequest
11, // 8: waymaker.sketches.WaymakerSketchesService.BloomInfo:input_type -> waymaker.sketches.BloomInfoRequest
13, // 9: waymaker.sketches.WaymakerSketchesService.BloomDelete:input_type -> waymaker.sketches.BloomDeleteRequest
15, // 10: waymaker.sketches.WaymakerSketchesService.HllReserve:input_type -> waymaker.sketches.HllReserveRequest
17, // 11: waymaker.sketches.WaymakerSketchesService.HllAdd:input_type -> waymaker.sketches.HllAddRequest
19, // 12: waymaker.sketches.WaymakerSketchesService.HllCount:input_type -> waymaker.sketches.HllCountRequest
21, // 13: waymaker.sketches.WaymakerSketchesService.HllMerge:input_type -> waymaker.sketches.HllMergeRequest
23, // 14: waymaker.sketches.WaymakerSketchesService.HllDelete:input_type -> waymaker.sketches.HllDeleteRequest
25, // 15: waymaker.sketches.WaymakerSketchesService.CmsReserve:input_type -> waymaker.sketches.CmsReserveRequest
28, // 16: waymaker.sketches.WaymakerSketchesService.CmsIncrBy:input_type -> waymaker.sketches.CmsIncrByRequest
30, // 17: waymaker.sketches.WaymakerSketchesService.CmsQuery:input_type -> waymaker.sketches.CmsQueryRequest
32, // 18: waymaker.sketches.WaymakerSketchesService.CmsDelete:input_type -> waymaker.sketches.CmsDeleteRequest
34, // 19: waymaker.sketches.WaymakerSketchesService.TopKReserve:input_type -> waymaker.sketches.TopKReserveRequest
36, // 20: waymaker.sketches.WaymakerSketchesService.TopKAdd:input_type -> waymaker.sketches.TopKAddRequest
38, // 21: waymaker.sketches.WaymakerSketchesService.TopKQuery:input_type -> waymaker.sketches.TopKQueryRequest
40, // 22: waymaker.sketches.WaymakerSketchesService.TopKList:input_type -> waymaker.sketches.TopKListRequest
43, // 23: waymaker.sketches.WaymakerSketchesService.TopKDelete:input_type -> waymaker.sketches.TopKDeleteRequest
45, // 24: waymaker.sketches.WaymakerSketchesService.TDigestCreate:input_type -> waymaker.sketches.TDigestCreateRequest
47, // 25: waymaker.sketches.WaymakerSketchesService.TDigestAdd:input_type -> waymaker.sketches.TDigestAddRequest
49, // 26: waymaker.sketches.WaymakerSketchesService.TDigestQuantile:input_type -> waymaker.sketches.TDigestQuantileRequest
51, // 27: waymaker.sketches.WaymakerSketchesService.TDigestMinMax:input_type -> waymaker.sketches.TDigestMinMaxRequest
53, // 28: waymaker.sketches.WaymakerSketchesService.TDigestDelete:input_type -> waymaker.sketches.TDigestDeleteRequest
55, // 29: waymaker.sketches.WaymakerSketchesService.ReplicateProbState:input_type -> waymaker.sketches.ReplicateProbStateRequest
2, // 30: waymaker.sketches.WaymakerSketchesService.BloomReserve:output_type -> waymaker.sketches.BloomReserveResponse
4, // 31: waymaker.sketches.WaymakerSketchesService.BloomAdd:output_type -> waymaker.sketches.BloomAddResponse
6, // 32: waymaker.sketches.WaymakerSketchesService.BloomMultiAdd:output_type -> waymaker.sketches.BloomMultiAddResponse
8, // 33: waymaker.sketches.WaymakerSketchesService.BloomExists:output_type -> waymaker.sketches.BloomExistsResponse
10, // 34: waymaker.sketches.WaymakerSketchesService.BloomMultiExists:output_type -> waymaker.sketches.BloomMultiExistsResponse
12, // 35: waymaker.sketches.WaymakerSketchesService.BloomInfo:output_type -> waymaker.sketches.BloomInfoResponse
14, // 36: waymaker.sketches.WaymakerSketchesService.BloomDelete:output_type -> waymaker.sketches.BloomDeleteResponse
16, // 37: waymaker.sketches.WaymakerSketchesService.HllReserve:output_type -> waymaker.sketches.HllReserveResponse
18, // 38: waymaker.sketches.WaymakerSketchesService.HllAdd:output_type -> waymaker.sketches.HllAddResponse
20, // 39: waymaker.sketches.WaymakerSketchesService.HllCount:output_type -> waymaker.sketches.HllCountResponse
22, // 40: waymaker.sketches.WaymakerSketchesService.HllMerge:output_type -> waymaker.sketches.HllMergeResponse
24, // 41: waymaker.sketches.WaymakerSketchesService.HllDelete:output_type -> waymaker.sketches.HllDeleteResponse
26, // 42: waymaker.sketches.WaymakerSketchesService.CmsReserve:output_type -> waymaker.sketches.CmsReserveResponse
29, // 43: waymaker.sketches.WaymakerSketchesService.CmsIncrBy:output_type -> waymaker.sketches.CmsIncrByResponse
31, // 44: waymaker.sketches.WaymakerSketchesService.CmsQuery:output_type -> waymaker.sketches.CmsQueryResponse
33, // 45: waymaker.sketches.WaymakerSketchesService.CmsDelete:output_type -> waymaker.sketches.CmsDeleteResponse
35, // 46: waymaker.sketches.WaymakerSketchesService.TopKReserve:output_type -> waymaker.sketches.TopKReserveResponse
37, // 47: waymaker.sketches.WaymakerSketchesService.TopKAdd:output_type -> waymaker.sketches.TopKAddResponse
39, // 48: waymaker.sketches.WaymakerSketchesService.TopKQuery:output_type -> waymaker.sketches.TopKQueryResponse
41, // 49: waymaker.sketches.WaymakerSketchesService.TopKList:output_type -> waymaker.sketches.TopKListResponse
44, // 50: waymaker.sketches.WaymakerSketchesService.TopKDelete:output_type -> waymaker.sketches.TopKDeleteResponse
46, // 51: waymaker.sketches.WaymakerSketchesService.TDigestCreate:output_type -> waymaker.sketches.TDigestCreateResponse
48, // 52: waymaker.sketches.WaymakerSketchesService.TDigestAdd:output_type -> waymaker.sketches.TDigestAddResponse
50, // 53: waymaker.sketches.WaymakerSketchesService.TDigestQuantile:output_type -> waymaker.sketches.TDigestQuantileResponse
52, // 54: waymaker.sketches.WaymakerSketchesService.TDigestMinMax:output_type -> waymaker.sketches.TDigestMinMaxResponse
54, // 55: waymaker.sketches.WaymakerSketchesService.TDigestDelete:output_type -> waymaker.sketches.TDigestDeleteResponse
56, // 56: waymaker.sketches.WaymakerSketchesService.ReplicateProbState:output_type -> waymaker.sketches.ReplicateProbStateResponse
30, // [30:57] is the sub-list for method output_type
3, // [3:30] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
}
func init() { file_sketches_proto_init() }
func file_sketches_proto_init() {
if File_sketches_proto != nil {
return
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_sketches_proto_rawDesc), len(file_sketches_proto_rawDesc)),
NumEnums: 1,
NumMessages: 56,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_sketches_proto_goTypes,
DependencyIndexes: file_sketches_proto_depIdxs,
EnumInfos: file_sketches_proto_enumTypes,
MessageInfos: file_sketches_proto_msgTypes,
}.Build()
File_sketches_proto = out.File
file_sketches_proto_goTypes = nil
file_sketches_proto_depIdxs = nil
}
Reference in New Issue View Git Blame Copy Permalink