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

package agent

import (
	_ "github.com/envoyproxy/protoc-gen-validate/validate"
	_ "github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2/options"
	common "github.com/tidbcloud/dataflow-service/idl/pbgen/proto/common"
	base "go.buf.build/protocolbuffers/go/linuxgit/tidbcloud/base"
	_ "google.golang.org/genproto/googleapis/api/annotations"
	_ "google.golang.org/genproto/googleapis/api/httpbody"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	_ "google.golang.org/protobuf/types/known/anypb"
	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 CheckItem int32

const (
	CheckItem_CHECK_ITEM_UNKNOWN             CheckItem = 0
	CheckItem_CHECK_ITEM_TARGET_TABLE_EMPTY  CheckItem = 1
	CheckItem_CHECK_ITEM_SOURCE_SCHEMA       CheckItem = 2
	CheckItem_CHECK_ITEM_CSV_HEADER          CheckItem = 3
	CheckItem_CHECK_ITEM_TARGET_CLUSTER_SIZE CheckItem = 4
)

// Enum value maps for CheckItem.
var (
	CheckItem_name = map[int32]string{
		0: "CHECK_ITEM_UNKNOWN",
		1: "CHECK_ITEM_TARGET_TABLE_EMPTY",
		2: "CHECK_ITEM_SOURCE_SCHEMA",
		3: "CHECK_ITEM_CSV_HEADER",
		4: "CHECK_ITEM_TARGET_CLUSTER_SIZE",
	}
	CheckItem_value = map[string]int32{
		"CHECK_ITEM_UNKNOWN":             0,
		"CHECK_ITEM_TARGET_TABLE_EMPTY":  1,
		"CHECK_ITEM_SOURCE_SCHEMA":       2,
		"CHECK_ITEM_CSV_HEADER":          3,
		"CHECK_ITEM_TARGET_CLUSTER_SIZE": 4,
	}
)

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

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

func (CheckItem) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[0].Descriptor()
}

func (CheckItem) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[0]
}

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

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

type ImportPrecheckStatusType_Enum int32

const (
	// The precheck status is unknown.
	ImportPrecheckStatusType_UNSPECIFIED ImportPrecheckStatusType_Enum = 0
	// The precheck is completed.
	ImportPrecheckStatusType_COMPLETED ImportPrecheckStatusType_Enum = 1
	// The precheck is timeout and return partial result.
	ImportPrecheckStatusType_TIMEOUT ImportPrecheckStatusType_Enum = 2
	// The precheck result is truncated.
	ImportPrecheckStatusType_TRUNCATED ImportPrecheckStatusType_Enum = 3
)

// Enum value maps for ImportPrecheckStatusType_Enum.
var (
	ImportPrecheckStatusType_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "COMPLETED",
		2: "TIMEOUT",
		3: "TRUNCATED",
	}
	ImportPrecheckStatusType_Enum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"COMPLETED":   1,
		"TIMEOUT":     2,
		"TRUNCATED":   3,
	}
)

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

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

func (ImportPrecheckStatusType_Enum) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[1].Descriptor()
}

func (ImportPrecheckStatusType_Enum) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[1]
}

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

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

type GetImportFilesResp_SourceType int32

const (
	GetImportFilesResp_UNKNOWN_TYPE  GetImportFilesResp_SourceType = 0
	GetImportFilesResp_SCHEMA_SCHEMA GetImportFilesResp_SourceType = 1
	GetImportFilesResp_TABLE_SCHEMA  GetImportFilesResp_SourceType = 2
	GetImportFilesResp_SQL           GetImportFilesResp_SourceType = 3
	GetImportFilesResp_CSV           GetImportFilesResp_SourceType = 4
	GetImportFilesResp_PARQUET       GetImportFilesResp_SourceType = 5
	GetImportFilesResp_VIEW_SCHEMA   GetImportFilesResp_SourceType = 6
)

// Enum value maps for GetImportFilesResp_SourceType.
var (
	GetImportFilesResp_SourceType_name = map[int32]string{
		0: "UNKNOWN_TYPE",
		1: "SCHEMA_SCHEMA",
		2: "TABLE_SCHEMA",
		3: "SQL",
		4: "CSV",
		5: "PARQUET",
		6: "VIEW_SCHEMA",
	}
	GetImportFilesResp_SourceType_value = map[string]int32{
		"UNKNOWN_TYPE":  0,
		"SCHEMA_SCHEMA": 1,
		"TABLE_SCHEMA":  2,
		"SQL":           3,
		"CSV":           4,
		"PARQUET":       5,
		"VIEW_SCHEMA":   6,
	}
)

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

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

func (GetImportFilesResp_SourceType) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[2].Descriptor()
}

func (GetImportFilesResp_SourceType) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[2]
}

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

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

type GetImportFilesResp_Compression int32

const (
	GetImportFilesResp_UNKNOWN GetImportFilesResp_Compression = 0
	GetImportFilesResp_GZ      GetImportFilesResp_Compression = 1
	GetImportFilesResp_LZ4     GetImportFilesResp_Compression = 2
	GetImportFilesResp_ZSTD    GetImportFilesResp_Compression = 3
	GetImportFilesResp_XZ      GetImportFilesResp_Compression = 4
	GetImportFilesResp_LZO     GetImportFilesResp_Compression = 5
	GetImportFilesResp_SNAPPY  GetImportFilesResp_Compression = 6
)

// Enum value maps for GetImportFilesResp_Compression.
var (
	GetImportFilesResp_Compression_name = map[int32]string{
		0: "UNKNOWN",
		1: "GZ",
		2: "LZ4",
		3: "ZSTD",
		4: "XZ",
		5: "LZO",
		6: "SNAPPY",
	}
	GetImportFilesResp_Compression_value = map[string]int32{
		"UNKNOWN": 0,
		"GZ":      1,
		"LZ4":     2,
		"ZSTD":    3,
		"XZ":      4,
		"LZO":     5,
		"SNAPPY":  6,
	}
)

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

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

func (GetImportFilesResp_Compression) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[3].Descriptor()
}

func (GetImportFilesResp_Compression) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[3]
}

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

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

type ClearSingleEmptyTableResult_Result int32

const (
	ClearSingleEmptyTableResult_Unknown  ClearSingleEmptyTableResult_Result = 0
	ClearSingleEmptyTableResult_Cleared  ClearSingleEmptyTableResult_Result = 1
	ClearSingleEmptyTableResult_NotExist ClearSingleEmptyTableResult_Result = 2
	ClearSingleEmptyTableResult_NotEmpty ClearSingleEmptyTableResult_Result = 3
	ClearSingleEmptyTableResult_HasError ClearSingleEmptyTableResult_Result = 4
)

// Enum value maps for ClearSingleEmptyTableResult_Result.
var (
	ClearSingleEmptyTableResult_Result_name = map[int32]string{
		0: "Unknown",
		1: "Cleared",
		2: "NotExist",
		3: "NotEmpty",
		4: "HasError",
	}
	ClearSingleEmptyTableResult_Result_value = map[string]int32{
		"Unknown":  0,
		"Cleared":  1,
		"NotExist": 2,
		"NotEmpty": 3,
		"HasError": 4,
	}
)

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

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

func (ClearSingleEmptyTableResult_Result) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[4].Descriptor()
}

func (ClearSingleEmptyTableResult_Result) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[4]
}

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

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

type ImportSourceType_Enum int32

const (
	// The source of the import is unknown.
	ImportSourceType_UNSPECIFIED ImportSourceType_Enum = 0
	// S3 source.
	ImportSourceType_S3 ImportSourceType_Enum = 1
	// gcs source
	ImportSourceType_GCS ImportSourceType_Enum = 2
	// azure blob source
	ImportSourceType_AZURE_BLOB ImportSourceType_Enum = 3
)

// Enum value maps for ImportSourceType_Enum.
var (
	ImportSourceType_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "S3",
		2: "GCS",
		3: "AZURE_BLOB",
	}
	ImportSourceType_Enum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"S3":          1,
		"GCS":         2,
		"AZURE_BLOB":  3,
	}
)

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

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

func (ImportSourceType_Enum) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[5].Descriptor()
}

func (ImportSourceType_Enum) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[5]
}

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

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

type ImportS3AuthType_Enum int32

const (
	// The access method is unknown.
	ImportS3AuthType_UNSPECIFIED ImportS3AuthType_Enum = 0
	// The access method is role arn.
	ImportS3AuthType_ROLE_ARN ImportS3AuthType_Enum = 1
	// The access method is access key.
	ImportS3AuthType_ACCESS_KEY ImportS3AuthType_Enum = 2
)

// Enum value maps for ImportS3AuthType_Enum.
var (
	ImportS3AuthType_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "ROLE_ARN",
		2: "ACCESS_KEY",
	}
	ImportS3AuthType_Enum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"ROLE_ARN":    1,
		"ACCESS_KEY":  2,
	}
)

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

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

func (ImportS3AuthType_Enum) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[6].Descriptor()
}

func (ImportS3AuthType_Enum) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[6]
}

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

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

type ImportGcsAuthType_Enum int32

const (
	// The access method is unknown.
	ImportGcsAuthType_AUTH_TYPE_UNSPECIFIED ImportGcsAuthType_Enum = 0
	// The access method is service account key.
	ImportGcsAuthType_SERVICE_ACCOUNT_KEY ImportGcsAuthType_Enum = 1
)

// Enum value maps for ImportGcsAuthType_Enum.
var (
	ImportGcsAuthType_Enum_name = map[int32]string{
		0: "AUTH_TYPE_UNSPECIFIED",
		1: "SERVICE_ACCOUNT_KEY",
	}
	ImportGcsAuthType_Enum_value = map[string]int32{
		"AUTH_TYPE_UNSPECIFIED": 0,
		"SERVICE_ACCOUNT_KEY":   1,
	}
)

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

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

func (ImportGcsAuthType_Enum) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[7].Descriptor()
}

func (ImportGcsAuthType_Enum) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[7]
}

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

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

type ImportAzureBlobAuthType_Enum int32

const (
	// The access method is unknown.
	ImportAzureBlobAuthType_UNSPECIFIED ImportAzureBlobAuthType_Enum = 0
	// The access method is sas token.
	ImportAzureBlobAuthType_SAS_TOKEN ImportAzureBlobAuthType_Enum = 1
)

// Enum value maps for ImportAzureBlobAuthType_Enum.
var (
	ImportAzureBlobAuthType_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SAS_TOKEN",
	}
	ImportAzureBlobAuthType_Enum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SAS_TOKEN":   1,
	}
)

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

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

func (ImportAzureBlobAuthType_Enum) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[8].Descriptor()
}

func (ImportAzureBlobAuthType_Enum) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[8]
}

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

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

type ImportFileType_Enum int32

const (
	// The type of the file is unknown.
	ImportFileType_UNSPECIFIED ImportFileType_Enum = 0
	// CSV type.
	ImportFileType_CSV ImportFileType_Enum = 1
	// SQL type.
	ImportFileType_SQL ImportFileType_Enum = 2
	// Aurora snapshot type.
	ImportFileType_AURORA_SNAPSHOT ImportFileType_Enum = 3
	// Parquet type.
	ImportFileType_PARQUET ImportFileType_Enum = 4
)

// Enum value maps for ImportFileType_Enum.
var (
	ImportFileType_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "CSV",
		2: "SQL",
		3: "AURORA_SNAPSHOT",
		4: "PARQUET",
	}
	ImportFileType_Enum_value = map[string]int32{
		"UNSPECIFIED":     0,
		"CSV":             1,
		"SQL":             2,
		"AURORA_SNAPSHOT": 3,
		"PARQUET":         4,
	}
)

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

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

func (ImportFileType_Enum) Descriptor() protoreflect.EnumDescriptor {
	return file_agent_agent_proto_enumTypes[9].Descriptor()
}

func (ImportFileType_Enum) Type() protoreflect.EnumType {
	return &file_agent_agent_proto_enumTypes[9]
}

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

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

type TableResult struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The target table.
	TargetTable *common.Table `protobuf:"bytes,1,opt,name=target_table,json=targetTable,proto3" json:"target_table,omitempty"`
	// The error message.
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// The matched data files.
	MatchedDataFiles []string `protobuf:"bytes,3,rep,name=matched_data_files,json=matchedDataFiles,proto3" json:"matched_data_files,omitempty"`
	// The matched schema file.
	MatchedSchemaFile string `protobuf:"bytes,4,opt,name=matched_schema_file,json=matchedSchemaFile,proto3" json:"matched_schema_file,omitempty"`
	// Whether the matched schema file is used in import.
	UseSchemaFile bool `protobuf:"varint,5,opt,name=use_schema_file,json=useSchemaFile,proto3" json:"use_schema_file,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*TableResult) ProtoMessage() {}

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

func (x *TableResult) GetTargetTable() *common.Table {
	if x != nil {
		return x.TargetTable
	}
	return nil
}

func (x *TableResult) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *TableResult) GetMatchedDataFiles() []string {
	if x != nil {
		return x.MatchedDataFiles
	}
	return nil
}

func (x *TableResult) GetMatchedSchemaFile() string {
	if x != nil {
		return x.MatchedSchemaFile
	}
	return ""
}

func (x *TableResult) GetUseSchemaFile() bool {
	if x != nil {
		return x.UseSchemaFile
	}
	return false
}

type PrecheckImportJobReq struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. The organize ID.
	OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	// Required. The project ID.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Required. The cluster ID.
	ClusterId string `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Required. The options of the import.
	ImportOptions *ImportOptions `protobuf:"bytes,4,opt,name=import_options,json=importOptions,proto3" json:"import_options,omitempty"`
	// Required. The source of the import.
	Source *ImportSource `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	// Required. The target cluster connection information.
	TargetCluster *Cluster `protobuf:"bytes,6,opt,name=target_cluster,json=targetCluster,proto3" json:"target_cluster,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*PrecheckImportJobReq) ProtoMessage() {}

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

func (x *PrecheckImportJobReq) GetOrgId() string {
	if x != nil {
		return x.OrgId
	}
	return ""
}

func (x *PrecheckImportJobReq) GetProjectId() string {
	if x != nil {
		return x.ProjectId
	}
	return ""
}

func (x *PrecheckImportJobReq) GetClusterId() string {
	if x != nil {
		return x.ClusterId
	}
	return ""
}

func (x *PrecheckImportJobReq) GetImportOptions() *ImportOptions {
	if x != nil {
		return x.ImportOptions
	}
	return nil
}

func (x *PrecheckImportJobReq) GetSource() *ImportSource {
	if x != nil {
		return x.Source
	}
	return nil
}

func (x *PrecheckImportJobReq) GetTargetCluster() *Cluster {
	if x != nil {
		return x.TargetCluster
	}
	return nil
}

type PrecheckImportJobResp struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The list of tables which has matched data files.
	TargetTables []*TableResult `protobuf:"bytes,1,rep,name=target_tables,json=targetTables,proto3" json:"target_tables,omitempty"`
	// The error message consists of the unmatched tables.
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// The total data files count.
	TotalDataFilesCount uint64 `protobuf:"varint,3,opt,name=total_data_files_count,json=totalDataFilesCount,proto3" json:"total_data_files_count,omitempty"`
	// The total tables count.
	TotalTablesCount uint64 `protobuf:"varint,4,opt,name=total_tables_count,json=totalTablesCount,proto3" json:"total_tables_count,omitempty"`
	// If the result is truncated.
	IsTruncated bool `protobuf:"varint,5,opt,name=is_truncated,json=isTruncated,proto3" json:"is_truncated,omitempty"`
	// The status.
	Status        ImportPrecheckStatusType_Enum `protobuf:"varint,6,opt,name=status,proto3,enum=agent.ImportPrecheckStatusType_Enum" json:"status,omitempty"`
	BaseResp      *base.BaseResp                `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*PrecheckImportJobResp) ProtoMessage() {}

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

func (x *PrecheckImportJobResp) GetTargetTables() []*TableResult {
	if x != nil {
		return x.TargetTables
	}
	return nil
}

func (x *PrecheckImportJobResp) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

func (x *PrecheckImportJobResp) GetTotalDataFilesCount() uint64 {
	if x != nil {
		return x.TotalDataFilesCount
	}
	return 0
}

func (x *PrecheckImportJobResp) GetTotalTablesCount() uint64 {
	if x != nil {
		return x.TotalTablesCount
	}
	return 0
}

func (x *PrecheckImportJobResp) GetIsTruncated() bool {
	if x != nil {
		return x.IsTruncated
	}
	return false
}

func (x *PrecheckImportJobResp) GetStatus() ImportPrecheckStatusType_Enum {
	if x != nil {
		return x.Status
	}
	return ImportPrecheckStatusType_UNSPECIFIED
}

func (x *PrecheckImportJobResp) GetBaseResp() *base.BaseResp {
	if x != nil {
		return x.BaseResp
	}
	return nil
}

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

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

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

func (*ImportPrecheckStatusType) ProtoMessage() {}

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

type DropClusterTablesReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Tables        []*common.Table        `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	Cluster       *Cluster               `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*DropClusterTablesReq) ProtoMessage() {}

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

func (x *DropClusterTablesReq) GetTables() []*common.Table {
	if x != nil {
		return x.Tables
	}
	return nil
}

func (x *DropClusterTablesReq) GetCluster() *Cluster {
	if x != nil {
		return x.Cluster
	}
	return nil
}

type PrecheckImportFileReq struct {
	state              protoimpl.MessageState          `protogen:"open.v1"`
	Sources            []*PrecheckImportFileReq_Source `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	DataFormat         uint64                          `protobuf:"varint,2,opt,name=data_format,json=dataFormat,proto3" json:"data_format,omitempty"`
	DataSource         uint64                          `protobuf:"varint,3,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	CsvConfig          *CsvConfig                      `protobuf:"bytes,5,opt,name=csv_config,json=csvConfig,proto3" json:"csv_config,omitempty"`
	Cluster            *Cluster                        `protobuf:"bytes,6,opt,name=cluster,proto3" json:"cluster,omitempty"`
	AwsRoleArn         string                          `protobuf:"bytes,10,opt,name=aws_role_arn,json=awsRoleArn,proto3" json:"aws_role_arn,omitempty"`
	AwsExternalId      string                          `protobuf:"bytes,11,opt,name=aws_external_id,json=awsExternalId,proto3" json:"aws_external_id,omitempty"`
	AwsAccessKeyId     string                          `protobuf:"bytes,12,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"`
	AwsSecretAccessKey string                          `protobuf:"bytes,13,opt,name=aws_secret_access_key,json=awsSecretAccessKey,proto3" json:"aws_secret_access_key,omitempty"`
	SasToken           string                          `protobuf:"bytes,14,opt,name=sas_token,json=sasToken,proto3" json:"sas_token,omitempty"`
	SourceUrl          string                          `protobuf:"bytes,15,opt,name=source_url,json=sourceUrl,proto3" json:"source_url,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

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

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

func (*PrecheckImportFileReq) ProtoMessage() {}

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

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

func (x *PrecheckImportFileReq) GetDataFormat() uint64 {
	if x != nil {
		return x.DataFormat
	}
	return 0
}

func (x *PrecheckImportFileReq) GetDataSource() uint64 {
	if x != nil {
		return x.DataSource
	}
	return 0
}

func (x *PrecheckImportFileReq) GetCsvConfig() *CsvConfig {
	if x != nil {
		return x.CsvConfig
	}
	return nil
}

func (x *PrecheckImportFileReq) GetCluster() *Cluster {
	if x != nil {
		return x.Cluster
	}
	return nil
}

func (x *PrecheckImportFileReq) GetAwsRoleArn() string {
	if x != nil {
		return x.AwsRoleArn
	}
	return ""
}

func (x *PrecheckImportFileReq) GetAwsExternalId() string {
	if x != nil {
		return x.AwsExternalId
	}
	return ""
}

func (x *PrecheckImportFileReq) GetAwsAccessKeyId() string {
	if x != nil {
		return x.AwsAccessKeyId
	}
	return ""
}

func (x *PrecheckImportFileReq) GetAwsSecretAccessKey() string {
	if x != nil {
		return x.AwsSecretAccessKey
	}
	return ""
}

func (x *PrecheckImportFileReq) GetSasToken() string {
	if x != nil {
		return x.SasToken
	}
	return ""
}

func (x *PrecheckImportFileReq) GetSourceUrl() string {
	if x != nil {
		return x.SourceUrl
	}
	return ""
}

