CeresDB 的协议缓冲区文件

// Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.28.1 // protoc v3.21.12 // source: meta_service.proto package metaservicepb import ( clusterpb "github.com/CeresDB/ceresdbproto/golang/pkg/clusterpb" commonpb "github.com/CeresDB/ceresdbproto/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 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]string `protobuf:"bytes,7,rep,name=options,proto3" json:"options,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` PartitionTableInfo *PartitionTableInfo `protobuf:"bytes,8,opt,name=partition_table_info,json=partitionTableInfo,proto3" json:"partition_table_info,omitempty"` } func (x *CreateTableRequest) Reset() { *x = CreateTableRequest{} if protoimpl.UnsafeEnabled { mi := &file_meta_service_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *CreateTableRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*CreateTableRequest) ProtoMessage() {} func (x *CreateTableRequest) ProtoReflect() protoreflect.Message { mi := &file_meta_service_proto_msgTypes[3] 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 CreateTableRequest.ProtoReflect.Descriptor instead. func (*CreateTableRequest) Descriptor() ([]byte, []int) { return file_meta_service_proto_rawDescGZIP(), []int{3} } func (x *CreateTableRequest) GetHeader() *RequestHeader { if x != nil { return x.Header } return nil } func (x *CreateTableRequest) GetSchemaName() string { if x != nil { return x.SchemaName } return "" } func (x *CreateTableRequest) GetName() string { if x != nil { return x.Name } return "" } func (x *CreateTableRequest) GetEncodedSchema() []byte { if x != nil { return x.EncodedSchema } return nil } func (x *CreateTableRequest) GetEngine() string { if x != nil { return x.Engine } return "" } func (x *CreateTableRequest) GetCreateIfNotExist() bool { if x != nil { return x.CreateIfNotExist } return false } func (x *CreateTableRequest) GetOptions() map[string]