// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.12
// 	protoc        (unknown)
// source: premium_dm/v1beta2/premium_dm.proto

package v1beta2

import (
	_ "github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2/options"
	consoleapi "github.com/tidbcloud/dataflow-service-ng/idl/pbgen/proto/consoleapi"
	_ "google.golang.org/genproto/googleapis/api/annotations"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
	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 PremiumDMConnType int32

const (
	PremiumDMConnType_CONN_TYPE_UNSPECIFIED PremiumDMConnType = 0
	PremiumDMConnType_PUBLIC                PremiumDMConnType = 1
	PremiumDMConnType_PRIVATELINK           PremiumDMConnType = 2
)

// Enum value maps for PremiumDMConnType.
var (
	PremiumDMConnType_name = map[int32]string{
		0: "CONN_TYPE_UNSPECIFIED",
		1: "PUBLIC",
		2: "PRIVATELINK",
	}
	PremiumDMConnType_value = map[string]int32{
		"CONN_TYPE_UNSPECIFIED": 0,
		"PUBLIC":                1,
		"PRIVATELINK":           2,
	}
)

func (x PremiumDMConnType) Enum() *PremiumDMConnType {
	p := new(PremiumDMConnType)
	*p = x
	return p
}

func (x PremiumDMConnType) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumDMConnType) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[0].Descriptor()
}

func (PremiumDMConnType) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[0]
}

func (x PremiumDMConnType) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumDMConnType.Descriptor instead.
func (PremiumDMConnType) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{0}
}

type PrecheckItemType int32

const (
	PrecheckItemType_PRECHECK_ITEM_TYPE_UNSPECIFIED PrecheckItemType = 0
	PrecheckItemType_DUMP_PRIVILEGE_CHECKING        PrecheckItemType = 1
	PrecheckItemType_REPLICATION_PRIVILEGE_CHECKING PrecheckItemType = 2
	PrecheckItemType_VERSION_CHECKING               PrecheckItemType = 3
	PrecheckItemType_SERVER_ID_CHECKING             PrecheckItemType = 4
	PrecheckItemType_BINLOG_ENABLE_CHECKING         PrecheckItemType = 5
	PrecheckItemType_BINLOG_FORMAT_CHECKING         PrecheckItemType = 6
	PrecheckItemType_BINLOG_ROW_IMAGE_CHECKING      PrecheckItemType = 7
	PrecheckItemType_TABLE_SCHEMA_CHECKING          PrecheckItemType = 8
	PrecheckItemType_BINLOG_DB_CHECKING             PrecheckItemType = 9
	PrecheckItemType_CONN_NUMBER_CHECKING           PrecheckItemType = 10
	PrecheckItemType_TARGET_DB_PRIVILEGE_CHECKING   PrecheckItemType = 11
	PrecheckItemType_META_POSITION_CHECKING         PrecheckItemType = 12
	PrecheckItemType_LIGHTNING_TABLE_EMPTY_CHECKING PrecheckItemType = 13
	PrecheckItemType_PRIMARY_KEY_CHECKING           PrecheckItemType = 14
)

// Enum value maps for PrecheckItemType.
var (
	PrecheckItemType_name = map[int32]string{
		0:  "PRECHECK_ITEM_TYPE_UNSPECIFIED",
		1:  "DUMP_PRIVILEGE_CHECKING",
		2:  "REPLICATION_PRIVILEGE_CHECKING",
		3:  "VERSION_CHECKING",
		4:  "SERVER_ID_CHECKING",
		5:  "BINLOG_ENABLE_CHECKING",
		6:  "BINLOG_FORMAT_CHECKING",
		7:  "BINLOG_ROW_IMAGE_CHECKING",
		8:  "TABLE_SCHEMA_CHECKING",
		9:  "BINLOG_DB_CHECKING",
		10: "CONN_NUMBER_CHECKING",
		11: "TARGET_DB_PRIVILEGE_CHECKING",
		12: "META_POSITION_CHECKING",
		13: "LIGHTNING_TABLE_EMPTY_CHECKING",
		14: "PRIMARY_KEY_CHECKING",
	}
	PrecheckItemType_value = map[string]int32{
		"PRECHECK_ITEM_TYPE_UNSPECIFIED": 0,
		"DUMP_PRIVILEGE_CHECKING":        1,
		"REPLICATION_PRIVILEGE_CHECKING": 2,
		"VERSION_CHECKING":               3,
		"SERVER_ID_CHECKING":             4,
		"BINLOG_ENABLE_CHECKING":         5,
		"BINLOG_FORMAT_CHECKING":         6,
		"BINLOG_ROW_IMAGE_CHECKING":      7,
		"TABLE_SCHEMA_CHECKING":          8,
		"BINLOG_DB_CHECKING":             9,
		"CONN_NUMBER_CHECKING":           10,
		"TARGET_DB_PRIVILEGE_CHECKING":   11,
		"META_POSITION_CHECKING":         12,
		"LIGHTNING_TABLE_EMPTY_CHECKING": 13,
		"PRIMARY_KEY_CHECKING":           14,
	}
)

func (x PrecheckItemType) Enum() *PrecheckItemType {
	p := new(PrecheckItemType)
	*p = x
	return p
}

func (x PrecheckItemType) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PrecheckItemType) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[1].Descriptor()
}

func (PrecheckItemType) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[1]
}

func (x PrecheckItemType) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PrecheckItemType.Descriptor instead.
func (PrecheckItemType) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{1}
}

type PremiumDMTaskMode int32

const (
	PremiumDMTaskMode_MODE_UNSPECIFIED PremiumDMTaskMode = 0
	PremiumDMTaskMode_ALL              PremiumDMTaskMode = 1
	PremiumDMTaskMode_INCREMENTAL      PremiumDMTaskMode = 2
)

// Enum value maps for PremiumDMTaskMode.
var (
	PremiumDMTaskMode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "ALL",
		2: "INCREMENTAL",
	}
	PremiumDMTaskMode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"ALL":              1,
		"INCREMENTAL":      2,
	}
)

func (x PremiumDMTaskMode) Enum() *PremiumDMTaskMode {
	p := new(PremiumDMTaskMode)
	*p = x
	return p
}

func (x PremiumDMTaskMode) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumDMTaskMode) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[2].Descriptor()
}

func (PremiumDMTaskMode) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[2]
}

func (x PremiumDMTaskMode) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumDMTaskMode.Descriptor instead.
func (PremiumDMTaskMode) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{2}
}

type PremiumDMSourceType int32

const (
	PremiumDMSourceType_SOURCE_TYPE_UNSPECIFIED PremiumDMSourceType = 0
	PremiumDMSourceType_MYSQL                   PremiumDMSourceType = 1
	PremiumDMSourceType_AZURE_FLEXIBLE_MYSQL    PremiumDMSourceType = 2
	PremiumDMSourceType_ALICLOUD_RDS_MYSQL      PremiumDMSourceType = 3
)

// Enum value maps for PremiumDMSourceType.
var (
	PremiumDMSourceType_name = map[int32]string{
		0: "SOURCE_TYPE_UNSPECIFIED",
		1: "MYSQL",
		2: "AZURE_FLEXIBLE_MYSQL",
		3: "ALICLOUD_RDS_MYSQL",
	}
	PremiumDMSourceType_value = map[string]int32{
		"SOURCE_TYPE_UNSPECIFIED": 0,
		"MYSQL":                   1,
		"AZURE_FLEXIBLE_MYSQL":    2,
		"ALICLOUD_RDS_MYSQL":      3,
	}
)

func (x PremiumDMSourceType) Enum() *PremiumDMSourceType {
	p := new(PremiumDMSourceType)
	*p = x
	return p
}

func (x PremiumDMSourceType) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumDMSourceType) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[3].Descriptor()
}

func (PremiumDMSourceType) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[3]
}

func (x PremiumDMSourceType) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumDMSourceType.Descriptor instead.
func (PremiumDMSourceType) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{3}
}

type PremiumMigrationPrecheck_Status int32

const (
	PremiumMigrationPrecheck_STATUS_UNSPECIFIED PremiumMigrationPrecheck_Status = 0
	PremiumMigrationPrecheck_RUNNING            PremiumMigrationPrecheck_Status = 1
	PremiumMigrationPrecheck_FINISHED           PremiumMigrationPrecheck_Status = 2
	PremiumMigrationPrecheck_PENDING            PremiumMigrationPrecheck_Status = 3
	PremiumMigrationPrecheck_FAILED             PremiumMigrationPrecheck_Status = 4
	PremiumMigrationPrecheck_CANCELED           PremiumMigrationPrecheck_Status = 5
)

// Enum value maps for PremiumMigrationPrecheck_Status.
var (
	PremiumMigrationPrecheck_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "RUNNING",
		2: "FINISHED",
		3: "PENDING",
		4: "FAILED",
		5: "CANCELED",
	}
	PremiumMigrationPrecheck_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"RUNNING":            1,
		"FINISHED":           2,
		"PENDING":            3,
		"FAILED":             4,
		"CANCELED":           5,
	}
)

func (x PremiumMigrationPrecheck_Status) Enum() *PremiumMigrationPrecheck_Status {
	p := new(PremiumMigrationPrecheck_Status)
	*p = x
	return p
}

func (x PremiumMigrationPrecheck_Status) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumMigrationPrecheck_Status) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[4].Descriptor()
}

func (PremiumMigrationPrecheck_Status) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[4]
}

func (x PremiumMigrationPrecheck_Status) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumMigrationPrecheck_Status.Descriptor instead.
func (PremiumMigrationPrecheck_Status) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{2, 0}
}

type PremiumDMPrecheckItem_Status int32

const (
	PremiumDMPrecheckItem_STATUS_UNSPECIFIED PremiumDMPrecheckItem_Status = 0
	PremiumDMPrecheckItem_SUCCESS            PremiumDMPrecheckItem_Status = 1
	PremiumDMPrecheckItem_WARNING            PremiumDMPrecheckItem_Status = 2
	PremiumDMPrecheckItem_FAILED             PremiumDMPrecheckItem_Status = 3
)

// Enum value maps for PremiumDMPrecheckItem_Status.
var (
	PremiumDMPrecheckItem_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "SUCCESS",
		2: "WARNING",
		3: "FAILED",
	}
	PremiumDMPrecheckItem_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"SUCCESS":            1,
		"WARNING":            2,
		"FAILED":             3,
	}
)

func (x PremiumDMPrecheckItem_Status) Enum() *PremiumDMPrecheckItem_Status {
	p := new(PremiumDMPrecheckItem_Status)
	*p = x
	return p
}

func (x PremiumDMPrecheckItem_Status) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumDMPrecheckItem_Status) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[5].Descriptor()
}

func (PremiumDMPrecheckItem_Status) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[5]
}

func (x PremiumDMPrecheckItem_Status) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumDMPrecheckItem_Status.Descriptor instead.
func (PremiumDMPrecheckItem_Status) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{7, 0}
}

type PremiumMigration_State int32

const (
	PremiumMigration_STATE_UNSPECIFIED PremiumMigration_State = 0
	PremiumMigration_CREATING          PremiumMigration_State = 1
	PremiumMigration_RUNNING           PremiumMigration_State = 2
	PremiumMigration_PAUSED            PremiumMigration_State = 3
	PremiumMigration_PAUSING           PremiumMigration_State = 4
	PremiumMigration_FAILED            PremiumMigration_State = 5
	PremiumMigration_DELETING          PremiumMigration_State = 6
	PremiumMigration_RESUMING          PremiumMigration_State = 7
)

// Enum value maps for PremiumMigration_State.
var (
	PremiumMigration_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "RUNNING",
		3: "PAUSED",
		4: "PAUSING",
		5: "FAILED",
		6: "DELETING",
		7: "RESUMING",
	}
	PremiumMigration_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"RUNNING":           2,
		"PAUSED":            3,
		"PAUSING":           4,
		"FAILED":            5,
		"DELETING":          6,
		"RESUMING":          7,
	}
)

func (x PremiumMigration_State) Enum() *PremiumMigration_State {
	p := new(PremiumMigration_State)
	*p = x
	return p
}

func (x PremiumMigration_State) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumMigration_State) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[6].Descriptor()
}

func (PremiumMigration_State) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[6]
}

func (x PremiumMigration_State) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumMigration_State.Descriptor instead.
func (PremiumMigration_State) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{11, 0}
}

type PremiumDMSubTask_Step int32

const (
	PremiumDMSubTask_STEP_UNSPECIFIED PremiumDMSubTask_Step = 0
	PremiumDMSubTask_DUMP             PremiumDMSubTask_Step = 1
	PremiumDMSubTask_LOAD             PremiumDMSubTask_Step = 2
	PremiumDMSubTask_SYNC             PremiumDMSubTask_Step = 3
)

// Enum value maps for PremiumDMSubTask_Step.
var (
	PremiumDMSubTask_Step_name = map[int32]string{
		0: "STEP_UNSPECIFIED",
		1: "DUMP",
		2: "LOAD",
		3: "SYNC",
	}
	PremiumDMSubTask_Step_value = map[string]int32{
		"STEP_UNSPECIFIED": 0,
		"DUMP":             1,
		"LOAD":             2,
		"SYNC":             3,
	}
)

func (x PremiumDMSubTask_Step) Enum() *PremiumDMSubTask_Step {
	p := new(PremiumDMSubTask_Step)
	*p = x
	return p
}

func (x PremiumDMSubTask_Step) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumDMSubTask_Step) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[7].Descriptor()
}

func (PremiumDMSubTask_Step) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[7]
}

func (x PremiumDMSubTask_Step) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumDMSubTask_Step.Descriptor instead.
func (PremiumDMSubTask_Step) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{12, 0}
}

type PremiumDMSubTask_Stage int32

const (
	PremiumDMSubTask_STAGE_UNSPECIFIED PremiumDMSubTask_Stage = 0
	PremiumDMSubTask_RUNNING           PremiumDMSubTask_Stage = 1
	PremiumDMSubTask_PAUSED            PremiumDMSubTask_Stage = 2
	PremiumDMSubTask_FAILED            PremiumDMSubTask_Stage = 3
	PremiumDMSubTask_FINISHED          PremiumDMSubTask_Stage = 4
	PremiumDMSubTask_UNKNOWN           PremiumDMSubTask_Stage = 5
)