type SearchImportFilesReq struct {
	state        protoimpl.MessageState               `protogen:"open.v1"`
	TargetSource []*SearchImportFilesReq_TargetSource `protobuf:"bytes,1,rep,name=target_source,json=targetSource,proto3" json:"target_source,omitempty"`
	// 1: sql
	// 2: aurora snapshot(parquet)
	// 3: csv
	// 4: parquet(not aurora)
	DataFormat uint32 `protobuf:"varint,2,opt,name=data_format,json=dataFormat,proto3" json:"data_format,omitempty"`
	// 1: aws s3
	// 2: gcs
	// 3: azblob
	DataSourceType     uint32      `protobuf:"varint,3,opt,name=data_source_type,json=dataSourceType,proto3" json:"data_source_type,omitempty"`
	SourceUri          string      `protobuf:"bytes,4,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	AwsRoleArn         string      `protobuf:"bytes,10,opt,name=aws_role_arn,json=awsRoleArn,proto3" json:"aws_role_arn,omitempty"`
	AwsExternalId      string      `protobuf:"bytes,11,opt,name=aws_external_id,json=awsExternalId,proto3" json:"aws_external_id,omitempty"`
	AwsAccessKeyId     string      `protobuf:"bytes,12,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"`
	AwsSecretAccessKey string      `protobuf:"bytes,13,opt,name=aws_secret_access_key,json=awsSecretAccessKey,proto3" json:"aws_secret_access_key,omitempty"`
	GcsOptions         *GcsOptions `protobuf:"bytes,14,opt,name=gcs_options,json=gcsOptions,proto3" json:"gcs_options,omitempty"`
	SasToken           string      `protobuf:"bytes,15,opt,name=sas_token,json=sasToken,proto3" json:"sas_token,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

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

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

func (*SearchImportFilesReq) ProtoMessage() {}

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

func (x *SearchImportFilesReq) GetTargetSource() []*SearchImportFilesReq_TargetSource {
	if x != nil {
		return x.TargetSource
	}
	return nil
}

func (x *SearchImportFilesReq) GetDataFormat() uint32 {
	if x != nil {
		return x.DataFormat
	}
	return 0
}

func (x *SearchImportFilesReq) GetDataSourceType() uint32 {
	if x != nil {
		return x.DataSourceType
	}
	return 0
}

func (x *SearchImportFilesReq) GetSourceUri() string {
	if x != nil {
		return x.SourceUri
	}
	return ""
}

func (x *SearchImportFilesReq) GetAwsRoleArn() string {
	if x != nil {
		return x.AwsRoleArn
	}
	return ""
}

func (x *SearchImportFilesReq) GetAwsExternalId() string {
	if x != nil {
		return x.AwsExternalId
	}
	return ""
}

func (x *SearchImportFilesReq) GetAwsAccessKeyId() string {
	if x != nil {
		return x.AwsAccessKeyId
	}
	return ""
}

func (x *SearchImportFilesReq) GetAwsSecretAccessKey() string {
	if x != nil {
		return x.AwsSecretAccessKey
	}
	return ""
}

func (x *SearchImportFilesReq) GetGcsOptions() *GcsOptions {
	if x != nil {
		return x.GcsOptions
	}
	return nil
}

func (x *SearchImportFilesReq) GetSasToken() string {
	if x != nil {
		return x.SasToken
	}
	return ""
}

type GetImportFilesReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ClusterId     uint64                 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	SourceUri     string                 `protobuf:"bytes,5,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*GetImportFilesReq) ProtoMessage() {}

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

func (x *GetImportFilesReq) GetClusterId() uint64 {
	if x != nil {
		return x.ClusterId
	}
	return 0
}

func (x *GetImportFilesReq) GetSourceUri() string {
	if x != nil {
		return x.SourceUri
	}
	return ""
}

type GetImportFilesResp struct {
	state         protoimpl.MessageState          `protogen:"open.v1"`
	TableMeta     []*GetImportFilesResp_TableMeta `protobuf:"bytes,1,rep,name=table_meta,json=tableMeta,proto3" json:"table_meta,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*GetImportFilesResp) ProtoMessage() {}

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

func (x *GetImportFilesResp) GetTableMeta() []*GetImportFilesResp_TableMeta {
	if x != nil {
		return x.TableMeta
	}
	return nil
}

type CreateSchemasReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ClusterId     uint64                 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_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"`
	SourceUri     string                 `protobuf:"bytes,4,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CreateSchemasReq) ProtoMessage() {}

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

func (x *CreateSchemasReq) GetClusterId() uint64 {
	if x != nil {
		return x.ClusterId
	}
	return 0
}

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

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

func (x *CreateSchemasReq) GetSourceUri() string {
	if x != nil {
		return x.SourceUri
	}
	return ""
}

type CsvConfig struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Specifies the field separator. The default separator is ,.
	Separator string `protobuf:"bytes,1,opt,name=separator,proto3" json:"separator,omitempty"`
	// Specifies the field delimiter. The default delimiter is "
	Delimiter string `protobuf:"bytes,2,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	// Import CSV files of the tables with header. Default is true.
	Header bool `protobuf:"varint,3,opt,name=header,proto3" json:"header,omitempty"`
	BackslashEscape   bool `protobuf:"varint,4,opt,name=backslash_escape,json=backslashEscape,proto3" json:"backslash_escape,omitempty"`
	TrimLastSeparator bool `protobuf:"varint,5,opt,name=trim_last_separator,json=trimLastSeparator,proto3" json:"trim_last_separator,omitempty"`
	// Whether the columns in CSV files can be null. Default is false.
	NotNull *bool `protobuf:"varint,6,opt,name=not_null,json=notNull,proto3,oneof" json:"not_null,omitempty"`
	// Representation of null values in CSV files. Default is "\N".
	NullValue     *string `protobuf:"bytes,7,opt,name=null_value,json=nullValue,proto3,oneof" json:"null_value,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CsvConfig) ProtoMessage() {}

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

func (x *CsvConfig) GetSeparator() string {
	if x != nil {
		return x.Separator
	}
	return ""
}

func (x *CsvConfig) GetDelimiter() string {
	if x != nil {
		return x.Delimiter
	}
	return ""
}

func (x *CsvConfig) GetHeader() bool {
	if x != nil {
		return x.Header
	}
	return false
}

func (x *CsvConfig) GetBackslashEscape() bool {
	if x != nil {
		return x.BackslashEscape
	}
	return false
}

func (x *CsvConfig) GetTrimLastSeparator() bool {
	if x != nil {
		return x.TrimLastSeparator
	}
	return false
}

func (x *CsvConfig) GetNotNull() bool {
	if x != nil && x.NotNull != nil {
		return *x.NotNull
	}
	return false
}

func (x *CsvConfig) GetNullValue() string {
	if x != nil && x.NullValue != nil {
		return *x.NullValue
	}
	return ""
}

type PreviewCsvFileReq struct {
	state              protoimpl.MessageState `protogen:"open.v1"`
	SourceUri          string                 `protobuf:"bytes,1,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	CsvConfig          *CsvConfig             `protobuf:"bytes,2,opt,name=csv_config,json=csvConfig,proto3" json:"csv_config,omitempty"`
	FirstN             uint64                 `protobuf:"varint,3,opt,name=first_n,json=firstN,proto3" json:"first_n,omitempty"`
	AwsRoleArn         string                 `protobuf:"bytes,10,opt,name=aws_role_arn,json=awsRoleArn,proto3" json:"aws_role_arn,omitempty"`
	AwsExternalId      string                 `protobuf:"bytes,11,opt,name=aws_external_id,json=awsExternalId,proto3" json:"aws_external_id,omitempty"`
	AwsAccessKeyId     string                 `protobuf:"bytes,12,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"`
	AwsSecretAccessKey string                 `protobuf:"bytes,13,opt,name=aws_secret_access_key,json=awsSecretAccessKey,proto3" json:"aws_secret_access_key,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

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

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

func (*PreviewCsvFileReq) ProtoMessage() {}

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

func (x *PreviewCsvFileReq) GetSourceUri() string {
	if x != nil {
		return x.SourceUri
	}
	return ""
}

func (x *PreviewCsvFileReq) GetCsvConfig() *CsvConfig {
	if x != nil {
		return x.CsvConfig
	}
	return nil
}

func (x *PreviewCsvFileReq) GetFirstN() uint64 {
	if x != nil {
		return x.FirstN
	}
	return 0
}

func (x *PreviewCsvFileReq) GetAwsRoleArn() string {
	if x != nil {
		return x.AwsRoleArn
	}
	return ""
}

func (x *PreviewCsvFileReq) GetAwsExternalId() string {
	if x != nil {
		return x.AwsExternalId
	}
	return ""
}

func (x *PreviewCsvFileReq) GetAwsAccessKeyId() string {
	if x != nil {
		return x.AwsAccessKeyId
	}
	return ""
}

func (x *PreviewCsvFileReq) GetAwsSecretAccessKey() string {
	if x != nil {
		return x.AwsSecretAccessKey
	}
	return ""
}

type SearchImportFilesResp struct {
	state         protoimpl.MessageState              `protogen:"open.v1"`
	TableMatches  []*SearchImportFilesResp_TableMatch `protobuf:"bytes,1,rep,name=table_matches,json=tableMatches,proto3" json:"table_matches,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*SearchImportFilesResp) ProtoMessage() {}

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

func (x *SearchImportFilesResp) GetTableMatches() []*SearchImportFilesResp_TableMatch {
	if x != nil {
		return x.TableMatches
	}
	return nil
}

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

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

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

func (*PreviewCsvFileResp) ProtoMessage() {}

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

func (x *PreviewCsvFileResp) GetTable() *Table {
	if x != nil {
		return x.Table
	}
	return nil
}

type CheckS3AccessReq struct {
	state              protoimpl.MessageState `protogen:"open.v1"`
	RoleArn            string                 `protobuf:"bytes,1,opt,name=role_arn,json=roleArn,proto3" json:"role_arn,omitempty"`
	S3Url              string                 `protobuf:"bytes,2,opt,name=s3_url,json=s3Url,proto3" json:"s3_url,omitempty"`
	ExternalId         string                 `protobuf:"bytes,3,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	AwsAccessKeyId     string                 `protobuf:"bytes,4,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"`
	AwsSecretAccessKey string                 `protobuf:"bytes,5,opt,name=aws_secret_access_key,json=awsSecretAccessKey,proto3" json:"aws_secret_access_key,omitempty"`
	unknownFields      protoimpl.UnknownFields
	sizeCache          protoimpl.SizeCache
}

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

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

func (*CheckS3AccessReq) ProtoMessage() {}

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

func (x *CheckS3AccessReq) GetRoleArn() string {
	if x != nil {
		return x.RoleArn
	}
	return ""
}

func (x *CheckS3AccessReq) GetS3Url() string {
	if x != nil {
		return x.S3Url
	}
	return ""
}

func (x *CheckS3AccessReq) GetExternalId() string {
	if x != nil {
		return x.ExternalId
	}
	return ""
}

func (x *CheckS3AccessReq) GetAwsAccessKeyId() string {
	if x != nil {
		return x.AwsAccessKeyId
	}
	return ""
}

func (x *CheckS3AccessReq) GetAwsSecretAccessKey() string {
	if x != nil {
		return x.AwsSecretAccessKey
	}
	return ""
}

type CheckS3AccessResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ErrorMsg      string                 `protobuf:"bytes,1,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CheckS3AccessResp) ProtoMessage() {}

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

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

type CheckGcsAccessReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	GcsUrl        string                 `protobuf:"bytes,1,opt,name=gcs_url,json=gcsUrl,proto3" json:"gcs_url,omitempty"`
	GcsOptions    *GcsOptions            `protobuf:"bytes,2,opt,name=gcs_options,json=gcsOptions,proto3" json:"gcs_options,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CheckGcsAccessReq) ProtoMessage() {}

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

func (x *CheckGcsAccessReq) GetGcsUrl() string {
	if x != nil {
		return x.GcsUrl
	}
	return ""
}

func (x *CheckGcsAccessReq) GetGcsOptions() *GcsOptions {
	if x != nil {
		return x.GcsOptions
	}
	return nil
}

type CheckGcsAccessResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ErrorMsg      string                 `protobuf:"bytes,1,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CheckGcsAccessResp) ProtoMessage() {}

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

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

type CheckAzblobAccessReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	AzblobUrl     string                 `protobuf:"bytes,1,opt,name=azblob_url,json=azblobUrl,proto3" json:"azblob_url,omitempty"`
	SasToken      string                 `protobuf:"bytes,2,opt,name=sas_token,json=sasToken,proto3" json:"sas_token,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CheckAzblobAccessReq) ProtoMessage() {}

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

func (x *CheckAzblobAccessReq) GetAzblobUrl() string {
	if x != nil {
		return x.AzblobUrl
	}
	return ""
}

func (x *CheckAzblobAccessReq) GetSasToken() string {
	if x != nil {
		return x.SasToken
	}
	return ""
}

type CheckAzblobAccessResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ErrorMsg      string                 `protobuf:"bytes,1,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CheckAzblobAccessResp) ProtoMessage() {}

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

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

type Cluster struct {
	state     protoimpl.MessageState `protogen:"open.v1"`
	ClusterId uint64                 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Namespace string                 `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	User      string                 `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Password  string                 `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// unit is second
	ReadTimeout       int64          `protobuf:"varint,6,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`
	WriteTimeout      int64          `protobuf:"varint,7,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"`
	ProviderType      string         `protobuf:"bytes,8,opt,name=provider_type,json=providerType,proto3" json:"provider_type,omitempty"`
	PasswordEncrypted bool           `protobuf:"varint,9,opt,name=password_encrypted,json=passwordEncrypted,proto3" json:"password_encrypted,omitempty"`
	EncryptedPassword *EncryptedData `protobuf:"bytes,10,opt,name=encrypted_password,json=encryptedPassword,proto3" json:"encrypted_password,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

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

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

func (*Cluster) ProtoMessage() {}

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

func (x *Cluster) GetClusterId() uint64 {
	if x != nil {
		return x.ClusterId
	}
	return 0
}

func (x *Cluster) GetNamespace() string {
	if x != nil {
		return x.Namespace
	}
	return ""
}

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

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

func (x *Cluster) GetReadTimeout() int64 {
	if x != nil {
		return x.ReadTimeout
	}
	return 0
}

func (x *Cluster) GetWriteTimeout() int64 {
	if x != nil {
		return x.WriteTimeout
	}
	return 0
}

func (x *Cluster) GetProviderType() string {
	if x != nil {
		return x.ProviderType
	}
	return ""
}

func (x *Cluster) GetPasswordEncrypted() bool {
	if x != nil {
		return x.PasswordEncrypted
	}
	return false
}

func (x *Cluster) GetEncryptedPassword() *EncryptedData {
	if x != nil {
		return x.EncryptedPassword
	}
	return nil
}

type LoadDataReq struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	Cluster         *Cluster               `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	TargetDb        string                 `protobuf:"bytes,2,opt,name=target_db,json=targetDb,proto3" json:"target_db,omitempty"`
	TargetTable     string                 `protobuf:"bytes,3,opt,name=target_table,json=targetTable,proto3" json:"target_table,omitempty"`
	SourceUri       string                 `protobuf:"bytes,4,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	Separator       string                 `protobuf:"bytes,11,opt,name=separator,proto3" json:"separator,omitempty"`
	Delimiter       string                 `protobuf:"bytes,12,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	BackslashEscape bool                   `protobuf:"varint,13,opt,name=backslash_escape,json=backslashEscape,proto3" json:"backslash_escape,omitempty"`
	IgnoreOneLine   bool                   `protobuf:"varint,14,opt,name=ignore_one_line,json=ignoreOneLine,proto3" json:"ignore_one_line,omitempty"`
	Terminator      string                 `protobuf:"bytes,15,opt,name=terminator,proto3" json:"terminator,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

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

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

func (*LoadDataReq) ProtoMessage() {}

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

func (x *LoadDataReq) GetCluster() *Cluster {
	if x != nil {
		return x.Cluster
	}
	return nil
}

func (x *LoadDataReq) GetTargetDb() string {
	if x != nil {
		return x.TargetDb
	}
	return ""
}

func (x *LoadDataReq) GetTargetTable() string {
	if x != nil {
		return x.TargetTable
	}
	return ""
}

func (x *LoadDataReq) GetSourceUri() string {
	if x != nil {
		return x.SourceUri
	}
	return ""
}

func (x *LoadDataReq) GetSeparator() string {
	if x != nil {
		return x.Separator
	}
	return ""
}

func (x *LoadDataReq) GetDelimiter() string {
	if x != nil {
		return x.Delimiter
	}
	return ""
}

func (x *LoadDataReq) GetBackslashEscape() bool {
	if x != nil {
		return x.BackslashEscape
	}
	return false
}

func (x *LoadDataReq) GetIgnoreOneLine() bool {
	if x != nil {
		return x.IgnoreOneLine
	}
	return false
}

func (x *LoadDataReq) GetTerminator() string {
	if x != nil {
		return x.Terminator
	}
	return ""
}

type LoadDataResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ErrMessage    string                 `protobuf:"bytes,1,opt,name=err_message,json=errMessage,proto3" json:"err_message,omitempty"` // string warning_message = 2;
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*LoadDataResp) ProtoMessage() {}

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

func (x *LoadDataResp) GetErrMessage() string {
	if x != nil {
		return x.ErrMessage
	}
	return ""
}

type LightningPrecheckReq struct {
	state             protoimpl.MessageState `protogen:"open.v1"`
	LightningConfig   string                 `protobuf:"bytes,1,opt,name=lightning_config,json=lightningConfig,proto3" json:"lightning_config,omitempty"`
	CheckItems        []CheckItem            `protobuf:"varint,2,rep,packed,name=check_items,json=checkItems,proto3,enum=agent.CheckItem" json:"check_items,omitempty"`
	ClusterNamespace  string                 `protobuf:"bytes,3,opt,name=cluster_namespace,json=clusterNamespace,proto3" json:"cluster_namespace,omitempty"`
	ClusterNamePrefix string                 `protobuf:"bytes,4,opt,name=cluster_name_prefix,json=clusterNamePrefix,proto3" json:"cluster_name_prefix,omitempty"`
	GenGcpCredential  bool                   `protobuf:"varint,5,opt,name=gen_gcp_credential,json=genGcpCredential,proto3" json:"gen_gcp_credential,omitempty"`
	ProviderType      string                 `protobuf:"bytes,6,opt,name=provider_type,json=providerType,proto3" json:"provider_type,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

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

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

func (*LightningPrecheckReq) ProtoMessage() {}

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

func (x *LightningPrecheckReq) GetLightningConfig() string {
	if x != nil {
		return x.LightningConfig
	}
	return ""
}

func (x *LightningPrecheckReq) GetCheckItems() []CheckItem {
	if x != nil {
		return x.CheckItems
	}
	return nil
}

func (x *LightningPrecheckReq) GetClusterNamespace() string {
	if x != nil {
		return x.ClusterNamespace
	}
	return ""
}

func (x *LightningPrecheckReq) GetClusterNamePrefix() string {
	if x != nil {
		return x.ClusterNamePrefix
	}
	return ""
}

func (x *LightningPrecheckReq) GetGenGcpCredential() bool {
	if x != nil {
		return x.GenGcpCredential
	}
	return false
}

func (x *LightningPrecheckReq) GetProviderType() string {
	if x != nil {
		return x.ProviderType
	}
	return ""
}

type LightningPrecheckResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	CheckResults  []*CheckResult         `protobuf:"bytes,1,rep,name=check_results,json=checkResults,proto3" json:"check_results,omitempty"`
	BaseResp      *base.BaseResp         `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*LightningPrecheckResp) ProtoMessage() {}

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

func (x *LightningPrecheckResp) GetCheckResults() []*CheckResult {
	if x != nil {
		return x.CheckResults
	}
	return nil
}

func (x *LightningPrecheckResp) GetBaseResp() *base.BaseResp {
	if x != nil {
		return x.BaseResp
	}
	return nil
}

type CheckResult struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	CheckItem     CheckItem              `protobuf:"varint,1,opt,name=check_item,json=checkItem,proto3,enum=agent.CheckItem" json:"check_item,omitempty"`
	HasPassed     bool                   `protobuf:"varint,2,opt,name=has_passed,json=hasPassed,proto3" json:"has_passed,omitempty"`
	Msg           string                 `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CheckResult) ProtoMessage() {}

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

func (x *CheckResult) GetCheckItem() CheckItem {
	if x != nil {
		return x.CheckItem
	}
	return CheckItem_CHECK_ITEM_UNKNOWN
}

func (x *CheckResult) GetHasPassed() bool {
	if x != nil {
		return x.HasPassed
	}
	return false
}

func (x *CheckResult) GetMsg() string {
	if x != nil {
		return x.Msg
	}
	return ""
}

type ExecSQLReq struct {
	state   protoimpl.MessageState `protogen:"open.v1"`
	Cluster *Cluster               `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Sql     string                 `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// column_num represents the column numbers in the SQL sentence
	ColumnNum     uint64   `protobuf:"varint,3,opt,name=column_num,json=columnNum,proto3" json:"column_num,omitempty"`
	TypedColumns  bool     `protobuf:"varint,4,opt,name=typed_columns,json=typedColumns,proto3" json:"typed_columns,omitempty"` // if true, the response rows will contain typed column values
	SetupSqls     []string `protobuf:"bytes,5,rep,name=setup_sqls,json=setupSqls,proto3" json:"setup_sqls,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*ExecSQLReq) ProtoMessage() {}

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

func (x *ExecSQLReq) GetCluster() *Cluster {
	if x != nil {
		return x.Cluster
	}
	return nil
}

func (x *ExecSQLReq) GetSql() string {
	if x != nil {
		return x.Sql
	}
	return ""
}

func (x *ExecSQLReq) GetColumnNum() uint64 {
	if x != nil {
		return x.ColumnNum
	}
	return 0
}

func (x *ExecSQLReq) GetTypedColumns() bool {
	if x != nil {
		return x.TypedColumns
	}
	return false
}

func (x *ExecSQLReq) GetSetupSqls() []string {
	if x != nil {
		return x.SetupSqls
	}
	return nil
}

type ExecSQLResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ErrorMsg      string                 `protobuf:"bytes,1,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	SqlResult     string                 `protobuf:"bytes,2,opt,name=sql_result,json=sqlResult,proto3" json:"sql_result,omitempty"`
	Rows          []*Row                 `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	ColumnNames   []string               `protobuf:"bytes,4,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*ExecSQLResp) ProtoMessage() {}

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

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

func (x *ExecSQLResp) GetSqlResult() string {
	if x != nil {
		return x.SqlResult
	}
	return ""
}

func (x *ExecSQLResp) GetRows() []*Row {
	if x != nil {
		return x.Rows
	}
	return nil
}

func (x *ExecSQLResp) GetColumnNames() []string {
	if x != nil {
		return x.ColumnNames
	}
	return nil
}

type LightningSourcePreviewReq struct {
	state             protoimpl.MessageState `protogen:"open.v1"`
	LightningConfig   string                 `protobuf:"bytes,1,opt,name=lightning_config,json=lightningConfig,proto3" json:"lightning_config,omitempty"`
	ClusterNamespace  string                 `protobuf:"bytes,2,opt,name=cluster_namespace,json=clusterNamespace,proto3" json:"cluster_namespace,omitempty"`
	ClusterNamePrefix string                 `protobuf:"bytes,3,opt,name=cluster_name_prefix,json=clusterNamePrefix,proto3" json:"cluster_name_prefix,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

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

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

func (*LightningSourcePreviewReq) ProtoMessage() {}

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

func (x *LightningSourcePreviewReq) GetLightningConfig() string {
	if x != nil {
		return x.LightningConfig
	}
	return ""
}

func (x *LightningSourcePreviewReq) GetClusterNamespace() string {
	if x != nil {
		return x.ClusterNamespace
	}
	return ""
}

func (x *LightningSourcePreviewReq) GetClusterNamePrefix() string {
	if x != nil {
		return x.ClusterNamePrefix
	}
	return ""
}

type LightningSourcePreviewResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Schemas       []*Schema              `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	BaseResp      *base.BaseResp         `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*LightningSourcePreviewResp) ProtoMessage() {}

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

func (x *LightningSourcePreviewResp) GetSchemas() []*Schema {
	if x != nil {
		return x.Schemas
	}
	return nil
}

func (x *LightningSourcePreviewResp) GetBaseResp() *base.BaseResp {
	if x != nil {
		return x.BaseResp
	}
	return nil
}

type EstimateSourceDataSizeReq struct {
	state             protoimpl.MessageState `protogen:"open.v1"`
	LightningConfig   string                 `protobuf:"bytes,1,opt,name=lightning_config,json=lightningConfig,proto3" json:"lightning_config,omitempty"`
	ClusterNamespace  string                 `protobuf:"bytes,2,opt,name=cluster_namespace,json=clusterNamespace,proto3" json:"cluster_namespace,omitempty"`
	ClusterNamePrefix string                 `protobuf:"bytes,3,opt,name=cluster_name_prefix,json=clusterNamePrefix,proto3" json:"cluster_name_prefix,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

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

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

func (*EstimateSourceDataSizeReq) ProtoMessage() {}

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

func (x *EstimateSourceDataSizeReq) GetLightningConfig() string {
	if x != nil {
		return x.LightningConfig
	}
	return ""
}

func (x *EstimateSourceDataSizeReq) GetClusterNamespace() string {
	if x != nil {
		return x.ClusterNamespace
	}
	return ""
}

func (x *EstimateSourceDataSizeReq) GetClusterNamePrefix() string {
	if x != nil {
		return x.ClusterNamePrefix
	}
	return ""
}

type EstimateSourceDataSizeResp struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	SizeWithIndex    uint64                 `protobuf:"varint,1,opt,name=size_with_index,json=sizeWithIndex,proto3" json:"size_with_index,omitempty"`
	SizeWithoutIndex uint64                 `protobuf:"varint,2,opt,name=size_without_index,json=sizeWithoutIndex,proto3" json:"size_without_index,omitempty"`
	BaseResp         *base.BaseResp         `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

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

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

func (*EstimateSourceDataSizeResp) ProtoMessage() {}

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

func (x *EstimateSourceDataSizeResp) GetSizeWithIndex() uint64 {
	if x != nil {
		return x.SizeWithIndex
	}
	return 0
}

func (x *EstimateSourceDataSizeResp) GetSizeWithoutIndex() uint64 {
	if x != nil {
		return x.SizeWithoutIndex
	}
	return 0
}

func (x *EstimateSourceDataSizeResp) GetBaseResp() *base.BaseResp {
	if x != nil {
		return x.BaseResp
	}
	return nil
}

type CheckDBConnectivityReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Host          string                 `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port          uint32                 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	User          string                 `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Password      string                 `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	SslCa         string                 `protobuf:"bytes,5,opt,name=ssl_ca,json=sslCa,proto3" json:"ssl_ca,omitempty"`
	SslCert       string                 `protobuf:"bytes,6,opt,name=ssl_cert,json=sslCert,proto3" json:"ssl_cert,omitempty"`
	SslKey        string                 `protobuf:"bytes,7,opt,name=ssl_key,json=sslKey,proto3" json:"ssl_key,omitempty"`
	RequestId     string                 `protobuf:"bytes,200,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CheckDBConnectivityReq) ProtoMessage() {}

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

func (x *CheckDBConnectivityReq) GetHost() string {
	if x != nil {
		return x.Host
	}
	return ""
}

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

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

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

func (x *CheckDBConnectivityReq) GetSslCa() string {
	if x != nil {
		return x.SslCa
	}
	return ""
}

func (x *CheckDBConnectivityReq) GetSslCert() string {
	if x != nil {
		return x.SslCert
	}
	return ""
}

func (x *CheckDBConnectivityReq) GetSslKey() string {
	if x != nil {
		return x.SslKey
	}
	return ""
}

func (x *CheckDBConnectivityReq) GetRequestId() string {
	if x != nil {
		return x.RequestId
	}
	return ""
}

type CheckDBConnectivityResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	DbVersion     string                 `protobuf:"bytes,1,opt,name=db_version,json=dbVersion,proto3" json:"db_version,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*CheckDBConnectivityResp) ProtoMessage() {}

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

func (x *CheckDBConnectivityResp) GetDbVersion() string {
	if x != nil {
		return x.DbVersion
	}
	return ""
}

type GetTiDBServerSecretReq struct {
	state             protoimpl.MessageState `protogen:"open.v1"`
	ClusterNamePrefix string                 `protobuf:"bytes,1,opt,name=cluster_name_prefix,json=clusterNamePrefix,proto3" json:"cluster_name_prefix,omitempty"`
	ClusterNamespace  string                 `protobuf:"bytes,2,opt,name=cluster_namespace,json=clusterNamespace,proto3" json:"cluster_namespace,omitempty"`
	ProviderType      string                 `protobuf:"bytes,3,opt,name=provider_type,json=providerType,proto3" json:"provider_type,omitempty"`
	RequestId         string                 `protobuf:"bytes,200,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

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

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

func (*GetTiDBServerSecretReq) ProtoMessage() {}

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

func (x *GetTiDBServerSecretReq) GetClusterNamePrefix() string {
	if x != nil {
		return x.ClusterNamePrefix
	}
	return ""
}

func (x *GetTiDBServerSecretReq) GetClusterNamespace() string {
	if x != nil {
		return x.ClusterNamespace
	}
	return ""
}

func (x *GetTiDBServerSecretReq) GetProviderType() string {
	if x != nil {
		return x.ProviderType
	}
	return ""
}

func (x *GetTiDBServerSecretReq) GetRequestId() string {
	if x != nil {
		return x.RequestId
	}
	return ""
}

type GetTiDBServerSecretResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	SslCa         string                 `protobuf:"bytes,1,opt,name=ssl_ca,json=sslCa,proto3" json:"ssl_ca,omitempty"`
	SslCert       string                 `protobuf:"bytes,2,opt,name=ssl_cert,json=sslCert,proto3" json:"ssl_cert,omitempty"`
	SslKey        string                 `protobuf:"bytes,3,opt,name=ssl_key,json=sslKey,proto3" json:"ssl_key,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetTiDBServerSecretResp) Reset() {
	*x = GetTiDBServerSecretResp{}
	mi := &file_agent_agent_proto_msgTypes[35]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetTiDBServerSecretResp) ProtoMessage() {}

func (x *GetTiDBServerSecretResp) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[35]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use GetTiDBServerSecretResp.ProtoReflect.Descriptor instead.
func (*GetTiDBServerSecretResp) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{35}
}

func (x *GetTiDBServerSecretResp) GetSslCa() string {
	if x != nil {
		return x.SslCa
	}
	return ""
}

func (x *GetTiDBServerSecretResp) GetSslCert() string {
	if x != nil {
		return x.SslCert
	}
	return ""
}

func (x *GetTiDBServerSecretResp) GetSslKey() string {
	if x != nil {
		return x.SslKey
	}
	return ""
}

type GetClusterClientSecretReq struct {
	state             protoimpl.MessageState `protogen:"open.v1"`
	ClusterNamePrefix string                 `protobuf:"bytes,1,opt,name=cluster_name_prefix,json=clusterNamePrefix,proto3" json:"cluster_name_prefix,omitempty"`
	ClusterNamespace  string                 `protobuf:"bytes,2,opt,name=cluster_namespace,json=clusterNamespace,proto3" json:"cluster_namespace,omitempty"`
	ProviderType      string                 `protobuf:"bytes,3,opt,name=provider_type,json=providerType,proto3" json:"provider_type,omitempty"`
	RequestId         string                 `protobuf:"bytes,200,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

func (x *GetClusterClientSecretReq) Reset() {
	*x = GetClusterClientSecretReq{}
	mi := &file_agent_agent_proto_msgTypes[36]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetClusterClientSecretReq) ProtoMessage() {}

func (x *GetClusterClientSecretReq) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[36]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use GetClusterClientSecretReq.ProtoReflect.Descriptor instead.
func (*GetClusterClientSecretReq) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{36}
}

func (x *GetClusterClientSecretReq) GetClusterNamePrefix() string {
	if x != nil {
		return x.ClusterNamePrefix
	}
	return ""
}

func (x *GetClusterClientSecretReq) GetClusterNamespace() string {
	if x != nil {
		return x.ClusterNamespace
	}
	return ""
}

func (x *GetClusterClientSecretReq) GetProviderType() string {
	if x != nil {
		return x.ProviderType
	}
	return ""
}

func (x *GetClusterClientSecretReq) GetRequestId() string {
	if x != nil {
		return x.RequestId
	}
	return ""
}

type GetClusterClientSecretResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	SslCa         string                 `protobuf:"bytes,1,opt,name=ssl_ca,json=sslCa,proto3" json:"ssl_ca,omitempty"`
	SslCert       string                 `protobuf:"bytes,2,opt,name=ssl_cert,json=sslCert,proto3" json:"ssl_cert,omitempty"`
	SslKey        string                 `protobuf:"bytes,3,opt,name=ssl_key,json=sslKey,proto3" json:"ssl_key,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetClusterClientSecretResp) Reset() {
	*x = GetClusterClientSecretResp{}
	mi := &file_agent_agent_proto_msgTypes[37]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetClusterClientSecretResp) ProtoMessage() {}

func (x *GetClusterClientSecretResp) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[37]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use GetClusterClientSecretResp.ProtoReflect.Descriptor instead.
func (*GetClusterClientSecretResp) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{37}
}

func (x *GetClusterClientSecretResp) GetSslCa() string {
	if x != nil {
		return x.SslCa
	}
	return ""
}

func (x *GetClusterClientSecretResp) GetSslCert() string {
	if x != nil {
		return x.SslCert
	}
	return ""
}

func (x *GetClusterClientSecretResp) GetSslKey() string {
	if x != nil {
		return x.SslKey
	}
	return ""
}

type ImportsSchemaMeta struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	CreateFile      string                 `protobuf:"bytes,1,opt,name=create_file,json=createFile,proto3" json:"create_file,omitempty"`
	MaxDataFileSize uint64                 `protobuf:"varint,2,opt,name=max_data_file_size,json=maxDataFileSize,proto3" json:"max_data_file_size,omitempty"`
	// map: <table id, table meta>
	TablesMeta     map[string]*ImportsTableMeta `protobuf:"bytes,3,rep,name=tables_meta,json=tablesMeta,proto3" json:"tables_meta,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	CreateFileSize uint64                       `protobuf:"varint,4,opt,name=create_file_size,json=createFileSize,proto3" json:"create_file_size,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *ImportsSchemaMeta) Reset() {
	*x = ImportsSchemaMeta{}
	mi := &file_agent_agent_proto_msgTypes[38]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportsSchemaMeta) ProtoMessage() {}

func (x *ImportsSchemaMeta) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[38]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ImportsSchemaMeta.ProtoReflect.Descriptor instead.
func (*ImportsSchemaMeta) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{38}
}

