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

3101 lines
94 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: collections.proto
package waymaker_collections
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 CreateHashStoreRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
MaxBytes uint64 `protobuf:"varint,2,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
Ephemeral bool `protobuf:"varint,3,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateHashStoreRequest) Reset() {
*x = CreateHashStoreRequest{}
mi := &file_collections_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateHashStoreRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateHashStoreRequest) ProtoMessage() {}
func (x *CreateHashStoreRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 CreateHashStoreRequest.ProtoReflect.Descriptor instead.
func (*CreateHashStoreRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{0}
}
func (x *CreateHashStoreRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *CreateHashStoreRequest) GetMaxBytes() uint64 {
if x != nil {
return x.MaxBytes
}
return 0
}
func (x *CreateHashStoreRequest) GetEphemeral() bool {
if x != nil {
return x.Ephemeral
}
return false
}
type CreateHashStoreResponse 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 *CreateHashStoreResponse) Reset() {
*x = CreateHashStoreResponse{}
mi := &file_collections_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateHashStoreResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateHashStoreResponse) ProtoMessage() {}
func (x *CreateHashStoreResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 CreateHashStoreResponse.ProtoReflect.Descriptor instead.
func (*CreateHashStoreResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{1}
}
func (x *CreateHashStoreResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *CreateHashStoreResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *CreateHashStoreResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type DeleteHashStoreRequest 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 *DeleteHashStoreRequest) Reset() {
*x = DeleteHashStoreRequest{}
mi := &file_collections_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DeleteHashStoreRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteHashStoreRequest) ProtoMessage() {}
func (x *DeleteHashStoreRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 DeleteHashStoreRequest.ProtoReflect.Descriptor instead.
func (*DeleteHashStoreRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{2}
}
func (x *DeleteHashStoreRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type DeleteHashStoreResponse 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 *DeleteHashStoreResponse) Reset() {
*x = DeleteHashStoreResponse{}
mi := &file_collections_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DeleteHashStoreResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteHashStoreResponse) ProtoMessage() {}
func (x *DeleteHashStoreResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 DeleteHashStoreResponse.ProtoReflect.Descriptor instead.
func (*DeleteHashStoreResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{3}
}
func (x *DeleteHashStoreResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *DeleteHashStoreResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *DeleteHashStoreResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type HashSetRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
HashKey string `protobuf:"bytes,2,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
Field string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashSetRequest) Reset() {
*x = HashSetRequest{}
mi := &file_collections_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashSetRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashSetRequest) ProtoMessage() {}
func (x *HashSetRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashSetRequest.ProtoReflect.Descriptor instead.
func (*HashSetRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{4}
}
func (x *HashSetRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *HashSetRequest) GetHashKey() string {
if x != nil {
return x.HashKey
}
return ""
}
func (x *HashSetRequest) GetField() string {
if x != nil {
return x.Field
}
return ""
}
func (x *HashSetRequest) GetValue() []byte {
if x != nil {
return x.Value
}
return nil
}
type HashSetResponse 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"`
Revision uint64 `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashSetResponse) Reset() {
*x = HashSetResponse{}
mi := &file_collections_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashSetResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashSetResponse) ProtoMessage() {}
func (x *HashSetResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashSetResponse.ProtoReflect.Descriptor instead.
func (*HashSetResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{5}
}
func (x *HashSetResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HashSetResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HashSetResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *HashSetResponse) GetRevision() uint64 {
if x != nil {
return x.Revision
}
return 0
}
type HashGetRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
HashKey string `protobuf:"bytes,2,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
Field string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashGetRequest) Reset() {
*x = HashGetRequest{}
mi := &file_collections_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashGetRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashGetRequest) ProtoMessage() {}
func (x *HashGetRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashGetRequest.ProtoReflect.Descriptor instead.
func (*HashGetRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{6}
}
func (x *HashGetRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *HashGetRequest) GetHashKey() string {
if x != nil {
return x.HashKey
}
return ""
}
func (x *HashGetRequest) GetField() string {
if x != nil {
return x.Field
}
return ""
}
type HashGetResponse 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"`
Value []byte `protobuf:"bytes,4,opt,name=value,proto3,oneof" json:"value,omitempty"`
Revision uint64 `protobuf:"varint,5,opt,name=revision,proto3" json:"revision,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashGetResponse) Reset() {
*x = HashGetResponse{}
mi := &file_collections_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashGetResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashGetResponse) ProtoMessage() {}
func (x *HashGetResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashGetResponse.ProtoReflect.Descriptor instead.
func (*HashGetResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{7}
}
func (x *HashGetResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HashGetResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HashGetResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *HashGetResponse) GetValue() []byte {
if x != nil {
return x.Value
}
return nil
}
func (x *HashGetResponse) GetRevision() uint64 {
if x != nil {
return x.Revision
}
return 0
}
type HashExistsRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
HashKey string `protobuf:"bytes,2,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
Field string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashExistsRequest) Reset() {
*x = HashExistsRequest{}
mi := &file_collections_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashExistsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashExistsRequest) ProtoMessage() {}
func (x *HashExistsRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashExistsRequest.ProtoReflect.Descriptor instead.
func (*HashExistsRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{8}
}
func (x *HashExistsRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *HashExistsRequest) GetHashKey() string {
if x != nil {
return x.HashKey
}
return ""
}
func (x *HashExistsRequest) GetField() string {
if x != nil {
return x.Field
}
return ""
}
type HashExistsResponse 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 *HashExistsResponse) Reset() {
*x = HashExistsResponse{}
mi := &file_collections_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashExistsResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashExistsResponse) ProtoMessage() {}
func (x *HashExistsResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashExistsResponse.ProtoReflect.Descriptor instead.
func (*HashExistsResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{9}
}
func (x *HashExistsResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HashExistsResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HashExistsResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *HashExistsResponse) GetExists() bool {
if x != nil {
return x.Exists
}
return false
}
type HashDeleteRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
HashKey string `protobuf:"bytes,2,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
Field string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashDeleteRequest) Reset() {
*x = HashDeleteRequest{}
mi := &file_collections_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashDeleteRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashDeleteRequest) ProtoMessage() {}
func (x *HashDeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashDeleteRequest.ProtoReflect.Descriptor instead.
func (*HashDeleteRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{10}
}
func (x *HashDeleteRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *HashDeleteRequest) GetHashKey() string {
if x != nil {
return x.HashKey
}
return ""
}
func (x *HashDeleteRequest) GetField() string {
if x != nil {
return x.Field
}
return ""
}
type HashDeleteResponse 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 *HashDeleteResponse) Reset() {
*x = HashDeleteResponse{}
mi := &file_collections_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashDeleteResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashDeleteResponse) ProtoMessage() {}
func (x *HashDeleteResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashDeleteResponse.ProtoReflect.Descriptor instead.
func (*HashDeleteResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{11}
}
func (x *HashDeleteResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HashDeleteResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HashDeleteResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type HashGetAllRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
HashKey string `protobuf:"bytes,2,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashGetAllRequest) Reset() {
*x = HashGetAllRequest{}
mi := &file_collections_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashGetAllRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashGetAllRequest) ProtoMessage() {}
func (x *HashGetAllRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashGetAllRequest.ProtoReflect.Descriptor instead.
func (*HashGetAllRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{12}
}
func (x *HashGetAllRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *HashGetAllRequest) GetHashKey() string {
if x != nil {
return x.HashKey
}
return ""
}
type HashGetAllResponse 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 []*HashFieldEntry `protobuf:"bytes,4,rep,name=entries,proto3" json:"entries,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashGetAllResponse) Reset() {
*x = HashGetAllResponse{}
mi := &file_collections_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashGetAllResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashGetAllResponse) ProtoMessage() {}
func (x *HashGetAllResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashGetAllResponse.ProtoReflect.Descriptor instead.
func (*HashGetAllResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{13}
}
func (x *HashGetAllResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HashGetAllResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HashGetAllResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *HashGetAllResponse) GetEntries() []*HashFieldEntry {
if x != nil {
return x.Entries
}
return nil
}
type HashFieldEntry struct {
state protoimpl.MessageState `protogen:"open.v1"`
Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
Revision uint64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashFieldEntry) Reset() {
*x = HashFieldEntry{}
mi := &file_collections_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashFieldEntry) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashFieldEntry) ProtoMessage() {}
func (x *HashFieldEntry) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashFieldEntry.ProtoReflect.Descriptor instead.
func (*HashFieldEntry) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{14}
}
func (x *HashFieldEntry) GetField() string {
if x != nil {
return x.Field
}
return ""
}
func (x *HashFieldEntry) GetValue() []byte {
if x != nil {
return x.Value
}
return nil
}
func (x *HashFieldEntry) GetRevision() uint64 {
if x != nil {
return x.Revision
}
return 0
}
type HashFieldsRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
HashKey string `protobuf:"bytes,2,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashFieldsRequest) Reset() {
*x = HashFieldsRequest{}
mi := &file_collections_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashFieldsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashFieldsRequest) ProtoMessage() {}
func (x *HashFieldsRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashFieldsRequest.ProtoReflect.Descriptor instead.
func (*HashFieldsRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{15}
}
func (x *HashFieldsRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *HashFieldsRequest) GetHashKey() string {
if x != nil {
return x.HashKey
}
return ""
}
type HashFieldsResponse 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"`
Fields []string `protobuf:"bytes,4,rep,name=fields,proto3" json:"fields,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashFieldsResponse) Reset() {
*x = HashFieldsResponse{}
mi := &file_collections_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashFieldsResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashFieldsResponse) ProtoMessage() {}
func (x *HashFieldsResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashFieldsResponse.ProtoReflect.Descriptor instead.
func (*HashFieldsResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{16}
}
func (x *HashFieldsResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HashFieldsResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HashFieldsResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *HashFieldsResponse) GetFields() []string {
if x != nil {
return x.Fields
}
return nil
}
type HashLenRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
HashKey string `protobuf:"bytes,2,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashLenRequest) Reset() {
*x = HashLenRequest{}
mi := &file_collections_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashLenRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashLenRequest) ProtoMessage() {}
func (x *HashLenRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashLenRequest.ProtoReflect.Descriptor instead.
func (*HashLenRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{17}
}
func (x *HashLenRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *HashLenRequest) GetHashKey() string {
if x != nil {
return x.HashKey
}
return ""
}
type HashLenResponse 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"`
Count uint64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HashLenResponse) Reset() {
*x = HashLenResponse{}
mi := &file_collections_proto_msgTypes[18]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HashLenResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HashLenResponse) ProtoMessage() {}
func (x *HashLenResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 HashLenResponse.ProtoReflect.Descriptor instead.
func (*HashLenResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{18}
}
func (x *HashLenResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *HashLenResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *HashLenResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *HashLenResponse) GetCount() uint64 {
if x != nil {
return x.Count
}
return 0
}
type CreateSetStoreRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
MaxBytes uint64 `protobuf:"varint,2,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
Ephemeral bool `protobuf:"varint,3,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateSetStoreRequest) Reset() {
*x = CreateSetStoreRequest{}
mi := &file_collections_proto_msgTypes[19]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateSetStoreRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateSetStoreRequest) ProtoMessage() {}
func (x *CreateSetStoreRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 CreateSetStoreRequest.ProtoReflect.Descriptor instead.
func (*CreateSetStoreRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{19}
}
func (x *CreateSetStoreRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *CreateSetStoreRequest) GetMaxBytes() uint64 {
if x != nil {
return x.MaxBytes
}
return 0
}
func (x *CreateSetStoreRequest) GetEphemeral() bool {
if x != nil {
return x.Ephemeral
}
return false
}
type CreateSetStoreResponse 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 *CreateSetStoreResponse) Reset() {
*x = CreateSetStoreResponse{}
mi := &file_collections_proto_msgTypes[20]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateSetStoreResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateSetStoreResponse) ProtoMessage() {}
func (x *CreateSetStoreResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 CreateSetStoreResponse.ProtoReflect.Descriptor instead.
func (*CreateSetStoreResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{20}
}
func (x *CreateSetStoreResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *CreateSetStoreResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *CreateSetStoreResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type DeleteSetStoreRequest 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 *DeleteSetStoreRequest) Reset() {
*x = DeleteSetStoreRequest{}
mi := &file_collections_proto_msgTypes[21]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DeleteSetStoreRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteSetStoreRequest) ProtoMessage() {}
func (x *DeleteSetStoreRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 DeleteSetStoreRequest.ProtoReflect.Descriptor instead.
func (*DeleteSetStoreRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{21}
}
func (x *DeleteSetStoreRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type DeleteSetStoreResponse 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 *DeleteSetStoreResponse) Reset() {
*x = DeleteSetStoreResponse{}
mi := &file_collections_proto_msgTypes[22]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DeleteSetStoreResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteSetStoreResponse) ProtoMessage() {}
func (x *DeleteSetStoreResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 DeleteSetStoreResponse.ProtoReflect.Descriptor instead.
func (*DeleteSetStoreResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{22}
}
func (x *DeleteSetStoreResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *DeleteSetStoreResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *DeleteSetStoreResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type SetAddRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
SetKey string `protobuf:"bytes,2,opt,name=set_key,json=setKey,proto3" json:"set_key,omitempty"`
Member string `protobuf:"bytes,3,opt,name=member,proto3" json:"member,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SetAddRequest) Reset() {
*x = SetAddRequest{}
mi := &file_collections_proto_msgTypes[23]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetAddRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetAddRequest) ProtoMessage() {}
func (x *SetAddRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetAddRequest.ProtoReflect.Descriptor instead.
func (*SetAddRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{23}
}
func (x *SetAddRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *SetAddRequest) GetSetKey() string {
if x != nil {
return x.SetKey
}
return ""
}
func (x *SetAddRequest) GetMember() string {
if x != nil {
return x.Member
}
return ""
}
type SetAddResponse 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 *SetAddResponse) Reset() {
*x = SetAddResponse{}
mi := &file_collections_proto_msgTypes[24]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetAddResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetAddResponse) ProtoMessage() {}
func (x *SetAddResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetAddResponse.ProtoReflect.Descriptor instead.
func (*SetAddResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{24}
}
func (x *SetAddResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *SetAddResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *SetAddResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type SetRemoveRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
SetKey string `protobuf:"bytes,2,opt,name=set_key,json=setKey,proto3" json:"set_key,omitempty"`
Member string `protobuf:"bytes,3,opt,name=member,proto3" json:"member,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SetRemoveRequest) Reset() {
*x = SetRemoveRequest{}
mi := &file_collections_proto_msgTypes[25]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetRemoveRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetRemoveRequest) ProtoMessage() {}
func (x *SetRemoveRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetRemoveRequest.ProtoReflect.Descriptor instead.
func (*SetRemoveRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{25}
}
func (x *SetRemoveRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *SetRemoveRequest) GetSetKey() string {
if x != nil {
return x.SetKey
}
return ""
}
func (x *SetRemoveRequest) GetMember() string {
if x != nil {
return x.Member
}
return ""
}
type SetRemoveResponse 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 *SetRemoveResponse) Reset() {
*x = SetRemoveResponse{}
mi := &file_collections_proto_msgTypes[26]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetRemoveResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetRemoveResponse) ProtoMessage() {}
func (x *SetRemoveResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetRemoveResponse.ProtoReflect.Descriptor instead.
func (*SetRemoveResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{26}
}
func (x *SetRemoveResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *SetRemoveResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *SetRemoveResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type SetIsMemberRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
SetKey string `protobuf:"bytes,2,opt,name=set_key,json=setKey,proto3" json:"set_key,omitempty"`
Member string `protobuf:"bytes,3,opt,name=member,proto3" json:"member,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SetIsMemberRequest) Reset() {
*x = SetIsMemberRequest{}
mi := &file_collections_proto_msgTypes[27]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetIsMemberRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetIsMemberRequest) ProtoMessage() {}
func (x *SetIsMemberRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetIsMemberRequest.ProtoReflect.Descriptor instead.
func (*SetIsMemberRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{27}
}
func (x *SetIsMemberRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *SetIsMemberRequest) GetSetKey() string {
if x != nil {
return x.SetKey
}
return ""
}
func (x *SetIsMemberRequest) GetMember() string {
if x != nil {
return x.Member
}
return ""
}
type SetIsMemberResponse 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"`
IsMember bool `protobuf:"varint,4,opt,name=is_member,json=isMember,proto3" json:"is_member,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SetIsMemberResponse) Reset() {
*x = SetIsMemberResponse{}
mi := &file_collections_proto_msgTypes[28]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetIsMemberResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetIsMemberResponse) ProtoMessage() {}
func (x *SetIsMemberResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetIsMemberResponse.ProtoReflect.Descriptor instead.
func (*SetIsMemberResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{28}
}
func (x *SetIsMemberResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *SetIsMemberResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *SetIsMemberResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *SetIsMemberResponse) GetIsMember() bool {
if x != nil {
return x.IsMember
}
return false
}
type SetMembersRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
SetKey string `protobuf:"bytes,2,opt,name=set_key,json=setKey,proto3" json:"set_key,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SetMembersRequest) Reset() {
*x = SetMembersRequest{}
mi := &file_collections_proto_msgTypes[29]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetMembersRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetMembersRequest) ProtoMessage() {}
func (x *SetMembersRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetMembersRequest.ProtoReflect.Descriptor instead.
func (*SetMembersRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{29}
}
func (x *SetMembersRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *SetMembersRequest) GetSetKey() string {
if x != nil {
return x.SetKey
}
return ""
}
type SetMembersResponse 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"`
Members []string `protobuf:"bytes,4,rep,name=members,proto3" json:"members,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SetMembersResponse) Reset() {
*x = SetMembersResponse{}
mi := &file_collections_proto_msgTypes[30]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetMembersResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetMembersResponse) ProtoMessage() {}
func (x *SetMembersResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetMembersResponse.ProtoReflect.Descriptor instead.
func (*SetMembersResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{30}
}
func (x *SetMembersResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *SetMembersResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *SetMembersResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *SetMembersResponse) GetMembers() []string {
if x != nil {
return x.Members
}
return nil
}
type SetLenRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
SetKey string `protobuf:"bytes,2,opt,name=set_key,json=setKey,proto3" json:"set_key,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SetLenRequest) Reset() {
*x = SetLenRequest{}
mi := &file_collections_proto_msgTypes[31]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetLenRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetLenRequest) ProtoMessage() {}
func (x *SetLenRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetLenRequest.ProtoReflect.Descriptor instead.
func (*SetLenRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{31}
}
func (x *SetLenRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *SetLenRequest) GetSetKey() string {
if x != nil {
return x.SetKey
}
return ""
}
type SetLenResponse 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"`
Count uint64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SetLenResponse) Reset() {
*x = SetLenResponse{}
mi := &file_collections_proto_msgTypes[32]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SetLenResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SetLenResponse) ProtoMessage() {}
func (x *SetLenResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 SetLenResponse.ProtoReflect.Descriptor instead.
func (*SetLenResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{32}
}
func (x *SetLenResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *SetLenResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *SetLenResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *SetLenResponse) GetCount() uint64 {
if x != nil {
return x.Count
}
return 0
}
type CreateQueueRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
MaxBytes uint64 `protobuf:"varint,2,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
MaxMessages uint64 `protobuf:"varint,3,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
Ephemeral bool `protobuf:"varint,4,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateQueueRequest) Reset() {
*x = CreateQueueRequest{}
mi := &file_collections_proto_msgTypes[33]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateQueueRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateQueueRequest) ProtoMessage() {}
func (x *CreateQueueRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 CreateQueueRequest.ProtoReflect.Descriptor instead.
func (*CreateQueueRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{33}
}
func (x *CreateQueueRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *CreateQueueRequest) GetMaxBytes() uint64 {
if x != nil {
return x.MaxBytes
}
return 0
}
func (x *CreateQueueRequest) GetMaxMessages() uint64 {
if x != nil {
return x.MaxMessages
}
return 0
}
func (x *CreateQueueRequest) GetEphemeral() bool {
if x != nil {
return x.Ephemeral
}
return false
}
type CreateQueueResponse 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 *CreateQueueResponse) Reset() {
*x = CreateQueueResponse{}
mi := &file_collections_proto_msgTypes[34]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateQueueResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateQueueResponse) ProtoMessage() {}
func (x *CreateQueueResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 CreateQueueResponse.ProtoReflect.Descriptor instead.
func (*CreateQueueResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{34}
}
func (x *CreateQueueResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *CreateQueueResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *CreateQueueResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type DeleteQueueRequest 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 *DeleteQueueRequest) Reset() {
*x = DeleteQueueRequest{}
mi := &file_collections_proto_msgTypes[35]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DeleteQueueRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteQueueRequest) ProtoMessage() {}
func (x *DeleteQueueRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 DeleteQueueRequest.ProtoReflect.Descriptor instead.
func (*DeleteQueueRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{35}
}
func (x *DeleteQueueRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
type DeleteQueueResponse 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 *DeleteQueueResponse) Reset() {
*x = DeleteQueueResponse{}
mi := &file_collections_proto_msgTypes[36]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DeleteQueueResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteQueueResponse) ProtoMessage() {}
func (x *DeleteQueueResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 DeleteQueueResponse.ProtoReflect.Descriptor instead.
func (*DeleteQueueResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{36}
}
func (x *DeleteQueueResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *DeleteQueueResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *DeleteQueueResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type QueuePushRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueuePushRequest) Reset() {
*x = QueuePushRequest{}
mi := &file_collections_proto_msgTypes[37]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueuePushRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueuePushRequest) ProtoMessage() {}
func (x *QueuePushRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 QueuePushRequest.ProtoReflect.Descriptor instead.
func (*QueuePushRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{37}
}
func (x *QueuePushRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *QueuePushRequest) GetValue() []byte {
if x != nil {
return x.Value
}
return nil
}
type QueuePushResponse 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"`
Sequence uint64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueuePushResponse) Reset() {
*x = QueuePushResponse{}
mi := &file_collections_proto_msgTypes[38]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueuePushResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueuePushResponse) ProtoMessage() {}
func (x *QueuePushResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 QueuePushResponse.ProtoReflect.Descriptor instead.
func (*QueuePushResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{38}
}
func (x *QueuePushResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *QueuePushResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *QueuePushResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *QueuePushResponse) GetSequence() uint64 {
if x != nil {
return x.Sequence
}
return 0
}
type QueuePopRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueuePopRequest) Reset() {
*x = QueuePopRequest{}
mi := &file_collections_proto_msgTypes[39]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueuePopRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueuePopRequest) ProtoMessage() {}
func (x *QueuePopRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 QueuePopRequest.ProtoReflect.Descriptor instead.
func (*QueuePopRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{39}
}
func (x *QueuePopRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
type QueuePopResponse 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"`
Value []byte `protobuf:"bytes,4,opt,name=value,proto3,oneof" json:"value,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueuePopResponse) Reset() {
*x = QueuePopResponse{}
mi := &file_collections_proto_msgTypes[40]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueuePopResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueuePopResponse) ProtoMessage() {}
func (x *QueuePopResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 QueuePopResponse.ProtoReflect.Descriptor instead.
func (*QueuePopResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{40}
}
func (x *QueuePopResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *QueuePopResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *QueuePopResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *QueuePopResponse) GetValue() []byte {
if x != nil {
return x.Value
}
return nil
}
type QueueRangeRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
FromSequence uint64 `protobuf:"varint,2,opt,name=from_sequence,json=fromSequence,proto3" json:"from_sequence,omitempty"`
Limit uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueueRangeRequest) Reset() {
*x = QueueRangeRequest{}
mi := &file_collections_proto_msgTypes[41]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueueRangeRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueueRangeRequest) ProtoMessage() {}
func (x *QueueRangeRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 QueueRangeRequest.ProtoReflect.Descriptor instead.
func (*QueueRangeRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{41}
}
func (x *QueueRangeRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *QueueRangeRequest) GetFromSequence() uint64 {
if x != nil {
return x.FromSequence
}
return 0
}
func (x *QueueRangeRequest) GetLimit() uint64 {
if x != nil {
return x.Limit
}
return 0
}
type QueueRangeResponse 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 [][]byte `protobuf:"bytes,4,rep,name=values,proto3" json:"values,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueueRangeResponse) Reset() {
*x = QueueRangeResponse{}
mi := &file_collections_proto_msgTypes[42]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueueRangeResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueueRangeResponse) ProtoMessage() {}
func (x *QueueRangeResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 QueueRangeResponse.ProtoReflect.Descriptor instead.
func (*QueueRangeResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{42}
}
func (x *QueueRangeResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *QueueRangeResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *QueueRangeResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *QueueRangeResponse) GetValues() [][]byte {
if x != nil {
return x.Values
}
return nil
}
type QueueLenRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueueLenRequest) Reset() {
*x = QueueLenRequest{}
mi := &file_collections_proto_msgTypes[43]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueueLenRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueueLenRequest) ProtoMessage() {}
func (x *QueueLenRequest) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 QueueLenRequest.ProtoReflect.Descriptor instead.
func (*QueueLenRequest) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{43}
}
func (x *QueueLenRequest) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
type QueueLenResponse 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"`
Count uint64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueueLenResponse) Reset() {
*x = QueueLenResponse{}
mi := &file_collections_proto_msgTypes[44]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueueLenResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueueLenResponse) ProtoMessage() {}
func (x *QueueLenResponse) ProtoReflect() protoreflect.Message {
mi := &file_collections_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 QueueLenResponse.ProtoReflect.Descriptor instead.
func (*QueueLenResponse) Descriptor() ([]byte, []int) {
return file_collections_proto_rawDescGZIP(), []int{44}
}
func (x *QueueLenResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *QueueLenResponse) GetResultCode() string {
if x != nil {
return x.ResultCode
}
return ""
}
func (x *QueueLenResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *QueueLenResponse) GetCount() uint64 {
if x != nil {
return x.Count
}
return 0
}
var File_collections_proto protoreflect.FileDescriptor
const file_collections_proto_rawDesc = "" +
"\n" +
"\x11collections.proto\x12\x14waymaker.collections\"g\n" +
"\x16CreateHashStoreRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x1b\n" +
"\tmax_bytes\x18\x02 \x01(\x04R\bmaxBytes\x12\x1c\n" +
"\tephemeral\x18\x03 \x01(\bR\tephemeral\"n\n" +
"\x17CreateHashStoreResponse\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" +
"\x16DeleteHashStoreRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"n\n" +
"\x17DeleteHashStoreResponse\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\"o\n" +
"\x0eHashSetRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x19\n" +
"\bhash_key\x18\x02 \x01(\tR\ahashKey\x12\x14\n" +
"\x05field\x18\x03 \x01(\tR\x05field\x12\x14\n" +
"\x05value\x18\x04 \x01(\fR\x05value\"\x82\x01\n" +
"\x0fHashSetResponse\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" +
"\brevision\x18\x04 \x01(\x04R\brevision\"Y\n" +
"\x0eHashGetRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x19\n" +
"\bhash_key\x18\x02 \x01(\tR\ahashKey\x12\x14\n" +
"\x05field\x18\x03 \x01(\tR\x05field\"\xa7\x01\n" +
"\x0fHashGetResponse\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\x19\n" +
"\x05value\x18\x04 \x01(\fH\x00R\x05value\x88\x01\x01\x12\x1a\n" +
"\brevision\x18\x05 \x01(\x04R\brevisionB\b\n" +
"\x06_value\"\\\n" +
"\x11HashExistsRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x19\n" +
"\bhash_key\x18\x02 \x01(\tR\ahashKey\x12\x14\n" +
"\x05field\x18\x03 \x01(\tR\x05field\"\x81\x01\n" +
"\x12HashExistsResponse\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\"\\\n" +
"\x11HashDeleteRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x19\n" +
"\bhash_key\x18\x02 \x01(\tR\ahashKey\x12\x14\n" +
"\x05field\x18\x03 \x01(\tR\x05field\"i\n" +
"\x12HashDeleteResponse\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\"F\n" +
"\x11HashGetAllRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x19\n" +
"\bhash_key\x18\x02 \x01(\tR\ahashKey\"\xa9\x01\n" +
"\x12HashGetAllResponse\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>\n" +
"\aentries\x18\x04 \x03(\v2$.waymaker.collections.HashFieldEntryR\aentries\"X\n" +
"\x0eHashFieldEntry\x12\x14\n" +
"\x05field\x18\x01 \x01(\tR\x05field\x12\x14\n" +
"\x05value\x18\x02 \x01(\fR\x05value\x12\x1a\n" +
"\brevision\x18\x03 \x01(\x04R\brevision\"F\n" +
"\x11HashFieldsRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x19\n" +
"\bhash_key\x18\x02 \x01(\tR\ahashKey\"\x81\x01\n" +
"\x12HashFieldsResponse\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" +
"\x06fields\x18\x04 \x03(\tR\x06fields\"C\n" +
"\x0eHashLenRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x19\n" +
"\bhash_key\x18\x02 \x01(\tR\ahashKey\"|\n" +
"\x0fHashLenResponse\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\x14\n" +
"\x05count\x18\x04 \x01(\x04R\x05count\"f\n" +
"\x15CreateSetStoreRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x1b\n" +
"\tmax_bytes\x18\x02 \x01(\x04R\bmaxBytes\x12\x1c\n" +
"\tephemeral\x18\x03 \x01(\bR\tephemeral\"m\n" +
"\x16CreateSetStoreResponse\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" +
"\x15DeleteSetStoreRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"m\n" +
"\x16DeleteSetStoreResponse\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" +
"\rSetAddRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x17\n" +
"\aset_key\x18\x02 \x01(\tR\x06setKey\x12\x16\n" +
"\x06member\x18\x03 \x01(\tR\x06member\"e\n" +
"\x0eSetAddResponse\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" +
"\x10SetRemoveRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x17\n" +
"\aset_key\x18\x02 \x01(\tR\x06setKey\x12\x16\n" +
"\x06member\x18\x03 \x01(\tR\x06member\"h\n" +
"\x11SetRemoveResponse\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" +
"\x12SetIsMemberRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x17\n" +
"\aset_key\x18\x02 \x01(\tR\x06setKey\x12\x16\n" +
"\x06member\x18\x03 \x01(\tR\x06member\"\x87\x01\n" +
"\x13SetIsMemberResponse\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\x1b\n" +
"\tis_member\x18\x04 \x01(\bR\bisMember\"D\n" +
"\x11SetMembersRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x17\n" +
"\aset_key\x18\x02 \x01(\tR\x06setKey\"\x83\x01\n" +
"\x12SetMembersResponse\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" +
"\amembers\x18\x04 \x03(\tR\amembers\"@\n" +
"\rSetLenRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x17\n" +
"\aset_key\x18\x02 \x01(\tR\x06setKey\"{\n" +
"\x0eSetLenResponse\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\x14\n" +
"\x05count\x18\x04 \x01(\x04R\x05count\"\x86\x01\n" +
"\x12CreateQueueRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x1b\n" +
"\tmax_bytes\x18\x02 \x01(\x04R\bmaxBytes\x12!\n" +
"\fmax_messages\x18\x03 \x01(\x04R\vmaxMessages\x12\x1c\n" +
"\tephemeral\x18\x04 \x01(\bR\tephemeral\"j\n" +
"\x13CreateQueueResponse\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" +
"\x12DeleteQueueRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\"j\n" +
"\x13DeleteQueueResponse\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" +
"\x10QueuePushRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12\x14\n" +
"\x05value\x18\x02 \x01(\fR\x05value\"\x84\x01\n" +
"\x11QueuePushResponse\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" +
"\bsequence\x18\x04 \x01(\x04R\bsequence\")\n" +
"\x0fQueuePopRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\"\x8c\x01\n" +
"\x10QueuePopResponse\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\x19\n" +
"\x05value\x18\x04 \x01(\fH\x00R\x05value\x88\x01\x01B\b\n" +
"\x06_value\"f\n" +
"\x11QueueRangeRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\x12#\n" +
"\rfrom_sequence\x18\x02 \x01(\x04R\ffromSequence\x12\x14\n" +
"\x05limit\x18\x03 \x01(\x04R\x05limit\"\x81\x01\n" +
"\x12QueueRangeResponse\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(\fR\x06values\")\n" +
"\x0fQueueLenRequest\x12\x16\n" +
"\x06bucket\x18\x01 \x01(\tR\x06bucket\"}\n" +
"\x10QueueLenResponse\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\x14\n" +
"\x05count\x18\x04 \x01(\x04R\x05count2\xec\x10\n" +
"\x1aWaymakerCollectionsService\x12n\n" +
"\x0fCreateHashStore\x12,.waymaker.collections.CreateHashStoreRequest\x1a-.waymaker.collections.CreateHashStoreResponse\x12n\n" +
"\x0fDeleteHashStore\x12,.waymaker.collections.DeleteHashStoreRequest\x1a-.waymaker.collections.DeleteHashStoreResponse\x12V\n" +
"\aHashSet\x12$.waymaker.collections.HashSetRequest\x1a%.waymaker.collections.HashSetResponse\x12V\n" +
"\aHashGet\x12$.waymaker.collections.HashGetRequest\x1a%.waymaker.collections.HashGetResponse\x12_\n" +
"\n" +
"HashExists\x12'.waymaker.collections.HashExistsRequest\x1a(.waymaker.collections.HashExistsResponse\x12_\n" +
"\n" +
"HashDelete\x12'.waymaker.collections.HashDeleteRequest\x1a(.waymaker.collections.HashDeleteResponse\x12_\n" +
"\n" +
"HashGetAll\x12'.waymaker.collections.HashGetAllRequest\x1a(.waymaker.collections.HashGetAllResponse\x12_\n" +
"\n" +
"HashFields\x12'.waymaker.collections.HashFieldsRequest\x1a(.waymaker.collections.HashFieldsResponse\x12V\n" +
"\aHashLen\x12$.waymaker.collections.HashLenRequest\x1a%.waymaker.collections.HashLenResponse\x12k\n" +
"\x0eCreateSetStore\x12+.waymaker.collections.CreateSetStoreRequest\x1a,.waymaker.collections.CreateSetStoreResponse\x12k\n" +
"\x0eDeleteSetStore\x12+.waymaker.collections.DeleteSetStoreRequest\x1a,.waymaker.collections.DeleteSetStoreResponse\x12S\n" +
"\x06SetAdd\x12#.waymaker.collections.SetAddRequest\x1a$.waymaker.collections.SetAddResponse\x12\\\n" +
"\tSetRemove\x12&.waymaker.collections.SetRemoveRequest\x1a'.waymaker.collections.SetRemoveResponse\x12b\n" +
"\vSetIsMember\x12(.waymaker.collections.SetIsMemberRequest\x1a).waymaker.collections.SetIsMemberResponse\x12_\n" +
"\n" +
"SetMembers\x12'.waymaker.collections.SetMembersRequest\x1a(.waymaker.collections.SetMembersResponse\x12S\n" +
"\x06SetLen\x12#.waymaker.collections.SetLenRequest\x1a$.waymaker.collections.SetLenResponse\x12b\n" +
"\vCreateQueue\x12(.waymaker.collections.CreateQueueRequest\x1a).waymaker.collections.CreateQueueResponse\x12b\n" +
"\vDeleteQueue\x12(.waymaker.collections.DeleteQueueRequest\x1a).waymaker.collections.DeleteQueueResponse\x12\\\n" +
"\tQueuePush\x12&.waymaker.collections.QueuePushRequest\x1a'.waymaker.collections.QueuePushResponse\x12Y\n" +
"\bQueuePop\x12%.waymaker.collections.QueuePopRequest\x1a&.waymaker.collections.QueuePopResponse\x12_\n" +
"\n" +
"QueueRange\x12'.waymaker.collections.QueueRangeRequest\x1a(.waymaker.collections.QueueRangeResponse\x12Y\n" +
"\bQueueLen\x12%.waymaker.collections.QueueLenRequest\x1a&.waymaker.collections.QueueLenResponseB\x1cZ\x1a/apis/waymaker_collectionsb\x06proto3"
var (
file_collections_proto_rawDescOnce sync.Once
file_collections_proto_rawDescData []byte
)
func file_collections_proto_rawDescGZIP() []byte {
file_collections_proto_rawDescOnce.Do(func() {
file_collections_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_collections_proto_rawDesc), len(file_collections_proto_rawDesc)))
})
return file_collections_proto_rawDescData
}
var file_collections_proto_msgTypes = make([]protoimpl.MessageInfo, 45)
var file_collections_proto_goTypes = []any{
(*CreateHashStoreRequest)(nil), // 0: waymaker.collections.CreateHashStoreRequest
(*CreateHashStoreResponse)(nil), // 1: waymaker.collections.CreateHashStoreResponse
(*DeleteHashStoreRequest)(nil), // 2: waymaker.collections.DeleteHashStoreRequest
(*DeleteHashStoreResponse)(nil), // 3: waymaker.collections.DeleteHashStoreResponse
(*HashSetRequest)(nil), // 4: waymaker.collections.HashSetRequest
(*HashSetResponse)(nil), // 5: waymaker.collections.HashSetResponse
(*HashGetRequest)(nil), // 6: waymaker.collections.HashGetRequest
(*HashGetResponse)(nil), // 7: waymaker.collections.HashGetResponse
(*HashExistsRequest)(nil), // 8: waymaker.collections.HashExistsRequest
(*HashExistsResponse)(nil), // 9: waymaker.collections.HashExistsResponse
(*HashDeleteRequest)(nil), // 10: waymaker.collections.HashDeleteRequest
(*HashDeleteResponse)(nil), // 11: waymaker.collections.HashDeleteResponse
(*HashGetAllRequest)(nil), // 12: waymaker.collections.HashGetAllRequest
(*HashGetAllResponse)(nil), // 13: waymaker.collections.HashGetAllResponse
(*HashFieldEntry)(nil), // 14: waymaker.collections.HashFieldEntry
(*HashFieldsRequest)(nil), // 15: waymaker.collections.HashFieldsRequest
(*HashFieldsResponse)(nil), // 16: waymaker.collections.HashFieldsResponse
(*HashLenRequest)(nil), // 17: waymaker.collections.HashLenRequest
(*HashLenResponse)(nil), // 18: waymaker.collections.HashLenResponse
(*CreateSetStoreRequest)(nil), // 19: waymaker.collections.CreateSetStoreRequest
(*CreateSetStoreResponse)(nil), // 20: waymaker.collections.CreateSetStoreResponse
(*DeleteSetStoreRequest)(nil), // 21: waymaker.collections.DeleteSetStoreRequest
(*DeleteSetStoreResponse)(nil), // 22: waymaker.collections.DeleteSetStoreResponse
(*SetAddRequest)(nil), // 23: waymaker.collections.SetAddRequest
(*SetAddResponse)(nil), // 24: waymaker.collections.SetAddResponse
(*SetRemoveRequest)(nil), // 25: waymaker.collections.SetRemoveRequest
(*SetRemoveResponse)(nil), // 26: waymaker.collections.SetRemoveResponse
(*SetIsMemberRequest)(nil), // 27: waymaker.collections.SetIsMemberRequest
(*SetIsMemberResponse)(nil), // 28: waymaker.collections.SetIsMemberResponse
(*SetMembersRequest)(nil), // 29: waymaker.collections.SetMembersRequest
(*SetMembersResponse)(nil), // 30: waymaker.collections.SetMembersResponse
(*SetLenRequest)(nil), // 31: waymaker.collections.SetLenRequest
(*SetLenResponse)(nil), // 32: waymaker.collections.SetLenResponse
(*CreateQueueRequest)(nil), // 33: waymaker.collections.CreateQueueRequest
(*CreateQueueResponse)(nil), // 34: waymaker.collections.CreateQueueResponse
(*DeleteQueueRequest)(nil), // 35: waymaker.collections.DeleteQueueRequest
(*DeleteQueueResponse)(nil), // 36: waymaker.collections.DeleteQueueResponse
(*QueuePushRequest)(nil), // 37: waymaker.collections.QueuePushRequest
(*QueuePushResponse)(nil), // 38: waymaker.collections.QueuePushResponse
(*QueuePopRequest)(nil), // 39: waymaker.collections.QueuePopRequest
(*QueuePopResponse)(nil), // 40: waymaker.collections.QueuePopResponse
(*QueueRangeRequest)(nil), // 41: waymaker.collections.QueueRangeRequest
(*QueueRangeResponse)(nil), // 42: waymaker.collections.QueueRangeResponse
(*QueueLenRequest)(nil), // 43: waymaker.collections.QueueLenRequest
(*QueueLenResponse)(nil), // 44: waymaker.collections.QueueLenResponse
}
var file_collections_proto_depIdxs = []int32{
14, // 0: waymaker.collections.HashGetAllResponse.entries:type_name -> waymaker.collections.HashFieldEntry
0, // 1: waymaker.collections.WaymakerCollectionsService.CreateHashStore:input_type -> waymaker.collections.CreateHashStoreRequest
2, // 2: waymaker.collections.WaymakerCollectionsService.DeleteHashStore:input_type -> waymaker.collections.DeleteHashStoreRequest
4, // 3: waymaker.collections.WaymakerCollectionsService.HashSet:input_type -> waymaker.collections.HashSetRequest
6, // 4: waymaker.collections.WaymakerCollectionsService.HashGet:input_type -> waymaker.collections.HashGetRequest
8, // 5: waymaker.collections.WaymakerCollectionsService.HashExists:input_type -> waymaker.collections.HashExistsRequest
10, // 6: waymaker.collections.WaymakerCollectionsService.HashDelete:input_type -> waymaker.collections.HashDeleteRequest
12, // 7: waymaker.collections.WaymakerCollectionsService.HashGetAll:input_type -> waymaker.collections.HashGetAllRequest
15, // 8: waymaker.collections.WaymakerCollectionsService.HashFields:input_type -> waymaker.collections.HashFieldsRequest
17, // 9: waymaker.collections.WaymakerCollectionsService.HashLen:input_type -> waymaker.collections.HashLenRequest
19, // 10: waymaker.collections.WaymakerCollectionsService.CreateSetStore:input_type -> waymaker.collections.CreateSetStoreRequest
21, // 11: waymaker.collections.WaymakerCollectionsService.DeleteSetStore:input_type -> waymaker.collections.DeleteSetStoreRequest
23, // 12: waymaker.collections.WaymakerCollectionsService.SetAdd:input_type -> waymaker.collections.SetAddRequest
25, // 13: waymaker.collections.WaymakerCollectionsService.SetRemove:input_type -> waymaker.collections.SetRemoveRequest
27, // 14: waymaker.collections.WaymakerCollectionsService.SetIsMember:input_type -> waymaker.collections.SetIsMemberRequest
29, // 15: waymaker.collections.WaymakerCollectionsService.SetMembers:input_type -> waymaker.collections.SetMembersRequest
31, // 16: waymaker.collections.WaymakerCollectionsService.SetLen:input_type -> waymaker.collections.SetLenRequest
33, // 17: waymaker.collections.WaymakerCollectionsService.CreateQueue:input_type -> waymaker.collections.CreateQueueRequest
35, // 18: waymaker.collections.WaymakerCollectionsService.DeleteQueue:input_type -> waymaker.collections.DeleteQueueRequest
37, // 19: waymaker.collections.WaymakerCollectionsService.QueuePush:input_type -> waymaker.collections.QueuePushRequest
39, // 20: waymaker.collections.WaymakerCollectionsService.QueuePop:input_type -> waymaker.collections.QueuePopRequest
41, // 21: waymaker.collections.WaymakerCollectionsService.QueueRange:input_type -> waymaker.collections.QueueRangeRequest
43, // 22: waymaker.collections.WaymakerCollectionsService.QueueLen:input_type -> waymaker.collections.QueueLenRequest
1, // 23: waymaker.collections.WaymakerCollectionsService.CreateHashStore:output_type -> waymaker.collections.CreateHashStoreResponse
3, // 24: waymaker.collections.WaymakerCollectionsService.DeleteHashStore:output_type -> waymaker.collections.DeleteHashStoreResponse
5, // 25: waymaker.collections.WaymakerCollectionsService.HashSet:output_type -> waymaker.collections.HashSetResponse
7, // 26: waymaker.collections.WaymakerCollectionsService.HashGet:output_type -> waymaker.collections.HashGetResponse
9, // 27: waymaker.collections.WaymakerCollectionsService.HashExists:output_type -> waymaker.collections.HashExistsResponse
11, // 28: waymaker.collections.WaymakerCollectionsService.HashDelete:output_type -> waymaker.collections.HashDeleteResponse
13, // 29: waymaker.collections.WaymakerCollectionsService.HashGetAll:output_type -> waymaker.collections.HashGetAllResponse
16, // 30: waymaker.collections.WaymakerCollectionsService.HashFields:output_type -> waymaker.collections.HashFieldsResponse
18, // 31: waymaker.collections.WaymakerCollectionsService.HashLen:output_type -> waymaker.collections.HashLenResponse
20, // 32: waymaker.collections.WaymakerCollectionsService.CreateSetStore:output_type -> waymaker.collections.CreateSetStoreResponse
22, // 33: waymaker.collections.WaymakerCollectionsService.DeleteSetStore:output_type -> waymaker.collections.DeleteSetStoreResponse
24, // 34: waymaker.collections.WaymakerCollectionsService.SetAdd:output_type -> waymaker.collections.SetAddResponse
26, // 35: waymaker.collections.WaymakerCollectionsService.SetRemove:output_type -> waymaker.collections.SetRemoveResponse
28, // 36: waymaker.collections.WaymakerCollectionsService.SetIsMember:output_type -> waymaker.collections.SetIsMemberResponse
30, // 37: waymaker.collections.WaymakerCollectionsService.SetMembers:output_type -> waymaker.collections.SetMembersResponse
32, // 38: waymaker.collections.WaymakerCollectionsService.SetLen:output_type -> waymaker.collections.SetLenResponse
34, // 39: waymaker.collections.WaymakerCollectionsService.CreateQueue:output_type -> waymaker.collections.CreateQueueResponse
36, // 40: waymaker.collections.WaymakerCollectionsService.DeleteQueue:output_type -> waymaker.collections.DeleteQueueResponse
38, // 41: waymaker.collections.WaymakerCollectionsService.QueuePush:output_type -> waymaker.collections.QueuePushResponse
40, // 42: waymaker.collections.WaymakerCollectionsService.QueuePop:output_type -> waymaker.collections.QueuePopResponse
42, // 43: waymaker.collections.WaymakerCollectionsService.QueueRange:output_type -> waymaker.collections.QueueRangeResponse
44, // 44: waymaker.collections.WaymakerCollectionsService.QueueLen:output_type -> waymaker.collections.QueueLenResponse
23, // [23:45] is the sub-list for method output_type
1, // [1:23] is the sub-list for method input_type
1, // [1:1] is the sub-list for extension type_name
1, // [1:1] is the sub-list for extension extendee
0, // [0:1] is the sub-list for field type_name
}
func init() { file_collections_proto_init() }
func file_collections_proto_init() {
if File_collections_proto != nil {
return
}
file_collections_proto_msgTypes[7].OneofWrappers = []any{}
file_collections_proto_msgTypes[40].OneofWrappers = []any{}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_collections_proto_rawDesc), len(file_collections_proto_rawDesc)),
NumEnums: 0,
NumMessages: 45,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_collections_proto_goTypes,
DependencyIndexes: file_collections_proto_depIdxs,
MessageInfos: file_collections_proto_msgTypes,
}.Build()
File_collections_proto = out.File
file_collections_proto_goTypes = nil
file_collections_proto_depIdxs = nil
}
Reference in New Issue View Git Blame Copy Permalink