// Enum value maps for PremiumDMSubTask_Stage.
var (
	PremiumDMSubTask_Stage_name = map[int32]string{
		0: "STAGE_UNSPECIFIED",
		1: "RUNNING",
		2: "PAUSED",
		3: "FAILED",
		4: "FINISHED",
		5: "UNKNOWN",
	}
	PremiumDMSubTask_Stage_value = map[string]int32{
		"STAGE_UNSPECIFIED": 0,
		"RUNNING":           1,
		"PAUSED":            2,
		"FAILED":            3,
		"FINISHED":          4,
		"UNKNOWN":           5,
	}
)

func (x PremiumDMSubTask_Stage) Enum() *PremiumDMSubTask_Stage {
	p := new(PremiumDMSubTask_Stage)
	*p = x
	return p
}

func (x PremiumDMSubTask_Stage) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumDMSubTask_Stage) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[8].Descriptor()
}

func (PremiumDMSubTask_Stage) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[8]
}

func (x PremiumDMSubTask_Stage) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumDMSubTask_Stage.Descriptor instead.
func (PremiumDMSubTask_Stage) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{12, 1}
}

type PremiumDMTaskImportMode_ENUM int32

const (
	PremiumDMTaskImportMode_IMPORTMODE_UNSPECIFIED PremiumDMTaskImportMode_ENUM = 0
	PremiumDMTaskImportMode_IMPORTMODE_PHYSICAL    PremiumDMTaskImportMode_ENUM = 1
	PremiumDMTaskImportMode_IMPORTMODE_LOGICAL     PremiumDMTaskImportMode_ENUM = 2
)

// Enum value maps for PremiumDMTaskImportMode_ENUM.
var (
	PremiumDMTaskImportMode_ENUM_name = map[int32]string{
		0: "IMPORTMODE_UNSPECIFIED",
		1: "IMPORTMODE_PHYSICAL",
		2: "IMPORTMODE_LOGICAL",
	}
	PremiumDMTaskImportMode_ENUM_value = map[string]int32{
		"IMPORTMODE_UNSPECIFIED": 0,
		"IMPORTMODE_PHYSICAL":    1,
		"IMPORTMODE_LOGICAL":     2,
	}
)

func (x PremiumDMTaskImportMode_ENUM) Enum() *PremiumDMTaskImportMode_ENUM {
	p := new(PremiumDMTaskImportMode_ENUM)
	*p = x
	return p
}

func (x PremiumDMTaskImportMode_ENUM) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (PremiumDMTaskImportMode_ENUM) Descriptor() protoreflect.EnumDescriptor {
	return file_premium_dm_v1beta2_premium_dm_proto_enumTypes[9].Descriptor()
}

func (PremiumDMTaskImportMode_ENUM) Type() protoreflect.EnumType {
	return &file_premium_dm_v1beta2_premium_dm_proto_enumTypes[9]
}

func (x PremiumDMTaskImportMode_ENUM) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use PremiumDMTaskImportMode_ENUM.Descriptor instead.
func (PremiumDMTaskImportMode_ENUM) EnumDescriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{31, 0}
}

type GetPremiumMigrationPrecheckReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	PrecheckId    string                 `protobuf:"bytes,2,opt,name=precheck_id,json=precheckId,proto3" json:"precheck_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetPremiumMigrationPrecheckReq) Reset() {
	*x = GetPremiumMigrationPrecheckReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetPremiumMigrationPrecheckReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetPremiumMigrationPrecheckReq) ProtoMessage() {}

func (x *GetPremiumMigrationPrecheckReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 GetPremiumMigrationPrecheckReq.ProtoReflect.Descriptor instead.
func (*GetPremiumMigrationPrecheckReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{0}
}

func (x *GetPremiumMigrationPrecheckReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *GetPremiumMigrationPrecheckReq) GetPrecheckId() string {
	if x != nil {
		return x.PrecheckId
	}
	return ""
}

type CancelPremiumMigrationPrecheckReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	PrecheckId    string                 `protobuf:"bytes,2,opt,name=precheck_id,json=precheckId,proto3" json:"precheck_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CancelPremiumMigrationPrecheckReq) Reset() {
	*x = CancelPremiumMigrationPrecheckReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CancelPremiumMigrationPrecheckReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CancelPremiumMigrationPrecheckReq) ProtoMessage() {}

func (x *CancelPremiumMigrationPrecheckReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 CancelPremiumMigrationPrecheckReq.ProtoReflect.Descriptor instead.
func (*CancelPremiumMigrationPrecheckReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{1}
}

func (x *CancelPremiumMigrationPrecheckReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *CancelPremiumMigrationPrecheckReq) GetPrecheckId() string {
	if x != nil {
		return x.PrecheckId
	}
	return ""
}

type PremiumMigrationPrecheck struct {
	state         protoimpl.MessageState          `protogen:"open.v1"`
	PrecheckId    string                          `protobuf:"bytes,1,opt,name=precheck_id,json=precheckId,proto3" json:"precheck_id,omitempty"`
	Total         int32                           `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	FailedCnt     int32                           `protobuf:"varint,3,opt,name=failed_cnt,json=failedCnt,proto3" json:"failed_cnt,omitempty"`
	WarnCnt       int32                           `protobuf:"varint,4,opt,name=warn_cnt,json=warnCnt,proto3" json:"warn_cnt,omitempty"`
	SuccessCnt    int32                           `protobuf:"varint,5,opt,name=success_cnt,json=successCnt,proto3" json:"success_cnt,omitempty"`
	Status        PremiumMigrationPrecheck_Status `protobuf:"varint,6,opt,name=status,proto3,enum=premium_dm.v1beta2.PremiumMigrationPrecheck_Status" json:"status,omitempty"`
	Items         []*PremiumDMPrecheckItem        `protobuf:"bytes,7,rep,name=items,proto3" json:"items,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationPrecheck) Reset() {
	*x = PremiumMigrationPrecheck{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationPrecheck) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationPrecheck) ProtoMessage() {}

func (x *PremiumMigrationPrecheck) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationPrecheck.ProtoReflect.Descriptor instead.
func (*PremiumMigrationPrecheck) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{2}
}

func (x *PremiumMigrationPrecheck) GetPrecheckId() string {
	if x != nil {
		return x.PrecheckId
	}
	return ""
}

func (x *PremiumMigrationPrecheck) GetTotal() int32 {
	if x != nil {
		return x.Total
	}
	return 0
}

func (x *PremiumMigrationPrecheck) GetFailedCnt() int32 {
	if x != nil {
		return x.FailedCnt
	}
	return 0
}

func (x *PremiumMigrationPrecheck) GetWarnCnt() int32 {
	if x != nil {
		return x.WarnCnt
	}
	return 0
}

func (x *PremiumMigrationPrecheck) GetSuccessCnt() int32 {
	if x != nil {
		return x.SuccessCnt
	}
	return 0
}

func (x *PremiumMigrationPrecheck) GetStatus() PremiumMigrationPrecheck_Status {
	if x != nil {
		return x.Status
	}
	return PremiumMigrationPrecheck_STATUS_UNSPECIFIED
}

func (x *PremiumMigrationPrecheck) GetItems() []*PremiumDMPrecheckItem {
	if x != nil {
		return x.Items
	}
	return nil
}

type CreatePremiumMigrationPrecheckResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	PrecheckId    string                 `protobuf:"bytes,1,opt,name=precheck_id,json=precheckId,proto3" json:"precheck_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CreatePremiumMigrationPrecheckResp) Reset() {
	*x = CreatePremiumMigrationPrecheckResp{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CreatePremiumMigrationPrecheckResp) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CreatePremiumMigrationPrecheckResp) ProtoMessage() {}

func (x *CreatePremiumMigrationPrecheckResp) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 CreatePremiumMigrationPrecheckResp.ProtoReflect.Descriptor instead.
func (*CreatePremiumMigrationPrecheckResp) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{3}
}

func (x *CreatePremiumMigrationPrecheckResp) GetPrecheckId() string {
	if x != nil {
		return x.PrecheckId
	}
	return ""
}

type ListPremiumMigrationPrechecksReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	PageToken     string                 `protobuf:"bytes,100,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	PageSize      int32                  `protobuf:"varint,101,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	OrderBy       string                 `protobuf:"bytes,102,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ListPremiumMigrationPrechecksReq) Reset() {
	*x = ListPremiumMigrationPrechecksReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ListPremiumMigrationPrechecksReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ListPremiumMigrationPrechecksReq) ProtoMessage() {}

func (x *ListPremiumMigrationPrechecksReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 ListPremiumMigrationPrechecksReq.ProtoReflect.Descriptor instead.
func (*ListPremiumMigrationPrechecksReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{4}
}

func (x *ListPremiumMigrationPrechecksReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *ListPremiumMigrationPrechecksReq) GetPageToken() string {
	if x != nil {
		return x.PageToken
	}
	return ""
}

func (x *ListPremiumMigrationPrechecksReq) GetPageSize() int32 {
	if x != nil {
		return x.PageSize
	}
	return 0
}

func (x *ListPremiumMigrationPrechecksReq) GetOrderBy() string {
	if x != nil {
		return x.OrderBy
	}
	return ""
}

// PremiumMigrationPrecheckSummary is a per-record summary used for listing only.
// Fetch the per-item detail via PremiumMigrationGetPrecheck.
type PremiumMigrationPrecheckSummary struct {
	state         protoimpl.MessageState          `protogen:"open.v1"`
	PrecheckId    string                          `protobuf:"bytes,1,opt,name=precheck_id,json=precheckId,proto3" json:"precheck_id,omitempty"`
	CreatedAt     *timestamppb.Timestamp          `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Status        PremiumMigrationPrecheck_Status `protobuf:"varint,3,opt,name=status,proto3,enum=premium_dm.v1beta2.PremiumMigrationPrecheck_Status" json:"status,omitempty"`
	Total         int32                           `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	FailedCnt     int32                           `protobuf:"varint,5,opt,name=failed_cnt,json=failedCnt,proto3" json:"failed_cnt,omitempty"`
	WarnCnt       int32                           `protobuf:"varint,6,opt,name=warn_cnt,json=warnCnt,proto3" json:"warn_cnt,omitempty"`
	SuccessCnt    int32                           `protobuf:"varint,7,opt,name=success_cnt,json=successCnt,proto3" json:"success_cnt,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationPrecheckSummary) Reset() {
	*x = PremiumMigrationPrecheckSummary{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationPrecheckSummary) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationPrecheckSummary) ProtoMessage() {}

func (x *PremiumMigrationPrecheckSummary) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationPrecheckSummary.ProtoReflect.Descriptor instead.
func (*PremiumMigrationPrecheckSummary) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{5}
}

func (x *PremiumMigrationPrecheckSummary) GetPrecheckId() string {
	if x != nil {
		return x.PrecheckId
	}
	return ""
}

func (x *PremiumMigrationPrecheckSummary) GetCreatedAt() *timestamppb.Timestamp {
	if x != nil {
		return x.CreatedAt
	}
	return nil
}

func (x *PremiumMigrationPrecheckSummary) GetStatus() PremiumMigrationPrecheck_Status {
	if x != nil {
		return x.Status
	}
	return PremiumMigrationPrecheck_STATUS_UNSPECIFIED
}

func (x *PremiumMigrationPrecheckSummary) GetTotal() int32 {
	if x != nil {
		return x.Total
	}
	return 0
}

func (x *PremiumMigrationPrecheckSummary) GetFailedCnt() int32 {
	if x != nil {
		return x.FailedCnt
	}
	return 0
}

func (x *PremiumMigrationPrecheckSummary) GetWarnCnt() int32 {
	if x != nil {
		return x.WarnCnt
	}
	return 0
}

func (x *PremiumMigrationPrecheckSummary) GetSuccessCnt() int32 {
	if x != nil {
		return x.SuccessCnt
	}
	return 0
}

type ListPremiumMigrationPrechecksResp struct {
	state         protoimpl.MessageState             `protogen:"open.v1"`
	Prechecks     []*PremiumMigrationPrecheckSummary `protobuf:"bytes,1,rep,name=prechecks,proto3" json:"prechecks,omitempty"`
	TotalSize     uint32                             `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	NextPageToken string                             `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ListPremiumMigrationPrechecksResp) Reset() {
	*x = ListPremiumMigrationPrechecksResp{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ListPremiumMigrationPrechecksResp) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ListPremiumMigrationPrechecksResp) ProtoMessage() {}

func (x *ListPremiumMigrationPrechecksResp) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 ListPremiumMigrationPrechecksResp.ProtoReflect.Descriptor instead.
func (*ListPremiumMigrationPrechecksResp) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{6}
}

func (x *ListPremiumMigrationPrechecksResp) GetPrechecks() []*PremiumMigrationPrecheckSummary {
	if x != nil {
		return x.Prechecks
	}
	return nil
}

func (x *ListPremiumMigrationPrechecksResp) GetTotalSize() uint32 {
	if x != nil {
		return x.TotalSize
	}
	return 0
}

func (x *ListPremiumMigrationPrechecksResp) GetNextPageToken() string {
	if x != nil {
		return x.NextPageToken
	}
	return ""
}