func (x *ImportsSchemaMeta) GetCreateFile() string {
	if x != nil {
		return x.CreateFile
	}
	return ""
}

func (x *ImportsSchemaMeta) GetMaxDataFileSize() uint64 {
	if x != nil {
		return x.MaxDataFileSize
	}
	return 0
}

func (x *ImportsSchemaMeta) GetTablesMeta() map[string]*ImportsTableMeta {
	if x != nil {
		return x.TablesMeta
	}
	return nil
}

func (x *ImportsSchemaMeta) GetCreateFileSize() uint64 {
	if x != nil {
		return x.CreateFileSize
	}
	return 0
}

type ImportsTableMeta struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	Name            string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CreateFile      string                 `protobuf:"bytes,2,opt,name=create_file,json=createFile,proto3" json:"create_file,omitempty"`
	DataFileNum     uint64                 `protobuf:"varint,3,opt,name=data_file_num,json=dataFileNum,proto3" json:"data_file_num,omitempty"`
	DataFileSize    uint64                 `protobuf:"varint,4,opt,name=data_file_size,json=dataFileSize,proto3" json:"data_file_size,omitempty"`
	FirstDataFile   string                 `protobuf:"bytes,5,opt,name=first_data_file,json=firstDataFile,proto3" json:"first_data_file,omitempty"`
	MaxDataFileSize uint64                 `protobuf:"varint,6,opt,name=max_data_file_size,json=maxDataFileSize,proto3" json:"max_data_file_size,omitempty"`
	CreateFileSize  uint64                 `protobuf:"varint,7,opt,name=create_file_size,json=createFileSize,proto3" json:"create_file_size,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *ImportsTableMeta) Reset() {
	*x = ImportsTableMeta{}
	mi := &file_agent_agent_proto_msgTypes[39]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportsTableMeta) ProtoMessage() {}

func (x *ImportsTableMeta) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[39]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ImportsTableMeta.ProtoReflect.Descriptor instead.
func (*ImportsTableMeta) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{39}
}

func (x *ImportsTableMeta) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *ImportsTableMeta) GetCreateFile() string {
	if x != nil {
		return x.CreateFile
	}
	return ""
}

func (x *ImportsTableMeta) GetDataFileNum() uint64 {
	if x != nil {
		return x.DataFileNum
	}
	return 0
}

func (x *ImportsTableMeta) GetDataFileSize() uint64 {
	if x != nil {
		return x.DataFileSize
	}
	return 0
}

func (x *ImportsTableMeta) GetFirstDataFile() string {
	if x != nil {
		return x.FirstDataFile
	}
	return ""
}

func (x *ImportsTableMeta) GetMaxDataFileSize() uint64 {
	if x != nil {
		return x.MaxDataFileSize
	}
	return 0
}

func (x *ImportsTableMeta) GetCreateFileSize() uint64 {
	if x != nil {
		return x.CreateFileSize
	}
	return 0
}

type GetImportSchemasMetaReq struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	LightningConfig string                 `protobuf:"bytes,1,opt,name=lightning_config,json=lightningConfig,proto3" json:"lightning_config,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *GetImportSchemasMetaReq) Reset() {
	*x = GetImportSchemasMetaReq{}
	mi := &file_agent_agent_proto_msgTypes[40]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetImportSchemasMetaReq) ProtoMessage() {}

func (x *GetImportSchemasMetaReq) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[40]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use GetImportSchemasMetaReq.ProtoReflect.Descriptor instead.
func (*GetImportSchemasMetaReq) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{40}
}

func (x *GetImportSchemasMetaReq) GetLightningConfig() string {
	if x != nil {
		return x.LightningConfig
	}
	return ""
}

type GetImportSchemasMetaResp struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// map: <schema id, schema meta>
	SchemasMeta   map[string]*ImportsSchemaMeta `protobuf:"bytes,1,rep,name=schemas_meta,json=schemasMeta,proto3" json:"schemas_meta,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	BaseResp      *base.BaseResp                `protobuf:"bytes,255,opt,name=base_resp,json=baseResp,proto3" json:"base_resp,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetImportSchemasMetaResp) Reset() {
	*x = GetImportSchemasMetaResp{}
	mi := &file_agent_agent_proto_msgTypes[41]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetImportSchemasMetaResp) ProtoMessage() {}

func (x *GetImportSchemasMetaResp) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[41]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use GetImportSchemasMetaResp.ProtoReflect.Descriptor instead.
func (*GetImportSchemasMetaResp) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{41}
}

func (x *GetImportSchemasMetaResp) GetSchemasMeta() map[string]*ImportsSchemaMeta {
	if x != nil {
		return x.SchemasMeta
	}
	return nil
}

func (x *GetImportSchemasMetaResp) GetBaseResp() *base.BaseResp {
	if x != nil {
		return x.BaseResp
	}
	return nil
}

type Row struct {
	state             protoimpl.MessageState `protogen:"open.v1"`
	ColumnValues      []string               `protobuf:"bytes,1,rep,name=column_values,json=columnValues,proto3" json:"column_values,omitempty"`
	TypedColumnValues []*ColumnValue         `protobuf:"bytes,2,rep,name=typed_column_values,json=typedColumnValues,proto3" json:"typed_column_values,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

func (x *Row) Reset() {
	*x = Row{}
	mi := &file_agent_agent_proto_msgTypes[42]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*Row) ProtoMessage() {}

func (x *Row) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[42]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Row.ProtoReflect.Descriptor instead.
func (*Row) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{42}
}

func (x *Row) GetColumnValues() []string {
	if x != nil {
		return x.ColumnValues
	}
	return nil
}

func (x *Row) GetTypedColumnValues() []*ColumnValue {
	if x != nil {
		return x.TypedColumnValues
	}
	return nil
}

type ColumnValue struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Value:
	//
	//	*ColumnValue_StringValue
	//	*ColumnValue_Int64Value
	//	*ColumnValue_DoubleValue
	//	*ColumnValue_BoolValue
	//	*ColumnValue_TimestampValue
	Value         isColumnValue_Value `protobuf_oneof:"value"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ColumnValue) Reset() {
	*x = ColumnValue{}
	mi := &file_agent_agent_proto_msgTypes[43]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ColumnValue) ProtoMessage() {}

func (x *ColumnValue) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[43]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ColumnValue.ProtoReflect.Descriptor instead.
func (*ColumnValue) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{43}
}

func (x *ColumnValue) GetValue() isColumnValue_Value {
	if x != nil {
		return x.Value
	}
	return nil
}

func (x *ColumnValue) GetStringValue() string {
	if x != nil {
		if x, ok := x.Value.(*ColumnValue_StringValue); ok {
			return x.StringValue
		}
	}
	return ""
}

func (x *ColumnValue) GetInt64Value() int64 {
	if x != nil {
		if x, ok := x.Value.(*ColumnValue_Int64Value); ok {
			return x.Int64Value
		}
	}
	return 0
}

func (x *ColumnValue) GetDoubleValue() float64 {
	if x != nil {
		if x, ok := x.Value.(*ColumnValue_DoubleValue); ok {
			return x.DoubleValue
		}
	}
	return 0
}

func (x *ColumnValue) GetBoolValue() bool {
	if x != nil {
		if x, ok := x.Value.(*ColumnValue_BoolValue); ok {
			return x.BoolValue
		}
	}
	return false
}

func (x *ColumnValue) GetTimestampValue() *timestamppb.Timestamp {
	if x != nil {
		if x, ok := x.Value.(*ColumnValue_TimestampValue); ok {
			return x.TimestampValue
		}
	}
	return nil
}

type isColumnValue_Value interface {
	isColumnValue_Value()
}

