Dima/orion_greptime_proto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: region procedure service (#137)

Browse Source 
* feat: adds region service and procedure service

* refactor: adds procedure service for ddl and region task

* feat: adds QueryProcedureRequest

* feat: improve ProcedureStateResponse and MigrateRegionRequest

* fix: forgot headers

* fix: remove cluster_id in MigrateRegionRequest

* refactor: rename Procedure to ProcedureService

* chore: rename peer

* fix: forgot java Procedure
This commit is contained in:
dennis zhuang
2024-02-02 22:56:40 +08:00
committed by GitHub
parent 188153f55e
commit 96f1f0404f
30 changed files with 12486 additions and 1205 deletions
Download Patch File Download Diff File Expand all files Collapse all files
go/greptime/v1/meta/common.pb.go
+82 -19
View File
@@ -561,6 +561,54 @@ func (x *KeyValue) GetValue() []byte {
return nil
}
// Procedure identifer
type ProcedureId struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}
func (x *ProcedureId) Reset() {
*x = ProcedureId{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_meta_common_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ProcedureId) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ProcedureId) ProtoMessage() {}
func (x *ProcedureId) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_meta_common_proto_msgTypes[8]
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 ProcedureId.ProtoReflect.Descriptor instead.
func (*ProcedureId) Descriptor() ([]byte, []int) {
return file_greptime_v1_meta_common_proto_rawDescGZIP(), []int{8}
}
func (x *ProcedureId) GetKey() []byte {
if x != nil {
return x.Key
}
return nil
}
var File_greptime_v1_meta_common_proto protoreflect.FileDescriptor
var file_greptime_v1_meta_common_proto_rawDesc = []byte{
@@ -621,14 +669,16 @@ var file_greptime_v1_meta_common_proto_rawDesc = []byte{
0x6d, 0x70, 0x4d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x22, 0x32, 0x0a, 0x08, 0x4b, 0x65, 0x79, 0x56,
0x61, 0x6c, 0x75, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28,
0x0c, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18,
0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x2a, 0x22, 0x0a, 0x04,
0x52, 0x6f, 0x6c, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x44, 0x41, 0x54, 0x41, 0x4e, 0x4f, 0x44, 0x45,
0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x46, 0x52, 0x4f, 0x4e, 0x54, 0x45, 0x4e, 0x44, 0x10, 0x01,
0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47,
0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70,
0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72,
0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62, 0x06,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x1f, 0x0a, 0x0b,
0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65, 0x49, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x6b,
0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x2a, 0x22, 0x0a,
0x04, 0x52, 0x6f, 0x6c, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x44, 0x41, 0x54, 0x41, 0x4e, 0x4f, 0x44,
0x45, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x46, 0x52, 0x4f, 0x4e, 0x54, 0x45, 0x4e, 0x44, 0x10,
0x01, 0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65,
0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67,
0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62,
0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
@@ -644,7 +694,7 @@ func file_greptime_v1_meta_common_proto_rawDescGZIP() []byte {
}
var file_greptime_v1_meta_common_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_greptime_v1_meta_common_proto_msgTypes = make([]protoimpl.MessageInfo, 9)
var file_greptime_v1_meta_common_proto_msgTypes = make([]protoimpl.MessageInfo, 10)
var file_greptime_v1_meta_common_proto_goTypes = []interface{}{
(Role)(0), // 0: greptime.v1.meta.Role
(*RequestHeader)(nil), // 1: greptime.v1.meta.RequestHeader
@@ -655,17 +705,18 @@ var file_greptime_v1_meta_common_proto_goTypes = []interface{}{
(*TableName)(nil), // 6: greptime.v1.meta.TableName
(*TimeInterval)(nil), // 7: greptime.v1.meta.TimeInterval
(*KeyValue)(nil), // 8: greptime.v1.meta.KeyValue
nil, // 9: greptime.v1.meta.RequestHeader.TracingContextEntry
(*ProcedureId)(nil), // 9: greptime.v1.meta.ProcedureId
nil, // 10: greptime.v1.meta.RequestHeader.TracingContextEntry
}
var file_greptime_v1_meta_common_proto_depIdxs = []int32{
0, // 0: greptime.v1.meta.RequestHeader.role:type_name -> greptime.v1.meta.Role
9, // 1: greptime.v1.meta.RequestHeader.tracing_context:type_name -> greptime.v1.meta.RequestHeader.TracingContextEntry
3, // 2: greptime.v1.meta.ResponseHeader.error:type_name -> greptime.v1.meta.Error
3, // [3:3] is the sub-list for method output_type
3, // [3:3] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
0, // 0: greptime.v1.meta.RequestHeader.role:type_name -> greptime.v1.meta.Role
10, // 1: greptime.v1.meta.RequestHeader.tracing_context:type_name -> greptime.v1.meta.RequestHeader.TracingContextEntry
3, // 2: greptime.v1.meta.ResponseHeader.error:type_name -> greptime.v1.meta.Error
3, // [3:3] is the sub-list for method output_type
3, // [3:3] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
}
func init() { file_greptime_v1_meta_common_proto_init() }
@@ -770,6 +821,18 @@ func file_greptime_v1_meta_common_proto_init() {
return nil
}
}
file_greptime_v1_meta_common_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcedureId); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
type x struct{}
out := protoimpl.TypeBuilder{
@@ -777,7 +840,7 @@ func file_greptime_v1_meta_common_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_greptime_v1_meta_common_proto_rawDesc,
NumEnums: 1,
NumMessages: 9,
NumMessages: 10,
NumExtensions: 0,
NumServices: 0,
},
go/greptime/v1/meta/ddl.pb.go
+170 -177
View File
@@ -426,7 +426,7 @@ func (x *TruncateTableTask) GetTruncateTable() *v1.TruncateTableExpr {
return nil
}
type SubmitDdlTaskRequest struct {
type DdlTaskRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
@@ -434,18 +434,18 @@ type SubmitDdlTaskRequest struct {
Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
// Types that are assignable to Task:
//
// *SubmitDdlTaskRequest_CreateTableTask
// *SubmitDdlTaskRequest_DropTableTask
// *SubmitDdlTaskRequest_AlterTableTask
// *SubmitDdlTaskRequest_TruncateTableTask
// *SubmitDdlTaskRequest_CreateTableTasks
// *SubmitDdlTaskRequest_DropTableTasks
// *SubmitDdlTaskRequest_AlterTableTasks
Task isSubmitDdlTaskRequest_Task `protobuf_oneof:"task"`
// *DdlTaskRequest_CreateTableTask
// *DdlTaskRequest_DropTableTask
// *DdlTaskRequest_AlterTableTask
// *DdlTaskRequest_TruncateTableTask
// *DdlTaskRequest_CreateTableTasks
// *DdlTaskRequest_DropTableTasks
// *DdlTaskRequest_AlterTableTasks
Task isDdlTaskRequest_Task `protobuf_oneof:"task"`
}
func (x *SubmitDdlTaskRequest) Reset() {
*x = SubmitDdlTaskRequest{}
func (x *DdlTaskRequest) Reset() {
*x = DdlTaskRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_meta_ddl_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
@@ -453,13 +453,13 @@ func (x *SubmitDdlTaskRequest) Reset() {
}
}
func (x *SubmitDdlTaskRequest) String() string {
func (x *DdlTaskRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SubmitDdlTaskRequest) ProtoMessage() {}
func (*DdlTaskRequest) ProtoMessage() {}
func (x *SubmitDdlTaskRequest) ProtoReflect() protoreflect.Message {
func (x *DdlTaskRequest) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_meta_ddl_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
@@ -471,128 +471,127 @@ func (x *SubmitDdlTaskRequest) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
// Deprecated: Use SubmitDdlTaskRequest.ProtoReflect.Descriptor instead.
func (*SubmitDdlTaskRequest) Descriptor() ([]byte, []int) {
// Deprecated: Use DdlTaskRequest.ProtoReflect.Descriptor instead.
func (*DdlTaskRequest) Descriptor() ([]byte, []int) {
return file_greptime_v1_meta_ddl_proto_rawDescGZIP(), []int{7}
}
func (x *SubmitDdlTaskRequest) GetHeader() *RequestHeader {
func (x *DdlTaskRequest) GetHeader() *RequestHeader {
if x != nil {
return x.Header
}
return nil
}
func (m *SubmitDdlTaskRequest) GetTask() isSubmitDdlTaskRequest_Task {
func (m *DdlTaskRequest) GetTask() isDdlTaskRequest_Task {
if m != nil {
return m.Task
}
return nil
}
func (x *SubmitDdlTaskRequest) GetCreateTableTask() *CreateTableTask {
if x, ok := x.GetTask().(*SubmitDdlTaskRequest_CreateTableTask); ok {
func (x *DdlTaskRequest) GetCreateTableTask() *CreateTableTask {
if x, ok := x.GetTask().(*DdlTaskRequest_CreateTableTask); ok {
return x.CreateTableTask
}
return nil
}
func (x *SubmitDdlTaskRequest) GetDropTableTask() *DropTableTask {
if x, ok := x.GetTask().(*SubmitDdlTaskRequest_DropTableTask); ok {
func (x *DdlTaskRequest) GetDropTableTask() *DropTableTask {
if x, ok := x.GetTask().(*DdlTaskRequest_DropTableTask); ok {
return x.DropTableTask
}
return nil
}
func (x *SubmitDdlTaskRequest) GetAlterTableTask() *AlterTableTask {
if x, ok := x.GetTask().(*SubmitDdlTaskRequest_AlterTableTask); ok {
func (x *DdlTaskRequest) GetAlterTableTask() *AlterTableTask {
if x, ok := x.GetTask().(*DdlTaskRequest_AlterTableTask); ok {
return x.AlterTableTask
}
return nil
}
func (x *SubmitDdlTaskRequest) GetTruncateTableTask() *TruncateTableTask {
if x, ok := x.GetTask().(*SubmitDdlTaskRequest_TruncateTableTask); ok {
func (x *DdlTaskRequest) GetTruncateTableTask() *TruncateTableTask {
if x, ok := x.GetTask().(*DdlTaskRequest_TruncateTableTask); ok {
return x.TruncateTableTask
}
return nil
}
func (x *SubmitDdlTaskRequest) GetCreateTableTasks() *CreateTableTasks {
if x, ok := x.GetTask().(*SubmitDdlTaskRequest_CreateTableTasks); ok {
func (x *DdlTaskRequest) GetCreateTableTasks() *CreateTableTasks {
if x, ok := x.GetTask().(*DdlTaskRequest_CreateTableTasks); ok {
return x.CreateTableTasks
}
return nil
}
func (x *SubmitDdlTaskRequest) GetDropTableTasks() *DropTableTasks {
if x, ok := x.GetTask().(*SubmitDdlTaskRequest_DropTableTasks); ok {
func (x *DdlTaskRequest) GetDropTableTasks() *DropTableTasks {
if x, ok := x.GetTask().(*DdlTaskRequest_DropTableTasks); ok {
return x.DropTableTasks
}
return nil
}
func (x *SubmitDdlTaskRequest) GetAlterTableTasks() *AlterTableTasks {
if x, ok := x.GetTask().(*SubmitDdlTaskRequest_AlterTableTasks); ok {
func (x *DdlTaskRequest) GetAlterTableTasks() *AlterTableTasks {
if x, ok := x.GetTask().(*DdlTaskRequest_AlterTableTasks); ok {
return x.AlterTableTasks
}
return nil
}
type isSubmitDdlTaskRequest_Task interface {
isSubmitDdlTaskRequest_Task()
type isDdlTaskRequest_Task interface {
isDdlTaskRequest_Task()
}
type SubmitDdlTaskRequest_CreateTableTask struct {
type DdlTaskRequest_CreateTableTask struct {
CreateTableTask *CreateTableTask `protobuf:"bytes,2,opt,name=create_table_task,json=createTableTask,proto3,oneof"`
}
type SubmitDdlTaskRequest_DropTableTask struct {
type DdlTaskRequest_DropTableTask struct {
DropTableTask *DropTableTask `protobuf:"bytes,3,opt,name=drop_table_task,json=dropTableTask,proto3,oneof"`
}
type SubmitDdlTaskRequest_AlterTableTask struct {
type DdlTaskRequest_AlterTableTask struct {
AlterTableTask *AlterTableTask `protobuf:"bytes,4,opt,name=alter_table_task,json=alterTableTask,proto3,oneof"`
}
type SubmitDdlTaskRequest_TruncateTableTask struct {
type DdlTaskRequest_TruncateTableTask struct {
TruncateTableTask *TruncateTableTask `protobuf:"bytes,5,opt,name=truncate_table_task,json=truncateTableTask,proto3,oneof"`
}
type SubmitDdlTaskRequest_CreateTableTasks struct {
type DdlTaskRequest_CreateTableTasks struct {
CreateTableTasks *CreateTableTasks `protobuf:"bytes,6,opt,name=create_table_tasks,json=createTableTasks,proto3,oneof"`
}
type SubmitDdlTaskRequest_DropTableTasks struct {
type DdlTaskRequest_DropTableTasks struct {
DropTableTasks *DropTableTasks `protobuf:"bytes,7,opt,name=drop_table_tasks,json=dropTableTasks,proto3,oneof"`
}
type SubmitDdlTaskRequest_AlterTableTasks struct {
type DdlTaskRequest_AlterTableTasks struct {
AlterTableTasks *AlterTableTasks `protobuf:"bytes,8,opt,name=alter_table_tasks,json=alterTableTasks,proto3,oneof"`
}
func (*SubmitDdlTaskRequest_CreateTableTask) isSubmitDdlTaskRequest_Task() {}
func (*DdlTaskRequest_CreateTableTask) isDdlTaskRequest_Task() {}
func (*SubmitDdlTaskRequest_DropTableTask) isSubmitDdlTaskRequest_Task() {}
func (*DdlTaskRequest_DropTableTask) isDdlTaskRequest_Task() {}
func (*SubmitDdlTaskRequest_AlterTableTask) isSubmitDdlTaskRequest_Task() {}
func (*DdlTaskRequest_AlterTableTask) isDdlTaskRequest_Task() {}
func (*SubmitDdlTaskRequest_TruncateTableTask) isSubmitDdlTaskRequest_Task() {}
func (*DdlTaskRequest_TruncateTableTask) isDdlTaskRequest_Task() {}
func (*SubmitDdlTaskRequest_CreateTableTasks) isSubmitDdlTaskRequest_Task() {}
func (*DdlTaskRequest_CreateTableTasks) isDdlTaskRequest_Task() {}
func (*SubmitDdlTaskRequest_DropTableTasks) isSubmitDdlTaskRequest_Task() {}
func (*DdlTaskRequest_DropTableTasks) isDdlTaskRequest_Task() {}
func (*SubmitDdlTaskRequest_AlterTableTasks) isSubmitDdlTaskRequest_Task() {}
func (*DdlTaskRequest_AlterTableTasks) isDdlTaskRequest_Task() {}
type SubmitDdlTaskResponse struct {
type DdlTaskResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
// Key is the identifier for the ddl task.
Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Pid *ProcedureId `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
// Returns if table created.
// TODO(jeremy): remove it?
TableId *TableId `protobuf:"bytes,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
@@ -600,8 +599,8 @@ type SubmitDdlTaskResponse struct {
TableIds []*TableId `protobuf:"bytes,5,rep,name=table_ids,json=tableIds,proto3" json:"table_ids,omitempty"`
}
func (x *SubmitDdlTaskResponse) Reset() {
*x = SubmitDdlTaskResponse{}
func (x *DdlTaskResponse) Reset() {
*x = DdlTaskResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_meta_ddl_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
@@ -609,13 +608,13 @@ func (x *SubmitDdlTaskResponse) Reset() {
}
}
func (x *SubmitDdlTaskResponse) String() string {
func (x *DdlTaskResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SubmitDdlTaskResponse) ProtoMessage() {}
func (*DdlTaskResponse) ProtoMessage() {}
func (x *SubmitDdlTaskResponse) ProtoReflect() protoreflect.Message {
func (x *DdlTaskResponse) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_meta_ddl_proto_msgTypes[8]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
@@ -627,33 +626,33 @@ func (x *SubmitDdlTaskResponse) ProtoReflect() protoreflect.Message {
return mi.MessageOf(x)
}
// Deprecated: Use SubmitDdlTaskResponse.ProtoReflect.Descriptor instead.
func (*SubmitDdlTaskResponse) Descriptor() ([]byte, []int) {
// Deprecated: Use DdlTaskResponse.ProtoReflect.Descriptor instead.
func (*DdlTaskResponse) Descriptor() ([]byte, []int) {
return file_greptime_v1_meta_ddl_proto_rawDescGZIP(), []int{8}
}
func (x *SubmitDdlTaskResponse) GetHeader() *ResponseHeader {
func (x *DdlTaskResponse) GetHeader() *ResponseHeader {
if x != nil {
return x.Header
}
return nil
}
func (x *SubmitDdlTaskResponse) GetKey() []byte {
func (x *DdlTaskResponse) GetPid() *ProcedureId {
if x != nil {
return x.Key
return x.Pid
}
return nil
}
func (x *SubmitDdlTaskResponse) GetTableId() *TableId {
func (x *DdlTaskResponse) GetTableId() *TableId {
if x != nil {
return x.TableId
}
return nil
}
func (x *SubmitDdlTaskResponse) GetTableIds() []*TableId {
func (x *DdlTaskResponse) GetTableIds() []*TableId {
if x != nil {
return x.TableIds
}
@@ -711,75 +710,69 @@ var file_greptime_v1_meta_ddl_proto_rawDesc = []byte{
0x6c, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74,
0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54,
0x61, 0x62, 0x6c, 0x65, 0x45, 0x78, 0x70, 0x72, 0x52, 0x0d, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61,
0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x22, 0x8b, 0x05, 0x0a, 0x14, 0x53, 0x75, 0x62, 0x6d,
0x69, 0x74, 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x12, 0x37, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d,
0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65,
0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x4f, 0x0a, 0x11, 0x63, 0x72, 0x65,
0x61, 0x74, 0x65, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x02,
0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e,
0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61,
0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0f, 0x63, 0x72, 0x65, 0x61, 0x74,
0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x49, 0x0a, 0x0f, 0x64, 0x72,
0x6f, 0x70, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x03, 0x20,
0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76,
0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0d, 0x64, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c,
0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x4c, 0x0a, 0x10, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x5f, 0x74,
0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32,
0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65,
0x74, 0x61, 0x2e, 0x41, 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73,
0x6b, 0x48, 0x00, 0x52, 0x0e, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54,
0x61, 0x73, 0x6b, 0x12, 0x55, 0x0a, 0x13, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x5f,
0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b,
0x32, 0x23, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d,
0x65, 0x74, 0x61, 0x2e, 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c,
0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x11, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74,
0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x52, 0x0a, 0x12, 0x63, 0x72,
0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73,
0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65,
0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x10, 0x63, 0x72,
0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x4c,
0x0a, 0x10, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73,
0x6b, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74,
0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70,
0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x0e, 0x64, 0x72,
0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x4f, 0x0a, 0x11,
0x61, 0x6c, 0x74, 0x65, 0x72, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b,
0x73, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69,
0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x6c, 0x74, 0x65, 0x72,
0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x0f, 0x61, 0x6c,
0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x42, 0x06, 0x0a,
0x04, 0x74, 0x61, 0x73, 0x6b, 0x22, 0xd1, 0x01, 0x0a, 0x15, 0x53, 0x75, 0x62, 0x6d, 0x69, 0x74,
0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
0x38, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65,
0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65,
0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79,
0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x34, 0x0a, 0x08, 0x74,
0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e,
0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x22, 0x85, 0x05, 0x0a, 0x0e, 0x44, 0x64, 0x6c, 0x54,
0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x06, 0x68, 0x65,
0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65,
0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65,
0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61,
0x64, 0x65, 0x72, 0x12, 0x4f, 0x0a, 0x11, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x61,
0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21,
0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74,
0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73,
0x6b, 0x48, 0x00, 0x52, 0x0f, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x54, 0x61, 0x73, 0x6b, 0x12, 0x49, 0x0a, 0x0f, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x74, 0x61, 0x62,
0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e,
0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61,
0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52, 0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49,
0x64, 0x12, 0x36, 0x0a, 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x05,
0x20, 0x03, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e,
0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52,
0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x73, 0x2a, 0x23, 0x0a, 0x0b, 0x44, 0x64, 0x6c,
0x54, 0x61, 0x73, 0x6b, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x43, 0x72, 0x65, 0x61,
0x74, 0x65, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x44, 0x72, 0x6f, 0x70, 0x10, 0x01, 0x32, 0x6b,
0x0a, 0x07, 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x60, 0x0a, 0x0d, 0x53, 0x75, 0x62,
0x6d, 0x69, 0x74, 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x26, 0x2e, 0x67, 0x72, 0x65,
0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x53, 0x75,
0x62, 0x6d, 0x69, 0x74, 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65,
0x73, 0x74, 0x1a, 0x27, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31,
0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x53, 0x75, 0x62, 0x6d, 0x69, 0x74, 0x44, 0x64, 0x6c, 0x54,
0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x3c, 0x5a, 0x3a, 0x67,
0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69,
0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x33,
0x2e, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00,
0x52, 0x0d, 0x64, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12,
0x4c, 0x0a, 0x10, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74,
0x61, 0x73, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70,
0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x6c, 0x74,
0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0e, 0x61,
0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x55, 0x0a,
0x13, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f,
0x74, 0x61, 0x73, 0x6b, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x67, 0x72, 0x65,
0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x54, 0x72,
0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48,
0x00, 0x52, 0x11, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x54, 0x61, 0x73, 0x6b, 0x12, 0x52, 0x0a, 0x12, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74,
0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b,
0x32, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d,
0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54,
0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x10, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61,
0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x4c, 0x0a, 0x10, 0x64, 0x72, 0x6f, 0x70,
0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x07, 0x20, 0x01,
0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31,
0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54,
0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x0e, 0x64, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c,
0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x4f, 0x0a, 0x11, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x5f,
0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28,
0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e,
0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54,
0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x0f, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62,
0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x42, 0x06, 0x0a, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x22,
0xea, 0x01, 0x0a, 0x0f, 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20,
0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76,
0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48,
0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x2f, 0x0a,
0x03, 0x70, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x65,
0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x72,
0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65, 0x49, 0x64, 0x52, 0x03, 0x70, 0x69, 0x64, 0x12, 0x34,
0x0a, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b,
0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d,
0x65, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52, 0x07, 0x74, 0x61, 0x62,
0x6c, 0x65, 0x49, 0x64, 0x12, 0x36, 0x0a, 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64,
0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69,
0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x49, 0x64, 0x52, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x73, 0x2a, 0x23, 0x0a, 0x0b,
0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x43,
0x72, 0x65, 0x61, 0x74, 0x65, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x44, 0x72, 0x6f, 0x70, 0x10,
0x01, 0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65,
0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67,
0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62,
0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
@@ -797,24 +790,25 @@ func file_greptime_v1_meta_ddl_proto_rawDescGZIP() []byte {
var file_greptime_v1_meta_ddl_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_greptime_v1_meta_ddl_proto_msgTypes = make([]protoimpl.MessageInfo, 9)
var file_greptime_v1_meta_ddl_proto_goTypes = []interface{}{
(DdlTaskType)(0), // 0: greptime.v1.meta.DdlTaskType
(*CreateTableTask)(nil), // 1: greptime.v1.meta.CreateTableTask
(*CreateTableTasks)(nil), // 2: greptime.v1.meta.CreateTableTasks
(*DropTableTask)(nil), // 3: greptime.v1.meta.DropTableTask
(*DropTableTasks)(nil), // 4: greptime.v1.meta.DropTableTasks
(*AlterTableTask)(nil), // 5: greptime.v1.meta.AlterTableTask
(*AlterTableTasks)(nil), // 6: greptime.v1.meta.AlterTableTasks
(*TruncateTableTask)(nil), // 7: greptime.v1.meta.TruncateTableTask
(*SubmitDdlTaskRequest)(nil), // 8: greptime.v1.meta.SubmitDdlTaskRequest
(*SubmitDdlTaskResponse)(nil), // 9: greptime.v1.meta.SubmitDdlTaskResponse
(*v1.CreateTableExpr)(nil), // 10: greptime.v1.CreateTableExpr
(*Partition)(nil), // 11: greptime.v1.meta.Partition
(*v1.DropTableExpr)(nil), // 12: greptime.v1.DropTableExpr
(*v1.AlterExpr)(nil), // 13: greptime.v1.AlterExpr
(*v1.TruncateTableExpr)(nil), // 14: greptime.v1.TruncateTableExpr
(*RequestHeader)(nil), // 15: greptime.v1.meta.RequestHeader
(*ResponseHeader)(nil), // 16: greptime.v1.meta.ResponseHeader
(*TableId)(nil), // 17: greptime.v1.meta.TableId
(DdlTaskType)(0), // 0: greptime.v1.meta.DdlTaskType
(*CreateTableTask)(nil), // 1: greptime.v1.meta.CreateTableTask
(*CreateTableTasks)(nil), // 2: greptime.v1.meta.CreateTableTasks
(*DropTableTask)(nil), // 3: greptime.v1.meta.DropTableTask
(*DropTableTasks)(nil), // 4: greptime.v1.meta.DropTableTasks
(*AlterTableTask)(nil), // 5: greptime.v1.meta.AlterTableTask
(*AlterTableTasks)(nil), // 6: greptime.v1.meta.AlterTableTasks
(*TruncateTableTask)(nil), // 7: greptime.v1.meta.TruncateTableTask
(*DdlTaskRequest)(nil), // 8: greptime.v1.meta.DdlTaskRequest
(*DdlTaskResponse)(nil), // 9: greptime.v1.meta.DdlTaskResponse
(*v1.CreateTableExpr)(nil), // 10: greptime.v1.CreateTableExpr
(*Partition)(nil), // 11: greptime.v1.meta.Partition
(*v1.DropTableExpr)(nil), // 12: greptime.v1.DropTableExpr
(*v1.AlterExpr)(nil), // 13: greptime.v1.AlterExpr
(*v1.TruncateTableExpr)(nil), // 14: greptime.v1.TruncateTableExpr
(*RequestHeader)(nil), // 15: greptime.v1.meta.RequestHeader
(*ResponseHeader)(nil), // 16: greptime.v1.meta.ResponseHeader
(*ProcedureId)(nil), // 17: greptime.v1.meta.ProcedureId
(*TableId)(nil), // 18: greptime.v1.meta.TableId
}
var file_greptime_v1_meta_ddl_proto_depIdxs = []int32{
10, // 0: greptime.v1.meta.CreateTableTask.create_table:type_name -> greptime.v1.CreateTableExpr
@@ -825,24 +819,23 @@ var file_greptime_v1_meta_ddl_proto_depIdxs = []int32{
13, // 5: greptime.v1.meta.AlterTableTask.alter_table:type_name -> greptime.v1.AlterExpr
5, // 6: greptime.v1.meta.AlterTableTasks.tasks:type_name -> greptime.v1.meta.AlterTableTask
14, // 7: greptime.v1.meta.TruncateTableTask.truncate_table:type_name -> greptime.v1.TruncateTableExpr
15, // 8: greptime.v1.meta.SubmitDdlTaskRequest.header:type_name -> greptime.v1.meta.RequestHeader
1, // 9: greptime.v1.meta.SubmitDdlTaskRequest.create_table_task:type_name -> greptime.v1.meta.CreateTableTask
3, // 10: greptime.v1.meta.SubmitDdlTaskRequest.drop_table_task:type_name -> greptime.v1.meta.DropTableTask
5, // 11: greptime.v1.meta.SubmitDdlTaskRequest.alter_table_task:type_name -> greptime.v1.meta.AlterTableTask
7, // 12: greptime.v1.meta.SubmitDdlTaskRequest.truncate_table_task:type_name -> greptime.v1.meta.TruncateTableTask
2, // 13: greptime.v1.meta.SubmitDdlTaskRequest.create_table_tasks:type_name -> greptime.v1.meta.CreateTableTasks
4, // 14: greptime.v1.meta.SubmitDdlTaskRequest.drop_table_tasks:type_name -> greptime.v1.meta.DropTableTasks
6, // 15: greptime.v1.meta.SubmitDdlTaskRequest.alter_table_tasks:type_name -> greptime.v1.meta.AlterTableTasks
16, // 16: greptime.v1.meta.SubmitDdlTaskResponse.header:type_name -> greptime.v1.meta.ResponseHeader
17, // 17: greptime.v1.meta.SubmitDdlTaskResponse.table_id:type_name -> greptime.v1.meta.TableId
17, // 18: greptime.v1.meta.SubmitDdlTaskResponse.table_ids:type_name -> greptime.v1.meta.TableId
8, // 19: greptime.v1.meta.DdlTask.SubmitDdlTask:input_type -> greptime.v1.meta.SubmitDdlTaskRequest
9, // 20: greptime.v1.meta.DdlTask.SubmitDdlTask:output_type -> greptime.v1.meta.SubmitDdlTaskResponse
20, // [20:21] is the sub-list for method output_type
19, // [19:20] is the sub-list for method input_type
19, // [19:19] is the sub-list for extension type_name
19, // [19:19] is the sub-list for extension extendee
0, // [0:19] is the sub-list for field type_name
15, // 8: greptime.v1.meta.DdlTaskRequest.header:type_name -> greptime.v1.meta.RequestHeader
1, // 9: greptime.v1.meta.DdlTaskRequest.create_table_task:type_name -> greptime.v1.meta.CreateTableTask
3, // 10: greptime.v1.meta.DdlTaskRequest.drop_table_task:type_name -> greptime.v1.meta.DropTableTask
5, // 11: greptime.v1.meta.DdlTaskRequest.alter_table_task:type_name -> greptime.v1.meta.AlterTableTask
7, // 12: greptime.v1.meta.DdlTaskRequest.truncate_table_task:type_name -> greptime.v1.meta.TruncateTableTask
2, // 13: greptime.v1.meta.DdlTaskRequest.create_table_tasks:type_name -> greptime.v1.meta.CreateTableTasks
4, // 14: greptime.v1.meta.DdlTaskRequest.drop_table_tasks:type_name -> greptime.v1.meta.DropTableTasks
6, // 15: greptime.v1.meta.DdlTaskRequest.alter_table_tasks:type_name -> greptime.v1.meta.AlterTableTasks
16, // 16: greptime.v1.meta.DdlTaskResponse.header:type_name -> greptime.v1.meta.ResponseHeader
17, // 17: greptime.v1.meta.DdlTaskResponse.pid:type_name -> greptime.v1.meta.ProcedureId
18, // 18: greptime.v1.meta.DdlTaskResponse.table_id:type_name -> greptime.v1.meta.TableId
18, // 19: greptime.v1.meta.DdlTaskResponse.table_ids:type_name -> greptime.v1.meta.TableId
20, // [20:20] is the sub-list for method output_type
20, // [20:20] is the sub-list for method input_type
20, // [20:20] is the sub-list for extension type_name
20, // [20:20] is the sub-list for extension extendee
0, // [0:20] is the sub-list for field type_name
}
func init() { file_greptime_v1_meta_ddl_proto_init() }
@@ -938,7 +931,7 @@ func file_greptime_v1_meta_ddl_proto_init() {
}
}
file_greptime_v1_meta_ddl_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SubmitDdlTaskRequest); i {
switch v := v.(*DdlTaskRequest); i {
case 0:
return &v.state
case 1:
@@ -950,7 +943,7 @@ func file_greptime_v1_meta_ddl_proto_init() {
}
}
file_greptime_v1_meta_ddl_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SubmitDdlTaskResponse); i {
switch v := v.(*DdlTaskResponse); i {
case 0:
return &v.state
case 1:
@@ -963,13 +956,13 @@ func file_greptime_v1_meta_ddl_proto_init() {
}
}
file_greptime_v1_meta_ddl_proto_msgTypes[7].OneofWrappers = []interface{}{
(*SubmitDdlTaskRequest_CreateTableTask)(nil),
(*SubmitDdlTaskRequest_DropTableTask)(nil),
(*SubmitDdlTaskRequest_AlterTableTask)(nil),
(*SubmitDdlTaskRequest_TruncateTableTask)(nil),
(*SubmitDdlTaskRequest_CreateTableTasks)(nil),
(*SubmitDdlTaskRequest_DropTableTasks)(nil),
(*SubmitDdlTaskRequest_AlterTableTasks)(nil),
(*DdlTaskRequest_CreateTableTask)(nil),
(*DdlTaskRequest_DropTableTask)(nil),
(*DdlTaskRequest_AlterTableTask)(nil),
(*DdlTaskRequest_TruncateTableTask)(nil),
(*DdlTaskRequest_CreateTableTasks)(nil),
(*DdlTaskRequest_DropTableTasks)(nil),
(*DdlTaskRequest_AlterTableTasks)(nil),
}
type x struct{}
out := protoimpl.TypeBuilder{
@@ -979,7 +972,7 @@ func file_greptime_v1_meta_ddl_proto_init() {
NumEnums: 1,
NumMessages: 9,
NumExtensions: 0,
NumServices: 1,
NumServices: 0,
},
GoTypes: file_greptime_v1_meta_ddl_proto_goTypes,
DependencyIndexes: file_greptime_v1_meta_ddl_proto_depIdxs,
go/greptime/v1/meta/procedure.pb.go
+353
View File
@@ -0,0 +1,353 @@
// 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 v3.21.6
// source: greptime/v1/meta/procedure.proto
package meta
import (
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 ProcedureStatus int32
const (
ProcedureStatus_Running ProcedureStatus = 0
ProcedureStatus_Done ProcedureStatus = 1
ProcedureStatus_Retrying ProcedureStatus = 2
ProcedureStatus_Failed ProcedureStatus = 3
)
// Enum value maps for ProcedureStatus.
var (
ProcedureStatus_name = map[int32]string{
0: "Running",
1: "Done",
2: "Retrying",
3: "Failed",
}
ProcedureStatus_value = map[string]int32{
"Running": 0,
"Done": 1,
"Retrying": 2,
"Failed": 3,
}
)
func (x ProcedureStatus) Enum() *ProcedureStatus {
p := new(ProcedureStatus)
*p = x
return p
}
func (x ProcedureStatus) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (ProcedureStatus) Descriptor() protoreflect.EnumDescriptor {
return file_greptime_v1_meta_procedure_proto_enumTypes[0].Descriptor()
}
func (ProcedureStatus) Type() protoreflect.EnumType {
return &file_greptime_v1_meta_procedure_proto_enumTypes[0]
}
func (x ProcedureStatus) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use ProcedureStatus.Descriptor instead.
func (ProcedureStatus) EnumDescriptor() ([]byte, []int) {
return file_greptime_v1_meta_procedure_proto_rawDescGZIP(), []int{0}
}
type QueryProcedureRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
Pid *ProcedureId `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
}
func (x *QueryProcedureRequest) Reset() {
*x = QueryProcedureRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_meta_procedure_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *QueryProcedureRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueryProcedureRequest) ProtoMessage() {}
func (x *QueryProcedureRequest) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_meta_procedure_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 QueryProcedureRequest.ProtoReflect.Descriptor instead.
func (*QueryProcedureRequest) Descriptor() ([]byte, []int) {
return file_greptime_v1_meta_procedure_proto_rawDescGZIP(), []int{0}
}
func (x *QueryProcedureRequest) GetHeader() *RequestHeader {
if x != nil {
return x.Header
}
return nil
}
func (x *QueryProcedureRequest) GetPid() *ProcedureId {
if x != nil {
return x.Pid
}
return nil
}
type ProcedureStateResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
Status ProcedureStatus `protobuf:"varint,2,opt,name=status,proto3,enum=greptime.v1.meta.ProcedureStatus" json:"status,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}
func (x *ProcedureStateResponse) Reset() {
*x = ProcedureStateResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_meta_procedure_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ProcedureStateResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ProcedureStateResponse) ProtoMessage() {}
func (x *ProcedureStateResponse) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_meta_procedure_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 ProcedureStateResponse.ProtoReflect.Descriptor instead.
func (*ProcedureStateResponse) Descriptor() ([]byte, []int) {
return file_greptime_v1_meta_procedure_proto_rawDescGZIP(), []int{1}
}
func (x *ProcedureStateResponse) GetHeader() *ResponseHeader {
if x != nil {
return x.Header
}
return nil
}
func (x *ProcedureStateResponse) GetStatus() ProcedureStatus {
if x != nil {
return x.Status
}
return ProcedureStatus_Running
}
func (x *ProcedureStateResponse) GetError() string {
if x != nil {
return x.Error
}
return ""
}
var File_greptime_v1_meta_procedure_proto protoreflect.FileDescriptor
var file_greptime_v1_meta_procedure_proto_rawDesc = []byte{
0x0a, 0x20, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65,
0x74, 0x61, 0x2f, 0x70, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65, 0x2e, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x12, 0x10, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e,
0x6d, 0x65, 0x74, 0x61, 0x1a, 0x1d, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76,
0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72,
0x6f, 0x74, 0x6f, 0x1a, 0x1a, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31,
0x2f, 0x6d, 0x65, 0x74, 0x61, 0x2f, 0x64, 0x64, 0x6c, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
0x1d, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74,
0x61, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x81,
0x01, 0x0a, 0x15, 0x51, 0x75, 0x65, 0x72, 0x79, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72,
0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64,
0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74,
0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75,
0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65,
0x72, 0x12, 0x2f, 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d,
0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74,
0x61, 0x2e, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65, 0x49, 0x64, 0x52, 0x03, 0x70,
0x69, 0x64, 0x22, 0xa3, 0x01, 0x0a, 0x16, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65,
0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a,
0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e,
0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61,
0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52,
0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x39, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75,
0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69,
0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x72, 0x6f, 0x63, 0x65,
0x64, 0x75, 0x72, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74,
0x75, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28,
0x09, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x2a, 0x42, 0x0a, 0x0f, 0x50, 0x72, 0x6f, 0x63,
0x65, 0x64, 0x75, 0x72, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x0b, 0x0a, 0x07, 0x52,
0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x44, 0x6f, 0x6e, 0x65,
0x10, 0x01, 0x12, 0x0c, 0x0a, 0x08, 0x52, 0x65, 0x74, 0x72, 0x79, 0x69, 0x6e, 0x67, 0x10, 0x02,
0x12, 0x0a, 0x0a, 0x06, 0x46, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x10, 0x03, 0x32, 0x96, 0x02, 0x0a,
0x10, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
0x65, 0x12, 0x5a, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x27, 0x2e, 0x67, 0x72, 0x65,
0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x51, 0x75,
0x65, 0x72, 0x79, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65, 0x52, 0x65, 0x71, 0x75,
0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76,
0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65,
0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4a, 0x0a,
0x03, 0x64, 0x64, 0x6c, 0x12, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e,
0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x52,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73,
0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x5a, 0x0a, 0x07, 0x6d, 0x69, 0x67,
0x72, 0x61, 0x74, 0x65, 0x12, 0x26, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e,
0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x65, 0x52,
0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x27, 0x2e, 0x67,
0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e,
0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x65, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73,
0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e,
0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d,
0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f,
0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d,
0x65, 0x74, 0x61, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
file_greptime_v1_meta_procedure_proto_rawDescOnce sync.Once
file_greptime_v1_meta_procedure_proto_rawDescData = file_greptime_v1_meta_procedure_proto_rawDesc
)
func file_greptime_v1_meta_procedure_proto_rawDescGZIP() []byte {
file_greptime_v1_meta_procedure_proto_rawDescOnce.Do(func() {
file_greptime_v1_meta_procedure_proto_rawDescData = protoimpl.X.CompressGZIP(file_greptime_v1_meta_procedure_proto_rawDescData)
})
return file_greptime_v1_meta_procedure_proto_rawDescData
}
var file_greptime_v1_meta_procedure_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_greptime_v1_meta_procedure_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
var file_greptime_v1_meta_procedure_proto_goTypes = []interface{}{
(ProcedureStatus)(0), // 0: greptime.v1.meta.ProcedureStatus
(*QueryProcedureRequest)(nil), // 1: greptime.v1.meta.QueryProcedureRequest
(*ProcedureStateResponse)(nil), // 2: greptime.v1.meta.ProcedureStateResponse
(*RequestHeader)(nil), // 3: greptime.v1.meta.RequestHeader
(*ProcedureId)(nil), // 4: greptime.v1.meta.ProcedureId
(*ResponseHeader)(nil), // 5: greptime.v1.meta.ResponseHeader
(*DdlTaskRequest)(nil), // 6: greptime.v1.meta.DdlTaskRequest
(*MigrateRegionRequest)(nil), // 7: greptime.v1.meta.MigrateRegionRequest
(*DdlTaskResponse)(nil), // 8: greptime.v1.meta.DdlTaskResponse
(*MigrateRegionResponse)(nil), // 9: greptime.v1.meta.MigrateRegionResponse
}
var file_greptime_v1_meta_procedure_proto_depIdxs = []int32{
3, // 0: greptime.v1.meta.QueryProcedureRequest.header:type_name -> greptime.v1.meta.RequestHeader
4, // 1: greptime.v1.meta.QueryProcedureRequest.pid:type_name -> greptime.v1.meta.ProcedureId
5, // 2: greptime.v1.meta.ProcedureStateResponse.header:type_name -> greptime.v1.meta.ResponseHeader
0, // 3: greptime.v1.meta.ProcedureStateResponse.status:type_name -> greptime.v1.meta.ProcedureStatus
1, // 4: greptime.v1.meta.ProcedureService.query:input_type -> greptime.v1.meta.QueryProcedureRequest
6, // 5: greptime.v1.meta.ProcedureService.ddl:input_type -> greptime.v1.meta.DdlTaskRequest
7, // 6: greptime.v1.meta.ProcedureService.migrate:input_type -> greptime.v1.meta.MigrateRegionRequest
2, // 7: greptime.v1.meta.ProcedureService.query:output_type -> greptime.v1.meta.ProcedureStateResponse
8, // 8: greptime.v1.meta.ProcedureService.ddl:output_type -> greptime.v1.meta.DdlTaskResponse
9, // 9: greptime.v1.meta.ProcedureService.migrate:output_type -> greptime.v1.meta.MigrateRegionResponse
7, // [7:10] is the sub-list for method output_type
4, // [4:7] is the sub-list for method input_type
4, // [4:4] is the sub-list for extension type_name
4, // [4:4] is the sub-list for extension extendee
0, // [0:4] is the sub-list for field type_name
}
func init() { file_greptime_v1_meta_procedure_proto_init() }
func file_greptime_v1_meta_procedure_proto_init() {
if File_greptime_v1_meta_procedure_proto != nil {
return
}
file_greptime_v1_meta_common_proto_init()
file_greptime_v1_meta_ddl_proto_init()
file_greptime_v1_meta_region_proto_init()
if !protoimpl.UnsafeEnabled {
file_greptime_v1_meta_procedure_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*QueryProcedureRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_greptime_v1_meta_procedure_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcedureStateResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_greptime_v1_meta_procedure_proto_rawDesc,
NumEnums: 1,
NumMessages: 2,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_greptime_v1_meta_procedure_proto_goTypes,
DependencyIndexes: file_greptime_v1_meta_procedure_proto_depIdxs,
EnumInfos: file_greptime_v1_meta_procedure_proto_enumTypes,
MessageInfos: file_greptime_v1_meta_procedure_proto_msgTypes,
}.Build()
File_greptime_v1_meta_procedure_proto = out.File
file_greptime_v1_meta_procedure_proto_rawDesc = nil
file_greptime_v1_meta_procedure_proto_goTypes = nil
file_greptime_v1_meta_procedure_proto_depIdxs = nil
}
go/greptime/v1/meta/procedure_grpc.pb.go
+183
View File
@@ -0,0 +1,183 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.2.0
// - protoc v3.21.6
// source: greptime/v1/meta/procedure.proto
package meta
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// ProcedureServiceClient is the client API for ProcedureService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type ProcedureServiceClient interface {
// Query a submitted procedure state
Query(ctx context.Context, in *QueryProcedureRequest, opts ...grpc.CallOption) (*ProcedureStateResponse, error)
// Submits a DDL task
Ddl(ctx context.Context, in *DdlTaskRequest, opts ...grpc.CallOption) (*DdlTaskResponse, error)
// Submits a region migration task
Migrate(ctx context.Context, in *MigrateRegionRequest, opts ...grpc.CallOption) (*MigrateRegionResponse, error)
}
type procedureServiceClient struct {
cc grpc.ClientConnInterface
}
func NewProcedureServiceClient(cc grpc.ClientConnInterface) ProcedureServiceClient {
return &procedureServiceClient{cc}
}
func (c *procedureServiceClient) Query(ctx context.Context, in *QueryProcedureRequest, opts ...grpc.CallOption) (*ProcedureStateResponse, error) {
out := new(ProcedureStateResponse)
err := c.cc.Invoke(ctx, "/greptime.v1.meta.ProcedureService/query", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *procedureServiceClient) Ddl(ctx context.Context, in *DdlTaskRequest, opts ...grpc.CallOption) (*DdlTaskResponse, error) {
out := new(DdlTaskResponse)
err := c.cc.Invoke(ctx, "/greptime.v1.meta.ProcedureService/ddl", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *procedureServiceClient) Migrate(ctx context.Context, in *MigrateRegionRequest, opts ...grpc.CallOption) (*MigrateRegionResponse, error) {
out := new(MigrateRegionResponse)
err := c.cc.Invoke(ctx, "/greptime.v1.meta.ProcedureService/migrate", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// ProcedureServiceServer is the server API for ProcedureService service.
// All implementations must embed UnimplementedProcedureServiceServer
// for forward compatibility
type ProcedureServiceServer interface {
// Query a submitted procedure state
Query(context.Context, *QueryProcedureRequest) (*ProcedureStateResponse, error)
// Submits a DDL task
Ddl(context.Context, *DdlTaskRequest) (*DdlTaskResponse, error)
// Submits a region migration task
Migrate(context.Context, *MigrateRegionRequest) (*MigrateRegionResponse, error)
mustEmbedUnimplementedProcedureServiceServer()
}
// UnimplementedProcedureServiceServer must be embedded to have forward compatible implementations.
type UnimplementedProcedureServiceServer struct {
}
func (UnimplementedProcedureServiceServer) Query(context.Context, *QueryProcedureRequest) (*ProcedureStateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Query not implemented")
}
func (UnimplementedProcedureServiceServer) Ddl(context.Context, *DdlTaskRequest) (*DdlTaskResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Ddl not implemented")
}
func (UnimplementedProcedureServiceServer) Migrate(context.Context, *MigrateRegionRequest) (*MigrateRegionResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Migrate not implemented")
}
func (UnimplementedProcedureServiceServer) mustEmbedUnimplementedProcedureServiceServer() {}
// UnsafeProcedureServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ProcedureServiceServer will
// result in compilation errors.
type UnsafeProcedureServiceServer interface {
mustEmbedUnimplementedProcedureServiceServer()
}
func RegisterProcedureServiceServer(s grpc.ServiceRegistrar, srv ProcedureServiceServer) {
s.RegisterService(&ProcedureService_ServiceDesc, srv)
}
func _ProcedureService_Query_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryProcedureRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ProcedureServiceServer).Query(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/greptime.v1.meta.ProcedureService/query",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ProcedureServiceServer).Query(ctx, req.(*QueryProcedureRequest))
}
return interceptor(ctx, in, info, handler)
}
func _ProcedureService_Ddl_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DdlTaskRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ProcedureServiceServer).Ddl(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/greptime.v1.meta.ProcedureService/ddl",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ProcedureServiceServer).Ddl(ctx, req.(*DdlTaskRequest))
}
return interceptor(ctx, in, info, handler)
}
func _ProcedureService_Migrate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(MigrateRegionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ProcedureServiceServer).Migrate(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/greptime.v1.meta.ProcedureService/migrate",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ProcedureServiceServer).Migrate(ctx, req.(*MigrateRegionRequest))
}
return interceptor(ctx, in, info, handler)
}
// ProcedureService_ServiceDesc is the grpc.ServiceDesc for ProcedureService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ProcedureService_ServiceDesc = grpc.ServiceDesc{
ServiceName: "greptime.v1.meta.ProcedureService",
HandlerType: (*ProcedureServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "query",
Handler: _ProcedureService_Query_Handler,
},
{
MethodName: "ddl",
Handler: _ProcedureService_Ddl_Handler,
},
{
MethodName: "migrate",
Handler: _ProcedureService_Migrate_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "greptime/v1/meta/procedure.proto",
}
go/greptime/v1/meta/region.pb.go
+288
View File
@@ -0,0 +1,288 @@
// Copyright 2023 Greptime Team
//
// Licensed 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 v3.21.6
// source: greptime/v1/meta/region.proto
package meta
import (
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 MigrateRegionRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
RegionId uint64 `protobuf:"varint,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
FromPeer uint64 `protobuf:"varint,4,opt,name=from_peer,json=fromPeer,proto3" json:"from_peer,omitempty"`
ToPeer uint64 `protobuf:"varint,5,opt,name=to_peer,json=toPeer,proto3" json:"to_peer,omitempty"`
ReplayTimeoutSecs uint32 `protobuf:"varint,6,opt,name=replay_timeout_secs,json=replayTimeoutSecs,proto3" json:"replay_timeout_secs,omitempty"`
}
func (x *MigrateRegionRequest) Reset() {
*x = MigrateRegionRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_meta_region_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *MigrateRegionRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*MigrateRegionRequest) ProtoMessage() {}
func (x *MigrateRegionRequest) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_meta_region_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 MigrateRegionRequest.ProtoReflect.Descriptor instead.
func (*MigrateRegionRequest) Descriptor() ([]byte, []int) {
return file_greptime_v1_meta_region_proto_rawDescGZIP(), []int{0}
}
func (x *MigrateRegionRequest) GetHeader() *RequestHeader {
if x != nil {
return x.Header
}
return nil
}
func (x *MigrateRegionRequest) GetRegionId() uint64 {
if x != nil {
return x.RegionId
}
return 0
}
func (x *MigrateRegionRequest) GetFromPeer() uint64 {
if x != nil {
return x.FromPeer
}
return 0
}
func (x *MigrateRegionRequest) GetToPeer() uint64 {
if x != nil {
return x.ToPeer
}
return 0
}
func (x *MigrateRegionRequest) GetReplayTimeoutSecs() uint32 {
if x != nil {
return x.ReplayTimeoutSecs
}
return 0
}
type MigrateRegionResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
Pid *ProcedureId `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
}
func (x *MigrateRegionResponse) Reset() {
*x = MigrateRegionResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_greptime_v1_meta_region_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *MigrateRegionResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*MigrateRegionResponse) ProtoMessage() {}
func (x *MigrateRegionResponse) ProtoReflect() protoreflect.Message {
mi := &file_greptime_v1_meta_region_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 MigrateRegionResponse.ProtoReflect.Descriptor instead.
func (*MigrateRegionResponse) Descriptor() ([]byte, []int) {
return file_greptime_v1_meta_region_proto_rawDescGZIP(), []int{1}
}
func (x *MigrateRegionResponse) GetHeader() *ResponseHeader {
if x != nil {
return x.Header
}
return nil
}
func (x *MigrateRegionResponse) GetPid() *ProcedureId {
if x != nil {
return x.Pid
}
return nil
}
var File_greptime_v1_meta_region_proto protoreflect.FileDescriptor
var file_greptime_v1_meta_region_proto_rawDesc = []byte{
0x0a, 0x1d, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65,
0x74, 0x61, 0x2f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12,
0x10, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74,
0x61, 0x1a, 0x1d, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d,
0x65, 0x74, 0x61, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x22, 0xd2, 0x01, 0x0a, 0x14, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x65, 0x52, 0x65, 0x67, 0x69,
0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x06, 0x68, 0x65, 0x61,
0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70,
0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x71,
0x75, 0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64,
0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18,
0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12,
0x1b, 0x0a, 0x09, 0x66, 0x72, 0x6f, 0x6d, 0x5f, 0x70, 0x65, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01,
0x28, 0x04, 0x52, 0x08, 0x66, 0x72, 0x6f, 0x6d, 0x50, 0x65, 0x65, 0x72, 0x12, 0x17, 0x0a, 0x07,
0x74, 0x6f, 0x5f, 0x70, 0x65, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x06, 0x74,
0x6f, 0x50, 0x65, 0x65, 0x72, 0x12, 0x2e, 0x0a, 0x13, 0x72, 0x65, 0x70, 0x6c, 0x61, 0x79, 0x5f,
0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x5f, 0x73, 0x65, 0x63, 0x73, 0x18, 0x06, 0x20, 0x01,
0x28, 0x0d, 0x52, 0x11, 0x72, 0x65, 0x70, 0x6c, 0x61, 0x79, 0x54, 0x69, 0x6d, 0x65, 0x6f, 0x75,
0x74, 0x53, 0x65, 0x63, 0x73, 0x22, 0x82, 0x01, 0x0a, 0x15, 0x4d, 0x69, 0x67, 0x72, 0x61, 0x74,
0x65, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
0x38, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65,
0x74, 0x61, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65,
0x72, 0x52, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x2f, 0x0a, 0x03, 0x70, 0x69, 0x64,
0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64,
0x75, 0x72, 0x65, 0x49, 0x64, 0x52, 0x03, 0x70, 0x69, 0x64, 0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69,
0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70,
0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65,
0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
file_greptime_v1_meta_region_proto_rawDescOnce sync.Once
file_greptime_v1_meta_region_proto_rawDescData = file_greptime_v1_meta_region_proto_rawDesc
)
func file_greptime_v1_meta_region_proto_rawDescGZIP() []byte {
file_greptime_v1_meta_region_proto_rawDescOnce.Do(func() {
file_greptime_v1_meta_region_proto_rawDescData = protoimpl.X.CompressGZIP(file_greptime_v1_meta_region_proto_rawDescData)
})
return file_greptime_v1_meta_region_proto_rawDescData
}
var file_greptime_v1_meta_region_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
var file_greptime_v1_meta_region_proto_goTypes = []interface{}{
(*MigrateRegionRequest)(nil), // 0: greptime.v1.meta.MigrateRegionRequest
(*MigrateRegionResponse)(nil), // 1: greptime.v1.meta.MigrateRegionResponse
(*RequestHeader)(nil), // 2: greptime.v1.meta.RequestHeader
(*ResponseHeader)(nil), // 3: greptime.v1.meta.ResponseHeader
(*ProcedureId)(nil), // 4: greptime.v1.meta.ProcedureId
}
var file_greptime_v1_meta_region_proto_depIdxs = []int32{
2, // 0: greptime.v1.meta.MigrateRegionRequest.header:type_name -> greptime.v1.meta.RequestHeader
3, // 1: greptime.v1.meta.MigrateRegionResponse.header:type_name -> greptime.v1.meta.ResponseHeader
4, // 2: greptime.v1.meta.MigrateRegionResponse.pid:type_name -> greptime.v1.meta.ProcedureId
3, // [3:3] is the sub-list for method output_type
3, // [3:3] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
}
func init() { file_greptime_v1_meta_region_proto_init() }
func file_greptime_v1_meta_region_proto_init() {
if File_greptime_v1_meta_region_proto != nil {
return
}
file_greptime_v1_meta_common_proto_init()
if !protoimpl.UnsafeEnabled {
file_greptime_v1_meta_region_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MigrateRegionRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_greptime_v1_meta_region_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MigrateRegionResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_greptime_v1_meta_region_proto_rawDesc,
NumEnums: 0,
NumMessages: 2,
NumExtensions: 0,
NumServices: 0,
},
GoTypes: file_greptime_v1_meta_region_proto_goTypes,
DependencyIndexes: file_greptime_v1_meta_region_proto_depIdxs,
MessageInfos: file_greptime_v1_meta_region_proto_msgTypes,
}.Build()
File_greptime_v1_meta_region_proto = out.File
file_greptime_v1_meta_region_proto_rawDesc = nil
file_greptime_v1_meta_region_proto_goTypes = nil
file_greptime_v1_meta_region_proto_depIdxs = nil
}