type PremiumDMPrecheckItem struct {
	state          protoimpl.MessageState       `protogen:"open.v1"`
	Description    string                       `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Status         PremiumDMPrecheckItem_Status `protobuf:"varint,2,opt,name=status,proto3,enum=premium_dm.v1beta2.PremiumDMPrecheckItem_Status" json:"status,omitempty"`
	Solution       string                       `protobuf:"bytes,3,opt,name=solution,proto3" json:"solution,omitempty"`
	Reason         string                       `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	SolutionDocUrl string                       `protobuf:"bytes,5,opt,name=solution_doc_url,json=solutionDocUrl,proto3" json:"solution_doc_url,omitempty"`
	Type           PrecheckItemType             `protobuf:"varint,6,opt,name=type,proto3,enum=premium_dm.v1beta2.PrecheckItemType" json:"type,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *PremiumDMPrecheckItem) Reset() {
	*x = PremiumDMPrecheckItem{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumDMPrecheckItem) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumDMPrecheckItem) ProtoMessage() {}

func (x *PremiumDMPrecheckItem) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumDMPrecheckItem.ProtoReflect.Descriptor instead.
func (*PremiumDMPrecheckItem) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{7}
}

func (x *PremiumDMPrecheckItem) GetDescription() string {
	if x != nil {
		return x.Description
	}
	return ""
}

func (x *PremiumDMPrecheckItem) GetStatus() PremiumDMPrecheckItem_Status {
	if x != nil {
		return x.Status
	}
	return PremiumDMPrecheckItem_STATUS_UNSPECIFIED
}

func (x *PremiumDMPrecheckItem) GetSolution() string {
	if x != nil {
		return x.Solution
	}
	return ""
}

func (x *PremiumDMPrecheckItem) GetReason() string {
	if x != nil {
		return x.Reason
	}
	return ""
}

func (x *PremiumDMPrecheckItem) GetSolutionDocUrl() string {
	if x != nil {
		return x.SolutionDocUrl
	}
	return ""
}

func (x *PremiumDMPrecheckItem) GetType() PrecheckItemType {
	if x != nil {
		return x.Type
	}
	return PrecheckItemType_PRECHECK_ITEM_TYPE_UNSPECIFIED
}

type CreatePremiumMigrationReq struct {
	state         protoimpl.MessageState       `protogen:"open.v1"`
	TidbId        string                       `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	DisplayName   string                       `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	Sources       []*PremiumDMSource           `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	Target        *PremiumDMTarget             `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	Mode          PremiumDMTaskMode            `protobuf:"varint,5,opt,name=mode,proto3,enum=premium_dm.v1beta2.PremiumDMTaskMode" json:"mode,omitempty"`
	ImportMode    PremiumDMTaskImportMode_ENUM `protobuf:"varint,6,opt,name=import_mode,json=importMode,proto3,enum=premium_dm.v1beta2.PremiumDMTaskImportMode_ENUM" json:"import_mode,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CreatePremiumMigrationReq) Reset() {
	*x = CreatePremiumMigrationReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CreatePremiumMigrationReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CreatePremiumMigrationReq) ProtoMessage() {}

func (x *CreatePremiumMigrationReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 CreatePremiumMigrationReq.ProtoReflect.Descriptor instead.
func (*CreatePremiumMigrationReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{8}
}

func (x *CreatePremiumMigrationReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *CreatePremiumMigrationReq) GetDisplayName() string {
	if x != nil {
		return x.DisplayName
	}
	return ""
}

func (x *CreatePremiumMigrationReq) GetSources() []*PremiumDMSource {
	if x != nil {
		return x.Sources
	}
	return nil
}

func (x *CreatePremiumMigrationReq) GetTarget() *PremiumDMTarget {
	if x != nil {
		return x.Target
	}
	return nil
}

func (x *CreatePremiumMigrationReq) GetMode() PremiumDMTaskMode {
	if x != nil {
		return x.Mode
	}
	return PremiumDMTaskMode_MODE_UNSPECIFIED
}

func (x *CreatePremiumMigrationReq) GetImportMode() PremiumDMTaskImportMode_ENUM {
	if x != nil {
		return x.ImportMode
	}
	return PremiumDMTaskImportMode_IMPORTMODE_UNSPECIFIED
}

type PremiumDMTarget struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	User          string                 `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Password      string                 `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumDMTarget) Reset() {
	*x = PremiumDMTarget{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumDMTarget) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumDMTarget) ProtoMessage() {}

func (x *PremiumDMTarget) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumDMTarget.ProtoReflect.Descriptor instead.
func (*PremiumDMTarget) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{9}
}

func (x *PremiumDMTarget) GetUser() string {
	if x != nil {
		return x.User
	}
	return ""
}

func (x *PremiumDMTarget) GetPassword() string {
	if x != nil {
		return x.Password
	}
	return ""
}

type PremiumMigrationRule struct {
	state         protoimpl.MessageState       `protogen:"open.v1"`
	SourceTable   *PremiumMigrationRule_Source `protobuf:"bytes,1,opt,name=source_table,json=sourceTable,proto3" json:"source_table,omitempty"`
	TargetTable   *PremiumMigrationRule_Table  `protobuf:"bytes,2,opt,name=target_table,json=targetTable,proto3" json:"target_table,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationRule) Reset() {
	*x = PremiumMigrationRule{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationRule) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationRule) ProtoMessage() {}

func (x *PremiumMigrationRule) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationRule.ProtoReflect.Descriptor instead.
func (*PremiumMigrationRule) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{10}
}

func (x *PremiumMigrationRule) GetSourceTable() *PremiumMigrationRule_Source {
	if x != nil {
		return x.SourceTable
	}
	return nil
}

func (x *PremiumMigrationRule) GetTargetTable() *PremiumMigrationRule_Table {
	if x != nil {
		return x.TargetTable
	}
	return nil
}

type PremiumMigration struct {
	state         protoimpl.MessageState       `protogen:"open.v1"`
	MigrationId   string                       `protobuf:"bytes,1,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"`
	DisplayName   string                       `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	SubTasks      []*PremiumDMSubTask          `protobuf:"bytes,3,rep,name=sub_tasks,json=subTasks,proto3" json:"sub_tasks,omitempty"`
	TargetUser    string                       `protobuf:"bytes,4,opt,name=target_user,json=targetUser,proto3" json:"target_user,omitempty"`
	CreateTime    *timestamppb.Timestamp       `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	Mode          PremiumDMTaskMode            `protobuf:"varint,6,opt,name=mode,proto3,enum=premium_dm.v1beta2.PremiumDMTaskMode" json:"mode,omitempty"`
	State         PremiumMigration_State       `protobuf:"varint,7,opt,name=state,proto3,enum=premium_dm.v1beta2.PremiumMigration_State" json:"state,omitempty"`
	ImportMode    PremiumDMTaskImportMode_ENUM `protobuf:"varint,8,opt,name=import_mode,json=importMode,proto3,enum=premium_dm.v1beta2.PremiumDMTaskImportMode_ENUM" json:"import_mode,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigration) Reset() {
	*x = PremiumMigration{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigration) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigration) ProtoMessage() {}

func (x *PremiumMigration) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigration.ProtoReflect.Descriptor instead.
func (*PremiumMigration) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{11}
}

func (x *PremiumMigration) GetMigrationId() string {
	if x != nil {
		return x.MigrationId
	}
	return ""
}

func (x *PremiumMigration) GetDisplayName() string {
	if x != nil {
		return x.DisplayName
	}
	return ""
}

func (x *PremiumMigration) GetSubTasks() []*PremiumDMSubTask {
	if x != nil {
		return x.SubTasks
	}
	return nil
}

func (x *PremiumMigration) GetTargetUser() string {
	if x != nil {
		return x.TargetUser
	}
	return ""
}

func (x *PremiumMigration) GetCreateTime() *timestamppb.Timestamp {
	if x != nil {
		return x.CreateTime
	}
	return nil
}

func (x *PremiumMigration) GetMode() PremiumDMTaskMode {
	if x != nil {
		return x.Mode
	}
	return PremiumDMTaskMode_MODE_UNSPECIFIED
}

func (x *PremiumMigration) GetState() PremiumMigration_State {
	if x != nil {
		return x.State
	}
	return PremiumMigration_STATE_UNSPECIFIED
}

func (x *PremiumMigration) GetImportMode() PremiumDMTaskImportMode_ENUM {
	if x != nil {
		return x.ImportMode
	}
	return PremiumDMTaskImportMode_IMPORTMODE_UNSPECIFIED
}

type PremiumDMSubTask struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Source        *PremiumDMSource       `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	CurrentStep   PremiumDMSubTask_Step  `protobuf:"varint,2,opt,name=current_step,json=currentStep,proto3,enum=premium_dm.v1beta2.PremiumDMSubTask_Step" json:"current_step,omitempty"`
	Stage         PremiumDMSubTask_Stage `protobuf:"varint,3,opt,name=stage,proto3,enum=premium_dm.v1beta2.PremiumDMSubTask_Stage" json:"stage,omitempty"`
	DumpDetail    *DumpDetail            `protobuf:"bytes,4,opt,name=dump_detail,json=dumpDetail,proto3,oneof" json:"dump_detail,omitempty"`
	LoadDetail    *LoadDetail            `protobuf:"bytes,5,opt,name=load_detail,json=loadDetail,proto3,oneof" json:"load_detail,omitempty"`
	SyncDetail    *SyncDetail            `protobuf:"bytes,6,opt,name=sync_detail,json=syncDetail,proto3,oneof" json:"sync_detail,omitempty"`
	ErrorMsg      *string                `protobuf:"bytes,7,opt,name=error_msg,json=errorMsg,proto3,oneof" json:"error_msg,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumDMSubTask) Reset() {
	*x = PremiumDMSubTask{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumDMSubTask) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumDMSubTask) ProtoMessage() {}

func (x *PremiumDMSubTask) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumDMSubTask.ProtoReflect.Descriptor instead.
func (*PremiumDMSubTask) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{12}
}

func (x *PremiumDMSubTask) GetSource() *PremiumDMSource {
	if x != nil {
		return x.Source
	}
	return nil
}

func (x *PremiumDMSubTask) GetCurrentStep() PremiumDMSubTask_Step {
	if x != nil {
		return x.CurrentStep
	}
	return PremiumDMSubTask_STEP_UNSPECIFIED
}

func (x *PremiumDMSubTask) GetStage() PremiumDMSubTask_Stage {
	if x != nil {
		return x.Stage
	}
	return PremiumDMSubTask_STAGE_UNSPECIFIED
}

func (x *PremiumDMSubTask) GetDumpDetail() *DumpDetail {
	if x != nil {
		return x.DumpDetail
	}
	return nil
}

func (x *PremiumDMSubTask) GetLoadDetail() *LoadDetail {
	if x != nil {
		return x.LoadDetail
	}
	return nil
}

func (x *PremiumDMSubTask) GetSyncDetail() *SyncDetail {
	if x != nil {
		return x.SyncDetail
	}
	return nil
}

func (x *PremiumDMSubTask) GetErrorMsg() string {
	if x != nil && x.ErrorMsg != nil {
		return *x.ErrorMsg
	}
	return ""
}

type PremiumDMSource struct {
	state                 protoimpl.MessageState  `protogen:"open.v1"`
	ConnProfile           *PremiumDMConnProfile   `protobuf:"bytes,1,opt,name=conn_profile,json=connProfile,proto3" json:"conn_profile,omitempty"`
	PremiumMigrationRules []*PremiumMigrationRule `protobuf:"bytes,3,rep,name=premium_migration_rules,json=premiumMigrationRules,proto3" json:"premium_migration_rules,omitempty"`
	BinlogName            *string                 `protobuf:"bytes,4,opt,name=binlog_name,json=binlogName,proto3,oneof" json:"binlog_name,omitempty"`
	BinlogPosition        *int32                  `protobuf:"varint,5,opt,name=binlog_position,json=binlogPosition,proto3,oneof" json:"binlog_position,omitempty"`
	BinlogGtid            *string                 `protobuf:"bytes,6,opt,name=binlog_gtid,json=binlogGtid,proto3,oneof" json:"binlog_gtid,omitempty"`
	SourceType            PremiumDMSourceType     `protobuf:"varint,7,opt,name=source_type,json=sourceType,proto3,enum=premium_dm.v1beta2.PremiumDMSourceType" json:"source_type,omitempty"`
	unknownFields         protoimpl.UnknownFields
	sizeCache             protoimpl.SizeCache
}

func (x *PremiumDMSource) Reset() {
	*x = PremiumDMSource{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumDMSource) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumDMSource) ProtoMessage() {}

func (x *PremiumDMSource) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumDMSource.ProtoReflect.Descriptor instead.
func (*PremiumDMSource) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{13}
}

func (x *PremiumDMSource) GetConnProfile() *PremiumDMConnProfile {
	if x != nil {
		return x.ConnProfile
	}
	return nil
}

func (x *PremiumDMSource) GetPremiumMigrationRules() []*PremiumMigrationRule {
	if x != nil {
		return x.PremiumMigrationRules
	}
	return nil
}

func (x *PremiumDMSource) GetBinlogName() string {
	if x != nil && x.BinlogName != nil {
		return *x.BinlogName
	}
	return ""
}

func (x *PremiumDMSource) GetBinlogPosition() int32 {
	if x != nil && x.BinlogPosition != nil {
		return *x.BinlogPosition
	}
	return 0
}

func (x *PremiumDMSource) GetBinlogGtid() string {
	if x != nil && x.BinlogGtid != nil {
		return *x.BinlogGtid
	}
	return ""
}

func (x *PremiumDMSource) GetSourceType() PremiumDMSourceType {
	if x != nil {
		return x.SourceType
	}
	return PremiumDMSourceType_SOURCE_TYPE_UNSPECIFIED
}

type DumpDetail struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	Bps             int64                  `protobuf:"varint,1,opt,name=bps,proto3" json:"bps,omitempty"`
	Progress        float64                `protobuf:"fixed64,2,opt,name=progress,proto3" json:"progress,omitempty"`
	TotalTables     int64                  `protobuf:"varint,3,opt,name=total_tables,json=totalTables,proto3" json:"total_tables,omitempty"`
	CompletedTables int64                  `protobuf:"varint,4,opt,name=completed_tables,json=completedTables,proto3" json:"completed_tables,omitempty"`
	FinishedBytes   int64                  `protobuf:"varint,5,opt,name=finished_bytes,json=finishedBytes,proto3" json:"finished_bytes,omitempty"`
	FinishedRows    int64                  `protobuf:"varint,6,opt,name=finished_rows,json=finishedRows,proto3" json:"finished_rows,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *DumpDetail) Reset() {
	*x = DumpDetail{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *DumpDetail) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*DumpDetail) ProtoMessage() {}

func (x *DumpDetail) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 DumpDetail.ProtoReflect.Descriptor instead.
func (*DumpDetail) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{14}
}

func (x *DumpDetail) GetBps() int64 {
	if x != nil {
		return x.Bps
	}
	return 0
}

func (x *DumpDetail) GetProgress() float64 {
	if x != nil {
		return x.Progress
	}
	return 0
}

func (x *DumpDetail) GetTotalTables() int64 {
	if x != nil {
		return x.TotalTables
	}
	return 0
}

func (x *DumpDetail) GetCompletedTables() int64 {
	if x != nil {
		return x.CompletedTables
	}
	return 0
}

func (x *DumpDetail) GetFinishedBytes() int64 {
	if x != nil {
		return x.FinishedBytes
	}
	return 0
}

func (x *DumpDetail) GetFinishedRows() int64 {
	if x != nil {
		return x.FinishedRows
	}
	return 0
}

type LoadDetail struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Bps           int64                  `protobuf:"varint,1,opt,name=bps,proto3" json:"bps,omitempty"`
	Progress      float64                `protobuf:"fixed64,2,opt,name=progress,proto3" json:"progress,omitempty"`
	FinishedBytes int64                  `protobuf:"varint,3,opt,name=finished_bytes,json=finishedBytes,proto3" json:"finished_bytes,omitempty"`
	TotalBytes    int64                  `protobuf:"varint,4,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *LoadDetail) Reset() {
	*x = LoadDetail{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *LoadDetail) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*LoadDetail) ProtoMessage() {}