type ColumnValue_StringValue struct {
	StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type ColumnValue_Int64Value struct {
	Int64Value int64 `protobuf:"varint,2,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type ColumnValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type ColumnValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type ColumnValue_TimestampValue struct {
	TimestampValue *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp_value,json=timestampValue,proto3,oneof"` // for datetime, timestamp, date
}

func (*ColumnValue_StringValue) isColumnValue_Value() {}

func (*ColumnValue_Int64Value) isColumnValue_Value() {}

func (*ColumnValue_DoubleValue) isColumnValue_Value() {}

func (*ColumnValue_BoolValue) isColumnValue_Value() {}

func (*ColumnValue_TimestampValue) isColumnValue_Value() {}

type Table struct {
	state        protoimpl.MessageState `protogen:"open.v1"`
	SchemaName   string                 `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	TableName    string                 `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	RowHeaders   []string               `protobuf:"bytes,3,rep,name=row_headers,json=rowHeaders,proto3" json:"row_headers,omitempty"`
	RowValues    []*Row                 `protobuf:"bytes,4,rep,name=row_values,json=rowValues,proto3" json:"row_values,omitempty"`
	RowDataTypes []string               `protobuf:"bytes,5,rep,name=row_data_types,json=rowDataTypes,proto3" json:"row_data_types,omitempty"`
	ColumnIsPk   []bool                 `protobuf:"varint,6,rep,packed,name=column_is_pk,json=columnIsPk,proto3" json:"column_is_pk,omitempty"`
	// column_auto_gen represents column is auto_increment or auto_random
	ColumnAutoGen []bool `protobuf:"varint,7,rep,packed,name=column_auto_gen,json=columnAutoGen,proto3" json:"column_auto_gen,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Table) Reset() {
	*x = Table{}
	mi := &file_agent_agent_proto_msgTypes[44]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*Table) ProtoMessage() {}

func (x *Table) ProtoReflect() protoreflect.Message {
	mi := &file_agent_agent_proto_msgTypes[44]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Table.ProtoReflect.Descriptor instead.
func (*Table) Descriptor() ([]byte, []int) {
	return file_agent_agent_proto_rawDescGZIP(), []int{44}
}

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

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

func (x *Table) GetRowHeaders() []string {
	if x != nil {
		return x.RowHeaders
	}
	return nil
}

func (x *Table) GetRowValues() []*Row {
	if x != nil {
		return x.RowValues
	}
	return nil
}

func (x *Table) GetRowDataTypes() []string {
	if x != nil {
		return x.RowDataTypes
	}
	return nil
}

func (x *Table) GetColumnIsPk() []bool {
	if x != nil {
		return x.ColumnIsPk
	}
	return nil
}

func (x *Table) GetColumnAutoGen() []bool {
	if x != nil {
		return x.ColumnAutoGen
	}
	return nil
}

type Schema struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	SchemaName    string                 `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	Tables        []*Table               `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Schema) Reset() {
	*x = Schema{}
	mi := &file_agent_agent_proto_msgTypes[45]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*Schema) ProtoMessage() {}

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

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

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

type PrecheckDMJobReq struct {
	state               protoimpl.MessageState `protogen:"open.v1"`
	ReqId               string                 `protobuf:"bytes,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	FullInstanceMigrate bool                   `protobuf:"varint,2,opt,name=full_instance_migrate,json=fullInstanceMigrate,proto3" json:"full_instance_migrate,omitempty"`
	TaskConfig          []string               `protobuf:"bytes,3,rep,name=task_config,json=taskConfig,proto3" json:"task_config,omitempty"`
	// TODO: support multiple sources
	ClusterPassword string `protobuf:"bytes,4,opt,name=cluster_password,json=clusterPassword,proto3" json:"cluster_password,omitempty"`
	Password        string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *PrecheckDMJobReq) Reset() {
	*x = PrecheckDMJobReq{}
	mi := &file_agent_agent_proto_msgTypes[46]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*PrecheckDMJobReq) ProtoMessage() {}

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

func (x *PrecheckDMJobReq) GetReqId() string {
	if x != nil {
		return x.ReqId
	}
	return ""
}

func (x *PrecheckDMJobReq) GetFullInstanceMigrate() bool {
	if x != nil {
		return x.FullInstanceMigrate
	}
	return false
}

func (x *PrecheckDMJobReq) GetTaskConfig() []string {
	if x != nil {
		return x.TaskConfig
	}
	return nil
}

func (x *PrecheckDMJobReq) GetClusterPassword() string {
	if x != nil {
		return x.ClusterPassword
	}
	return ""
}

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

type GcsOptions struct {
	state                     protoimpl.MessageState `protogen:"open.v1"`
	ImpersonateServiceAccount string                 `protobuf:"bytes,1,opt,name=impersonate_service_account,json=impersonateServiceAccount,proto3" json:"impersonate_service_account,omitempty"`
	unknownFields             protoimpl.UnknownFields
	sizeCache                 protoimpl.SizeCache
}

func (x *GcsOptions) Reset() {
	*x = GcsOptions{}
	mi := &file_agent_agent_proto_msgTypes[47]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GcsOptions) ProtoMessage() {}

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

func (x *GcsOptions) GetImpersonateServiceAccount() string {
	if x != nil {
		return x.ImpersonateServiceAccount
	}
	return ""
}

type PrecheckDMJobResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	CheckResults  []byte                 `protobuf:"bytes,2,opt,name=check_results,json=checkResults,proto3" json:"check_results,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PrecheckDMJobResp) Reset() {
	*x = PrecheckDMJobResp{}
	mi := &file_agent_agent_proto_msgTypes[48]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*PrecheckDMJobResp) ProtoMessage() {}

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

func (x *PrecheckDMJobResp) GetCheckResults() []byte {
	if x != nil {
		return x.CheckResults
	}
	return nil
}

type GetUserFileReq struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Deprecated: use `source_url` instead
	S3Url          string      `protobuf:"bytes,1,opt,name=s3_url,json=s3Url,proto3" json:"s3_url,omitempty"`
	RoleArn        string      `protobuf:"bytes,2,opt,name=role_arn,json=roleArn,proto3" json:"role_arn,omitempty"`
	ExternalId     string      `protobuf:"bytes,3,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	StartOffset    int64       `protobuf:"varint,4,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	EndOffset      int64       `protobuf:"varint,5,opt,name=end_offset,json=endOffset,proto3" json:"end_offset,omitempty"`
	SourceUrl      string      `protobuf:"bytes,6,opt,name=source_url,json=sourceUrl,proto3" json:"source_url,omitempty"`
	DataSourceType uint32      `protobuf:"varint,7,opt,name=data_source_type,json=dataSourceType,proto3" json:"data_source_type,omitempty"`
	GcsOptions     *GcsOptions `protobuf:"bytes,8,opt,name=gcs_options,json=gcsOptions,proto3" json:"gcs_options,omitempty"`
	SasToken       string      `protobuf:"bytes,9,opt,name=sas_token,json=sasToken,proto3" json:"sas_token,omitempty"`
	RequestId      string      `protobuf:"bytes,200,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *GetUserFileReq) Reset() {
	*x = GetUserFileReq{}
	mi := &file_agent_agent_proto_msgTypes[49]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetUserFileReq) ProtoMessage() {}

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

func (x *GetUserFileReq) GetS3Url() string {
	if x != nil {
		return x.S3Url
	}
	return ""
}

func (x *GetUserFileReq) GetRoleArn() string {
	if x != nil {
		return x.RoleArn
	}
	return ""
}

func (x *GetUserFileReq) GetExternalId() string {
	if x != nil {
		return x.ExternalId
	}
	return ""
}

func (x *GetUserFileReq) GetStartOffset() int64 {
	if x != nil {
		return x.StartOffset
	}
	return 0
}

func (x *GetUserFileReq) GetEndOffset() int64 {
	if x != nil {
		return x.EndOffset
	}
	return 0
}

func (x *GetUserFileReq) GetSourceUrl() string {
	if x != nil {
		return x.SourceUrl
	}
	return ""
}

func (x *GetUserFileReq) GetDataSourceType() uint32 {
	if x != nil {
		return x.DataSourceType
	}
	return 0
}

func (x *GetUserFileReq) GetGcsOptions() *GcsOptions {
	if x != nil {
		return x.GcsOptions
	}
	return nil
}

func (x *GetUserFileReq) GetSasToken() string {
	if x != nil {
		return x.SasToken
	}
	return ""
}

func (x *GetUserFileReq) GetRequestId() string {
	if x != nil {
		return x.RequestId
	}
	return ""
}

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

func (x *GetUserFileResp) Reset() {
	*x = GetUserFileResp{}
	mi := &file_agent_agent_proto_msgTypes[50]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetUserFileResp) ProtoMessage() {}

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

func (x *GetUserFileResp) GetContent() string {
	if x != nil {
		return x.Content
	}
	return ""
}

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

func (x *GetSourceTablesResp) Reset() {
	*x = GetSourceTablesResp{}
	mi := &file_agent_agent_proto_msgTypes[51]
	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_agent_agent_proto_msgTypes[51]
	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_agent_agent_proto_rawDescGZIP(), []int{51}
}

func (x *GetSourceTablesResp) GetSchemas() []*Schema {
	if x != nil {
		return x.Schemas
	}
	return nil
}

type GetSourceBinlogStatusResp struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	BinlogName      string                 `protobuf:"bytes,1,opt,name=binlog_name,json=binlogName,proto3" json:"binlog_name,omitempty"`
	BinlogPos       uint32                 `protobuf:"varint,2,opt,name=binlog_pos,json=binlogPos,proto3" json:"binlog_pos,omitempty"`
	BinlogDoDbs     string                 `protobuf:"bytes,3,opt,name=binlog_do_dbs,json=binlogDoDbs,proto3" json:"binlog_do_dbs,omitempty"`
	BinlogIgnoreDbs string                 `protobuf:"bytes,4,opt,name=binlog_ignore_dbs,json=binlogIgnoreDbs,proto3" json:"binlog_ignore_dbs,omitempty"`
	GtidStr         string                 `protobuf:"bytes,5,opt,name=gtid_str,json=gtidStr,proto3" json:"gtid_str,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *GetSourceBinlogStatusResp) Reset() {
	*x = GetSourceBinlogStatusResp{}
	mi := &file_agent_agent_proto_msgTypes[52]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetSourceBinlogStatusResp) ProtoMessage() {}

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

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

func (x *GetSourceBinlogStatusResp) GetBinlogPos() uint32 {
	if x != nil {
		return x.BinlogPos
	}
	return 0
}

func (x *GetSourceBinlogStatusResp) GetBinlogDoDbs() string {
	if x != nil {
		return x.BinlogDoDbs
	}
	return ""
}

func (x *GetSourceBinlogStatusResp) GetBinlogIgnoreDbs() string {
	if x != nil {
		return x.BinlogIgnoreDbs
	}
	return ""
}

func (x *GetSourceBinlogStatusResp) GetGtidStr() string {
	if x != nil {
		return x.GtidStr
	}
	return ""
}

type GetClusterTablesResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Schemas       []*Schema              `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetClusterTablesResp) Reset() {
	*x = GetClusterTablesResp{}
	mi := &file_agent_agent_proto_msgTypes[53]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetClusterTablesResp) ProtoMessage() {}

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

func (x *GetClusterTablesResp) GetSchemas() []*Schema {
	if x != nil {
		return x.Schemas
	}
	return nil
}

type NsLookupReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Host          string                 `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	RequestId     string                 `protobuf:"bytes,200,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *NsLookupReq) Reset() {
	*x = NsLookupReq{}
	mi := &file_agent_agent_proto_msgTypes[54]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*NsLookupReq) ProtoMessage() {}

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

func (x *NsLookupReq) GetHost() string {
	if x != nil {
		return x.Host
	}
	return ""
}

func (x *NsLookupReq) GetRequestId() string {
	if x != nil {
		return x.RequestId
	}
	return ""
}

type NsLookupResp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Ips           []string               `protobuf:"bytes,1,rep,name=ips,proto3" json:"ips,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *NsLookupResp) Reset() {
	*x = NsLookupResp{}
	mi := &file_agent_agent_proto_msgTypes[55]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*NsLookupResp) ProtoMessage() {}

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

func (x *NsLookupResp) GetIps() []string {
	if x != nil {
		return x.Ips
	}
	return nil
}

type ClearEmptyTablesReq struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Cluster       *Cluster               `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Tables        []*common.Table        `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ClearEmptyTablesReq) Reset() {
	*x = ClearEmptyTablesReq{}
	mi := &file_agent_agent_proto_msgTypes[56]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ClearEmptyTablesReq) ProtoMessage() {}

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

func (x *ClearEmptyTablesReq) GetCluster() *Cluster {
	if x != nil {
		return x.Cluster
	}
	return nil
}

func (x *ClearEmptyTablesReq) GetTables() []*common.Table {
	if x != nil {
		return x.Tables
	}
	return nil
}

type ClearEmptyTablesResp struct {
	state         protoimpl.MessageState         `protogen:"open.v1"`
	Results       []*ClearSingleEmptyTableResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ClearEmptyTablesResp) Reset() {
	*x = ClearEmptyTablesResp{}
	mi := &file_agent_agent_proto_msgTypes[57]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ClearEmptyTablesResp) ProtoMessage() {}

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

func (x *ClearEmptyTablesResp) GetResults() []*ClearSingleEmptyTableResult {
	if x != nil {
		return x.Results
	}
	return nil
}

type ClearSingleEmptyTableResult struct {
	state         protoimpl.MessageState             `protogen:"open.v1"`
	Table         *common.Table                      `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Result        ClearSingleEmptyTableResult_Result `protobuf:"varint,2,opt,name=result,proto3,enum=agent.ClearSingleEmptyTableResult_Result" json:"result,omitempty"`
	ErrMessage    string                             `protobuf:"bytes,3,opt,name=ErrMessage,proto3" json:"ErrMessage,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ClearSingleEmptyTableResult) Reset() {
	*x = ClearSingleEmptyTableResult{}
	mi := &file_agent_agent_proto_msgTypes[58]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ClearSingleEmptyTableResult) ProtoMessage() {}

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

func (x *ClearSingleEmptyTableResult) GetTable() *common.Table {
	if x != nil {
		return x.Table
	}
	return nil
}

func (x *ClearSingleEmptyTableResult) GetResult() ClearSingleEmptyTableResult_Result {
	if x != nil {
		return x.Result
	}
	return ClearSingleEmptyTableResult_Unknown
}

func (x *ClearSingleEmptyTableResult) GetErrMessage() string {
	if x != nil {
		return x.ErrMessage
	}
	return ""
}

// GetPublicKeyRequest is the request for fetching the agent's public key.
type GetPublicKeyRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetPublicKeyRequest) Reset() {
	*x = GetPublicKeyRequest{}
	mi := &file_agent_agent_proto_msgTypes[59]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetPublicKeyRequest) ProtoMessage() {}

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

// GetPublicKeyResponse contains the agent's public key.
type GetPublicKeyResponse struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The public key in PEM format.
	Pem           []byte `protobuf:"bytes,1,opt,name=pem,proto3" json:"pem,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetPublicKeyResponse) Reset() {
	*x = GetPublicKeyResponse{}
	mi := &file_agent_agent_proto_msgTypes[60]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetPublicKeyResponse) ProtoMessage() {}

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

func (x *GetPublicKeyResponse) GetPem() []byte {
	if x != nil {
		return x.Pem
	}
	return nil
}

type ImportSource struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The import source type.
	Type ImportSourceType_Enum `protobuf:"varint,1,opt,name=type,proto3,enum=agent.ImportSourceType_Enum" json:"type,omitempty"`
	// Types that are valid to be assigned to Source:
	//
	//	*ImportSource_S3
	//	*ImportSource_Gcs
	//	*ImportSource_AzureBlob
	Source        isImportSource_Source `protobuf_oneof:"source"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ImportSource) Reset() {
	*x = ImportSource{}
	mi := &file_agent_agent_proto_msgTypes[61]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportSource) ProtoMessage() {}

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

func (x *ImportSource) GetType() ImportSourceType_Enum {
	if x != nil {
		return x.Type
	}
	return ImportSourceType_UNSPECIFIED
}

func (x *ImportSource) GetSource() isImportSource_Source {
	if x != nil {
		return x.Source
	}
	return nil
}

func (x *ImportSource) GetS3() *S3Source {
	if x != nil {
		if x, ok := x.Source.(*ImportSource_S3); ok {
			return x.S3
		}
	}
	return nil
}

func (x *ImportSource) GetGcs() *GCSSource {
	if x != nil {
		if x, ok := x.Source.(*ImportSource_Gcs); ok {
			return x.Gcs
		}
	}
	return nil
}

func (x *ImportSource) GetAzureBlob() *AzureBlobSource {
	if x != nil {
		if x, ok := x.Source.(*ImportSource_AzureBlob); ok {
			return x.AzureBlob
		}
	}
	return nil
}

type isImportSource_Source interface {
	isImportSource_Source()
}

type ImportSource_S3 struct {
	S3 *S3Source `protobuf:"bytes,2,opt,name=s3,proto3,oneof"`
}

type ImportSource_Gcs struct {
	Gcs *GCSSource `protobuf:"bytes,3,opt,name=gcs,proto3,oneof"`
}

type ImportSource_AzureBlob struct {
	AzureBlob *AzureBlobSource `protobuf:"bytes,4,opt,name=azure_blob,json=azureBlob,proto3,oneof"`
}

func (*ImportSource_S3) isImportSource_Source() {}

func (*ImportSource_Gcs) isImportSource_Source() {}

func (*ImportSource_AzureBlob) isImportSource_Source() {}

type S3Source struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The S3 URI of the import source.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// The auth method of the import source.
	AuthType ImportS3AuthType_Enum `protobuf:"varint,2,opt,name=auth_type,json=authType,proto3,enum=agent.ImportS3AuthType_Enum" json:"auth_type,omitempty"`
	// Types that are valid to be assigned to Auth:
	//
	//	*S3Source_RoleArn_
	//	*S3Source_AccessKey_
	Auth isS3Source_Auth `protobuf_oneof:"auth"`
	// The target table information of the import.
	TargetTableInfos []*ImportTargetTableInfo `protobuf:"bytes,5,rep,name=target_table_infos,json=targetTableInfos,proto3" json:"target_table_infos,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *S3Source) Reset() {
	*x = S3Source{}
	mi := &file_agent_agent_proto_msgTypes[62]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*S3Source) ProtoMessage() {}

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

func (x *S3Source) GetUri() string {
	if x != nil {
		return x.Uri
	}
	return ""
}

func (x *S3Source) GetAuthType() ImportS3AuthType_Enum {
	if x != nil {
		return x.AuthType
	}
	return ImportS3AuthType_UNSPECIFIED
}

func (x *S3Source) GetAuth() isS3Source_Auth {
	if x != nil {
		return x.Auth
	}
	return nil
}

func (x *S3Source) GetRoleArn() *S3Source_RoleArn {
	if x != nil {
		if x, ok := x.Auth.(*S3Source_RoleArn_); ok {
			return x.RoleArn
		}
	}
	return nil
}

func (x *S3Source) GetAccessKey() *S3Source_AccessKey {
	if x != nil {
		if x, ok := x.Auth.(*S3Source_AccessKey_); ok {
			return x.AccessKey
		}
	}
	return nil
}

func (x *S3Source) GetTargetTableInfos() []*ImportTargetTableInfo {
	if x != nil {
		return x.TargetTableInfos
	}
	return nil
}

type isS3Source_Auth interface {
	isS3Source_Auth()
}

type S3Source_RoleArn_ struct {
	// The role arn
	RoleArn *S3Source_RoleArn `protobuf:"bytes,3,opt,name=role_arn,json=roleArn,proto3,oneof"`
}

type S3Source_AccessKey_ struct {
	// The access key.
	AccessKey *S3Source_AccessKey `protobuf:"bytes,4,opt,name=access_key,json=accessKey,proto3,oneof"`
}

func (*S3Source_RoleArn_) isS3Source_Auth() {}

func (*S3Source_AccessKey_) isS3Source_Auth() {}

type GCSSource struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The GCS URI of the import source.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// The auth method of the import source.
	AuthType ImportGcsAuthType_Enum `protobuf:"varint,2,opt,name=auth_type,json=authType,proto3,enum=agent.ImportGcsAuthType_Enum" json:"auth_type,omitempty"`
	// Types that are valid to be assigned to Auth:
	//
	//	*GCSSource_ServiceAccountKey
	Auth isGCSSource_Auth `protobuf_oneof:"auth"`
	// The target table information of the import.
	TargetTableInfos []*ImportTargetTableInfo `protobuf:"bytes,4,rep,name=target_table_infos,json=targetTableInfos,proto3" json:"target_table_infos,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *GCSSource) Reset() {
	*x = GCSSource{}
	mi := &file_agent_agent_proto_msgTypes[63]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GCSSource) ProtoMessage() {}

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

func (x *GCSSource) GetUri() string {
	if x != nil {
		return x.Uri
	}
	return ""
}

func (x *GCSSource) GetAuthType() ImportGcsAuthType_Enum {
	if x != nil {
		return x.AuthType
	}
	return ImportGcsAuthType_AUTH_TYPE_UNSPECIFIED
}

func (x *GCSSource) GetAuth() isGCSSource_Auth {
	if x != nil {
		return x.Auth
	}
	return nil
}

func (x *GCSSource) GetServiceAccountKey() string {
	if x != nil {
		if x, ok := x.Auth.(*GCSSource_ServiceAccountKey); ok {
			return x.ServiceAccountKey
		}
	}
	return ""
}

func (x *GCSSource) GetTargetTableInfos() []*ImportTargetTableInfo {
	if x != nil {
		return x.TargetTableInfos
	}
	return nil
}

type isGCSSource_Auth interface {
	isGCSSource_Auth()
}

type GCSSource_ServiceAccountKey struct {
	// The service account key
	ServiceAccountKey string `protobuf:"bytes,3,opt,name=service_account_key,json=serviceAccountKey,proto3,oneof"`
}

func (*GCSSource_ServiceAccountKey) isGCSSource_Auth() {}

