HoraeDB 的协议缓冲区文件 管理不同语言生成代码的项目也在此存储库中 它们充当客户端、服务器和元的底层依赖项

// // Licensed to the Apache Software Foundation (ASF) under one // or more contributor license agreements. See the NOTICE file // distributed with this work for additional information // regarding copyright ownership. The ASF licenses this file // to you under the Apache License, Version 2.0 (the // "License"); you may not use this file except in compliance // with the License. You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, // software distributed under the License is distributed on an // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY // KIND, either express or implied. See the License for the // specific language governing permissions and limitations // under the License. // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.28.1 // protoc v4.25.1 // source: meta_service.proto package metaservicepb import ( clusterpb "github.com/apache/incubator-horaedb-proto/golang/pkg/clusterpb" commonpb "github.com/apache/incubator-horaedb-proto/golang/pkg/commonpb" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" ) 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 ShardInfo_Status int32 const ( ShardInfo_Ready ShardInfo_Status = 0 ShardInfo_PartialOpen ShardInfo_Status = 1 ) // Enum value maps for ShardInfo_Status. var ( ShardInfo_Status_name = map[int32]string{ 0: "Ready", 1: "PartialOpen", } ShardInfo_Status_value = map[string]int32{ "Ready": 0, "PartialOpen": 1, } ) func (x ShardInfo_Status) Enum() *ShardInfo_Status { p := new(ShardInfo_Status) *p = x return p } func (x ShardInfo_Status) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (ShardInfo_Status) Descriptor() protoreflect.EnumDescriptor { return file_meta_service_proto_enumTypes[0].Descriptor() } func (ShardInfo_Status) Type() protoreflect.EnumType { return &file_meta_service_proto_enumTypes[0] } func (x ShardInfo_Status) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use ShardInfo_Status.Descriptor instead. func (ShardInfo_Status) EnumDescriptor() ([]byte, []int) { return file_meta_service_proto_rawDescGZIP(), []int{19, 0} } type RequestHeader struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` } func (x *RequestHeader) Reset() { *x = RequestHeader{} if protoimpl.UnsafeEnabled { mi := &file_meta_service_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *RequestHeader) String() string { return protoimpl.X.MessageStringOf(x) } func (*RequestHeader) ProtoMessage() {} func (x *RequestHeader) ProtoReflect() protoreflect.Message { mi := &file_meta_service_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead. func (*RequestHeader) Descriptor() ([]byte, []int) { return file_meta_service_proto_rawDescGZIP(), []int{0} } func (x *RequestHeader) GetNode() string { if x != nil { return x.Node } return "" } func (x *RequestHeader) GetClusterName() string { if x != nil { return x.ClusterName } return "" } type AllocSchemaIdRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` } func (x *AllocSchemaIdRequest) Reset() { *x = AllocSchemaIdRequest{} if protoimpl.UnsafeEnabled { mi := &file_meta_service_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *AllocSchemaIdRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*AllocSchemaIdRequest) ProtoMessage() {} func (x *AllocSchemaIdRequest) ProtoReflect() protoreflect.Message { mi := &file_meta_service_proto_msgTypes[1] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use AllocSchemaIdRequest.ProtoReflect.Descriptor instead. func (*AllocSchemaIdRequest) Descriptor() ([]byte, []int) { return file_meta_service_proto_rawDescGZIP(), []int{1} } func (x *AllocSchemaIdRequest) GetHeader() *RequestHeader { if x != nil { return x.Header } return nil } func (x *AllocSchemaIdRequest) GetName() string { if x != nil { return x.Name } return "" } type AllocSchemaIdResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Id uint32 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` } func (x *AllocSchemaIdResponse) Reset() { *x = AllocSchemaIdResponse{} if protoimpl.UnsafeEnabled { mi := &file_meta_service_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *AllocSchemaIdResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*AllocSchemaIdResponse) ProtoMessage() {} func (x *AllocSchemaIdResponse) ProtoReflect() protoreflect.Message { mi := &file_meta_service_proto_msgTypes[2] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use AllocSchemaIdResponse.ProtoReflect.Descriptor instead. func (*AllocSchemaIdResponse) Descriptor() ([]byte, []int) { return file_meta_service_proto_rawDescGZIP(), []int{2} } func (x *AllocSchemaIdResponse) GetHeader() *commonpb.ResponseHeader { if x != nil { return x.Header } return nil } func (x *AllocSchemaIdResponse) GetName() string { if x != nil { return x.Name } return "" } func (x *AllocSchemaIdResponse) GetId() uint32 { if x != nil { return x.Id } return 0 } type CreateTableRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` EncodedSchema []byte `protobuf:"bytes,4,opt,name=encoded_schema,json=encodedSchema,proto3" json:"encoded_schema,omitempty"` Engine string `protobuf:"bytes,5,opt,name=engine,proto3" json:"engine,omitempty"` CreateIfNotExist bool `protobuf:"varint,6,opt,name=create_if_not_exist,json=createIfNotExist,proto3" json:"create_if_not_exist,omitempty"` Options map[string