func (x *LoadDetail) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 LoadDetail.ProtoReflect.Descriptor instead.
func (*LoadDetail) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{15}
}

func (x *LoadDetail) GetBps() int64 {
	if x != nil {
		return x.Bps
	}
	return 0
}

func (x *LoadDetail) GetProgress() float64 {
	if x != nil {
		return x.Progress
	}
	return 0
}

func (x *LoadDetail) GetFinishedBytes() int64 {
	if x != nil {
		return x.FinishedBytes
	}
	return 0
}

func (x *LoadDetail) GetTotalBytes() int64 {
	if x != nil {
		return x.TotalBytes
	}
	return 0
}

type SyncDetail struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Rps           int64                  `protobuf:"varint,1,opt,name=rps,proto3" json:"rps,omitempty"`
	Latency       int64                  `protobuf:"varint,2,opt,name=latency,proto3" json:"latency,omitempty"`
	Checkpoint    string                 `protobuf:"bytes,3,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SyncDetail) Reset() {
	*x = SyncDetail{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SyncDetail) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SyncDetail) ProtoMessage() {}

func (x *SyncDetail) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 SyncDetail.ProtoReflect.Descriptor instead.
func (*SyncDetail) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{16}
}

func (x *SyncDetail) GetRps() int64 {
	if x != nil {
		return x.Rps
	}
	return 0
}

func (x *SyncDetail) GetLatency() int64 {
	if x != nil {
		return x.Latency
	}
	return 0
}

func (x *SyncDetail) GetCheckpoint() string {
	if x != nil {
		return x.Checkpoint
	}
	return ""
}

type PremiumDMConnProfile struct {
	state    protoimpl.MessageState `protogen:"open.v1"`
	ConnType PremiumDMConnType      `protobuf:"varint,1,opt,name=conn_type,json=connType,proto3,enum=premium_dm.v1beta2.PremiumDMConnType" json:"conn_type,omitempty"`
	// Types that are valid to be assigned to Endpoint:
	//
	//	*PremiumDMConnProfile_SinkEndpointId
	//	*PremiumDMConnProfile_Host
	Endpoint        isPremiumDMConnProfile_Endpoint `protobuf_oneof:"endpoint"`
	Port            int32                           `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	User            string                          `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Password        string                          `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	Security        *Security                       `protobuf:"bytes,7,opt,name=security,proto3" json:"security,omitempty"`
	PrivatelinkInfo *consoleapi.PrivatelinkInfo     `protobuf:"bytes,8,opt,name=privatelink_info,json=privatelinkInfo,proto3,oneof" json:"privatelink_info,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *PremiumDMConnProfile) Reset() {
	*x = PremiumDMConnProfile{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumDMConnProfile) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumDMConnProfile) ProtoMessage() {}

func (x *PremiumDMConnProfile) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumDMConnProfile.ProtoReflect.Descriptor instead.
func (*PremiumDMConnProfile) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{17}
}

func (x *PremiumDMConnProfile) GetConnType() PremiumDMConnType {
	if x != nil {
		return x.ConnType
	}
	return PremiumDMConnType_CONN_TYPE_UNSPECIFIED
}

func (x *PremiumDMConnProfile) GetEndpoint() isPremiumDMConnProfile_Endpoint {
	if x != nil {
		return x.Endpoint
	}
	return nil
}

func (x *PremiumDMConnProfile) GetSinkEndpointId() uint64 {
	if x != nil {
		if x, ok := x.Endpoint.(*PremiumDMConnProfile_SinkEndpointId); ok {
			return x.SinkEndpointId
		}
	}
	return 0
}

func (x *PremiumDMConnProfile) GetHost() string {
	if x != nil {
		if x, ok := x.Endpoint.(*PremiumDMConnProfile_Host); ok {
			return x.Host
		}
	}
	return ""
}

func (x *PremiumDMConnProfile) GetPort() int32 {
	if x != nil {
		return x.Port
	}
	return 0
}

func (x *PremiumDMConnProfile) GetUser() string {
	if x != nil {
		return x.User
	}
	return ""
}

func (x *PremiumDMConnProfile) GetPassword() string {
	if x != nil {
		return x.Password
	}
	return ""
}

func (x *PremiumDMConnProfile) GetSecurity() *Security {
	if x != nil {
		return x.Security
	}
	return nil
}

func (x *PremiumDMConnProfile) GetPrivatelinkInfo() *consoleapi.PrivatelinkInfo {
	if x != nil {
		return x.PrivatelinkInfo
	}
	return nil
}

type isPremiumDMConnProfile_Endpoint interface {
	isPremiumDMConnProfile_Endpoint()
}

type PremiumDMConnProfile_SinkEndpointId struct {
	// It's the id of SinkEndpoint created by consoleapi/dataflow.proto:SinkEndpointService.
	SinkEndpointId uint64 `protobuf:"varint,2,opt,name=sink_endpoint_id,json=sinkEndpointId,proto3,oneof"`
}

type PremiumDMConnProfile_Host struct {
	Host string `protobuf:"bytes,3,opt,name=host,proto3,oneof"`
}

func (*PremiumDMConnProfile_SinkEndpointId) isPremiumDMConnProfile_Endpoint() {}

func (*PremiumDMConnProfile_Host) isPremiumDMConnProfile_Endpoint() {}

type Security struct {
	state          protoimpl.MessageState `protogen:"open.v1"`
	CertAllowedCn  []string               `protobuf:"bytes,1,rep,name=cert_allowed_cn,json=certAllowedCn,proto3" json:"cert_allowed_cn,omitempty"`
	SslCaContent   []byte                 `protobuf:"bytes,2,opt,name=ssl_ca_content,json=sslCaContent,proto3" json:"ssl_ca_content,omitempty"`
	SslCertContent []byte                 `protobuf:"bytes,3,opt,name=ssl_cert_content,json=sslCertContent,proto3" json:"ssl_cert_content,omitempty"`
	SslKeyContent  []byte                 `protobuf:"bytes,4,opt,name=ssl_key_content,json=sslKeyContent,proto3" json:"ssl_key_content,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *Security) Reset() {
	*x = Security{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Security) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Security) ProtoMessage() {}

func (x *Security) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 Security.ProtoReflect.Descriptor instead.
func (*Security) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{18}
}

func (x *Security) GetCertAllowedCn() []string {
	if x != nil {
		return x.CertAllowedCn
	}
	return nil
}

func (x *Security) GetSslCaContent() []byte {
	if x != nil {
		return x.SslCaContent
	}
	return nil
}

func (x *Security) GetSslCertContent() []byte {
	if x != nil {
		return x.SslCertContent
	}
	return nil
}

func (x *Security) GetSslKeyContent() []byte {
	if x != nil {
		return x.SslKeyContent
	}
	return nil
}

type GetPremiumMigrationReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	MigrationId   string                 `protobuf:"bytes,2,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetPremiumMigrationReq) Reset() {
	*x = GetPremiumMigrationReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetPremiumMigrationReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetPremiumMigrationReq) ProtoMessage() {}

func (x *GetPremiumMigrationReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 GetPremiumMigrationReq.ProtoReflect.Descriptor instead.
func (*GetPremiumMigrationReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{19}
}

func (x *GetPremiumMigrationReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *GetPremiumMigrationReq) GetMigrationId() string {
	if x != nil {
		return x.MigrationId
	}
	return ""
}

type ListPremiumMigrationsReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	PageToken     string                 `protobuf:"bytes,100,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	PageSize      int32                  `protobuf:"varint,101,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	OrderBy       string                 `protobuf:"bytes,102,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ListPremiumMigrationsReq) Reset() {
	*x = ListPremiumMigrationsReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[20]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ListPremiumMigrationsReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ListPremiumMigrationsReq) ProtoMessage() {}

func (x *ListPremiumMigrationsReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 ListPremiumMigrationsReq.ProtoReflect.Descriptor instead.
func (*ListPremiumMigrationsReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{20}
}

func (x *ListPremiumMigrationsReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *ListPremiumMigrationsReq) GetPageToken() string {
	if x != nil {
		return x.PageToken
	}
	return ""
}

func (x *ListPremiumMigrationsReq) GetPageSize() int32 {
	if x != nil {
		return x.PageSize
	}
	return 0
}

func (x *ListPremiumMigrationsReq) GetOrderBy() string {
	if x != nil {
		return x.OrderBy
	}
	return ""
}

type ListPremiumMigrationsResp struct {
	state             protoimpl.MessageState `protogen:"open.v1"`
	PremiumMigrations []*PremiumMigration    `protobuf:"bytes,1,rep,name=PremiumMigrations,proto3" json:"PremiumMigrations,omitempty"`
	TotalSize         uint32                 `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	NextPageToken     string                 `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

func (x *ListPremiumMigrationsResp) Reset() {
	*x = ListPremiumMigrationsResp{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[21]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ListPremiumMigrationsResp) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ListPremiumMigrationsResp) ProtoMessage() {}

func (x *ListPremiumMigrationsResp) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 ListPremiumMigrationsResp.ProtoReflect.Descriptor instead.
func (*ListPremiumMigrationsResp) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{21}
}

func (x *ListPremiumMigrationsResp) GetPremiumMigrations() []*PremiumMigration {
	if x != nil {
		return x.PremiumMigrations
	}
	return nil
}

func (x *ListPremiumMigrationsResp) GetTotalSize() uint32 {
	if x != nil {
		return x.TotalSize
	}
	return 0
}

func (x *ListPremiumMigrationsResp) GetNextPageToken() string {
	if x != nil {
		return x.NextPageToken
	}
	return ""
}

type DeletePremiumMigrationReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	MigrationId   string                 `protobuf:"bytes,2,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *DeletePremiumMigrationReq) Reset() {
	*x = DeletePremiumMigrationReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[22]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *DeletePremiumMigrationReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*DeletePremiumMigrationReq) ProtoMessage() {}

func (x *DeletePremiumMigrationReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 DeletePremiumMigrationReq.ProtoReflect.Descriptor instead.
func (*DeletePremiumMigrationReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{22}
}

func (x *DeletePremiumMigrationReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *DeletePremiumMigrationReq) GetMigrationId() string {
	if x != nil {
		return x.MigrationId
	}
	return ""
}

type PausePremiumMigrationReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	MigrationId   string                 `protobuf:"bytes,2,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PausePremiumMigrationReq) Reset() {
	*x = PausePremiumMigrationReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[23]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PausePremiumMigrationReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PausePremiumMigrationReq) ProtoMessage() {}

func (x *PausePremiumMigrationReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PausePremiumMigrationReq.ProtoReflect.Descriptor instead.
func (*PausePremiumMigrationReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{23}
}

func (x *PausePremiumMigrationReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *PausePremiumMigrationReq) GetMigrationId() string {
	if x != nil {
		return x.MigrationId
	}
	return ""
}

type ResumePremiumMigrationReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	MigrationId   string                 `protobuf:"bytes,2,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ResumePremiumMigrationReq) Reset() {
	*x = ResumePremiumMigrationReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[24]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ResumePremiumMigrationReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ResumePremiumMigrationReq) ProtoMessage() {}

func (x *ResumePremiumMigrationReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 ResumePremiumMigrationReq.ProtoReflect.Descriptor instead.
func (*ResumePremiumMigrationReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{24}
}

func (x *ResumePremiumMigrationReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *ResumePremiumMigrationReq) GetMigrationId() string {
	if x != nil {
		return x.MigrationId
	}
	return ""
}

type GetSourceTablesResp struct {
	state         protoimpl.MessageState       `protogen:"open.v1"`
	Tables        []*GetSourceTablesResp_Table `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetSourceTablesResp) Reset() {
	*x = GetSourceTablesResp{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[25]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetSourceTablesResp) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetSourceTablesResp) ProtoMessage() {}

func (x *GetSourceTablesResp) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 GetSourceTablesResp.ProtoReflect.Descriptor instead.
func (*GetSourceTablesResp) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{25}
}

func (x *GetSourceTablesResp) GetTables() []*GetSourceTablesResp_Table {
	if x != nil {
		return x.Tables
	}
	return nil
}

type PremiumMigrationSourceDBConnProfile struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	ConnProfile   *PremiumDMConnProfile  `protobuf:"bytes,2,opt,name=conn_profile,json=connProfile,proto3" json:"conn_profile,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationSourceDBConnProfile) Reset() {
	*x = PremiumMigrationSourceDBConnProfile{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[26]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationSourceDBConnProfile) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationSourceDBConnProfile) ProtoMessage() {}

func (x *PremiumMigrationSourceDBConnProfile) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationSourceDBConnProfile.ProtoReflect.Descriptor instead.
func (*PremiumMigrationSourceDBConnProfile) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{26}
}

func (x *PremiumMigrationSourceDBConnProfile) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *PremiumMigrationSourceDBConnProfile) GetConnProfile() *PremiumDMConnProfile {
	if x != nil {
		return x.ConnProfile
	}
	return nil
}

type PremiumMigrationTargetDBConnProfile struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	User          string                 `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Password      string                 `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationTargetDBConnProfile) Reset() {
	*x = PremiumMigrationTargetDBConnProfile{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[27]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationTargetDBConnProfile) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationTargetDBConnProfile) ProtoMessage() {}