type AzureBlobSource struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The Azure Blob URI of the import source.
	AuthType ImportAzureBlobAuthType_Enum `protobuf:"varint,1,opt,name=auth_type,json=authType,proto3,enum=agent.ImportAzureBlobAuthType_Enum" json:"auth_type,omitempty"`
	// Types that are valid to be assigned to Auth:
	//
	//	*AzureBlobSource_SasToken
	Auth isAzureBlobSource_Auth `protobuf_oneof:"auth"`
	// The Azure Blob URI of the import source. For example: azure://<account>.blob.core.windows.net/<container>/<path>.
	Uri string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	// The target table information of the import.
	TargetTableInfos []*ImportTargetTableInfo `protobuf:"bytes,4,rep,name=target_table_infos,json=targetTableInfos,proto3" json:"target_table_infos,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

func (x *AzureBlobSource) Reset() {
	*x = AzureBlobSource{}
	mi := &file_agent_agent_proto_msgTypes[64]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*AzureBlobSource) ProtoMessage() {}

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

func (x *AzureBlobSource) GetAuthType() ImportAzureBlobAuthType_Enum {
	if x != nil {
		return x.AuthType
	}
	return ImportAzureBlobAuthType_UNSPECIFIED
}

func (x *AzureBlobSource) GetAuth() isAzureBlobSource_Auth {
	if x != nil {
		return x.Auth
	}
	return nil
}

func (x *AzureBlobSource) GetSasToken() string {
	if x != nil {
		if x, ok := x.Auth.(*AzureBlobSource_SasToken); ok {
			return x.SasToken
		}
	}
	return ""
}

func (x *AzureBlobSource) GetUri() string {
	if x != nil {
		return x.Uri
	}
	return ""
}

func (x *AzureBlobSource) GetTargetTableInfos() []*ImportTargetTableInfo {
	if x != nil {
		return x.TargetTableInfos
	}
	return nil
}

type isAzureBlobSource_Auth interface {
	isAzureBlobSource_Auth()
}

type AzureBlobSource_SasToken struct {
	// The sas token. This field is input-only.
	SasToken string `protobuf:"bytes,2,opt,name=sas_token,json=sasToken,proto3,oneof"`
}

func (*AzureBlobSource_SasToken) isAzureBlobSource_Auth() {}

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

func (x *ImportSourceType) Reset() {
	*x = ImportSourceType{}
	mi := &file_agent_agent_proto_msgTypes[65]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportSourceType) ProtoMessage() {}

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

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

func (x *ImportS3AuthType) Reset() {
	*x = ImportS3AuthType{}
	mi := &file_agent_agent_proto_msgTypes[66]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportS3AuthType) ProtoMessage() {}

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

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

func (x *ImportGcsAuthType) Reset() {
	*x = ImportGcsAuthType{}
	mi := &file_agent_agent_proto_msgTypes[67]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportGcsAuthType) ProtoMessage() {}

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

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

func (x *ImportAzureBlobAuthType) Reset() {
	*x = ImportAzureBlobAuthType{}
	mi := &file_agent_agent_proto_msgTypes[68]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportAzureBlobAuthType) ProtoMessage() {}

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

type ImportTargetTableInfo struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TargetTable   *common.Table          `protobuf:"bytes,1,opt,name=target_table,json=targetTable,proto3" json:"target_table,omitempty"`
	CustomFile    string                 `protobuf:"bytes,2,opt,name=custom_file,json=customFile,proto3" json:"custom_file,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ImportTargetTableInfo) Reset() {
	*x = ImportTargetTableInfo{}
	mi := &file_agent_agent_proto_msgTypes[69]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportTargetTableInfo) ProtoMessage() {}

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

func (x *ImportTargetTableInfo) GetTargetTable() *common.Table {
	if x != nil {
		return x.TargetTable
	}
	return nil
}

func (x *ImportTargetTableInfo) GetCustomFile() string {
	if x != nil {
		return x.CustomFile
	}
	return ""
}

type ImportOptions struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The import file type.
	FileType ImportFileType_Enum `protobuf:"varint,1,opt,name=file_type,json=fileType,proto3,enum=agent.ImportFileType_Enum" json:"file_type,omitempty"`
	// Types that are valid to be assigned to Format:
	//
	//	*ImportOptions_CsvConfig
	Format isImportOptions_Format `protobuf_oneof:"format"`
	// Optional. Only used in tutorial.
	NeedDropTable bool `protobuf:"varint,3,opt,name=need_drop_table,json=needDropTable,proto3" json:"need_drop_table,omitempty"`
	// Optional. The display name of the import.
	DisplayName   string `protobuf:"bytes,4,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ImportOptions) Reset() {
	*x = ImportOptions{}
	mi := &file_agent_agent_proto_msgTypes[70]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportOptions) ProtoMessage() {}

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

func (x *ImportOptions) GetFileType() ImportFileType_Enum {
	if x != nil {
		return x.FileType
	}
	return ImportFileType_UNSPECIFIED
}

func (x *ImportOptions) GetFormat() isImportOptions_Format {
	if x != nil {
		return x.Format
	}
	return nil
}

func (x *ImportOptions) GetCsvConfig() *CsvConfig {
	if x != nil {
		if x, ok := x.Format.(*ImportOptions_CsvConfig); ok {
			return x.CsvConfig
		}
	}
	return nil
}

func (x *ImportOptions) GetNeedDropTable() bool {
	if x != nil {
		return x.NeedDropTable
	}
	return false
}

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

type isImportOptions_Format interface {
	isImportOptions_Format()
}

type ImportOptions_CsvConfig struct {
	// Optional. The CSV format.
	CsvConfig *CsvConfig `protobuf:"bytes,2,opt,name=csv_config,json=csvConfig,proto3,oneof"`
}

func (*ImportOptions_CsvConfig) isImportOptions_Format() {}

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

func (x *ImportFileType) Reset() {
	*x = ImportFileType{}
	mi := &file_agent_agent_proto_msgTypes[71]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*ImportFileType) ProtoMessage() {}

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

type EncryptedData struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The encrypted data.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The public key PEM string used for encryption.
	Pem           []byte `protobuf:"bytes,2,opt,name=pem,proto3" json:"pem,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *EncryptedData) Reset() {
	*x = EncryptedData{}
	mi := &file_agent_agent_proto_msgTypes[72]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*EncryptedData) ProtoMessage() {}

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

func (x *EncryptedData) GetData() []byte {
	if x != nil {
		return x.Data
	}
	return nil
}

func (x *EncryptedData) GetPem() []byte {
	if x != nil {
		return x.Pem
	}
	return nil
}

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

func (x *PrecheckImportFileReq_Source) Reset() {
	*x = PrecheckImportFileReq_Source{}
	mi := &file_agent_agent_proto_msgTypes[73]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*PrecheckImportFileReq_Source) ProtoMessage() {}

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

func (x *PrecheckImportFileReq_Source) GetTable() *common.Table {
	if x != nil {
		return x.Table
	}
	return nil
}

func (x *PrecheckImportFileReq_Source) GetFile() string {
	if x != nil {
		return x.File
	}
	return ""
}

type SearchImportFilesReq_TargetSource struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	TargetTable   *common.Table          `protobuf:"bytes,1,opt,name=target_table,json=targetTable,proto3" json:"target_table,omitempty"`
	CustomFile    string                 `protobuf:"bytes,3,opt,name=custom_file,json=customFile,proto3" json:"custom_file,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SearchImportFilesReq_TargetSource) Reset() {
	*x = SearchImportFilesReq_TargetSource{}
	mi := &file_agent_agent_proto_msgTypes[74]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SearchImportFilesReq_TargetSource) ProtoMessage() {}

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

func (x *SearchImportFilesReq_TargetSource) GetTargetTable() *common.Table {
	if x != nil {
		return x.TargetTable
	}
	return nil
}

func (x *SearchImportFilesReq_TargetSource) GetCustomFile() string {
	if x != nil {
		return x.CustomFile
	}
	return ""
}

type GetImportFilesResp_DataFileMeta struct {
	state         protoimpl.MessageState         `protogen:"open.v1"`
	Path          string                         `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Size          uint64                         `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	SourceType    GetImportFilesResp_SourceType  `protobuf:"varint,3,opt,name=source_type,json=sourceType,proto3,enum=agent.GetImportFilesResp_SourceType" json:"source_type,omitempty"`
	Compression   GetImportFilesResp_Compression `protobuf:"varint,4,opt,name=compression,proto3,enum=agent.GetImportFilesResp_Compression" json:"compression,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetImportFilesResp_DataFileMeta) Reset() {
	*x = GetImportFilesResp_DataFileMeta{}
	mi := &file_agent_agent_proto_msgTypes[75]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetImportFilesResp_DataFileMeta) ProtoMessage() {}

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

func (x *GetImportFilesResp_DataFileMeta) GetPath() string {
	if x != nil {
		return x.Path
	}
	return ""
}

func (x *GetImportFilesResp_DataFileMeta) GetSize() uint64 {
	if x != nil {
		return x.Size
	}
	return 0
}

func (x *GetImportFilesResp_DataFileMeta) GetSourceType() GetImportFilesResp_SourceType {
	if x != nil {
		return x.SourceType
	}
	return GetImportFilesResp_UNKNOWN_TYPE
}

func (x *GetImportFilesResp_DataFileMeta) GetCompression() GetImportFilesResp_Compression {
	if x != nil {
		return x.Compression
	}
	return GetImportFilesResp_UNKNOWN
}

type GetImportFilesResp_TableMeta struct {
	state         protoimpl.MessageState             `protogen:"open.v1"`
	Database      string                             `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table         string                             `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	DataFiles     []*GetImportFilesResp_DataFileMeta `protobuf:"bytes,3,rep,name=data_files,json=dataFiles,proto3" json:"data_files,omitempty"`
	TotalSize     uint64                             `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	WildcardPath  string                             `protobuf:"bytes,5,opt,name=wildcard_path,json=wildcardPath,proto3" json:"wildcard_path,omitempty"`
	SchemaFile    string                             `protobuf:"bytes,6,opt,name=schema_file,json=schemaFile,proto3" json:"schema_file,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetImportFilesResp_TableMeta) Reset() {
	*x = GetImportFilesResp_TableMeta{}
	mi := &file_agent_agent_proto_msgTypes[76]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*GetImportFilesResp_TableMeta) ProtoMessage() {}

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

func (x *GetImportFilesResp_TableMeta) GetDatabase() string {
	if x != nil {
		return x.Database
	}
	return ""
}

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

func (x *GetImportFilesResp_TableMeta) GetDataFiles() []*GetImportFilesResp_DataFileMeta {
	if x != nil {
		return x.DataFiles
	}
	return nil
}

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

func (x *GetImportFilesResp_TableMeta) GetWildcardPath() string {
	if x != nil {
		return x.WildcardPath
	}
	return ""
}

func (x *GetImportFilesResp_TableMeta) GetSchemaFile() string {
	if x != nil {
		return x.SchemaFile
	}
	return ""
}

type SearchImportFilesResp_TableMatch struct {
	state       protoimpl.MessageState `protogen:"open.v1"`
	TargetTable *common.Table          `protobuf:"bytes,1,opt,name=target_table,json=targetTable,proto3" json:"target_table,omitempty"`
	// if source_uri is empty, it means the table is not found in source
	SourceUri     string `protobuf:"bytes,2,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SearchImportFilesResp_TableMatch) Reset() {
	*x = SearchImportFilesResp_TableMatch{}
	mi := &file_agent_agent_proto_msgTypes[77]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*SearchImportFilesResp_TableMatch) ProtoMessage() {}

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

func (x *SearchImportFilesResp_TableMatch) GetTargetTable() *common.Table {
	if x != nil {
		return x.TargetTable
	}
	return nil
}

func (x *SearchImportFilesResp_TableMatch) GetSourceUri() string {
	if x != nil {
		return x.SourceUri
	}
	return ""
}

type S3Source_AccessKey struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The access key id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The secret access key. This field is input-only.
	Secret        string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *S3Source_AccessKey) Reset() {
	*x = S3Source_AccessKey{}
	mi := &file_agent_agent_proto_msgTypes[80]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*S3Source_AccessKey) ProtoMessage() {}

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

func (x *S3Source_AccessKey) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *S3Source_AccessKey) GetSecret() string {
	if x != nil {
		return x.Secret
	}
	return ""
}

type S3Source_RoleArn struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The role arn
	RoleArn string `protobuf:"bytes,1,opt,name=role_arn,json=roleArn,proto3" json:"role_arn,omitempty"`
	// The aws external id
	ExternalId    string `protobuf:"bytes,2,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *S3Source_RoleArn) Reset() {
	*x = S3Source_RoleArn{}
	mi := &file_agent_agent_proto_msgTypes[81]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

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

func (*S3Source_RoleArn) ProtoMessage() {}

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

func (x *S3Source_RoleArn) GetRoleArn() string {
	if x != nil {
		return x.RoleArn
	}
	return ""
}

func (x *S3Source_RoleArn) GetExternalId() string {
	if x != nil {
		return x.ExternalId
	}
	return ""
}

var File_agent_agent_proto protoreflect.FileDescriptor

const file_agent_agent_proto_rawDesc = "" +
	"\n" +
	"\x11agent/agent.proto\x12\x05agent\x1a\x0fbase/base.proto\x1a\x13common/common.proto\x1a\x1cgoogle/api/annotations.proto\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/httpbody.proto\x1a\x19google/protobuf/any.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\x1a\x17validate/validate.proto\"\xea\x01\n" +
	"\vTableResult\x120\n" +
	"\ftarget_table\x18\x01 \x01(\v2\r.common.TableR\vtargetTable\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x12,\n" +
	"\x12matched_data_files\x18\x03 \x03(\tR\x10matchedDataFiles\x12.\n" +
	"\x13matched_schema_file\x18\x04 \x01(\tR\x11matchedSchemaFile\x12&\n" +
	"\x0fuse_schema_file\x18\x05 \x01(\bR\ruseSchemaFile\"\xaa\x02\n" +
	"\x14PrecheckImportJobReq\x12\x1a\n" +
	"\x06org_id\x18\x01 \x01(\tB\x03\xe0A\x02R\x05orgId\x12\"\n" +
	"\n" +
	"project_id\x18\x02 \x01(\tB\x03\xe0A\x02R\tprojectId\x12\"\n" +
	"\n" +
	"cluster_id\x18\x03 \x01(\tB\x03\xe0A\x02R\tclusterId\x12@\n" +
	"\x0eimport_options\x18\x04 \x01(\v2\x14.agent.ImportOptionsB\x03\xe0A\x02R\rimportOptions\x120\n" +
	"\x06source\x18\x05 \x01(\v2\x13.agent.ImportSourceB\x03\xe0A\x02R\x06source\x12:\n" +
	"\x0etarget_cluster\x18\x06 \x01(\v2\x0e.agent.ClusterB\x03\xe0A\x02R\rtargetCluster\"\xe7\x02\n" +
	"\x15PrecheckImportJobResp\x127\n" +
	"\rtarget_tables\x18\x01 \x03(\v2\x12.agent.TableResultR\ftargetTables\x12#\n" +
	"\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x123\n" +
	"\x16total_data_files_count\x18\x03 \x01(\x04R\x13totalDataFilesCount\x12,\n" +
	"\x12total_tables_count\x18\x04 \x01(\x04R\x10totalTablesCount\x12!\n" +
	"\fis_truncated\x18\x05 \x01(\bR\visTruncated\x12<\n" +
	"\x06status\x18\x06 \x01(\x0e2$.agent.ImportPrecheckStatusType.EnumR\x06status\x12,\n" +
	"\tbase_resp\x18\xff\x01 \x01(\v2\x0e.base.BaseRespR\bbaseResp\"^\n" +
	"\x18ImportPrecheckStatusType\"B\n" +
	"\x04Enum\x12\x0f\n" +
	"\vUNSPECIFIED\x10\x00\x12\r\n" +
	"\tCOMPLETED\x10\x01\x12\v\n" +
	"\aTIMEOUT\x10\x02\x12\r\n" +
	"\tTRUNCATED\x10\x03\"g\n" +
	"\x14DropClusterTablesReq\x12%\n" +
	"\x06tables\x18\x01 \x03(\v2\r.common.TableR\x06tables\x12(\n" +
	"\acluster\x18\x02 \x01(\v2\x0e.agent.ClusterR\acluster\"\x9a\x04\n" +
	"\x15PrecheckImportFileReq\x12=\n" +
	"\asources\x18\x01 \x03(\v2#.agent.PrecheckImportFileReq.SourceR\asources\x12\x1f\n" +
	"\vdata_format\x18\x02 \x01(\x04R\n" +
	"dataFormat\x12\x1f\n" +
	"\vdata_source\x18\x03 \x01(\x04R\n" +
	"dataSource\x12/\n" +
	"\n" +
	"csv_config\x18\x05 \x01(\v2\x10.agent.CsvConfigR\tcsvConfig\x12(\n" +
	"\acluster\x18\x06 \x01(\v2\x0e.agent.ClusterR\acluster\x12 \n" +
	"\faws_role_arn\x18\n" +
	" \x01(\tR\n" +
	"awsRoleArn\x12&\n" +
	"\x0faws_external_id\x18\v \x01(\tR\rawsExternalId\x12)\n" +
	"\x11aws_access_key_id\x18\f \x01(\tR\x0eawsAccessKeyId\x121\n" +
	"\x15aws_secret_access_key\x18\r \x01(\tR\x12awsSecretAccessKey\x12\x1b\n" +
	"\tsas_token\x18\x0e \x01(\tR\bsasToken\x12\x1d\n" +
	"\n" +
	"source_url\x18\x0f \x01(\tR\tsourceUrl\x1aA\n" +
	"\x06Source\x12#\n" +
	"\x05table\x18\x01 \x01(\v2\r.common.TableR\x05table\x12\x12\n" +
	"\x04file\x18\x02 \x01(\tR\x04file\"\xf0\x04\n" +
	"\x14SearchImportFilesReq\x12M\n" +
	"\rtarget_source\x18\x01 \x03(\v2(.agent.SearchImportFilesReq.TargetSourceR\ftargetSource\x12\x1f\n" +
	"\vdata_format\x18\x02 \x01(\rR\n" +
	"dataFormat\x12(\n" +
	"\x10data_source_type\x18\x03 \x01(\rR\x0edataSourceType\x12\x1d\n" +
	"\n" +
	"source_uri\x18\x04 \x01(\tR\tsourceUri\x12 \n" +
	"\faws_role_arn\x18\n" +
	" \x01(\tR\n" +
	"awsRoleArn\x12&\n" +
	"\x0faws_external_id\x18\v \x01(\tR\rawsExternalId\x12)\n" +
	"\x11aws_access_key_id\x18\f \x01(\tR\x0eawsAccessKeyId\x121\n" +
	"\x15aws_secret_access_key\x18\r \x01(\tR\x12awsSecretAccessKey\x122\n" +
	"\vgcs_options\x18\x0e \x01(\v2\x11.agent.GcsOptionsR\n" +
	"gcsOptions\x12\x1b\n" +
	"\tsas_token\x18\x0f \x01(\tR\bsasToken\x1aa\n" +
	"\fTargetSource\x120\n" +
	"\ftarget_table\x18\x01 \x01(\v2\r.common.TableR\vtargetTable\x12\x1f\n" +
	"\vcustom_file\x18\x03 \x01(\tR\n" +
	"customFile:C\x92A@\n" +
	">\xd2\x01\rtarget_source\xd2\x01\vdata_format\xd2\x01\x10data_source_type\xd2\x01\n" +
	"source_uri\"Q\n" +
	"\x11GetImportFilesReq\x12\x1d\n" +
	"\n" +
	"cluster_id\x18\x01 \x01(\x04R\tclusterId\x12\x1d\n" +
	"\n" +
	"source_uri\x18\x05 \x01(\tR\tsourceUri\"\xd6\x05\n" +
	"\x12GetImportFilesResp\x12B\n" +
	"\n" +
	"table_meta\x18\x01 \x03(\v2#.agent.GetImportFilesResp.TableMetaR\ttableMeta\x1a\xc6\x01\n" +
	"\fDataFileMeta\x12\x12\n" +
	"\x04path\x18\x01 \x01(\tR\x04path\x12\x12\n" +
	"\x04size\x18\x02 \x01(\x04R\x04size\x12E\n" +
	"\vsource_type\x18\x03 \x01(\x0e2$.agent.GetImportFilesResp.SourceTypeR\n" +
	"sourceType\x12G\n" +
	"\vcompression\x18\x04 \x01(\x0e2%.agent.GetImportFilesResp.CompressionR\vcompression\x1a\xe9\x01\n" +
	"\tTableMeta\x12\x1a\n" +
	"\bdatabase\x18\x01 \x01(\tR\bdatabase\x12\x14\n" +
	"\x05table\x18\x02 \x01(\tR\x05table\x12E\n" +
	"\n" +
	"data_files\x18\x03 \x03(\v2&.agent.GetImportFilesResp.DataFileMetaR\tdataFiles\x12\x1d\n" +
	"\n" +
	"total_size\x18\x04 \x01(\x04R\ttotalSize\x12#\n" +
	"\rwildcard_path\x18\x05 \x01(\tR\fwildcardPath\x12\x1f\n" +
	"\vschema_file\x18\x06 \x01(\tR\n" +
	"schemaFile\"s\n" +
	"\n" +
	"SourceType\x12\x10\n" +
	"\fUNKNOWN_TYPE\x10\x00\x12\x11\n" +
	"\rSCHEMA_SCHEMA\x10\x01\x12\x10\n" +
	"\fTABLE_SCHEMA\x10\x02\x12\a\n" +
	"\x03SQL\x10\x03\x12\a\n" +
	"\x03CSV\x10\x04\x12\v\n" +
	"\aPARQUET\x10\x05\x12\x0f\n" +
	"\vVIEW_SCHEMA\x10\x06\"R\n" +
	"\vCompression\x12\v\n" +
	"\aUNKNOWN\x10\x00\x12\x06\n" +
	"\x02GZ\x10\x01\x12\a\n" +
	"\x03LZ4\x10\x02\x12\b\n" +
	"\x04ZSTD\x10\x03\x12\x06\n" +
	"\x02XZ\x10\x04\x12\a\n" +
	"\x03LZO\x10\x05\x12\n" +
	"\n" +
	"\x06SNAPPY\x10\x06\"\x80\x01\n" +
	"\x10CreateSchemasReq\x12\x1d\n" +
	"\n" +
	"cluster_id\x18\x01 \x01(\x04R\tclusterId\x12\x12\n" +
	"\x04user\x18\x02 \x01(\tR\x04user\x12\x1a\n" +
	"\bpassword\x18\x03 \x01(\tR\bpassword\x12\x1d\n" +
	"\n" +
	"source_uri\x18\x04 \x01(\tR\tsourceUri\"\xa4\x02\n" +
	"\tCsvConfig\x12\x1c\n" +
	"\tseparator\x18\x01 \x01(\tR\tseparator\x12\x1c\n" +
	"\tdelimiter\x18\x02 \x01(\tR\tdelimiter\x12\x16\n" +
	"\x06header\x18\x03 \x01(\bR\x06header\x12)\n" +
	"\x10backslash_escape\x18\x04 \x01(\bR\x0fbackslashEscape\x12.\n" +
	"\x13trim_last_separator\x18\x05 \x01(\bR\x11trimLastSeparator\x12#\n" +
	"\bnot_null\x18\x06 \x01(\bB\x03\xe0A\x01H\x00R\anotNull\x88\x01\x01\x12'\n" +
	"\n" +
	"null_value\x18\a \x01(\tB\x03\xe0A\x01H\x01R\tnullValue\x88\x01\x01B\v\n" +
	"\t_not_nullB\r\n" +
	"\v_null_value\"\xa4\x02\n" +
	"\x11PreviewCsvFileReq\x12\x1d\n" +
	"\n" +
	"source_uri\x18\x01 \x01(\tR\tsourceUri\x12/\n" +
	"\n" +
	"csv_config\x18\x02 \x01(\v2\x10.agent.CsvConfigR\tcsvConfig\x12\x17\n" +
	"\afirst_n\x18\x03 \x01(\x04R\x06firstN\x12 \n" +
	"\faws_role_arn\x18\n" +
	" \x01(\tR\n" +
	"awsRoleArn\x12&\n" +
	"\x0faws_external_id\x18\v \x01(\tR\rawsExternalId\x12)\n" +
	"\x11aws_access_key_id\x18\f \x01(\tR\x0eawsAccessKeyId\x121\n" +
	"\x15aws_secret_access_key\x18\r \x01(\tR\x12awsSecretAccessKey\"\xc4\x01\n" +
	"\x15SearchImportFilesResp\x12L\n" +
	"\rtable_matches\x18\x01 \x03(\v2'.agent.SearchImportFilesResp.TableMatchR\ftableMatches\x1a]\n" +
	"\n" +
	"TableMatch\x120\n" +
	"\ftarget_table\x18\x01 \x01(\v2\r.common.TableR\vtargetTable\x12\x1d\n" +
	"\n" +
	"source_uri\x18\x02 \x01(\tR\tsourceUri\"8\n" +
	"\x12PreviewCsvFileResp\x12\"\n" +
	"\x05table\x18\x01 \x01(\v2\f.agent.TableR\x05table\"\xec\x01\n" +
	"\x10CheckS3AccessReq\x12\x19\n" +
	"\brole_arn\x18\x01 \x01(\tR\aroleArn\x12\x15\n" +
	"\x06s3_url\x18\x02 \x01(\tR\x05s3Url\x12\x1f\n" +
	"\vexternal_id\x18\x03 \x01(\tR\n" +
	"externalId\x12)\n" +
	"\x11aws_access_key_id\x18\x04 \x01(\tR\x0eawsAccessKeyId\x121\n" +
	"\x15aws_secret_access_key\x18\x05 \x01(\tR\x12awsSecretAccessKey:'\x92A$\n" +
	"\"\xd2\x01\brole_arn\xd2\x01\x06s3_url\xd2\x01\vexternal_id\"C\n" +
	"\x11CheckS3AccessResp\x12\x1b\n" +
	"\terror_msg\x18\x01 \x01(\tR\berrorMsg:\x11\x92A\x0e\n" +
	"\f\xd2\x01\terror_msg\"q\n" +
	"\x11CheckGcsAccessReq\x12\x17\n" +
	"\agcs_url\x18\x01 \x01(\tR\x06gcsUrl\x122\n" +
	"\vgcs_options\x18\x02 \x01(\v2\x11.agent.GcsOptionsR\n" +
	"gcsOptions:\x0f\x92A\f\n" +
	"\n" +
	"\xd2\x01\agcs_url\"D\n" +
	"\x12CheckGcsAccessResp\x12\x1b\n" +
	"\terror_msg\x18\x01 \x01(\tR\berrorMsg:\x11\x92A\x0e\n" +
	"\f\xd2\x01\terror_msg\"r\n" +
	"\x14CheckAzblobAccessReq\x12\x1d\n" +
	"\n" +
	"azblob_url\x18\x01 \x01(\tR\tazblobUrl\x12\x1b\n" +
	"\tsas_token\x18\x02 \x01(\tR\bsasToken:\x1e\x92A\x1b\n" +
	"\x19\xd2\x01\n" +
	"azblob_url\xd2\x01\tsas_token\"G\n" +
	"\x15CheckAzblobAccessResp\x12\x1b\n" +
	"\terror_msg\x18\x01 \x01(\tR\berrorMsg:\x11\x92A\x0e\n" +
	"\f\xd2\x01\terror_msg\"\x8f\x03\n" +
	"\aCluster\x12\x1d\n" +
	"\n" +
	"cluster_id\x18\x01 \x01(\x04R\tclusterId\x12\x1c\n" +
	"\tnamespace\x18\x02 \x01(\tR\tnamespace\x12\x12\n" +
	"\x04user\x18\x03 \x01(\tR\x04user\x12\x1a\n" +
	"\bpassword\x18\x04 \x01(\tR\bpassword\x12!\n" +
	"\fread_timeout\x18\x06 \x01(\x03R\vreadTimeout\x12#\n" +
	"\rwrite_timeout\x18\a \x01(\x03R\fwriteTimeout\x12#\n" +
	"\rprovider_type\x18\b \x01(\tR\fproviderType\x12-\n" +
	"\x12password_encrypted\x18\t \x01(\bR\x11passwordEncrypted\x12C\n" +
	"\x12encrypted_password\x18\n" +
	" \x01(\v2\x14.agent.EncryptedDataR\x11encryptedPassword:0\x92A-\n" +
	"+\xd2\x01\n" +
	"cluster_id\xd2\x01\tnamespace\xd2\x01\x04user\xd2\x01\bpasswordJ\x04\b\x05\x10\x06\"\xfe\x02\n" +
	"\vLoadDataReq\x12(\n" +
	"\acluster\x18\x01 \x01(\v2\x0e.agent.ClusterR\acluster\x12\x1b\n" +
	"\ttarget_db\x18\x02 \x01(\tR\btargetDb\x12!\n" +
	"\ftarget_table\x18\x03 \x01(\tR\vtargetTable\x12\x1d\n" +
	"\n" +
	"source_uri\x18\x04 \x01(\tR\tsourceUri\x12\x1c\n" +
	"\tseparator\x18\v \x01(\tR\tseparator\x12\x1c\n" +
	"\tdelimiter\x18\f \x01(\tR\tdelimiter\x12)\n" +
	"\x10backslash_escape\x18\r \x01(\bR\x0fbackslashEscape\x12&\n" +
	"\x0fignore_one_line\x18\x0e \x01(\bR\rignoreOneLine\x12\x1e\n" +
	"\n" +
	"terminator\x18\x0f \x01(\tR\n" +
	"terminator:7\x92A4\n" +
	"2\xd2\x01\acluster\xd2\x01\ttarget_db\xd2\x01\ftarget_table\xd2\x01\n" +
	"source_uri\"/\n" +
	"\fLoadDataResp\x12\x1f\n" +
	"\verr_message\x18\x01 \x01(\tR\n" +
	"errMessage\"\xbe\x02\n" +
	"\x14LightningPrecheckReq\x12)\n" +
	"\x10lightning_config\x18\x01 \x01(\tR\x0flightningConfig\x121\n" +
	"\vcheck_items\x18\x02 \x03(\x0e2\x10.agent.CheckItemR\n" +
	"checkItems\x12+\n" +
	"\x11cluster_namespace\x18\x03 \x01(\tR\x10clusterNamespace\x12.\n" +
	"\x13cluster_name_prefix\x18\x04 \x01(\tR\x11clusterNamePrefix\x12,\n" +
	"\x12gen_gcp_credential\x18\x05 \x01(\bR\x10genGcpCredential\x12#\n" +
	"\rprovider_type\x18\x06 \x01(\tR\fproviderType:\x18\x92A\x15\n" +
	"\x13\xd2\x01\x10lightning_config\"\x95\x01\n" +
	"\x15LightningPrecheckResp\x127\n" +
	"\rcheck_results\x18\x01 \x03(\v2\x12.agent.CheckResultR\fcheckResults\x12,\n" +
	"\tbase_resp\x18\xff\x01 \x01(\v2\x0e.base.BaseRespR\bbaseResp:\x15\x92A\x12\n" +
	"\x10\xd2\x01\rcheck_results\"\x96\x01\n" +
	"\vCheckResult\x12/\n" +
	"\n" +
	"check_item\x18\x01 \x01(\x0e2\x10.agent.CheckItemR\tcheckItem\x12\x1d\n" +
	"\n" +
	"has_passed\x18\x02 \x01(\bR\thasPassed\x12\x10\n" +
	"\x03msg\x18\x03 \x01(\tR\x03msg:%\x92A\"\n" +
	" \xd2\x01\n" +
	"check_item\xd2\x01\n" +
	"has_passed\xd2\x01\x03msg\"\xc2\x01\n" +
	"\n" +
	"ExecSQLReq\x12(\n" +
	"\acluster\x18\x01 \x01(\v2\x0e.agent.ClusterR\acluster\x12\x10\n" +
	"\x03sql\x18\x02 \x01(\tR\x03sql\x12\x1d\n" +
	"\n" +
	"column_num\x18\x03 \x01(\x04R\tcolumnNum\x12#\n" +
	"\rtyped_columns\x18\x04 \x01(\bR\ftypedColumns\x12\x1d\n" +
	"\n" +
	"setup_sqls\x18\x05 \x03(\tR\tsetupSqls:\x15\x92A\x12\n" +
	"\x10\xd2\x01\acluster\xd2\x01\x03sql\"\xac\x01\n" +
	"\vExecSQLResp\x12\x1b\n" +
	"\terror_msg\x18\x01 \x01(\tR\berrorMsg\x12\x1d\n" +
	"\n" +
	"sql_result\x18\x02 \x01(\tR\tsqlResult\x12\x1e\n" +
	"\x04rows\x18\x03 \x03(\v2\n" +
	".agent.RowR\x04rows\x12!\n" +
	"\fcolumn_names\x18\x04 \x03(\tR\vcolumnNames:\x1e\x92A\x1b\n" +
	"\x19\xd2\x01\terror_msg\xd2\x01\n" +
	"sql_result\"\xe7\x01\n" +
	"\x19LightningSourcePreviewReq\x12)\n" +
	"\x10lightning_config\x18\x01 \x01(\tR\x0flightningConfig\x12+\n" +
	"\x11cluster_namespace\x18\x02 \x01(\tR\x10clusterNamespace\x12.\n" +
	"\x13cluster_name_prefix\x18\x03 \x01(\tR\x11clusterNamePrefix:B\x92A?\n" +
	"=\xd2\x01\x10lightning_config\xd2\x01\x11cluster_namespace\xd2\x01\x13cluster_name_prefix\"\x84\x01\n" +
	"\x1aLightningSourcePreviewResp\x12'\n" +
	"\aschemas\x18\x01 \x03(\v2\r.agent.SchemaR\aschemas\x12,\n" +
	"\tbase_resp\x18\xff\x01 \x01(\v2\x0e.base.BaseRespR\bbaseResp:\x0f\x92A\f\n" +
	"\n" +
	"\xd2\x01\aschemas\"\xbd\x01\n" +
	"\x19EstimateSourceDataSizeReq\x12)\n" +
	"\x10lightning_config\x18\x01 \x01(\tR\x0flightningConfig\x12+\n" +
	"\x11cluster_namespace\x18\x02 \x01(\tR\x10clusterNamespace\x12.\n" +
	"\x13cluster_name_prefix\x18\x03 \x01(\tR\x11clusterNamePrefix:\x18\x92A\x15\n" +
	"\x13\xd2\x01\x10lightning_config\"\xa0\x01\n" +
	"\x1aEstimateSourceDataSizeResp\x12&\n" +
	"\x0fsize_with_index\x18\x01 \x01(\x04R\rsizeWithIndex\x12,\n" +
	"\x12size_without_index\x18\x02 \x01(\x04R\x10sizeWithoutIndex\x12,\n" +
	"\tbase_resp\x18\xff\x01 \x01(\v2\x0e.base.BaseRespR\bbaseResp\"\xdb\x01\n" +
	"\x16CheckDBConnectivityReq\x12\x12\n" +
	"\x04host\x18\x01 \x01(\tR\x04host\x12\x12\n" +
	"\x04port\x18\x02 \x01(\rR\x04port\x12\x12\n" +
	"\x04user\x18\x03 \x01(\tR\x04user\x12\x1a\n" +
	"\bpassword\x18\x04 \x01(\tR\bpassword\x12\x15\n" +
	"\x06ssl_ca\x18\x05 \x01(\tR\x05sslCa\x12\x19\n" +
	"\bssl_cert\x18\x06 \x01(\tR\asslCert\x12\x17\n" +
	"\assl_key\x18\a \x01(\tR\x06sslKey\x12\x1e\n" +
	"\n" +
	"request_id\x18\xc8\x01 \x01(\tR\trequestId\"8\n" +
	"\x17CheckDBConnectivityResp\x12\x1d\n" +
	"\n" +
	"db_version\x18\x01 \x01(\tR\tdbVersion\"\xba\x01\n" +
	"\x16GetTiDBServerSecretReq\x12.\n" +
	"\x13cluster_name_prefix\x18\x01 \x01(\tR\x11clusterNamePrefix\x12+\n" +
	"\x11cluster_namespace\x18\x02 \x01(\tR\x10clusterNamespace\x12#\n" +
	"\rprovider_type\x18\x03 \x01(\tR\fproviderType\x12\x1e\n" +
	"\n" +
	"request_id\x18\xc8\x01 \x01(\tR\trequestId\"d\n" +
	"\x17GetTiDBServerSecretResp\x12\x15\n" +
	"\x06ssl_ca\x18\x01 \x01(\tR\x05sslCa\x12\x19\n" +
	"\bssl_cert\x18\x02 \x01(\tR\asslCert\x12\x17\n" +
	"\assl_key\x18\x03 \x01(\tR\x06sslKey\"\xbd\x01\n" +
	"\x19GetClusterClientSecretReq\x12.\n" +
	"\x13cluster_name_prefix\x18\x01 \x01(\tR\x11clusterNamePrefix\x12+\n" +
	"\x11cluster_namespace\x18\x02 \x01(\tR\x10clusterNamespace\x12#\n" +
	"\rprovider_type\x18\x03 \x01(\tR\fproviderType\x12\x1e\n" +
	"\n" +
	"request_id\x18\xc8\x01 \x01(\tR\trequestId\"g\n" +
	"\x1aGetClusterClientSecretResp\x12\x15\n" +
	"\x06ssl_ca\x18\x01 \x01(\tR\x05sslCa\x12\x19\n" +
	"\bssl_cert\x18\x02 \x01(\tR\asslCert\x12\x17\n" +
	"\assl_key\x18\x03 \x01(\tR\x06sslKey\"\xae\x02\n" +
	"\x11ImportsSchemaMeta\x12\x1f\n" +
	"\vcreate_file\x18\x01 \x01(\tR\n" +
	"createFile\x12+\n" +
	"\x12max_data_file_size\x18\x02 \x01(\x04R\x0fmaxDataFileSize\x12I\n" +
	"\vtables_meta\x18\x03 \x03(\v2(.agent.ImportsSchemaMeta.TablesMetaEntryR\n" +
	"tablesMeta\x12(\n" +
	"\x10create_file_size\x18\x04 \x01(\x04R\x0ecreateFileSize\x1aV\n" +
	"\x0fTablesMetaEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12-\n" +
	"\x05value\x18\x02 \x01(\v2\x17.agent.ImportsTableMetaR\x05value:\x028\x01\"\x90\x02\n" +
	"\x10ImportsTableMeta\x12\x12\n" +
	"\x04name\x18\x01 \x01(\tR\x04name\x12\x1f\n" +
	"\vcreate_file\x18\x02 \x01(\tR\n" +
	"createFile\x12\"\n" +
	"\rdata_file_num\x18\x03 \x01(\x04R\vdataFileNum\x12$\n" +
	"\x0edata_file_size\x18\x04 \x01(\x04R\fdataFileSize\x12&\n" +
	"\x0ffirst_data_file\x18\x05 \x01(\tR\rfirstDataFile\x12+\n" +
	"\x12max_data_file_size\x18\x06 \x01(\x04R\x0fmaxDataFileSize\x12(\n" +
	"\x10create_file_size\x18\a \x01(\x04R\x0ecreateFileSize\"^\n" +
	"\x17GetImportSchemasMetaReq\x12)\n" +
	"\x10lightning_config\x18\x01 \x01(\tR\x0flightningConfig:\x18\x92A\x15\n" +
	"\x13\xd2\x01\x10lightning_config\"\x8d\x02\n" +
	"\x18GetImportSchemasMetaResp\x12S\n" +
	"\fschemas_meta\x18\x01 \x03(\v20.agent.GetImportSchemasMetaResp.SchemasMetaEntryR\vschemasMeta\x12,\n" +
	"\tbase_resp\x18\xff\x01 \x01(\v2\x0e.base.BaseRespR\bbaseResp\x1aX\n" +
	"\x10SchemasMetaEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12.\n" +
	"\x05value\x18\x02 \x01(\v2\x18.agent.ImportsSchemaMetaR\x05value:\x028\x01:\x14\x92A\x11\n" +
	"\x0f\xd2\x01\fschemas_meta\"n\n" +
	"\x03Row\x12#\n" +
	"\rcolumn_values\x18\x01 \x03(\tR\fcolumnValues\x12B\n" +
	"\x13typed_column_values\x18\x02 \x03(\v2\x12.agent.ColumnValueR\x11typedColumnValues\"\xeb\x01\n" +
	"\vColumnValue\x12#\n" +
	"\fstring_value\x18\x01 \x01(\tH\x00R\vstringValue\x12!\n" +
	"\vint64_value\x18\x02 \x01(\x03H\x00R\n" +
	"int64Value\x12#\n" +
	"\fdouble_value\x18\x03 \x01(\x01H\x00R\vdoubleValue\x12\x1f\n" +
	"\n" +
	"bool_value\x18\x04 \x01(\bH\x00R\tboolValue\x12E\n" +
	"\x0ftimestamp_value\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampH\x00R\x0etimestampValueB\a\n" +
	"\x05value\"\x83\x02\n" +
	"\x05Table\x12\x1f\n" +
	"\vschema_name\x18\x01 \x01(\tR\n" +
	"schemaName\x12\x1d\n" +
	"\n" +
	"table_name\x18\x02 \x01(\tR\ttableName\x12\x1f\n" +
	"\vrow_headers\x18\x03 \x03(\tR\n" +
	"rowHeaders\x12)\n" +
	"\n" +
	"row_values\x18\x04 \x03(\v2\n" +
	".agent.RowR\trowValues\x12$\n" +
	"\x0erow_data_types\x18\x05 \x03(\tR\frowDataTypes\x12 \n" +
	"\fcolumn_is_pk\x18\x06 \x03(\bR\n" +
	"columnIsPk\x12&\n" +
	"\x0fcolumn_auto_gen\x18\a \x03(\bR\rcolumnAutoGen\"O\n" +
	"\x06Schema\x12\x1f\n" +
	"\vschema_name\x18\x01 \x01(\tR\n" +
	"schemaName\x12$\n" +
	"\x06tables\x18\x02 \x03(\v2\f.agent.TableR\x06tables\"\xc5\x01\n" +
	"\x10PrecheckDMJobReq\x12\x15\n" +
	"\x06req_id\x18\x01 \x01(\tR\x05reqId\x122\n" +
	"\x15full_instance_migrate\x18\x02 \x01(\bR\x13fullInstanceMigrate\x12\x1f\n" +
	"\vtask_config\x18\x03 \x03(\tR\n" +
	"taskConfig\x12)\n" +
	"\x10cluster_password\x18\x04 \x01(\tR\x0fclusterPassword\x12\x1a\n" +
	"\bpassword\x18\x05 \x01(\tR\bpassword\"L\n" +
	"\n" +
	"GcsOptions\x12>\n" +
	"\x1bimpersonate_service_account\x18\x01 \x01(\tR\x19impersonateServiceAccount\"8\n" +
	"\x11PrecheckDMJobResp\x12#\n" +
	"\rcheck_results\x18\x02 \x01(\fR\fcheckResults\"\xdf\x02\n" +
	"\x0eGetUserFileReq\x12\x15\n" +
	"\x06s3_url\x18\x01 \x01(\tR\x05s3Url\x12\x19\n" +
	"\brole_arn\x18\x02 \x01(\tR\aroleArn\x12\x1f\n" +
	"\vexternal_id\x18\x03 \x01(\tR\n" +
	"externalId\x12!\n" +
	"\fstart_offset\x18\x04 \x01(\x03R\vstartOffset\x12\x1d\n" +
	"\n" +
	"end_offset\x18\x05 \x01(\x03R\tendOffset\x12\x1d\n" +
	"\n" +
	"source_url\x18\x06 \x01(\tR\tsourceUrl\x12(\n" +
	"\x10data_source_type\x18\a \x01(\rR\x0edataSourceType\x122\n" +
	"\vgcs_options\x18\b \x01(\v2\x11.agent.GcsOptionsR\n" +
	"gcsOptions\x12\x1b\n" +
	"\tsas_token\x18\t \x01(\tR\bsasToken\x12\x1e\n" +
	"\n" +
	"request_id\x18\xc8\x01 \x01(\tR\trequestId\"+\n" +
	"\x0fGetUserFileResp\x12\x18\n" +
	"\acontent\x18\x01 \x01(\tR\acontent\">\n" +
	"\x13GetSourceTablesResp\x12'\n" +
	"\aschemas\x18\x01 \x03(\v2\r.agent.SchemaR\aschemas\"\xc6\x01\n" +
	"\x19GetSourceBinlogStatusResp\x12\x1f\n" +
	"\vbinlog_name\x18\x01 \x01(\tR\n" +
	"binlogName\x12\x1d\n" +
	"\n" +
	"binlog_pos\x18\x02 \x01(\rR\tbinlogPos\x12\"\n" +
	"\rbinlog_do_dbs\x18\x03 \x01(\tR\vbinlogDoDbs\x12*\n" +
	"\x11binlog_ignore_dbs\x18\x04 \x01(\tR\x0fbinlogIgnoreDbs\x12\x19\n" +
	"\bgtid_str\x18\x05 \x01(\tR\agtidStr\"?\n" +
	"\x14GetClusterTablesResp\x12'\n" +
	"\aschemas\x18\x01 \x03(\v2\r.agent.SchemaR\aschemas\"A\n" +
	"\vNsLookupReq\x12\x12\n" +
	"\x04host\x18\x01 \x01(\tR\x04host\x12\x1e\n" +
	"\n" +
	"request_id\x18\xc8\x01 \x01(\tR\trequestId\" \n" +
	"\fNsLookupResp\x12\x10\n" +
	"\x03ips\x18\x01 \x03(\tR\x03ips\"f\n" +
	"\x13ClearEmptyTablesReq\x12(\n" +
	"\acluster\x18\x01 \x01(\v2\x0e.agent.ClusterR\acluster\x12%\n" +
	"\x06tables\x18\x02 \x03(\v2\r.common.TableR\x06tables\"T\n" +
	"\x14ClearEmptyTablesResp\x12<\n" +
	"\aresults\x18\x01 \x03(\v2\".agent.ClearSingleEmptyTableResultR\aresults\"\xf3\x01\n" +
	"\x1bClearSingleEmptyTableResult\x12#\n" +
	"\x05table\x18\x01 \x01(\v2\r.common.TableR\x05table\x12A\n" +
	"\x06result\x18\x02 \x01(\x0e2).agent.ClearSingleEmptyTableResult.ResultR\x06result\x12\x1e\n" +
	"\n" +
	"ErrMessage\x18\x03 \x01(\tR\n" +
	"ErrMessage\"L\n" +
	"\x06Result\x12\v\n" +
	"\aUnknown\x10\x00\x12\v\n" +
	"\aCleared\x10\x01\x12\f\n" +
	"\bNotExist\x10\x02\x12\f\n" +
	"\bNotEmpty\x10\x03\x12\f\n" +
	"\bHasError\x10\x04\"\x15\n" +
	"\x13GetPublicKeyRequest\"(\n" +
	"\x14GetPublicKeyResponse\x12\x10\n" +
	"\x03pem\x18\x01 \x01(\fR\x03pem\"\xe0\x01\n" +
	"\fImportSource\x125\n" +
	"\x04type\x18\x01 \x01(\x0e2\x1c.agent.ImportSourceType.EnumB\x03\xe0A\x02R\x04type\x12&\n" +
	"\x02s3\x18\x02 \x01(\v2\x0f.agent.S3SourceB\x03\xe0A\x01H\x00R\x02s3\x12)\n" +
	"\x03gcs\x18\x03 \x01(\v2\x10.agent.GCSSourceB\x03\xe0A\x01H\x00R\x03gcs\x12<\n" +
	"\n" +
	"azure_blob\x18\x04 \x01(\v2\x16.agent.AzureBlobSourceB\x03\xe0A\x01H\x00R\tazureBlobB\b\n" +
	"\x06source\"\xc9\x03\n" +
	"\bS3Source\x12\x15\n" +
	"\x03uri\x18\x01 \x01(\tB\x03\xe0A\x02R\x03uri\x12>\n" +
	"\tauth_type\x18\x02 \x01(\x0e2\x1c.agent.ImportS3AuthType.EnumB\x03\xe0A\x02R\bauthType\x129\n" +
	"\brole_arn\x18\x03 \x01(\v2\x17.agent.S3Source.RoleArnB\x03\xe0A\x01H\x00R\aroleArn\x12?\n" +
	"\n" +
	"access_key\x18\x04 \x01(\v2\x19.agent.S3Source.AccessKeyB\x03\xe0A\x01H\x00R\taccessKey\x12O\n" +
	"\x12target_table_infos\x18\x05 \x03(\v2\x1c.agent.ImportTargetTableInfoB\x03\xe0A\x01R\x10targetTableInfos\x1a@\n" +
	"\tAccessKey\x12\x13\n" +
	"\x02id\x18\x01 \x01(\tB\x03\xe0A\x02R\x02id\x12\x1e\n" +
	"\x06secret\x18\x02 \x01(\tB\x06\xe0A\x02\xe0A\x04R\x06secret\x1aO\n" +
	"\aRoleArn\x12\x1e\n" +
	"\brole_arn\x18\x01 \x01(\tB\x03\xe0A\x02R\aroleArn\x12$\n" +
	"\vexternal_id\x18\x02 \x01(\tB\x03\xe0A\x02R\n" +
	"externalIdB\x06\n" +
	"\x04auth\"\xf3\x01\n" +
	"\tGCSSource\x12\x15\n" +
	"\x03uri\x18\x01 \x01(\tB\x03\xe0A\x02R\x03uri\x12?\n" +
	"\tauth_type\x18\x02 \x01(\x0e2\x1d.agent.ImportGcsAuthType.EnumB\x03\xe0A\x02R\bauthType\x125\n" +
	"\x13service_account_key\x18\x03 \x01(\tB\x03\xe0A\x01H\x00R\x11serviceAccountKey\x12O\n" +
	"\x12target_table_infos\x18\x04 \x03(\v2\x1c.agent.ImportTargetTableInfoB\x03\xe0A\x01R\x10targetTableInfosB\x06\n" +
	"\x04auth\"\xec\x01\n" +
	"\x0fAzureBlobSource\x12E\n" +
	"\tauth_type\x18\x01 \x01(\x0e2#.agent.ImportAzureBlobAuthType.EnumB\x03\xe0A\x02R\bauthType\x12\"\n" +
	"\tsas_token\x18\x02 \x01(\tB\x03\xe0A\x04H\x00R\bsasToken\x12\x15\n" +
	"\x03uri\x18\x03 \x01(\tB\x03\xe0A\x02R\x03uri\x12O\n" +
	"\x12target_table_infos\x18\x04 \x03(\v2\x1c.agent.ImportTargetTableInfoB\x03\xe0A\x01R\x10targetTableInfosB\x06\n" +
	"\x04auth\"L\n" +
	"\x10ImportSourceType\"8\n" +
	"\x04Enum\x12\x0f\n" +
	"\vUNSPECIFIED\x10\x00\x12\x06\n" +
	"\x02S3\x10\x01\x12\a\n" +
	"\x03GCS\x10\x02\x12\x0e\n" +
	"\n" +
	"AZURE_BLOB\x10\x03\"I\n" +
	"\x10ImportS3AuthType\"5\n" +
	"\x04Enum\x12\x0f\n" +
	"\vUNSPECIFIED\x10\x00\x12\f\n" +
	"\bROLE_ARN\x10\x01\x12\x0e\n" +
	"\n" +
	"ACCESS_KEY\x10\x02\"O\n" +
	"\x11ImportGcsAuthType\":\n" +
	"\x04Enum\x12\x19\n" +
	"\x15AUTH_TYPE_UNSPECIFIED\x10\x00\x12\x17\n" +
	"\x13SERVICE_ACCOUNT_KEY\x10\x01\"A\n" +
	"\x17ImportAzureBlobAuthType\"&\n" +
	"\x04Enum\x12\x0f\n" +
	"\vUNSPECIFIED\x10\x00\x12\r\n" +
	"\tSAS_TOKEN\x10\x01\"t\n" +
	"\x15ImportTargetTableInfo\x125\n" +
	"\ftarget_table\x18\x01 \x01(\v2\r.common.TableB\x03\xe0A\x02R\vtargetTable\x12$\n" +
	"\vcustom_file\x18\x02 \x01(\tB\x03\xe0A\x02R\n" +
	"customFile\"\xe4\x01\n" +
	"\rImportOptions\x12<\n" +
	"\tfile_type\x18\x01 \x01(\x0e2\x1a.agent.ImportFileType.EnumB\x03\xe0A\x02R\bfileType\x126\n" +
	"\n" +
	"csv_config\x18\x02 \x01(\v2\x10.agent.CsvConfigB\x03\xe0A\x01H\x00R\tcsvConfig\x12+\n" +
	"\x0fneed_drop_table\x18\x03 \x01(\bB\x03\xe0A\x01R\rneedDropTable\x12&\n" +
	"\fdisplay_name\x18\x04 \x01(\tB\x03\xe0A\x01R\vdisplayNameB\b\n" +
	"\x06format\"]\n" +
	"\x0eImportFileType\"K\n" +
	"\x04Enum\x12\x0f\n" +
	"\vUNSPECIFIED\x10\x00\x12\a\n" +
	"\x03CSV\x10\x01\x12\a\n" +
	"\x03SQL\x10\x02\x12\x13\n" +
	"\x0fAURORA_SNAPSHOT\x10\x03\x12\v\n" +
	"\aPARQUET\x10\x04\"5\n" +
	"\rEncryptedData\x12\x12\n" +
	"\x04data\x18\x01 \x01(\fR\x04data\x12\x10\n" +
	"\x03pem\x18\x02 \x01(\fR\x03pem*\xa3\x01\n" +
	"\tCheckItem\x12\x16\n" +
	"\x12CHECK_ITEM_UNKNOWN\x10\x00\x12!\n" +
	"\x1dCHECK_ITEM_TARGET_TABLE_EMPTY\x10\x01\x12\x1c\n" +
	"\x18CHECK_ITEM_SOURCE_SCHEMA\x10\x02\x12\x19\n" +
	"\x15CHECK_ITEM_CSV_HEADER\x10\x03\x12\"\n" +
	"\x1eCHECK_ITEM_TARGET_CLUSTER_SIZE\x10\x042\xba\x1d\n" +
	"\fAgentService\x12\xad\x01\n" +
	"\x11PrecheckImportJob\x12\x1b.agent.PrecheckImportJobReq\x1a\x1c.agent.PrecheckImportJobResp\"]\x82\xd3\xe4\x93\x02W:\x01*\"R/api/v1/orgs/{org_id}/projects/{project_id}/clusters/{cluster_id}/imports:precheck\x12x\n" +
	"\rCheckS3Access\x12\x17.agent.CheckS3AccessReq\x1a\x18.agent.CheckS3AccessResp\"4\x92A\x0f*\rCheckS3Access\x82\xd3\xe4\x93\x02\x1c:\x01*\"\x17/api/v1/s3/check_access\x12}\n" +
	"\x0eCheckGcsAccess\x12\x18.agent.CheckGcsAccessReq\x1a\x19.agent.CheckGcsAccessResp\"6\x92A\x10*\x0eCheckGcsAccess\x82\xd3\xe4\x93\x02\x1d:\x01*\"\x18/api/v1/gcs/check_access\x12\x8c\x01\n" +
	"\x11CheckAzblobAccess\x12\x1b.agent.CheckAzblobAccessReq\x1a\x1c.agent.CheckAzblobAccessResp\"<\x92A\x13*\x11CheckAzblobAccess\x82\xd3\xe4\x93\x02 :\x01*\"\x1b/api/v1/azblob/check_access\x12\x92\x01\n" +
	"\x11LightningPrecheck\x12\x1b.agent.LightningPrecheckReq\x1a\x1c.agent.LightningPrecheckResp\"B\x92A\x13*\x11LightningPrecheck\x82\xd3\xe4\x93\x02&:\x01*\"!/api/v1/import/lightning-precheck\x12i\n" +
	"\x10ExecSQLOnCluster\x12\x11.agent.ExecSQLReq\x1a\x12.agent.ExecSQLResp\".\x92A\t*\aExecSQL\x82\xd3\xe4\x93\x02\x1c:\x01*\"\x17/api/v1/cluster/execsql\x12o\n" +
	"\x11LoadDataToCluster\x12\x12.agent.LoadDataReq\x1a\x13.agent.LoadDataResp\"1\x92A\n" +
	"*\bLoadData\x82\xd3\xe4\x93\x02\x1e:\x01*\"\x19/api/v1/cluster/load-data\x12\x98\x01\n" +
	"\x14GetImportSchemasMeta\x12\x1e.agent.GetImportSchemasMetaReq\x1a\x1f.agent.GetImportSchemasMetaResp\"?\x92A\x16*\x14GetImportSchemasMeta\x82\xd3\xe4\x93\x02 :\x01*\"\x1b/api/v1/import/schemas-meta\x12\xac\x01\n" +
	"\x16LightningSourcePreview\x12 .agent.LightningSourcePreviewReq\x1a!.agent.LightningSourcePreviewResp\"M\x92A\x18*\x16LightningSourcePreview\x82\xd3\xe4\x93\x02,:\x01*\"'/api/v1/import/lightning-source-preview\x12\xaa\x01\n" +
	"\x16EstimateSourceDataSize\x12 .agent.EstimateSourceDataSizeReq\x1a!.agent.EstimateSourceDataSizeResp\"K\x92A\x18*\x16EstimateSourceDataSize\x82\xd3\xe4\x93\x02*:\x01*\"%/api/v1/import/estimate-src-data-size\x12\x90\x01\n" +
	"\x13CheckDBConnectivity\x12\x1d.agent.CheckDBConnectivityReq\x1a\x1e.agent.CheckDBConnectivityResp\":\x92A\x15*\x13CheckDBConnectivity\x82\xd3\xe4\x93\x02\x1c:\x01*\"\x17/api/v1/db-connectivity\x12\x93\x01\n" +
	"\x13GetTiDBServerSecret\x12\x1d.agent.GetTiDBServerSecretReq\x1a\x1e.agent.GetTiDBServerSecretResp\"=\x92A\x15*\x13GetTiDBServerSecret\x82\xd3\xe4\x93\x02\x1f:\x01*\"\x1a/api/v1/tidb-server-secret\x12\xa2\x01\n" +
	"\x16GetClusterClientSecret\x12 .agent.GetClusterClientSecretReq\x1a!.agent.GetClusterClientSecretResp\"C\x92A\x18*\x16GetClusterClientSecret\x82\xd3\xe4\x93\x02\":\x01*\"\x1d/api/v1/cluster-client-secret\x12w\n" +
	"\rPrecheckDMJob\x12\x17.agent.PrecheckDMJobReq\x1a\x18.agent.PrecheckDMJobResp\"3\x92A\x0f*\rPrecheckDMJob\x82\xd3\xe4\x93\x02\x1b:\x01*\"\x16/api/v1/dm/jobprecheck\x12x\n" +
	"\x12GetUserFileContent\x12\x15.agent.GetUserFileReq\x1a\x16.agent.GetUserFileResp\"3\x92A\x14*\x12GetUserFileContent\x82\xd3\xe4\x93\x02\x16:\x01*\"\x11/api/v1/user-file\x12\x82\x01\n" +
	"\x0fGetSourceTables\x12\x1d.agent.CheckDBConnectivityReq\x1a\x1a.agent.GetSourceTablesResp\"4\x92A\x11*\x0fGetSourceTables\x82\xd3\xe4\x93\x02\x1a:\x01*\"\x15/api/v1/source-tables\x12\x9b\x01\n" +
	"\x15GetSourceBinlogStatus\x12\x1d.agent.CheckDBConnectivityReq\x1a .agent.GetSourceBinlogStatusResp\"A\x92A\x17*\x15GetSourceBinlogStatus\x82\xd3\xe4\x93\x02!:\x01*\"\x1c/api/v1/source/binlog-status\x12w\n" +
	"\x10GetClusterTables\x12\x0e.agent.Cluster\x1a\x1b.agent.GetClusterTablesResp\"6\x92A\x12*\x10GetClusterTables\x82\xd3\xe4\x93\x02\x1b:\x01*\"\x16/api/v1/cluster-tables\x12]\n" +
	"\bNsLookup\x12\x12.agent.NsLookupReq\x1a\x13.agent.NsLookupResp\"(\x92A\n" +
	"*\bNsLookup\x82\xd3\xe4\x93\x02\x15:\x01*\"\x10/api/v1/nslookup\x12\x8e\x01\n" +
	"\x10ClearEmptyTables\x12\x1a.agent.ClearEmptyTablesReq\x1a\x1b.agent.ClearEmptyTablesResp\"A\x92A\x12*\x10ClearEmptyTables\x82\xd3\xe4\x93\x02&:\x01*\"!/api/v1/import/clear-empty-tables\x12\x93\x01\n" +
	"\x11SearchImportFiles\x12\x1b.agent.SearchImportFilesReq\x1a\x1c.agent.SearchImportFilesResp\"C\x92A\x13*\x11SearchImportFiles\x82\xd3\xe4\x93\x02':\x01*\"\"/api/v1/import/search-import-files\x12\x84\x01\n" +
	"\x0eGetImportFiles\x12\x18.agent.GetImportFilesReq\x1a\x19.agent.GetImportFilesResp\"=\x92A\x10*\x0eGetImportFiles\x82\xd3\xe4\x93\x02$:\x01*\"\x1f/api/v1/import/get-import-files\x12|\n" +
	"\rCreateSchemas\x12\x17.agent.CreateSchemasReq\x1a\x16.google.protobuf.Empty\":\x92A\x0f*\rCreateSchemas\x82\xd3\xe4\x93\x02\":\x01*\"\x1d/api/v1/import/create-schemas\x12\x84\x01\n" +
	"\x0ePreviewCsvFile\x12\x18.agent.PreviewCsvFileReq\x1a\x19.agent.PreviewCsvFileResp\"=\x92A\x10*\x0ePreviewCsvFile\x82\xd3\xe4\x93\x02$:\x01*\"\x1f/api/v1/import/preview-csv-file\x12\x91\x01\n" +
	"\x12PrecheckImportFile\x12\x1c.agent.PrecheckImportFileReq\x1a\x16.google.protobuf.Empty\"E\x92A\x14*\x12PrecheckImportFile\x82\xd3\xe4\x93\x02(:\x01*\"#/api/v1/import/precheck-import-file\x12\x8d\x01\n" +
	"\x11DropClusterTables\x12\x1b.agent.DropClusterTablesReq\x1a\x16.google.protobuf.Empty\"C\x92A\x13*\x11DropClusterTables\x82\xd3\xe4\x93\x02':\x01*\"\"/api/v1/import/drop-cluster-tables\x12w\n" +
	"\fGetPublicKey\x12\x1a.agent.GetPublicKeyRequest\x1a\x1b.agent.GetPublicKeyResponse\".\x92A\x0e*\fGetPublicKey\x82\xd3\xe4\x93\x02\x17:\x01*\"\x12/api/v1/crypto/pemBCZAgithub.com/tidbcloud/dataflow-service/idl/pbgen/proto/agent;agentb\x06proto3"

var (
	file_agent_agent_proto_rawDescOnce sync.Once
	file_agent_agent_proto_rawDescData []byte
)

func file_agent_agent_proto_rawDescGZIP() []byte {
	file_agent_agent_proto_rawDescOnce.Do(func() {
		file_agent_agent_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_agent_agent_proto_rawDesc), len(file_agent_agent_proto_rawDesc)))
	})
	return file_agent_agent_proto_rawDescData
}