func (x *PremiumMigrationTargetDBConnProfile) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationTargetDBConnProfile.ProtoReflect.Descriptor instead.
func (*PremiumMigrationTargetDBConnProfile) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{27}
}

func (x *PremiumMigrationTargetDBConnProfile) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

func (x *PremiumMigrationTargetDBConnProfile) GetUser() string {
	if x != nil {
		return x.User
	}
	return ""
}

func (x *PremiumMigrationTargetDBConnProfile) GetPassword() string {
	if x != nil {
		return x.Password
	}
	return ""
}

type PremiumMigrationGetSupportedSourcesReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TidbId        string                 `protobuf:"bytes,1,opt,name=tidb_id,json=tidbId,proto3" json:"tidb_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationGetSupportedSourcesReq) Reset() {
	*x = PremiumMigrationGetSupportedSourcesReq{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[28]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationGetSupportedSourcesReq) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationGetSupportedSourcesReq) ProtoMessage() {}

func (x *PremiumMigrationGetSupportedSourcesReq) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationGetSupportedSourcesReq.ProtoReflect.Descriptor instead.
func (*PremiumMigrationGetSupportedSourcesReq) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{28}
}

func (x *PremiumMigrationGetSupportedSourcesReq) GetTidbId() string {
	if x != nil {
		return x.TidbId
	}
	return ""
}

type PremiumMigrationGetSupportedSourcesResp struct {
	state         protoimpl.MessageState    `protogen:"open.v1"`
	Sources       []*PremiumSupportedSource `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationGetSupportedSourcesResp) Reset() {
	*x = PremiumMigrationGetSupportedSourcesResp{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[29]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationGetSupportedSourcesResp) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationGetSupportedSourcesResp) ProtoMessage() {}

func (x *PremiumMigrationGetSupportedSourcesResp) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationGetSupportedSourcesResp.ProtoReflect.Descriptor instead.
func (*PremiumMigrationGetSupportedSourcesResp) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{29}
}

func (x *PremiumMigrationGetSupportedSourcesResp) GetSources() []*PremiumSupportedSource {
	if x != nil {
		return x.Sources
	}
	return nil
}