var file_agent_agent_proto_enumTypes = make([]protoimpl.EnumInfo, 10)
var file_agent_agent_proto_msgTypes = make([]protoimpl.MessageInfo, 82)
var file_agent_agent_proto_goTypes = []any{
	(CheckItem)(0),                            // 0: agent.CheckItem
	(ImportPrecheckStatusType_Enum)(0),        // 1: agent.ImportPrecheckStatusType.Enum
	(GetImportFilesResp_SourceType)(0),        // 2: agent.GetImportFilesResp.SourceType
	(GetImportFilesResp_Compression)(0),       // 3: agent.GetImportFilesResp.Compression
	(ClearSingleEmptyTableResult_Result)(0),   // 4: agent.ClearSingleEmptyTableResult.Result
	(ImportSourceType_Enum)(0),                // 5: agent.ImportSourceType.Enum
	(ImportS3AuthType_Enum)(0),                // 6: agent.ImportS3AuthType.Enum
	(ImportGcsAuthType_Enum)(0),               // 7: agent.ImportGcsAuthType.Enum
	(ImportAzureBlobAuthType_Enum)(0),         // 8: agent.ImportAzureBlobAuthType.Enum
	(ImportFileType_Enum)(0),                  // 9: agent.ImportFileType.Enum
	(*TableResult)(nil),                       // 10: agent.TableResult
	(*PrecheckImportJobReq)(nil),              // 11: agent.PrecheckImportJobReq
	(*PrecheckImportJobResp)(nil),             // 12: agent.PrecheckImportJobResp
	(*ImportPrecheckStatusType)(nil),          // 13: agent.ImportPrecheckStatusType
	(*DropClusterTablesReq)(nil),              // 14: agent.DropClusterTablesReq
	(*PrecheckImportFileReq)(nil),             // 15: agent.PrecheckImportFileReq
	(*SearchImportFilesReq)(nil),              // 16: agent.SearchImportFilesReq
	(*GetImportFilesReq)(nil),                 // 17: agent.GetImportFilesReq
	(*GetImportFilesResp)(nil),                // 18: agent.GetImportFilesResp
	(*CreateSchemasReq)(nil),                  // 19: agent.CreateSchemasReq
	(*CsvConfig)(nil),                         // 20: agent.CsvConfig
	(*PreviewCsvFileReq)(nil),                 // 21: agent.PreviewCsvFileReq
	(*SearchImportFilesResp)(nil),             // 22: agent.SearchImportFilesResp
	(*PreviewCsvFileResp)(nil),                // 23: agent.PreviewCsvFileResp
	(*CheckS3AccessReq)(nil),                  // 24: agent.CheckS3AccessReq
	(*CheckS3AccessResp)(nil),                 // 25: agent.CheckS3AccessResp
	(*CheckGcsAccessReq)(nil),                 // 26: agent.CheckGcsAccessReq
	(*CheckGcsAccessResp)(nil),                // 27: agent.CheckGcsAccessResp
	(*CheckAzblobAccessReq)(nil),              // 28: agent.CheckAzblobAccessReq
	(*CheckAzblobAccessResp)(nil),             // 29: agent.CheckAzblobAccessResp
	(*Cluster)(nil),                           // 30: agent.Cluster
	(*LoadDataReq)(nil),                       // 31: agent.LoadDataReq
	(*LoadDataResp)(nil),                      // 32: agent.LoadDataResp
	(*LightningPrecheckReq)(nil),              // 33: agent.LightningPrecheckReq
	(*LightningPrecheckResp)(nil),             // 34: agent.LightningPrecheckResp
	(*CheckResult)(nil),                       // 35: agent.CheckResult
	(*ExecSQLReq)(nil),                        // 36: agent.ExecSQLReq
	(*ExecSQLResp)(nil),                       // 37: agent.ExecSQLResp
	(*LightningSourcePreviewReq)(nil),         // 38: agent.LightningSourcePreviewReq
	(*LightningSourcePreviewResp)(nil),        // 39: agent.LightningSourcePreviewResp
	(*EstimateSourceDataSizeReq)(nil),         // 40: agent.EstimateSourceDataSizeReq
	(*EstimateSourceDataSizeResp)(nil),        // 41: agent.EstimateSourceDataSizeResp
	(*CheckDBConnectivityReq)(nil),            // 42: agent.CheckDBConnectivityReq
	(*CheckDBConnectivityResp)(nil),           // 43: agent.CheckDBConnectivityResp
	(*GetTiDBServerSecretReq)(nil),            // 44: agent.GetTiDBServerSecretReq
	(*GetTiDBServerSecretResp)(nil),           // 45: agent.GetTiDBServerSecretResp
	(*GetClusterClientSecretReq)(nil),         // 46: agent.GetClusterClientSecretReq
	(*GetClusterClientSecretResp)(nil),        // 47: agent.GetClusterClientSecretResp
	(*ImportsSchemaMeta)(nil),                 // 48: agent.ImportsSchemaMeta
	(*ImportsTableMeta)(nil),                  // 49: agent.ImportsTableMeta
	(*GetImportSchemasMetaReq)(nil),           // 50: agent.GetImportSchemasMetaReq
	(*GetImportSchemasMetaResp)(nil),          // 51: agent.GetImportSchemasMetaResp
	(*Row)(nil),                               // 52: agent.Row
	(*ColumnValue)(nil),                       // 53: agent.ColumnValue
	(*Table)(nil),                             // 54: agent.Table
	(*Schema)(nil),                            // 55: agent.Schema
	(*PrecheckDMJobReq)(nil),                  // 56: agent.PrecheckDMJobReq
	(*GcsOptions)(nil),                        // 57: agent.GcsOptions
	(*PrecheckDMJobResp)(nil),                 // 58: agent.PrecheckDMJobResp
	(*GetUserFileReq)(nil),                    // 59: agent.GetUserFileReq
	(*GetUserFileResp)(nil),                   // 60: agent.GetUserFileResp
	(*GetSourceTablesResp)(nil),               // 61: agent.GetSourceTablesResp
	(*GetSourceBinlogStatusResp)(nil),         // 62: agent.GetSourceBinlogStatusResp
	(*GetClusterTablesResp)(nil),              // 63: agent.GetClusterTablesResp
	(*NsLookupReq)(nil),                       // 64: agent.NsLookupReq
	(*NsLookupResp)(nil),                      // 65: agent.NsLookupResp
	(*ClearEmptyTablesReq)(nil),               // 66: agent.ClearEmptyTablesReq
	(*ClearEmptyTablesResp)(nil),              // 67: agent.ClearEmptyTablesResp
	(*ClearSingleEmptyTableResult)(nil),       // 68: agent.ClearSingleEmptyTableResult
	(*GetPublicKeyRequest)(nil),               // 69: agent.GetPublicKeyRequest
	(*GetPublicKeyResponse)(nil),              // 70: agent.GetPublicKeyResponse
	(*ImportSource)(nil),                      // 71: agent.ImportSource
	(*S3Source)(nil),                          // 72: agent.S3Source
	(*GCSSource)(nil),                         // 73: agent.GCSSource
	(*AzureBlobSource)(nil),                   // 74: agent.AzureBlobSource
	(*ImportSourceType)(nil),                  // 75: agent.ImportSourceType
	(*ImportS3AuthType)(nil),                  // 76: agent.ImportS3AuthType
	(*ImportGcsAuthType)(nil),                 // 77: agent.ImportGcsAuthType
	(*ImportAzureBlobAuthType)(nil),           // 78: agent.ImportAzureBlobAuthType
	(*ImportTargetTableInfo)(nil),             // 79: agent.ImportTargetTableInfo
	(*ImportOptions)(nil),                     // 80: agent.ImportOptions
	(*ImportFileType)(nil),                    // 81: agent.ImportFileType
	(*EncryptedData)(nil),                     // 82: agent.EncryptedData
	(*PrecheckImportFileReq_Source)(nil),      // 83: agent.PrecheckImportFileReq.Source
	(*SearchImportFilesReq_TargetSource)(nil), // 84: agent.SearchImportFilesReq.TargetSource
	(*GetImportFilesResp_DataFileMeta)(nil),   // 85: agent.GetImportFilesResp.DataFileMeta
	(*GetImportFilesResp_TableMeta)(nil),      // 86: agent.GetImportFilesResp.TableMeta
	(*SearchImportFilesResp_TableMatch)(nil),  // 87: agent.SearchImportFilesResp.TableMatch
	nil,                                       // 88: agent.ImportsSchemaMeta.TablesMetaEntry
	nil,                                       // 89: agent.GetImportSchemasMetaResp.SchemasMetaEntry
	(*S3Source_AccessKey)(nil),                // 90: agent.S3Source.AccessKey
	(*S3Source_RoleArn)(nil),                  // 91: agent.S3Source.RoleArn
	(*common.Table)(nil),                      // 92: common.Table
	(*base.BaseResp)(nil),                     // 93: base.BaseResp
	(*timestamppb.Timestamp)(nil),             // 94: google.protobuf.Timestamp
	(*emptypb.Empty)(nil),                     // 95: google.protobuf.Empty
}
var file_agent_agent_proto_depIdxs = []int32{
	92, // 0: agent.TableResult.target_table:type_name -> common.Table
	80, // 1: agent.PrecheckImportJobReq.import_options:type_name -> agent.ImportOptions
	71, // 2: agent.PrecheckImportJobReq.source:type_name -> agent.ImportSource
	30, // 3: agent.PrecheckImportJobReq.target_cluster:type_name -> agent.Cluster
	10, // 4: agent.PrecheckImportJobResp.target_tables:type_name -> agent.TableResult
	1,  // 5: agent.PrecheckImportJobResp.status:type_name -> agent.ImportPrecheckStatusType.Enum
	93, // 6: agent.PrecheckImportJobResp.base_resp:type_name -> base.BaseResp
	92, // 7: agent.DropClusterTablesReq.tables:type_name -> common.Table
	30, // 8: agent.DropClusterTablesReq.cluster:type_name -> agent.Cluster
	83, // 9: agent.PrecheckImportFileReq.sources:type_name -> agent.PrecheckImportFileReq.Source
	20, // 10: agent.PrecheckImportFileReq.csv_config:type_name -> agent.CsvConfig
	30, // 11: agent.PrecheckImportFileReq.cluster:type_name -> agent.Cluster
	84, // 12: agent.SearchImportFilesReq.target_source:type_name -> agent.SearchImportFilesReq.TargetSource
	57, // 13: agent.SearchImportFilesReq.gcs_options:type_name -> agent.GcsOptions
	86, // 14: agent.GetImportFilesResp.table_meta:type_name -> agent.GetImportFilesResp.TableMeta
	20, // 15: agent.PreviewCsvFileReq.csv_config:type_name -> agent.CsvConfig
	87, // 16: agent.SearchImportFilesResp.table_matches:type_name -> agent.SearchImportFilesResp.TableMatch
	54, // 17: agent.PreviewCsvFileResp.table:type_name -> agent.Table
	57, // 18: agent.CheckGcsAccessReq.gcs_options:type_name -> agent.GcsOptions
	82, // 19: agent.Cluster.encrypted_password:type_name -> agent.EncryptedData
	30, // 20: agent.LoadDataReq.cluster:type_name -> agent.Cluster
	0,  // 21: agent.LightningPrecheckReq.check_items:type_name -> agent.CheckItem
	35, // 22: agent.LightningPrecheckResp.check_results:type_name -> agent.CheckResult
	93, // 23: agent.LightningPrecheckResp.base_resp:type_name -> base.BaseResp
	0,  // 24: agent.CheckResult.check_item:type_name -> agent.CheckItem
	30, // 25: agent.ExecSQLReq.cluster:type_name -> agent.Cluster
	52, // 26: agent.ExecSQLResp.rows:type_name -> agent.Row
	55, // 27: agent.LightningSourcePreviewResp.schemas:type_name -> agent.Schema
	93, // 28: agent.LightningSourcePreviewResp.base_resp:type_name -> base.BaseResp
	93, // 29: agent.EstimateSourceDataSizeResp.base_resp:type_name -> base.BaseResp
	88, // 30: agent.ImportsSchemaMeta.tables_meta:type_name -> agent.ImportsSchemaMeta.TablesMetaEntry
	89, // 31: agent.GetImportSchemasMetaResp.schemas_meta:type_name -> agent.GetImportSchemasMetaResp.SchemasMetaEntry
	93, // 32: agent.GetImportSchemasMetaResp.base_resp:type_name -> base.BaseResp
	53, // 33: agent.Row.typed_column_values:type_name -> agent.ColumnValue
	94, // 34: agent.ColumnValue.timestamp_value:type_name -> google.protobuf.Timestamp
	52, // 35: agent.Table.row_values:type_name -> agent.Row
	54, // 36: agent.Schema.tables:type_name -> agent.Table
	57, // 37: agent.GetUserFileReq.gcs_options:type_name -> agent.GcsOptions
	55, // 38: agent.GetSourceTablesResp.schemas:type_name -> agent.Schema
	55, // 39: agent.GetClusterTablesResp.schemas:type_name -> agent.Schema
	30, // 40: agent.ClearEmptyTablesReq.cluster:type_name -> agent.Cluster
	92, // 41: agent.ClearEmptyTablesReq.tables:type_name -> common.Table
	68, // 42: agent.ClearEmptyTablesResp.results:type_name -> agent.ClearSingleEmptyTableResult
	92, // 43: agent.ClearSingleEmptyTableResult.table:type_name -> common.Table
	4,  // 44: agent.ClearSingleEmptyTableResult.result:type_name -> agent.ClearSingleEmptyTableResult.Result
	5,  // 45: agent.ImportSource.type:type_name -> agent.ImportSourceType.Enum
	72, // 46: agent.ImportSource.s3:type_name -> agent.S3Source
	73, // 47: agent.ImportSource.gcs:type_name -> agent.GCSSource
	74, // 48: agent.ImportSource.azure_blob:type_name -> agent.AzureBlobSource
	6,  // 49: agent.S3Source.auth_type:type_name -> agent.ImportS3AuthType.Enum
	91, // 50: agent.S3Source.role_arn:type_name -> agent.S3Source.RoleArn
	90, // 51: agent.S3Source.access_key:type_name -> agent.S3Source.AccessKey
	79, // 52: agent.S3Source.target_table_infos:type_name -> agent.ImportTargetTableInfo
	7,  // 53: agent.GCSSource.auth_type:type_name -> agent.ImportGcsAuthType.Enum
	79, // 54: agent.GCSSource.target_table_infos:type_name -> agent.ImportTargetTableInfo
	8,  // 55: agent.AzureBlobSource.auth_type:type_name -> agent.ImportAzureBlobAuthType.Enum
	79, // 56: agent.AzureBlobSource.target_table_infos:type_name -> agent.ImportTargetTableInfo
	92, // 57: agent.ImportTargetTableInfo.target_table:type_name -> common.Table
	9,  // 58: agent.ImportOptions.file_type:type_name -> agent.ImportFileType.Enum
	20, // 59: agent.ImportOptions.csv_config:type_name -> agent.CsvConfig
	92, // 60: agent.PrecheckImportFileReq.Source.table:type_name -> common.Table
	92, // 61: agent.SearchImportFilesReq.TargetSource.target_table:type_name -> common.Table
	2,  // 62: agent.GetImportFilesResp.DataFileMeta.source_type:type_name -> agent.GetImportFilesResp.SourceType
	3,  // 63: agent.GetImportFilesResp.DataFileMeta.compression:type_name -> agent.GetImportFilesResp.Compression
	85, // 64: agent.GetImportFilesResp.TableMeta.data_files:type_name -> agent.GetImportFilesResp.DataFileMeta
	92, // 65: agent.SearchImportFilesResp.TableMatch.target_table:type_name -> common.Table
	49, // 66: agent.ImportsSchemaMeta.TablesMetaEntry.value:type_name -> agent.ImportsTableMeta
	48, // 67: agent.GetImportSchemasMetaResp.SchemasMetaEntry.value:type_name -> agent.ImportsSchemaMeta
	11, // 68: agent.AgentService.PrecheckImportJob:input_type -> agent.PrecheckImportJobReq
	24, // 69: agent.AgentService.CheckS3Access:input_type -> agent.CheckS3AccessReq
	26, // 70: agent.AgentService.CheckGcsAccess:input_type -> agent.CheckGcsAccessReq
	28, // 71: agent.AgentService.CheckAzblobAccess:input_type -> agent.CheckAzblobAccessReq
	33, // 72: agent.AgentService.LightningPrecheck:input_type -> agent.LightningPrecheckReq
	36, // 73: agent.AgentService.ExecSQLOnCluster:input_type -> agent.ExecSQLReq
	31, // 74: agent.AgentService.LoadDataToCluster:input_type -> agent.LoadDataReq
	50, // 75: agent.AgentService.GetImportSchemasMeta:input_type -> agent.GetImportSchemasMetaReq
	38, // 76: agent.AgentService.LightningSourcePreview:input_type -> agent.LightningSourcePreviewReq
	40, // 77: agent.AgentService.EstimateSourceDataSize:input_type -> agent.EstimateSourceDataSizeReq
	42, // 78: agent.AgentService.CheckDBConnectivity:input_type -> agent.CheckDBConnectivityReq
	44, // 79: agent.AgentService.GetTiDBServerSecret:input_type -> agent.GetTiDBServerSecretReq
	46, // 80: agent.AgentService.GetClusterClientSecret:input_type -> agent.GetClusterClientSecretReq
	56, // 81: agent.AgentService.PrecheckDMJob:input_type -> agent.PrecheckDMJobReq
	59, // 82: agent.AgentService.GetUserFileContent:input_type -> agent.GetUserFileReq
	42, // 83: agent.AgentService.GetSourceTables:input_type -> agent.CheckDBConnectivityReq
	42, // 84: agent.AgentService.GetSourceBinlogStatus:input_type -> agent.CheckDBConnectivityReq
	30, // 85: agent.AgentService.GetClusterTables:input_type -> agent.Cluster
	64, // 86: agent.AgentService.NsLookup:input_type -> agent.NsLookupReq
	66, // 87: agent.AgentService.ClearEmptyTables:input_type -> agent.ClearEmptyTablesReq
	16, // 88: agent.AgentService.SearchImportFiles:input_type -> agent.SearchImportFilesReq
	17, // 89: agent.AgentService.GetImportFiles:input_type -> agent.GetImportFilesReq
	19, // 90: agent.AgentService.CreateSchemas:input_type -> agent.CreateSchemasReq
	21, // 91: agent.AgentService.PreviewCsvFile:input_type -> agent.PreviewCsvFileReq
	15, // 92: agent.AgentService.PrecheckImportFile:input_type -> agent.PrecheckImportFileReq
	14, // 93: agent.AgentService.DropClusterTables:input_type -> agent.DropClusterTablesReq
	69, // 94: agent.AgentService.GetPublicKey:input_type -> agent.GetPublicKeyRequest
	12, // 95: agent.AgentService.PrecheckImportJob:output_type -> agent.PrecheckImportJobResp
	25, // 96: agent.AgentService.CheckS3Access:output_type -> agent.CheckS3AccessResp
	27, // 97: agent.AgentService.CheckGcsAccess:output_type -> agent.CheckGcsAccessResp
	29, // 98: agent.AgentService.CheckAzblobAccess:output_type -> agent.CheckAzblobAccessResp
	34, // 99: agent.AgentService.LightningPrecheck:output_type -> agent.LightningPrecheckResp
	37, // 100: agent.AgentService.ExecSQLOnCluster:output_type -> agent.ExecSQLResp
	32, // 101: agent.AgentService.LoadDataToCluster:output_type -> agent.LoadDataResp
	51, // 102: agent.AgentService.GetImportSchemasMeta:output_type -> agent.GetImportSchemasMetaResp
	39, // 103: agent.AgentService.LightningSourcePreview:output_type -> agent.LightningSourcePreviewResp
	41, // 104: agent.AgentService.EstimateSourceDataSize:output_type -> agent.EstimateSourceDataSizeResp
	43, // 105: agent.AgentService.CheckDBConnectivity:output_type -> agent.CheckDBConnectivityResp
	45, // 106: agent.AgentService.GetTiDBServerSecret:output_type -> agent.GetTiDBServerSecretResp
	47, // 107: agent.AgentService.GetClusterClientSecret:output_type -> agent.GetClusterClientSecretResp
	58, // 108: agent.AgentService.PrecheckDMJob:output_type -> agent.PrecheckDMJobResp
	60, // 109: agent.AgentService.GetUserFileContent:output_type -> agent.GetUserFileResp
	61, // 110: agent.AgentService.GetSourceTables:output_type -> agent.GetSourceTablesResp
	62, // 111: agent.AgentService.GetSourceBinlogStatus:output_type -> agent.GetSourceBinlogStatusResp
	63, // 112: agent.AgentService.GetClusterTables:output_type -> agent.GetClusterTablesResp
	65, // 113: agent.AgentService.NsLookup:output_type -> agent.NsLookupResp
	67, // 114: agent.AgentService.ClearEmptyTables:output_type -> agent.ClearEmptyTablesResp
	22, // 115: agent.AgentService.SearchImportFiles:output_type -> agent.SearchImportFilesResp
	18, // 116: agent.AgentService.GetImportFiles:output_type -> agent.GetImportFilesResp
	95, // 117: agent.AgentService.CreateSchemas:output_type -> google.protobuf.Empty
	23, // 118: agent.AgentService.PreviewCsvFile:output_type -> agent.PreviewCsvFileResp
	95, // 119: agent.AgentService.PrecheckImportFile:output_type -> google.protobuf.Empty
	95, // 120: agent.AgentService.DropClusterTables:output_type -> google.protobuf.Empty
	70, // 121: agent.AgentService.GetPublicKey:output_type -> agent.GetPublicKeyResponse
	95, // [95:122] is the sub-list for method output_type
	68, // [68:95] is the sub-list for method input_type
	68, // [68:68] is the sub-list for extension type_name
	68, // [68:68] is the sub-list for extension extendee
	0,  // [0:68] is the sub-list for field type_name
}

func init() { file_agent_agent_proto_init() }
func file_agent_agent_proto_init() {
	if File_agent_agent_proto != nil {
		return
	}
	file_agent_agent_proto_msgTypes[10].OneofWrappers = []any{}
	file_agent_agent_proto_msgTypes[43].OneofWrappers = []any{
		(*ColumnValue_StringValue)(nil),
		(*ColumnValue_Int64Value)(nil),
		(*ColumnValue_DoubleValue)(nil),
		(*ColumnValue_BoolValue)(nil),
		(*ColumnValue_TimestampValue)(nil),
	}
	file_agent_agent_proto_msgTypes[61].OneofWrappers = []any{
		(*ImportSource_S3)(nil),
		(*ImportSource_Gcs)(nil),
		(*ImportSource_AzureBlob)(nil),
	}
	file_agent_agent_proto_msgTypes[62].OneofWrappers = []any{
		(*S3Source_RoleArn_)(nil),
		(*S3Source_AccessKey_)(nil),
	}
	file_agent_agent_proto_msgTypes[63].OneofWrappers = []any{
		(*GCSSource_ServiceAccountKey)(nil),
	}
	file_agent_agent_proto_msgTypes[64].OneofWrappers = []any{
		(*AzureBlobSource_SasToken)(nil),
	}
	file_agent_agent_proto_msgTypes[70].OneofWrappers = []any{
		(*ImportOptions_CsvConfig)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_agent_agent_proto_rawDesc), len(file_agent_agent_proto_rawDesc)),
			NumEnums:      10,
			NumMessages:   82,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_agent_agent_proto_goTypes,
		DependencyIndexes: file_agent_agent_proto_depIdxs,
		EnumInfos:         file_agent_agent_proto_enumTypes,
		MessageInfos:      file_agent_agent_proto_msgTypes,
	}.Build()
	File_agent_agent_proto = out.File
	file_agent_agent_proto_goTypes = nil
	file_agent_agent_proto_depIdxs = nil
}