type PremiumSupportedSource struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	SourceType    PremiumDMSourceType    `protobuf:"varint,1,opt,name=source_type,json=sourceType,proto3,enum=premium_dm.v1beta2.PremiumDMSourceType" json:"source_type,omitempty"`
	ConnMethods   []PremiumDMConnType    `protobuf:"varint,2,rep,packed,name=conn_methods,json=connMethods,proto3,enum=premium_dm.v1beta2.PremiumDMConnType" json:"conn_methods,omitempty"`
	DisplayName   string                 `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumSupportedSource) Reset() {
	*x = PremiumSupportedSource{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[30]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumSupportedSource) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumSupportedSource) ProtoMessage() {}

func (x *PremiumSupportedSource) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumSupportedSource.ProtoReflect.Descriptor instead.
func (*PremiumSupportedSource) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{30}
}

func (x *PremiumSupportedSource) GetSourceType() PremiumDMSourceType {
	if x != nil {
		return x.SourceType
	}
	return PremiumDMSourceType_SOURCE_TYPE_UNSPECIFIED
}

func (x *PremiumSupportedSource) GetConnMethods() []PremiumDMConnType {
	if x != nil {
		return x.ConnMethods
	}
	return nil
}

func (x *PremiumSupportedSource) GetDisplayName() string {
	if x != nil {
		return x.DisplayName
	}
	return ""
}

type PremiumDMTaskImportMode struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumDMTaskImportMode) Reset() {
	*x = PremiumDMTaskImportMode{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[31]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumDMTaskImportMode) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumDMTaskImportMode) ProtoMessage() {}

func (x *PremiumDMTaskImportMode) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumDMTaskImportMode.ProtoReflect.Descriptor instead.
func (*PremiumDMTaskImportMode) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{31}
}

type PremiumMigrationRule_Source struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	SchemaPattern string                 `protobuf:"bytes,1,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
	TablePattern  string                 `protobuf:"bytes,2,opt,name=table_pattern,json=tablePattern,proto3" json:"table_pattern,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationRule_Source) Reset() {
	*x = PremiumMigrationRule_Source{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[32]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationRule_Source) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationRule_Source) ProtoMessage() {}

func (x *PremiumMigrationRule_Source) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationRule_Source.ProtoReflect.Descriptor instead.
func (*PremiumMigrationRule_Source) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{10, 0}
}

func (x *PremiumMigrationRule_Source) GetSchemaPattern() string {
	if x != nil {
		return x.SchemaPattern
	}
	return ""
}

func (x *PremiumMigrationRule_Source) GetTablePattern() string {
	if x != nil {
		return x.TablePattern
	}
	return ""
}

type PremiumMigrationRule_Table struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Schema        string                 `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Table         string                 `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PremiumMigrationRule_Table) Reset() {
	*x = PremiumMigrationRule_Table{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[33]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PremiumMigrationRule_Table) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PremiumMigrationRule_Table) ProtoMessage() {}

func (x *PremiumMigrationRule_Table) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 PremiumMigrationRule_Table.ProtoReflect.Descriptor instead.
func (*PremiumMigrationRule_Table) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{10, 1}
}

func (x *PremiumMigrationRule_Table) GetSchema() string {
	if x != nil {
		return x.Schema
	}
	return ""
}

func (x *PremiumMigrationRule_Table) GetTable() string {
	if x != nil {
		return x.Table
	}
	return ""
}

type GetSourceTablesResp_Table struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Schema        string                 `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Table         string                 `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetSourceTablesResp_Table) Reset() {
	*x = GetSourceTablesResp_Table{}
	mi := &file_premium_dm_v1beta2_premium_dm_proto_msgTypes[34]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetSourceTablesResp_Table) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetSourceTablesResp_Table) ProtoMessage() {}

func (x *GetSourceTablesResp_Table) ProtoReflect() protoreflect.Message {
	mi := &file_premium_dm_v1beta2_premium_dm_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 GetSourceTablesResp_Table.ProtoReflect.Descriptor instead.
func (*GetSourceTablesResp_Table) Descriptor() ([]byte, []int) {
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP(), []int{25, 0}
}

func (x *GetSourceTablesResp_Table) GetSchema() string {
	if x != nil {
		return x.Schema
	}
	return ""
}

func (x *GetSourceTablesResp_Table) GetTable() string {
	if x != nil {
		return x.Table
	}
	return ""
}

var File_premium_dm_v1beta2_premium_dm_proto protoreflect.FileDescriptor

const file_premium_dm_v1beta2_premium_dm_proto_rawDesc = "" +
	"\n" +
	"#premium_dm/v1beta2/premium_dm.proto\x12\x12premium_dm.v1beta2\x1a\x19consoleapi/dataflow.proto\x1a\x1cgoogle/api/annotations.proto\x1a\x1fgoogle/api/field_behavior.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\"d\n" +
	"\x1eGetPremiumMigrationPrecheckReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12$\n" +
	"\vprecheck_id\x18\x02 \x01(\tB\x03\xe0A\x02R\n" +
	"precheckId\"g\n" +
	"!CancelPremiumMigrationPrecheckReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12$\n" +
	"\vprecheck_id\x18\x02 \x01(\tB\x03\xe0A\x02R\n" +
	"precheckId\"\xc1\x03\n" +
	"\x18PremiumMigrationPrecheck\x12$\n" +
	"\vprecheck_id\x18\x01 \x01(\tB\x03\xe0A\x03R\n" +
	"precheckId\x12\x19\n" +
	"\x05total\x18\x02 \x01(\x05B\x03\xe0A\x03R\x05total\x12\"\n" +
	"\n" +
	"failed_cnt\x18\x03 \x01(\x05B\x03\xe0A\x03R\tfailedCnt\x12\x1e\n" +
	"\bwarn_cnt\x18\x04 \x01(\x05B\x03\xe0A\x03R\awarnCnt\x12$\n" +
	"\vsuccess_cnt\x18\x05 \x01(\x05B\x03\xe0A\x03R\n" +
	"successCnt\x12P\n" +
	"\x06status\x18\x06 \x01(\x0e23.premium_dm.v1beta2.PremiumMigrationPrecheck.StatusB\x03\xe0A\x03R\x06status\x12D\n" +
	"\x05items\x18\a \x03(\v2).premium_dm.v1beta2.PremiumDMPrecheckItemB\x03\xe0A\x03R\x05items\"b\n" +
	"\x06Status\x12\x16\n" +
	"\x12STATUS_UNSPECIFIED\x10\x00\x12\v\n" +
	"\aRUNNING\x10\x01\x12\f\n" +
	"\bFINISHED\x10\x02\x12\v\n" +
	"\aPENDING\x10\x03\x12\n" +
	"\n" +
	"\x06FAILED\x10\x04\x12\f\n" +
	"\bCANCELED\x10\x05\"J\n" +
	"\"CreatePremiumMigrationPrecheckResp\x12$\n" +
	"\vprecheck_id\x18\x01 \x01(\tB\x03\xe0A\x03R\n" +
	"precheckId\"\xa6\x01\n" +
	" ListPremiumMigrationPrechecksReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12\"\n" +
	"\n" +
	"page_token\x18d \x01(\tB\x03\xe0A\x01R\tpageToken\x12 \n" +
	"\tpage_size\x18e \x01(\x05B\x03\xe0A\x01R\bpageSize\x12\x1e\n" +
	"\border_by\x18f \x01(\tB\x03\xe0A\x01R\aorderBy\"\xde\x02\n" +
	"\x1fPremiumMigrationPrecheckSummary\x12$\n" +
	"\vprecheck_id\x18\x01 \x01(\tB\x03\xe0A\x03R\n" +
	"precheckId\x12>\n" +
	"\n" +
	"created_at\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampB\x03\xe0A\x03R\tcreatedAt\x12P\n" +
	"\x06status\x18\x03 \x01(\x0e23.premium_dm.v1beta2.PremiumMigrationPrecheck.StatusB\x03\xe0A\x03R\x06status\x12\x19\n" +
	"\x05total\x18\x04 \x01(\x05B\x03\xe0A\x03R\x05total\x12\"\n" +
	"\n" +
	"failed_cnt\x18\x05 \x01(\x05B\x03\xe0A\x03R\tfailedCnt\x12\x1e\n" +
	"\bwarn_cnt\x18\x06 \x01(\x05B\x03\xe0A\x03R\awarnCnt\x12$\n" +
	"\vsuccess_cnt\x18\a \x01(\x05B\x03\xe0A\x03R\n" +
	"successCnt\"\xcc\x01\n" +
	"!ListPremiumMigrationPrechecksResp\x12V\n" +
	"\tprechecks\x18\x01 \x03(\v23.premium_dm.v1beta2.PremiumMigrationPrecheckSummaryB\x03\xe0A\x03R\tprechecks\x12\"\n" +
	"\n" +
	"total_size\x18\x02 \x01(\rB\x03\xe0A\x03R\ttotalSize\x12+\n" +
	"\x0fnext_page_token\x18\x03 \x01(\tB\x03\xe0A\x03R\rnextPageToken\"\x81\x03\n" +
	"\x15PremiumDMPrecheckItem\x12%\n" +
	"\vdescription\x18\x01 \x01(\tB\x03\xe0A\x03R\vdescription\x12M\n" +
	"\x06status\x18\x02 \x01(\x0e20.premium_dm.v1beta2.PremiumDMPrecheckItem.StatusB\x03\xe0A\x03R\x06status\x12\x1f\n" +
	"\bsolution\x18\x03 \x01(\tB\x03\xe0A\x03R\bsolution\x12\x1b\n" +
	"\x06reason\x18\x04 \x01(\tB\x03\xe0A\x03R\x06reason\x12-\n" +
	"\x10solution_doc_url\x18\x05 \x01(\tB\x03\xe0A\x03R\x0esolutionDocUrl\x12=\n" +
	"\x04type\x18\x06 \x01(\x0e2$.premium_dm.v1beta2.PrecheckItemTypeB\x03\xe0A\x03R\x04type\"F\n" +
	"\x06Status\x12\x16\n" +
	"\x12STATUS_UNSPECIFIED\x10\x00\x12\v\n" +
	"\aSUCCESS\x10\x01\x12\v\n" +
	"\aWARNING\x10\x02\x12\n" +
	"\n" +
	"\x06FAILED\x10\x03\"\xff\x02\n" +
	"\x19CreatePremiumMigrationReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12&\n" +
	"\fdisplay_name\x18\x02 \x01(\tB\x03\xe0A\x02R\vdisplayName\x12B\n" +
	"\asources\x18\x03 \x03(\v2#.premium_dm.v1beta2.PremiumDMSourceB\x03\xe0A\x02R\asources\x12@\n" +
	"\x06target\x18\x04 \x01(\v2#.premium_dm.v1beta2.PremiumDMTargetB\x03\xe0A\x02R\x06target\x12>\n" +
	"\x04mode\x18\x05 \x01(\x0e2%.premium_dm.v1beta2.PremiumDMTaskModeB\x03\xe0A\x02R\x04mode\x12V\n" +
	"\vimport_mode\x18\x06 \x01(\x0e20.premium_dm.v1beta2.PremiumDMTaskImportMode.ENUMB\x03\xe0A\x02R\n" +
	"importMode\"N\n" +
	"\x0fPremiumDMTarget\x12\x17\n" +
	"\x04user\x18\x01 \x01(\tB\x03\xe0A\x02R\x04user\x12\"\n" +
	"\bpassword\x18\x02 \x01(\tB\x06\xe0A\x02\xe0A\x04R\bpassword\"\xe8\x02\n" +
	"\x14PremiumMigrationRule\x12W\n" +
	"\fsource_table\x18\x01 \x01(\v2/.premium_dm.v1beta2.PremiumMigrationRule.SourceB\x03\xe0A\x01R\vsourceTable\x12V\n" +
	"\ftarget_table\x18\x02 \x01(\v2..premium_dm.v1beta2.PremiumMigrationRule.TableB\x03\xe0A\x01R\vtargetTable\x1a^\n" +
	"\x06Source\x12*\n" +
	"\x0eschema_pattern\x18\x01 \x01(\tB\x03\xe0A\x02R\rschemaPattern\x12(\n" +
	"\rtable_pattern\x18\x02 \x01(\tB\x03\xe0A\x01R\ftablePattern\x1a?\n" +
	"\x05Table\x12\x1b\n" +
	"\x06schema\x18\x01 \x01(\tB\x03\xe0A\x02R\x06schema\x12\x19\n" +
	"\x05table\x18\x02 \x01(\tB\x03\xe0A\x01R\x05table\"\xed\x04\n" +
	"\x10PremiumMigration\x12&\n" +
	"\fmigration_id\x18\x01 \x01(\tB\x03\xe0A\x03R\vmigrationId\x12&\n" +
	"\fdisplay_name\x18\x02 \x01(\tB\x03\xe0A\x03R\vdisplayName\x12F\n" +
	"\tsub_tasks\x18\x03 \x03(\v2$.premium_dm.v1beta2.PremiumDMSubTaskB\x03\xe0A\x03R\bsubTasks\x12$\n" +
	"\vtarget_user\x18\x04 \x01(\tB\x03\xe0A\x03R\n" +
	"targetUser\x12@\n" +
	"\vcreate_time\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampB\x03\xe0A\x03R\n" +
	"createTime\x12>\n" +
	"\x04mode\x18\x06 \x01(\x0e2%.premium_dm.v1beta2.PremiumDMTaskModeB\x03\xe0A\x03R\x04mode\x12E\n" +
	"\x05state\x18\a \x01(\x0e2*.premium_dm.v1beta2.PremiumMigration.StateB\x03\xe0A\x03R\x05state\x12V\n" +
	"\vimport_mode\x18\b \x01(\x0e20.premium_dm.v1beta2.PremiumDMTaskImportMode.ENUMB\x03\xe0A\x03R\n" +
	"importMode\"z\n" +
	"\x05State\x12\x15\n" +
	"\x11STATE_UNSPECIFIED\x10\x00\x12\f\n" +
	"\bCREATING\x10\x01\x12\v\n" +
	"\aRUNNING\x10\x02\x12\n" +
	"\n" +
	"\x06PAUSED\x10\x03\x12\v\n" +
	"\aPAUSING\x10\x04\x12\n" +
	"\n" +
	"\x06FAILED\x10\x05\x12\f\n" +
	"\bDELETING\x10\x06\x12\f\n" +
	"\bRESUMING\x10\a\"\xd0\x05\n" +
	"\x10PremiumDMSubTask\x12@\n" +
	"\x06source\x18\x01 \x01(\v2#.premium_dm.v1beta2.PremiumDMSourceB\x03\xe0A\x03R\x06source\x12Q\n" +
	"\fcurrent_step\x18\x02 \x01(\x0e2).premium_dm.v1beta2.PremiumDMSubTask.StepB\x03\xe0A\x03R\vcurrentStep\x12E\n" +
	"\x05stage\x18\x03 \x01(\x0e2*.premium_dm.v1beta2.PremiumDMSubTask.StageB\x03\xe0A\x03R\x05stage\x12I\n" +
	"\vdump_detail\x18\x04 \x01(\v2\x1e.premium_dm.v1beta2.DumpDetailB\x03\xe0A\x03H\x00R\n" +
	"dumpDetail\x88\x01\x01\x12I\n" +
	"\vload_detail\x18\x05 \x01(\v2\x1e.premium_dm.v1beta2.LoadDetailB\x03\xe0A\x03H\x01R\n" +
	"loadDetail\x88\x01\x01\x12I\n" +
	"\vsync_detail\x18\x06 \x01(\v2\x1e.premium_dm.v1beta2.SyncDetailB\x03\xe0A\x03H\x02R\n" +
	"syncDetail\x88\x01\x01\x12%\n" +
	"\terror_msg\x18\a \x01(\tB\x03\xe0A\x03H\x03R\berrorMsg\x88\x01\x01\":\n" +
	"\x04Step\x12\x14\n" +
	"\x10STEP_UNSPECIFIED\x10\x00\x12\b\n" +
	"\x04DUMP\x10\x01\x12\b\n" +
	"\x04LOAD\x10\x02\x12\b\n" +
	"\x04SYNC\x10\x03\"^\n" +
	"\x05Stage\x12\x15\n" +
	"\x11STAGE_UNSPECIFIED\x10\x00\x12\v\n" +
	"\aRUNNING\x10\x01\x12\n" +
	"\n" +
	"\x06PAUSED\x10\x02\x12\n" +
	"\n" +
	"\x06FAILED\x10\x03\x12\f\n" +
	"\bFINISHED\x10\x04\x12\v\n" +
	"\aUNKNOWN\x10\x05B\x0e\n" +
	"\f_dump_detailB\x0e\n" +
	"\f_load_detailB\x0e\n" +
	"\f_sync_detailB\f\n" +
	"\n" +
	"_error_msg\"\xd6\x03\n" +
	"\x0fPremiumDMSource\x12P\n" +
	"\fconn_profile\x18\x01 \x01(\v2(.premium_dm.v1beta2.PremiumDMConnProfileB\x03\xe0A\x02R\vconnProfile\x12e\n" +
	"\x17premium_migration_rules\x18\x03 \x03(\v2(.premium_dm.v1beta2.PremiumMigrationRuleB\x03\xe0A\x01R\x15premiumMigrationRules\x12)\n" +
	"\vbinlog_name\x18\x04 \x01(\tB\x03\xe0A\x01H\x00R\n" +
	"binlogName\x88\x01\x01\x121\n" +
	"\x0fbinlog_position\x18\x05 \x01(\x05B\x03\xe0A\x01H\x01R\x0ebinlogPosition\x88\x01\x01\x12)\n" +
	"\vbinlog_gtid\x18\x06 \x01(\tB\x03\xe0A\x01H\x02R\n" +
	"binlogGtid\x88\x01\x01\x12M\n" +
	"\vsource_type\x18\a \x01(\x0e2'.premium_dm.v1beta2.PremiumDMSourceTypeB\x03\xe0A\x02R\n" +
	"sourceTypeB\x0e\n" +
	"\f_binlog_nameB\x12\n" +
	"\x10_binlog_positionB\x0e\n" +
	"\f_binlog_gtid\"\xf2\x01\n" +
	"\n" +
	"DumpDetail\x12\x15\n" +
	"\x03bps\x18\x01 \x01(\x03B\x03\xe0A\x03R\x03bps\x12\x1f\n" +
	"\bprogress\x18\x02 \x01(\x01B\x03\xe0A\x03R\bprogress\x12&\n" +
	"\ftotal_tables\x18\x03 \x01(\x03B\x03\xe0A\x03R\vtotalTables\x12.\n" +
	"\x10completed_tables\x18\x04 \x01(\x03B\x03\xe0A\x03R\x0fcompletedTables\x12*\n" +
	"\x0efinished_bytes\x18\x05 \x01(\x03B\x03\xe0A\x03R\rfinishedBytes\x12(\n" +
	"\rfinished_rows\x18\x06 \x01(\x03B\x03\xe0A\x03R\ffinishedRows\"\x96\x01\n" +
	"\n" +
	"LoadDetail\x12\x15\n" +
	"\x03bps\x18\x01 \x01(\x03B\x03\xe0A\x03R\x03bps\x12\x1f\n" +
	"\bprogress\x18\x02 \x01(\x01B\x03\xe0A\x03R\bprogress\x12*\n" +
	"\x0efinished_bytes\x18\x03 \x01(\x03B\x03\xe0A\x03R\rfinishedBytes\x12$\n" +
	"\vtotal_bytes\x18\x04 \x01(\x03B\x03\xe0A\x03R\n" +
	"totalBytes\"g\n" +
	"\n" +
	"SyncDetail\x12\x15\n" +
	"\x03rps\x18\x01 \x01(\x03B\x03\xe0A\x03R\x03rps\x12\x1d\n" +
	"\alatency\x18\x02 \x01(\x03B\x03\xe0A\x03R\alatency\x12#\n" +
	"\n" +
	"checkpoint\x18\x03 \x01(\tB\x03\xe0A\x03R\n" +
	"checkpoint\"\xb6\x03\n" +
	"\x14PremiumDMConnProfile\x12G\n" +
	"\tconn_type\x18\x01 \x01(\x0e2%.premium_dm.v1beta2.PremiumDMConnTypeB\x03\xe0A\x02R\bconnType\x12/\n" +
	"\x10sink_endpoint_id\x18\x02 \x01(\x04B\x03\xe0A\x01H\x00R\x0esinkEndpointId\x12\x19\n" +
	"\x04host\x18\x03 \x01(\tB\x03\xe0A\x01H\x00R\x04host\x12\x17\n" +
	"\x04port\x18\x04 \x01(\x05B\x03\xe0A\x02R\x04port\x12\x17\n" +
	"\x04user\x18\x05 \x01(\tB\x03\xe0A\x02R\x04user\x12\"\n" +
	"\bpassword\x18\x06 \x01(\tB\x06\xe0A\x02\xe0A\x04R\bpassword\x12=\n" +
	"\bsecurity\x18\a \x01(\v2\x1c.premium_dm.v1beta2.SecurityB\x03\xe0A\x01R\bsecurity\x12S\n" +
	"\x10privatelink_info\x18\b \x01(\v2\x1b.consoleapi.PrivatelinkInfoB\x06\xe0A\x01\xe0A\x03H\x01R\x0fprivatelinkInfo\x88\x01\x01B\n" +
	"\n" +
	"\bendpointB\x13\n" +
	"\x11_privatelink_info\"\xbe\x01\n" +
	"\bSecurity\x12+\n" +
	"\x0fcert_allowed_cn\x18\x01 \x03(\tB\x03\xe0A\x01R\rcertAllowedCn\x12)\n" +
	"\x0essl_ca_content\x18\x02 \x01(\fB\x03\xe0A\x04R\fsslCaContent\x12-\n" +
	"\x10ssl_cert_content\x18\x03 \x01(\fB\x03\xe0A\x04R\x0esslCertContent\x12+\n" +
	"\x0fssl_key_content\x18\x04 \x01(\fB\x03\xe0A\x04R\rsslKeyContent\"^\n" +
	"\x16GetPremiumMigrationReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12&\n" +
	"\fmigration_id\x18\x02 \x01(\tB\x03\xe0A\x02R\vmigrationId\"\x9e\x01\n" +
	"\x18ListPremiumMigrationsReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12\"\n" +
	"\n" +
	"page_token\x18d \x01(\tB\x03\xe0A\x01R\tpageToken\x12 \n" +
	"\tpage_size\x18e \x01(\x05B\x03\xe0A\x01R\bpageSize\x12\x1e\n" +
	"\border_by\x18f \x01(\tB\x03\xe0A\x01R\aorderBy\"\xc5\x01\n" +
	"\x19ListPremiumMigrationsResp\x12W\n" +
	"\x11PremiumMigrations\x18\x01 \x03(\v2$.premium_dm.v1beta2.PremiumMigrationB\x03\xe0A\x03R\x11PremiumMigrations\x12\"\n" +
	"\n" +
	"total_size\x18\x02 \x01(\rB\x03\xe0A\x03R\ttotalSize\x12+\n" +
	"\x0fnext_page_token\x18\x03 \x01(\tB\x03\xe0A\x03R\rnextPageToken\"a\n" +
	"\x19DeletePremiumMigrationReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12&\n" +
	"\fmigration_id\x18\x02 \x01(\tB\x03\xe0A\x02R\vmigrationId\"`\n" +
	"\x18PausePremiumMigrationReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12&\n" +
	"\fmigration_id\x18\x02 \x01(\tB\x03\xe0A\x02R\vmigrationId\"a\n" +
	"\x19ResumePremiumMigrationReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12&\n" +
	"\fmigration_id\x18\x02 \x01(\tB\x03\xe0A\x02R\vmigrationId\"\x93\x01\n" +
	"\x13GetSourceTablesResp\x12E\n" +
	"\x06tables\x18\x01 \x03(\v2-.premium_dm.v1beta2.GetSourceTablesResp.TableR\x06tables\x1a5\n" +
	"\x05Table\x12\x16\n" +
	"\x06schema\x18\x01 \x01(\tR\x06schema\x12\x14\n" +
	"\x05table\x18\x02 \x01(\tR\x05table\"\x90\x01\n" +
	"#PremiumMigrationSourceDBConnProfile\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12K\n" +
	"\fconn_profile\x18\x02 \x01(\v2(.premium_dm.v1beta2.PremiumDMConnProfileR\vconnProfile\"s\n" +
	"#PremiumMigrationTargetDBConnProfile\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\x12\x12\n" +
	"\x04user\x18\x02 \x01(\tR\x04user\x12\x1a\n" +
	"\bpassword\x18\x03 \x01(\tR\bpassword\"F\n" +
	"&PremiumMigrationGetSupportedSourcesReq\x12\x1c\n" +
	"\atidb_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x06tidbId\"o\n" +
	"'PremiumMigrationGetSupportedSourcesResp\x12D\n" +
	"\asources\x18\x01 \x03(\v2*.premium_dm.v1beta2.PremiumSupportedSourceR\asources\"\xcf\x01\n" +
	"\x16PremiumSupportedSource\x12H\n" +
	"\vsource_type\x18\x01 \x01(\x0e2'.premium_dm.v1beta2.PremiumDMSourceTypeR\n" +
	"sourceType\x12H\n" +
	"\fconn_methods\x18\x02 \x03(\x0e2%.premium_dm.v1beta2.PremiumDMConnTypeR\vconnMethods\x12!\n" +
	"\fdisplay_name\x18\x03 \x01(\tR\vdisplayName\"n\n" +
	"\x17PremiumDMTaskImportMode\"S\n" +
	"\x04ENUM\x12\x1a\n" +
	"\x16IMPORTMODE_UNSPECIFIED\x10\x00\x12\x17\n" +
	"\x13IMPORTMODE_PHYSICAL\x10\x01\x12\x16\n" +
	"\x12IMPORTMODE_LOGICAL\x10\x02*K\n" +
	"\x11PremiumDMConnType\x12\x19\n" +
	"\x15CONN_TYPE_UNSPECIFIED\x10\x00\x12\n" +
	"\n" +
	"\x06PUBLIC\x10\x01\x12\x0f\n" +
	"\vPRIVATELINK\x10\x02*\xc5\x03\n" +
	"\x10PrecheckItemType\x12\"\n" +
	"\x1ePRECHECK_ITEM_TYPE_UNSPECIFIED\x10\x00\x12\x1b\n" +
	"\x17DUMP_PRIVILEGE_CHECKING\x10\x01\x12\"\n" +
	"\x1eREPLICATION_PRIVILEGE_CHECKING\x10\x02\x12\x14\n" +
	"\x10VERSION_CHECKING\x10\x03\x12\x16\n" +
	"\x12SERVER_ID_CHECKING\x10\x04\x12\x1a\n" +
	"\x16BINLOG_ENABLE_CHECKING\x10\x05\x12\x1a\n" +
	"\x16BINLOG_FORMAT_CHECKING\x10\x06\x12\x1d\n" +
	"\x19BINLOG_ROW_IMAGE_CHECKING\x10\a\x12\x19\n" +
	"\x15TABLE_SCHEMA_CHECKING\x10\b\x12\x16\n" +
	"\x12BINLOG_DB_CHECKING\x10\t\x12\x18\n" +
	"\x14CONN_NUMBER_CHECKING\x10\n" +
	"\x12 \n" +
	"\x1cTARGET_DB_PRIVILEGE_CHECKING\x10\v\x12\x1a\n" +
	"\x16META_POSITION_CHECKING\x10\f\x12\"\n" +
	"\x1eLIGHTNING_TABLE_EMPTY_CHECKING\x10\r\x12\x18\n" +
	"\x14PRIMARY_KEY_CHECKING\x10\x0e*C\n" +
	"\x11PremiumDMTaskMode\x12\x14\n" +
	"\x10MODE_UNSPECIFIED\x10\x00\x12\a\n" +
	"\x03ALL\x10\x01\x12\x0f\n" +
	"\vINCREMENTAL\x10\x02*o\n" +
	"\x13PremiumDMSourceType\x12\x1b\n" +
	"\x17SOURCE_TYPE_UNSPECIFIED\x10\x00\x12\t\n" +
	"\x05MYSQL\x10\x01\x12\x18\n" +
	"\x14AZURE_FLEXIBLE_MYSQL\x10\x02\x12\x16\n" +
	"\x12ALICLOUD_RDS_MYSQL\x10\x032\x94\x1a\n" +
	"\x17PremiumMigrationService\x12\xd8\x01\n" +
	"\x16CreatePremiumMigration\x12-.premium_dm.v1beta2.CreatePremiumMigrationReq\x1a$.premium_dm.v1beta2.PremiumMigration\"i\x92A1\n" +
	"\x17PremiumMigrationService*\x16CreatePremiumMigration\x82\xd3\xe4\x93\x02/:\x01*\"*/v1beta2/tidbs/{tidb_id}/premiumMigrations\x12\xdb\x01\n" +
	"\x13GetPremiumMigration\x12*.premium_dm.v1beta2.GetPremiumMigrationReq\x1a$.premium_dm.v1beta2.PremiumMigration\"r\x92A.\n" +
	"\x17PremiumMigrationService*\x13GetPremiumMigration\x82\xd3\xe4\x93\x02;\x129/v1beta2/tidbs/{tidb_id}/premiumMigrations/{migration_id}\x12\xdb\x01\n" +
	"\x15ListPremiumMigrations\x12,.premium_dm.v1beta2.ListPremiumMigrationsReq\x1a-.premium_dm.v1beta2.ListPremiumMigrationsResp\"e\x92A0\n" +
	"\x17PremiumMigrationService*\x15ListPremiumMigrations\x82\xd3\xe4\x93\x02,\x12*/v1beta2/tidbs/{tidb_id}/premiumMigrations\x12\xe4\x01\n" +
	"\x16DeletePremiumMigration\x12-.premium_dm.v1beta2.DeletePremiumMigrationReq\x1a$.premium_dm.v1beta2.PremiumMigration\"u\x92A1\n" +
	"\x17PremiumMigrationService*\x16DeletePremiumMigration\x82\xd3\xe4\x93\x02;*9/v1beta2/tidbs/{tidb_id}/premiumMigrations/{migration_id}\x12\xdc\x01\n" +
	"\x15PausePremiumMigration\x12,.premium_dm.v1beta2.PausePremiumMigrationReq\x1a\x16.google.protobuf.Empty\"}\x92A0\n" +
	"\x17PremiumMigrationService*\x15PausePremiumMigration\x82\xd3\xe4\x93\x02D:\x01*\"?/v1beta2/tidbs/{tidb_id}/premiumMigrations/{migration_id}:pause\x12\xe0\x01\n" +
	"\x16ResumePremiumMigration\x12-.premium_dm.v1beta2.ResumePremiumMigrationReq\x1a\x16.google.protobuf.Empty\"\x7f\x92A1\n" +
	"\x17PremiumMigrationService*\x16ResumePremiumMigration\x82\xd3\xe4\x93\x02E:\x01*\"@/v1beta2/tidbs/{tidb_id}/premiumMigrations/{migration_id}:resume\x12\x82\x02\n" +
	"\x1eCreatePremiumMigrationPrecheck\x12-.premium_dm.v1beta2.CreatePremiumMigrationReq\x1a6.premium_dm.v1beta2.CreatePremiumMigrationPrecheckResp\"y\x92A9\n" +
	"\x17PremiumMigrationService*\x1eCreatePremiumMigrationPrecheck\x82\xd3\xe4\x93\x027:\x01*\"2/v1beta2/tidbs/{tidb_id}/premiumMigrationPrechecks\x12\xf6\x01\n" +
	"\x1ePremiumMigrationCancelPrecheck\x125.premium_dm.v1beta2.CancelPremiumMigrationPrecheckReq\x1a\x16.google.protobuf.Empty\"\x84\x01\x92A9\n" +
	"\x17PremiumMigrationService*\x1ePremiumMigrationCancelPrecheck\x82\xd3\xe4\x93\x02B*@/v1beta2/tidbs/{tidb_id}/premiumMigrationPrechecks/{precheck_id}\x12\x83\x02\n" +
	"\x1bPremiumMigrationGetPrecheck\x122.premium_dm.v1beta2.GetPremiumMigrationPrecheckReq\x1a,.premium_dm.v1beta2.PremiumMigrationPrecheck\"\x81\x01\x92A6\n" +
	"\x17PremiumMigrationService*\x1bPremiumMigrationGetPrecheck\x82\xd3\xe4\x93\x02B\x12@/v1beta2/tidbs/{tidb_id}/premiumMigrationPrechecks/{precheck_id}\x12\x8e\x01\n" +
	"\x1dListPremiumMigrationPrechecks\x124.premium_dm.v1beta2.ListPremiumMigrationPrechecksReq\x1a5.premium_dm.v1beta2.ListPremiumMigrationPrechecksResp\"\x00\x12\x88\x02\n" +
	"\x1fGetPremiumMigrationSourceTables\x127.premium_dm.v1beta2.PremiumMigrationSourceDBConnProfile\x1a'.premium_dm.v1beta2.GetSourceTablesResp\"\x82\x01\x92A:\n" +
	"\x17PremiumMigrationService*\x1fGetPremiumMigrationSourceTables\x82\xd3\xe4\x93\x02?:\x01*\":/v1beta2/tidbs/{tidb_id}/premiumMigrations:getSourceTables\x12\x86\x02\n" +
	"\"ValidatePremiumMigrationSourceConn\x127.premium_dm.v1beta2.PremiumMigrationSourceDBConnProfile\x1a\x16.google.protobuf.Empty\"\x8e\x01\x92A=\n" +
	"\x17PremiumMigrationService*\"ValidatePremiumMigrationSourceConn\x82\xd3\xe4\x93\x02H:\x01*\"C/v1beta2/tidbs/{tidb_id}/premiumMigrations:validateSourceConnection\x12\x98\x02\n" +
	"+ValidatePremiumMigrationMigrationTargetConn\x127.premium_dm.v1beta2.PremiumMigrationTargetDBConnProfile\x1a\x16.google.protobuf.Empty\"\x97\x01\x92AF\n" +
	"\x17PremiumMigrationService*+ValidatePremiumMigrationMigrationTargetConn\x82\xd3\xe4\x93\x02H:\x01*\"C/v1beta2/tidbs/{tidb_id}/premiumMigrations:validateTargetConnection\x12\xf4\x01\n" +
	"\x13GetSupportedSources\x12:.premium_dm.v1beta2.PremiumMigrationGetSupportedSourcesReq\x1a;.premium_dm.v1beta2.PremiumMigrationGetSupportedSourcesResp\"d\x92A\x1e*\x1cGetPremiumDMSupportedSources\x82\xd3\xe4\x93\x02=\x12;/v1beta2/tidbs/{tidb_id}/premiumMigrations/supportedSourcesB\xfe\x01\x92A`\n" +
	"\x032.0\x12C\n" +
	"\x1bTiDB Cloud Premium Open API\x12\x1bTiDB Cloud Premium Open API2\av1beta2\x1a\x11cloud.tidbapi.com*\x01\x02\n" +
	")com.tidbcloud.dataflow.premium_dm.v1beta2B\x17PremiumMigrationProtoV2P\x01ZSgithub.com/tidbcloud/dataflow-service-ng/idl/pbgen/proto/premium_dm/v1beta2;v1beta2b\x06proto3"

var (
	file_premium_dm_v1beta2_premium_dm_proto_rawDescOnce sync.Once
	file_premium_dm_v1beta2_premium_dm_proto_rawDescData []byte
)

func file_premium_dm_v1beta2_premium_dm_proto_rawDescGZIP() []byte {
	file_premium_dm_v1beta2_premium_dm_proto_rawDescOnce.Do(func() {
		file_premium_dm_v1beta2_premium_dm_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_premium_dm_v1beta2_premium_dm_proto_rawDesc), len(file_premium_dm_v1beta2_premium_dm_proto_rawDesc)))
	})
	return file_premium_dm_v1beta2_premium_dm_proto_rawDescData
}

var file_premium_dm_v1beta2_premium_dm_proto_enumTypes = make([]protoimpl.EnumInfo, 10)
var file_premium_dm_v1beta2_premium_dm_proto_msgTypes = make([]protoimpl.MessageInfo, 35)
var file_premium_dm_v1beta2_premium_dm_proto_goTypes = []any{
	(PremiumDMConnType)(0),                          // 0: premium_dm.v1beta2.PremiumDMConnType
	(PrecheckItemType)(0),                           // 1: premium_dm.v1beta2.PrecheckItemType
	(PremiumDMTaskMode)(0),                          // 2: premium_dm.v1beta2.PremiumDMTaskMode
	(PremiumDMSourceType)(0),                        // 3: premium_dm.v1beta2.PremiumDMSourceType
	(PremiumMigrationPrecheck_Status)(0),            // 4: premium_dm.v1beta2.PremiumMigrationPrecheck.Status
	(PremiumDMPrecheckItem_Status)(0),               // 5: premium_dm.v1beta2.PremiumDMPrecheckItem.Status
	(PremiumMigration_State)(0),                     // 6: premium_dm.v1beta2.PremiumMigration.State
	(PremiumDMSubTask_Step)(0),                      // 7: premium_dm.v1beta2.PremiumDMSubTask.Step
	(PremiumDMSubTask_Stage)(0),                     // 8: premium_dm.v1beta2.PremiumDMSubTask.Stage
	(PremiumDMTaskImportMode_ENUM)(0),               // 9: premium_dm.v1beta2.PremiumDMTaskImportMode.ENUM
	(*GetPremiumMigrationPrecheckReq)(nil),          // 10: premium_dm.v1beta2.GetPremiumMigrationPrecheckReq
	(*CancelPremiumMigrationPrecheckReq)(nil),       // 11: premium_dm.v1beta2.CancelPremiumMigrationPrecheckReq
	(*PremiumMigrationPrecheck)(nil),                // 12: premium_dm.v1beta2.PremiumMigrationPrecheck
	(*CreatePremiumMigrationPrecheckResp)(nil),      // 13: premium_dm.v1beta2.CreatePremiumMigrationPrecheckResp
	(*ListPremiumMigrationPrechecksReq)(nil),        // 14: premium_dm.v1beta2.ListPremiumMigrationPrechecksReq
	(*PremiumMigrationPrecheckSummary)(nil),         // 15: premium_dm.v1beta2.PremiumMigrationPrecheckSummary
	(*ListPremiumMigrationPrechecksResp)(nil),       // 16: premium_dm.v1beta2.ListPremiumMigrationPrechecksResp
	(*PremiumDMPrecheckItem)(nil),                   // 17: premium_dm.v1beta2.PremiumDMPrecheckItem
	(*CreatePremiumMigrationReq)(nil),               // 18: premium_dm.v1beta2.CreatePremiumMigrationReq
	(*PremiumDMTarget)(nil),                         // 19: premium_dm.v1beta2.PremiumDMTarget
	(*PremiumMigrationRule)(nil),                    // 20: premium_dm.v1beta2.PremiumMigrationRule
	(*PremiumMigration)(nil),                        // 21: premium_dm.v1beta2.PremiumMigration
	(*PremiumDMSubTask)(nil),                        // 22: premium_dm.v1beta2.PremiumDMSubTask
	(*PremiumDMSource)(nil),                         // 23: premium_dm.v1beta2.PremiumDMSource
	(*DumpDetail)(nil),                              // 24: premium_dm.v1beta2.DumpDetail
	(*LoadDetail)(nil),                              // 25: premium_dm.v1beta2.LoadDetail
	(*SyncDetail)(nil),                              // 26: premium_dm.v1beta2.SyncDetail
	(*PremiumDMConnProfile)(nil),                    // 27: premium_dm.v1beta2.PremiumDMConnProfile
	(*Security)(nil),                                // 28: premium_dm.v1beta2.Security
	(*GetPremiumMigrationReq)(nil),                  // 29: premium_dm.v1beta2.GetPremiumMigrationReq
	(*ListPremiumMigrationsReq)(nil),                // 30: premium_dm.v1beta2.ListPremiumMigrationsReq
	(*ListPremiumMigrationsResp)(nil),               // 31: premium_dm.v1beta2.ListPremiumMigrationsResp
	(*DeletePremiumMigrationReq)(nil),               // 32: premium_dm.v1beta2.DeletePremiumMigrationReq
	(*PausePremiumMigrationReq)(nil),                // 33: premium_dm.v1beta2.PausePremiumMigrationReq
	(*ResumePremiumMigrationReq)(nil),               // 34: premium_dm.v1beta2.ResumePremiumMigrationReq
	(*GetSourceTablesResp)(nil),                     // 35: premium_dm.v1beta2.GetSourceTablesResp
	(*PremiumMigrationSourceDBConnProfile)(nil),     // 36: premium_dm.v1beta2.PremiumMigrationSourceDBConnProfile
	(*PremiumMigrationTargetDBConnProfile)(nil),     // 37: premium_dm.v1beta2.PremiumMigrationTargetDBConnProfile
	(*PremiumMigrationGetSupportedSourcesReq)(nil),  // 38: premium_dm.v1beta2.PremiumMigrationGetSupportedSourcesReq
	(*PremiumMigrationGetSupportedSourcesResp)(nil), // 39: premium_dm.v1beta2.PremiumMigrationGetSupportedSourcesResp
	(*PremiumSupportedSource)(nil),                  // 40: premium_dm.v1beta2.PremiumSupportedSource
	(*PremiumDMTaskImportMode)(nil),                 // 41: premium_dm.v1beta2.PremiumDMTaskImportMode
	(*PremiumMigrationRule_Source)(nil),             // 42: premium_dm.v1beta2.PremiumMigrationRule.Source
	(*PremiumMigrationRule_Table)(nil),              // 43: premium_dm.v1beta2.PremiumMigrationRule.Table
	(*GetSourceTablesResp_Table)(nil),               // 44: premium_dm.v1beta2.GetSourceTablesResp.Table
	(*timestamppb.Timestamp)(nil),                   // 45: google.protobuf.Timestamp
	(*consoleapi.PrivatelinkInfo)(nil),              // 46: consoleapi.PrivatelinkInfo
	(*emptypb.Empty)(nil),                           // 47: google.protobuf.Empty
}
var file_premium_dm_v1beta2_premium_dm_proto_depIdxs = []int32{
	4,  // 0: premium_dm.v1beta2.PremiumMigrationPrecheck.status:type_name -> premium_dm.v1beta2.PremiumMigrationPrecheck.Status
	17, // 1: premium_dm.v1beta2.PremiumMigrationPrecheck.items:type_name -> premium_dm.v1beta2.PremiumDMPrecheckItem
	45, // 2: premium_dm.v1beta2.PremiumMigrationPrecheckSummary.created_at:type_name -> google.protobuf.Timestamp
	4,  // 3: premium_dm.v1beta2.PremiumMigrationPrecheckSummary.status:type_name -> premium_dm.v1beta2.PremiumMigrationPrecheck.Status
	15, // 4: premium_dm.v1beta2.ListPremiumMigrationPrechecksResp.prechecks:type_name -> premium_dm.v1beta2.PremiumMigrationPrecheckSummary
	5,  // 5: premium_dm.v1beta2.PremiumDMPrecheckItem.status:type_name -> premium_dm.v1beta2.PremiumDMPrecheckItem.Status
	1,  // 6: premium_dm.v1beta2.PremiumDMPrecheckItem.type:type_name -> premium_dm.v1beta2.PrecheckItemType
	23, // 7: premium_dm.v1beta2.CreatePremiumMigrationReq.sources:type_name -> premium_dm.v1beta2.PremiumDMSource
	19, // 8: premium_dm.v1beta2.CreatePremiumMigrationReq.target:type_name -> premium_dm.v1beta2.PremiumDMTarget
	2,  // 9: premium_dm.v1beta2.CreatePremiumMigrationReq.mode:type_name -> premium_dm.v1beta2.PremiumDMTaskMode
	9,  // 10: premium_dm.v1beta2.CreatePremiumMigrationReq.import_mode:type_name -> premium_dm.v1beta2.PremiumDMTaskImportMode.ENUM
	42, // 11: premium_dm.v1beta2.PremiumMigrationRule.source_table:type_name -> premium_dm.v1beta2.PremiumMigrationRule.Source
	43, // 12: premium_dm.v1beta2.PremiumMigrationRule.target_table:type_name -> premium_dm.v1beta2.PremiumMigrationRule.Table
	22, // 13: premium_dm.v1beta2.PremiumMigration.sub_tasks:type_name -> premium_dm.v1beta2.PremiumDMSubTask
	45, // 14: premium_dm.v1beta2.PremiumMigration.create_time:type_name -> google.protobuf.Timestamp
	2,  // 15: premium_dm.v1beta2.PremiumMigration.mode:type_name -> premium_dm.v1beta2.PremiumDMTaskMode
	6,  // 16: premium_dm.v1beta2.PremiumMigration.state:type_name -> premium_dm.v1beta2.PremiumMigration.State
	9,  // 17: premium_dm.v1beta2.PremiumMigration.import_mode:type_name -> premium_dm.v1beta2.PremiumDMTaskImportMode.ENUM
	23, // 18: premium_dm.v1beta2.PremiumDMSubTask.source:type_name -> premium_dm.v1beta2.PremiumDMSource
	7,  // 19: premium_dm.v1beta2.PremiumDMSubTask.current_step:type_name -> premium_dm.v1beta2.PremiumDMSubTask.Step
	8,  // 20: premium_dm.v1beta2.PremiumDMSubTask.stage:type_name -> premium_dm.v1beta2.PremiumDMSubTask.Stage
	24, // 21: premium_dm.v1beta2.PremiumDMSubTask.dump_detail:type_name -> premium_dm.v1beta2.DumpDetail
	25, // 22: premium_dm.v1beta2.PremiumDMSubTask.load_detail:type_name -> premium_dm.v1beta2.LoadDetail
	26, // 23: premium_dm.v1beta2.PremiumDMSubTask.sync_detail:type_name -> premium_dm.v1beta2.SyncDetail
	27, // 24: premium_dm.v1beta2.PremiumDMSource.conn_profile:type_name -> premium_dm.v1beta2.PremiumDMConnProfile
	20, // 25: premium_dm.v1beta2.PremiumDMSource.premium_migration_rules:type_name -> premium_dm.v1beta2.PremiumMigrationRule
	3,  // 26: premium_dm.v1beta2.PremiumDMSource.source_type:type_name -> premium_dm.v1beta2.PremiumDMSourceType
	0,  // 27: premium_dm.v1beta2.PremiumDMConnProfile.conn_type:type_name -> premium_dm.v1beta2.PremiumDMConnType
	28, // 28: premium_dm.v1beta2.PremiumDMConnProfile.security:type_name -> premium_dm.v1beta2.Security
	46, // 29: premium_dm.v1beta2.PremiumDMConnProfile.privatelink_info:type_name -> consoleapi.PrivatelinkInfo
	21, // 30: premium_dm.v1beta2.ListPremiumMigrationsResp.PremiumMigrations:type_name -> premium_dm.v1beta2.PremiumMigration
	44, // 31: premium_dm.v1beta2.GetSourceTablesResp.tables:type_name -> premium_dm.v1beta2.GetSourceTablesResp.Table
	27, // 32: premium_dm.v1beta2.PremiumMigrationSourceDBConnProfile.conn_profile:type_name -> premium_dm.v1beta2.PremiumDMConnProfile
	40, // 33: premium_dm.v1beta2.PremiumMigrationGetSupportedSourcesResp.sources:type_name -> premium_dm.v1beta2.PremiumSupportedSource
	3,  // 34: premium_dm.v1beta2.PremiumSupportedSource.source_type:type_name -> premium_dm.v1beta2.PremiumDMSourceType
	0,  // 35: premium_dm.v1beta2.PremiumSupportedSource.conn_methods:type_name -> premium_dm.v1beta2.PremiumDMConnType
	18, // 36: premium_dm.v1beta2.PremiumMigrationService.CreatePremiumMigration:input_type -> premium_dm.v1beta2.CreatePremiumMigrationReq
	29, // 37: premium_dm.v1beta2.PremiumMigrationService.GetPremiumMigration:input_type -> premium_dm.v1beta2.GetPremiumMigrationReq
	30, // 38: premium_dm.v1beta2.PremiumMigrationService.ListPremiumMigrations:input_type -> premium_dm.v1beta2.ListPremiumMigrationsReq
	32, // 39: premium_dm.v1beta2.PremiumMigrationService.DeletePremiumMigration:input_type -> premium_dm.v1beta2.DeletePremiumMigrationReq
	33, // 40: premium_dm.v1beta2.PremiumMigrationService.PausePremiumMigration:input_type -> premium_dm.v1beta2.PausePremiumMigrationReq
	34, // 41: premium_dm.v1beta2.PremiumMigrationService.ResumePremiumMigration:input_type -> premium_dm.v1beta2.ResumePremiumMigrationReq
	18, // 42: premium_dm.v1beta2.PremiumMigrationService.CreatePremiumMigrationPrecheck:input_type -> premium_dm.v1beta2.CreatePremiumMigrationReq
	11, // 43: premium_dm.v1beta2.PremiumMigrationService.PremiumMigrationCancelPrecheck:input_type -> premium_dm.v1beta2.CancelPremiumMigrationPrecheckReq
	10, // 44: premium_dm.v1beta2.PremiumMigrationService.PremiumMigrationGetPrecheck:input_type -> premium_dm.v1beta2.GetPremiumMigrationPrecheckReq
	14, // 45: premium_dm.v1beta2.PremiumMigrationService.ListPremiumMigrationPrechecks:input_type -> premium_dm.v1beta2.ListPremiumMigrationPrechecksReq
	36, // 46: premium_dm.v1beta2.PremiumMigrationService.GetPremiumMigrationSourceTables:input_type -> premium_dm.v1beta2.PremiumMigrationSourceDBConnProfile
	36, // 47: premium_dm.v1beta2.PremiumMigrationService.ValidatePremiumMigrationSourceConn:input_type -> premium_dm.v1beta2.PremiumMigrationSourceDBConnProfile
	37, // 48: premium_dm.v1beta2.PremiumMigrationService.ValidatePremiumMigrationMigrationTargetConn:input_type -> premium_dm.v1beta2.PremiumMigrationTargetDBConnProfile
	38, // 49: premium_dm.v1beta2.PremiumMigrationService.GetSupportedSources:input_type -> premium_dm.v1beta2.PremiumMigrationGetSupportedSourcesReq
	21, // 50: premium_dm.v1beta2.PremiumMigrationService.CreatePremiumMigration:output_type -> premium_dm.v1beta2.PremiumMigration
	21, // 51: premium_dm.v1beta2.PremiumMigrationService.GetPremiumMigration:output_type -> premium_dm.v1beta2.PremiumMigration
	31, // 52: premium_dm.v1beta2.PremiumMigrationService.ListPremiumMigrations:output_type -> premium_dm.v1beta2.ListPremiumMigrationsResp
	21, // 53: premium_dm.v1beta2.PremiumMigrationService.DeletePremiumMigration:output_type -> premium_dm.v1beta2.PremiumMigration
	47, // 54: premium_dm.v1beta2.PremiumMigrationService.PausePremiumMigration:output_type -> google.protobuf.Empty
	47, // 55: premium_dm.v1beta2.PremiumMigrationService.ResumePremiumMigration:output_type -> google.protobuf.Empty
	13, // 56: premium_dm.v1beta2.PremiumMigrationService.CreatePremiumMigrationPrecheck:output_type -> premium_dm.v1beta2.CreatePremiumMigrationPrecheckResp
	47, // 57: premium_dm.v1beta2.PremiumMigrationService.PremiumMigrationCancelPrecheck:output_type -> google.protobuf.Empty
	12, // 58: premium_dm.v1beta2.PremiumMigrationService.PremiumMigrationGetPrecheck:output_type -> premium_dm.v1beta2.PremiumMigrationPrecheck
	16, // 59: premium_dm.v1beta2.PremiumMigrationService.ListPremiumMigrationPrechecks:output_type -> premium_dm.v1beta2.ListPremiumMigrationPrechecksResp
	35, // 60: premium_dm.v1beta2.PremiumMigrationService.GetPremiumMigrationSourceTables:output_type -> premium_dm.v1beta2.GetSourceTablesResp
	47, // 61: premium_dm.v1beta2.PremiumMigrationService.ValidatePremiumMigrationSourceConn:output_type -> google.protobuf.Empty
	47, // 62: premium_dm.v1beta2.PremiumMigrationService.ValidatePremiumMigrationMigrationTargetConn:output_type -> google.protobuf.Empty
	39, // 63: premium_dm.v1beta2.PremiumMigrationService.GetSupportedSources:output_type -> premium_dm.v1beta2.PremiumMigrationGetSupportedSourcesResp
	50, // [50:64] is the sub-list for method output_type
	36, // [36:50] is the sub-list for method input_type
	36, // [36:36] is the sub-list for extension type_name
	36, // [36:36] is the sub-list for extension extendee
	0,  // [0:36] is the sub-list for field type_name
}

func init() { file_premium_dm_v1beta2_premium_dm_proto_init() }
func file_premium_dm_v1beta2_premium_dm_proto_init() {
	if File_premium_dm_v1beta2_premium_dm_proto != nil {
		return
	}
	file_premium_dm_v1beta2_premium_dm_proto_msgTypes[12].OneofWrappers = []any{}
	file_premium_dm_v1beta2_premium_dm_proto_msgTypes[13].OneofWrappers = []any{}
	file_premium_dm_v1beta2_premium_dm_proto_msgTypes[17].OneofWrappers = []any{
		(*PremiumDMConnProfile_SinkEndpointId)(nil),
		(*PremiumDMConnProfile_Host)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_premium_dm_v1beta2_premium_dm_proto_rawDesc), len(file_premium_dm_v1beta2_premium_dm_proto_rawDesc)),
			NumEnums:      10,
			NumMessages:   35,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_premium_dm_v1beta2_premium_dm_proto_goTypes,
		DependencyIndexes: file_premium_dm_v1beta2_premium_dm_proto_depIdxs,
		EnumInfos:         file_premium_dm_v1beta2_premium_dm_proto_enumTypes,
		MessageInfos:      file_premium_dm_v1beta2_premium_dm_proto_msgTypes,
	}.Build()
	File_premium_dm_v1beta2_premium_dm_proto = out.File
	file_premium_dm_v1beta2_premium_dm_proto_goTypes = nil
	file_premium_dm_v1beta2_premium_dm_proto_depIdxs = nil
}