pb

package
v0.0.18 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	Master_UpsertDatabase_FullMethodName          = "/proto.Master/UpsertDatabase"
	Master_DeleteDatabase_FullMethodName          = "/proto.Master/DeleteDatabase"
	Master_ShowDatabase_FullMethodName            = "/proto.Master/ShowDatabase"
	Master_UpsertDatasource_FullMethodName        = "/proto.Master/UpsertDatasource"
	Master_DeleteDatasource_FullMethodName        = "/proto.Master/DeleteDatasource"
	Master_ShowDatasource_FullMethodName          = "/proto.Master/ShowDatasource"
	Master_UpsertAssessMigrateTask_FullMethodName = "/proto.Master/UpsertAssessMigrateTask"
	Master_DeleteAssessMigrateTask_FullMethodName = "/proto.Master/DeleteAssessMigrateTask"
	Master_ShowAssessMigrateTask_FullMethodName   = "/proto.Master/ShowAssessMigrateTask"
	Master_UpsertStructMigrateTask_FullMethodName = "/proto.Master/UpsertStructMigrateTask"
	Master_DeleteStructMigrateTask_FullMethodName = "/proto.Master/DeleteStructMigrateTask"
	Master_ShowStructMigrateTask_FullMethodName   = "/proto.Master/ShowStructMigrateTask"
	Master_UpsertStructCompareTask_FullMethodName = "/proto.Master/UpsertStructCompareTask"
	Master_DeleteStructCompareTask_FullMethodName = "/proto.Master/DeleteStructCompareTask"
	Master_ShowStructCompareTask_FullMethodName   = "/proto.Master/ShowStructCompareTask"
	Master_UpsertStmtMigrateTask_FullMethodName   = "/proto.Master/UpsertStmtMigrateTask"
	Master_DeleteStmtMigrateTask_FullMethodName   = "/proto.Master/DeleteStmtMigrateTask"
	Master_ShowStmtMigrateTask_FullMethodName     = "/proto.Master/ShowStmtMigrateTask"
	Master_UpsertSqlMigrateTask_FullMethodName    = "/proto.Master/UpsertSqlMigrateTask"
	Master_DeleteSqlMigrateTask_FullMethodName    = "/proto.Master/DeleteSqlMigrateTask"
	Master_ShowSqlMigrateTask_FullMethodName      = "/proto.Master/ShowSqlMigrateTask"
	Master_UpsertCsvMigrateTask_FullMethodName    = "/proto.Master/UpsertCsvMigrateTask"
	Master_DeleteCsvMigrateTask_FullMethodName    = "/proto.Master/DeleteCsvMigrateTask"
	Master_ShowCsvMigrateTask_FullMethodName      = "/proto.Master/ShowCsvMigrateTask"
	Master_UpsertDataCompareTask_FullMethodName   = "/proto.Master/UpsertDataCompareTask"
	Master_DeleteDataCompareTask_FullMethodName   = "/proto.Master/DeleteDataCompareTask"
	Master_ShowDataCompareTask_FullMethodName     = "/proto.Master/ShowDataCompareTask"
	Master_UpsertDataScanTask_FullMethodName      = "/proto.Master/UpsertDataScanTask"
	Master_DeleteDataScanTask_FullMethodName      = "/proto.Master/DeleteDataScanTask"
	Master_ShowDataScanTask_FullMethodName        = "/proto.Master/ShowDataScanTask"
	Master_UpsertCdcConsumeTask_FullMethodName    = "/proto.Master/UpsertCdcConsumeTask"
	Master_DeleteCdcConsumeTask_FullMethodName    = "/proto.Master/DeleteCdcConsumeTask"
	Master_ShowCdcConsumeTask_FullMethodName      = "/proto.Master/ShowCdcConsumeTask"
	Master_OperateTask_FullMethodName             = "/proto.Master/OperateTask"
)
View Source 
const (
	Worker_OperateWorker_FullMethodName = "/proto.Worker/OperateWorker"
)

Variables

View Source 
var File_dbms_master_proto protoreflect.FileDescriptor
View Source 
var File_dbms_worker_proto protoreflect.FileDescriptor
View Source 
var File_response_proto protoreflect.FileDescriptor
View Source 
var Master_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Master",
	HandlerType: (*MasterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpsertDatabase",
			Handler:    _Master_UpsertDatabase_Handler,
		},
		{
			MethodName: "DeleteDatabase",
			Handler:    _Master_DeleteDatabase_Handler,
		},
		{
			MethodName: "ShowDatabase",
			Handler:    _Master_ShowDatabase_Handler,
		},
		{
			MethodName: "UpsertDatasource",
			Handler:    _Master_UpsertDatasource_Handler,
		},
		{
			MethodName: "DeleteDatasource",
			Handler:    _Master_DeleteDatasource_Handler,
		},
		{
			MethodName: "ShowDatasource",
			Handler:    _Master_ShowDatasource_Handler,
		},
		{
			MethodName: "UpsertAssessMigrateTask",
			Handler:    _Master_UpsertAssessMigrateTask_Handler,
		},
		{
			MethodName: "DeleteAssessMigrateTask",
			Handler:    _Master_DeleteAssessMigrateTask_Handler,
		},
		{
			MethodName: "ShowAssessMigrateTask",
			Handler:    _Master_ShowAssessMigrateTask_Handler,
		},
		{
			MethodName: "UpsertStructMigrateTask",
			Handler:    _Master_UpsertStructMigrateTask_Handler,
		},
		{
			MethodName: "DeleteStructMigrateTask",
			Handler:    _Master_DeleteStructMigrateTask_Handler,
		},
		{
			MethodName: "ShowStructMigrateTask",
			Handler:    _Master_ShowStructMigrateTask_Handler,
		},
		{
			MethodName: "UpsertStructCompareTask",
			Handler:    _Master_UpsertStructCompareTask_Handler,
		},
		{
			MethodName: "DeleteStructCompareTask",
			Handler:    _Master_DeleteStructCompareTask_Handler,
		},
		{
			MethodName: "ShowStructCompareTask",
			Handler:    _Master_ShowStructCompareTask_Handler,
		},
		{
			MethodName: "UpsertStmtMigrateTask",
			Handler:    _Master_UpsertStmtMigrateTask_Handler,
		},
		{
			MethodName: "DeleteStmtMigrateTask",
			Handler:    _Master_DeleteStmtMigrateTask_Handler,
		},
		{
			MethodName: "ShowStmtMigrateTask",
			Handler:    _Master_ShowStmtMigrateTask_Handler,
		},
		{
			MethodName: "UpsertSqlMigrateTask",
			Handler:    _Master_UpsertSqlMigrateTask_Handler,
		},
		{
			MethodName: "DeleteSqlMigrateTask",
			Handler:    _Master_DeleteSqlMigrateTask_Handler,
		},
		{
			MethodName: "ShowSqlMigrateTask",
			Handler:    _Master_ShowSqlMigrateTask_Handler,
		},
		{
			MethodName: "UpsertCsvMigrateTask",
			Handler:    _Master_UpsertCsvMigrateTask_Handler,
		},
		{
			MethodName: "DeleteCsvMigrateTask",
			Handler:    _Master_DeleteCsvMigrateTask_Handler,
		},
		{
			MethodName: "ShowCsvMigrateTask",
			Handler:    _Master_ShowCsvMigrateTask_Handler,
		},
		{
			MethodName: "UpsertDataCompareTask",
			Handler:    _Master_UpsertDataCompareTask_Handler,
		},
		{
			MethodName: "DeleteDataCompareTask",
			Handler:    _Master_DeleteDataCompareTask_Handler,
		},
		{
			MethodName: "ShowDataCompareTask",
			Handler:    _Master_ShowDataCompareTask_Handler,
		},
		{
			MethodName: "UpsertDataScanTask",
			Handler:    _Master_UpsertDataScanTask_Handler,
		},
		{
			MethodName: "DeleteDataScanTask",
			Handler:    _Master_DeleteDataScanTask_Handler,
		},
		{
			MethodName: "ShowDataScanTask",
			Handler:    _Master_ShowDataScanTask_Handler,
		},
		{
			MethodName: "UpsertCdcConsumeTask",
			Handler:    _Master_UpsertCdcConsumeTask_Handler,
		},
		{
			MethodName: "DeleteCdcConsumeTask",
			Handler:    _Master_DeleteCdcConsumeTask_Handler,
		},
		{
			MethodName: "ShowCdcConsumeTask",
			Handler:    _Master_ShowCdcConsumeTask_Handler,
		},
		{
			MethodName: "OperateTask",
			Handler:    _Master_OperateTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dbms_master.proto",
}

Master_ServiceDesc is the grpc.ServiceDesc for Master service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Worker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Worker",
	HandlerType: (*WorkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OperateWorker",
			Handler:    _Worker_OperateWorker_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dbms_worker.proto",
}

Worker_ServiceDesc is the grpc.ServiceDesc for Worker service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMasterHandler 

func RegisterMasterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMasterHandler registers the http handlers for service Master to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMasterHandlerClient 

func RegisterMasterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MasterClient) error

RegisterMasterHandlerClient registers the http handlers for service Master to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MasterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MasterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MasterClient" to call the correct interceptors.

func RegisterMasterHandlerFromEndpoint 

func RegisterMasterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMasterHandlerFromEndpoint is same as RegisterMasterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMasterHandlerServer 

func RegisterMasterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MasterServer) error

RegisterMasterHandlerServer registers the http handlers for service Master to "mux". UnaryRPC :call MasterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMasterHandlerFromEndpoint instead.

func RegisterMasterServer 

func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)

func RegisterWorkerHandler 

func RegisterWorkerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterWorkerHandler registers the http handlers for service Worker to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterWorkerHandlerClient 

func RegisterWorkerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkerClient) error

RegisterWorkerHandlerClient registers the http handlers for service Worker to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WorkerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WorkerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "WorkerClient" to call the correct interceptors.

func RegisterWorkerHandlerFromEndpoint 

func RegisterWorkerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterWorkerHandlerFromEndpoint is same as RegisterWorkerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterWorkerHandlerServer 

func RegisterWorkerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkerServer) error

RegisterWorkerHandlerServer registers the http handlers for service Worker to "mux". UnaryRPC :call WorkerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWorkerHandlerFromEndpoint instead.

func RegisterWorkerServer 

func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)

Types

type AssessMigrateParam 

type AssessMigrateParam struct {
	CaseFieldRuleS string `protobuf:"bytes,1,opt,name=caseFieldRuleS,proto3" json:"caseFieldRuleS,omitempty"`
	SchemaNameS    string `protobuf:"bytes,2,opt,name=schemaNameS,proto3" json:"schemaNameS,omitempty"`
	CallTimeout    uint64 `protobuf:"varint,3,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	// contains filtered or unexported fields
}

func (*AssessMigrateParam) Descriptor deprecated 

func (*AssessMigrateParam) Descriptor() ([]byte, []int)

Deprecated: Use AssessMigrateParam.ProtoReflect.Descriptor instead.

func (*AssessMigrateParam) GetCallTimeout added in v0.0.8 

func (x *AssessMigrateParam) GetCallTimeout() uint64

func (*AssessMigrateParam) GetCaseFieldRuleS 

func (x *AssessMigrateParam) GetCaseFieldRuleS() string

func (*AssessMigrateParam) GetSchemaNameS 

func (x *AssessMigrateParam) GetSchemaNameS() string

func (*AssessMigrateParam) ProtoMessage 

func (*AssessMigrateParam) ProtoMessage()

func (*AssessMigrateParam) ProtoReflect 

func (x *AssessMigrateParam) ProtoReflect() protoreflect.Message

func (*AssessMigrateParam) Reset 

func (x *AssessMigrateParam) Reset()

func (*AssessMigrateParam) String 

func (x *AssessMigrateParam) String() string

type CaseFieldRule 

type CaseFieldRule struct {
	CaseFieldRuleS string `protobuf:"bytes,1,opt,name=caseFieldRuleS,proto3" json:"caseFieldRuleS,omitempty"`
	CaseFieldRuleT string `protobuf:"bytes,2,opt,name=caseFieldRuleT,proto3" json:"caseFieldRuleT,omitempty"`
	// contains filtered or unexported fields
}

func (*CaseFieldRule) Descriptor deprecated 

func (*CaseFieldRule) Descriptor() ([]byte, []int)

Deprecated: Use CaseFieldRule.ProtoReflect.Descriptor instead.

func (*CaseFieldRule) GetCaseFieldRuleS 

func (x *CaseFieldRule) GetCaseFieldRuleS() string

func (*CaseFieldRule) GetCaseFieldRuleT 

func (x *CaseFieldRule) GetCaseFieldRuleT() string

func (*CaseFieldRule) ProtoMessage 

func (*CaseFieldRule) ProtoMessage()

func (*CaseFieldRule) ProtoReflect 

func (x *CaseFieldRule) ProtoReflect() protoreflect.Message

func (*CaseFieldRule) Reset 

func (x *CaseFieldRule) Reset()

func (*CaseFieldRule) String 

func (x *CaseFieldRule) String() string

type CdcConsumeParam added in v0.0.17 

type CdcConsumeParam struct {
	TableThread           uint64   `protobuf:"varint,1,opt,name=tableThread,proto3" json:"tableThread,omitempty"`
	MessageCompression    string   `protobuf:"bytes,2,opt,name=messageCompression,proto3" json:"messageCompression,omitempty"`
	IdleResolvedThreshold uint64   `protobuf:"varint,3,opt,name=idleResolvedThreshold,proto3" json:"idleResolvedThreshold,omitempty"`
	CallTimeout           uint64   `protobuf:"varint,4,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	ServerAddress         []string `protobuf:"bytes,5,rep,name=serverAddress,proto3" json:"serverAddress,omitempty"`
	SubscribeTopic        string   `protobuf:"bytes,6,opt,name=subscribeTopic,proto3" json:"subscribeTopic,omitempty"`
	EnableCheckpoint      bool     `protobuf:"varint,7,opt,name=enableCheckpoint,proto3" json:"enableCheckpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*CdcConsumeParam) Descriptor deprecated added in v0.0.17 

func (*CdcConsumeParam) Descriptor() ([]byte, []int)

Deprecated: Use CdcConsumeParam.ProtoReflect.Descriptor instead.

func (*CdcConsumeParam) GetCallTimeout added in v0.0.17 

func (x *CdcConsumeParam) GetCallTimeout() uint64

func (*CdcConsumeParam) GetEnableCheckpoint added in v0.0.17 

func (x *CdcConsumeParam) GetEnableCheckpoint() bool

func (*CdcConsumeParam) GetIdleResolvedThreshold added in v0.0.17 

func (x *CdcConsumeParam) GetIdleResolvedThreshold() uint64

func (*CdcConsumeParam) GetMessageCompression added in v0.0.17 

func (x *CdcConsumeParam) GetMessageCompression() string

func (*CdcConsumeParam) GetServerAddress added in v0.0.17 

func (x *CdcConsumeParam) GetServerAddress() []string

func (*CdcConsumeParam) GetSubscribeTopic added in v0.0.17 

func (x *CdcConsumeParam) GetSubscribeTopic() string

func (*CdcConsumeParam) GetTableThread added in v0.0.17 

func (x *CdcConsumeParam) GetTableThread() uint64

func (*CdcConsumeParam) ProtoMessage added in v0.0.17 

func (*CdcConsumeParam) ProtoMessage()

func (*CdcConsumeParam) ProtoReflect added in v0.0.17 

func (x *CdcConsumeParam) ProtoReflect() protoreflect.Message

func (*CdcConsumeParam) Reset added in v0.0.17 

func (x *CdcConsumeParam) Reset()

func (*CdcConsumeParam) String added in v0.0.17 

func (x *CdcConsumeParam) String() string

type ColumnStructRule 

type ColumnStructRule struct {
	SchemaNameS   string `protobuf:"bytes,1,opt,name=schemaNameS,proto3" json:"schemaNameS,omitempty"`
	TableNameS    string `protobuf:"bytes,2,opt,name=tableNameS,proto3" json:"tableNameS,omitempty"`
	ColumnNameS   string `protobuf:"bytes,3,opt,name=columnNameS,proto3" json:"columnNameS,omitempty"`
	ColumnTypeS   string `protobuf:"bytes,4,opt,name=columnTypeS,proto3" json:"columnTypeS,omitempty"`
	ColumnTypeT   string `protobuf:"bytes,5,opt,name=columnTypeT,proto3" json:"columnTypeT,omitempty"`
	DefaultValueS string `protobuf:"bytes,6,opt,name=defaultValueS,proto3" json:"defaultValueS,omitempty"`
	DefaultValueT string `protobuf:"bytes,7,opt,name=defaultValueT,proto3" json:"defaultValueT,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnStructRule) Descriptor deprecated 

func (*ColumnStructRule) Descriptor() ([]byte, []int)

Deprecated: Use ColumnStructRule.ProtoReflect.Descriptor instead.

func (*ColumnStructRule) GetColumnNameS 

func (x *ColumnStructRule) GetColumnNameS() string

func (*ColumnStructRule) GetColumnTypeS 

func (x *ColumnStructRule) GetColumnTypeS() string

func (*ColumnStructRule) GetColumnTypeT 

func (x *ColumnStructRule) GetColumnTypeT() string

func (*ColumnStructRule) GetDefaultValueS 

func (x *ColumnStructRule) GetDefaultValueS() string

func (*ColumnStructRule) GetDefaultValueT 

func (x *ColumnStructRule) GetDefaultValueT() string

func (*ColumnStructRule) GetSchemaNameS 

func (x *ColumnStructRule) GetSchemaNameS() string

func (*ColumnStructRule) GetTableNameS 

func (x *ColumnStructRule) GetTableNameS() string

func (*ColumnStructRule) ProtoMessage 

func (*ColumnStructRule) ProtoMessage()

func (*ColumnStructRule) ProtoReflect 

func (x *ColumnStructRule) ProtoReflect() protoreflect.Message

func (*ColumnStructRule) Reset 

func (x *ColumnStructRule) Reset()

func (*ColumnStructRule) String 

func (x *ColumnStructRule) String() string

type CsvMigrateParam 

type CsvMigrateParam struct {
	TableThread          uint64            `protobuf:"varint,1,opt,name=tableThread,proto3" json:"tableThread,omitempty"`
	BatchSize            uint64            `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	Header               bool              `protobuf:"varint,3,opt,name=header,proto3" json:"header,omitempty"`
	DiskUsageFactor      string            `protobuf:"bytes,4,opt,name=diskUsageFactor,proto3" json:"diskUsageFactor,omitempty"`
	Separator            string            `protobuf:"bytes,5,opt,name=separator,proto3" json:"separator,omitempty"`
	Terminator           string            `protobuf:"bytes,6,opt,name=terminator,proto3" json:"terminator,omitempty"`
	DataCharsetT         string            `protobuf:"bytes,7,opt,name=dataCharsetT,proto3" json:"dataCharsetT,omitempty"`
	Delimiter            string            `protobuf:"bytes,8,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	NullValue            string            `protobuf:"bytes,9,opt,name=nullValue,proto3" json:"nullValue,omitempty"`
	EscapeBackslash      bool              `protobuf:"varint,10,opt,name=escapeBackslash,proto3" json:"escapeBackslash,omitempty"`
	ChunkSize            uint64            `protobuf:"varint,11,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
	OutputDir            string            `protobuf:"bytes,12,opt,name=outputDir,proto3" json:"outputDir,omitempty"`
	SqlThreadS           uint64            `protobuf:"varint,13,opt,name=sqlThreadS,proto3" json:"sqlThreadS,omitempty"`
	SqlHintS             string            `protobuf:"bytes,14,opt,name=sqlHintS,proto3" json:"sqlHintS,omitempty"`
	CallTimeout          uint64            `protobuf:"varint,15,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	EnableCheckpoint     bool              `protobuf:"varint,16,opt,name=enableCheckpoint,proto3" json:"enableCheckpoint,omitempty"`
	EnableConsistentRead bool              `protobuf:"varint,17,opt,name=enableConsistentRead,proto3" json:"enableConsistentRead,omitempty"`
	WriteThread          uint64            `protobuf:"varint,18,opt,name=writeThread,proto3" json:"writeThread,omitempty"`
	EnableImportFeature  bool              `protobuf:"varint,19,opt,name=enableImportFeature,proto3" json:"enableImportFeature,omitempty"`
	CsvImportParams      map[string]string `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CsvMigrateParam) Descriptor deprecated 

func (*CsvMigrateParam) Descriptor() ([]byte, []int)

Deprecated: Use CsvMigrateParam.ProtoReflect.Descriptor instead.

func (*CsvMigrateParam) GetBatchSize 

func (x *CsvMigrateParam) GetBatchSize() uint64

func (*CsvMigrateParam) GetCallTimeout 

func (x *CsvMigrateParam) GetCallTimeout() uint64

func (*CsvMigrateParam) GetChunkSize 

func (x *CsvMigrateParam) GetChunkSize() uint64

func (*CsvMigrateParam) GetCsvImportParams added in v0.0.14 

func (x *CsvMigrateParam) GetCsvImportParams() map[string]string

func (*CsvMigrateParam) GetDataCharsetT 

func (x *CsvMigrateParam) GetDataCharsetT() string

func (*CsvMigrateParam) GetDelimiter 

func (x *CsvMigrateParam) GetDelimiter() string

func (*CsvMigrateParam) GetDiskUsageFactor 

func (x *CsvMigrateParam) GetDiskUsageFactor() string

func (*CsvMigrateParam) GetEnableCheckpoint 

func (x *CsvMigrateParam) GetEnableCheckpoint() bool

func (*CsvMigrateParam) GetEnableConsistentRead 

func (x *CsvMigrateParam) GetEnableConsistentRead() bool

func (*CsvMigrateParam) GetEnableImportFeature added in v0.0.14 

func (x *CsvMigrateParam) GetEnableImportFeature() bool

func (*CsvMigrateParam) GetEscapeBackslash 

func (x *CsvMigrateParam) GetEscapeBackslash() bool

func (*CsvMigrateParam) GetHeader 

func (x *CsvMigrateParam) GetHeader() bool

func (*CsvMigrateParam) GetNullValue 

func (x *CsvMigrateParam) GetNullValue() string

func (*CsvMigrateParam) GetOutputDir 

func (x *CsvMigrateParam) GetOutputDir() string

func (*CsvMigrateParam) GetSeparator 

func (x *CsvMigrateParam) GetSeparator() string

func (*CsvMigrateParam) GetSqlHintS 

func (x *CsvMigrateParam) GetSqlHintS() string

func (*CsvMigrateParam) GetSqlThreadS 

func (x *CsvMigrateParam) GetSqlThreadS() uint64

func (*CsvMigrateParam) GetTableThread 

func (x *CsvMigrateParam) GetTableThread() uint64

func (*CsvMigrateParam) GetTerminator 

func (x *CsvMigrateParam) GetTerminator() string

func (*CsvMigrateParam) GetWriteThread added in v0.0.9 

func (x *CsvMigrateParam) GetWriteThread() uint64

func (*CsvMigrateParam) ProtoMessage 

func (*CsvMigrateParam) ProtoMessage()

func (*CsvMigrateParam) ProtoReflect 

func (x *CsvMigrateParam) ProtoReflect() protoreflect.Message

func (*CsvMigrateParam) Reset 

func (x *CsvMigrateParam) Reset()

func (*CsvMigrateParam) String 

func (x *CsvMigrateParam) String() string

type DataCompareParam 

type DataCompareParam struct {
	TableThread            uint64   `protobuf:"varint,1,opt,name=tableThread,proto3" json:"tableThread,omitempty"`
	BatchSize              uint64   `protobuf:"varint,2,opt,name=BatchSize,proto3" json:"BatchSize,omitempty"`
	SqlThread              uint64   `protobuf:"varint,3,opt,name=sqlThread,proto3" json:"sqlThread,omitempty"`
	SqlHintS               string   `protobuf:"bytes,4,opt,name=sqlHintS,proto3" json:"sqlHintS,omitempty"`
	SqlHintT               string   `protobuf:"bytes,5,opt,name=sqlHintT,proto3" json:"sqlHintT,omitempty"`
	CallTimeout            uint64   `protobuf:"varint,6,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	EnableCheckpoint       bool     `protobuf:"varint,7,opt,name=enableCheckpoint,proto3" json:"enableCheckpoint,omitempty"`
	EnableConsistentRead   bool     `protobuf:"varint,8,opt,name=enableConsistentRead,proto3" json:"enableConsistentRead,omitempty"`
	OnlyCompareRow         bool     `protobuf:"varint,9,opt,name=OnlyCompareRow,proto3" json:"OnlyCompareRow,omitempty"`
	ConsistentReadPointS   string   `protobuf:"bytes,10,opt,name=consistentReadPointS,proto3" json:"consistentReadPointS,omitempty"`
	ConsistentReadPointT   string   `protobuf:"bytes,11,opt,name=consistentReadPointT,proto3" json:"consistentReadPointT,omitempty"`
	WriteThread            uint64   `protobuf:"varint,13,opt,name=writeThread,proto3" json:"writeThread,omitempty"`
	ChunkSize              uint64   `protobuf:"varint,14,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
	IgnoreConditionFields  []string `protobuf:"bytes,15,rep,name=ignoreConditionFields,proto3" json:"ignoreConditionFields,omitempty"`
	RepairStmtFlow         string   `protobuf:"bytes,16,opt,name=repairStmtFlow,proto3" json:"repairStmtFlow,omitempty"`
	EnableCollationSetting bool     `protobuf:"varint,17,opt,name=enableCollationSetting,proto3" json:"enableCollationSetting,omitempty"`
	DisableMd5Checksum     bool     `protobuf:"varint,18,opt,name=disableMd5Checksum,proto3" json:"disableMd5Checksum,omitempty"`
	Separator              string   `protobuf:"bytes,19,opt,name=separator,proto3" json:"separator,omitempty"`
	// contains filtered or unexported fields
}

func (*DataCompareParam) Descriptor deprecated 

func (*DataCompareParam) Descriptor() ([]byte, []int)

Deprecated: Use DataCompareParam.ProtoReflect.Descriptor instead.

func (*DataCompareParam) GetBatchSize 

func (x *DataCompareParam) GetBatchSize() uint64

func (*DataCompareParam) GetCallTimeout 

func (x *DataCompareParam) GetCallTimeout() uint64

func (*DataCompareParam) GetChunkSize added in v0.0.7 

func (x *DataCompareParam) GetChunkSize() uint64

func (*DataCompareParam) GetConsistentReadPointS added in v0.0.4 

func (x *DataCompareParam) GetConsistentReadPointS() string

func (*DataCompareParam) GetConsistentReadPointT added in v0.0.4 

func (x *DataCompareParam) GetConsistentReadPointT() string

func (*DataCompareParam) GetDisableMd5Checksum added in v0.0.8 

func (x *DataCompareParam) GetDisableMd5Checksum() bool

func (*DataCompareParam) GetEnableCheckpoint 

func (x *DataCompareParam) GetEnableCheckpoint() bool

func (*DataCompareParam) GetEnableCollationSetting added in v0.0.7 

func (x *DataCompareParam) GetEnableCollationSetting() bool

func (*DataCompareParam) GetEnableConsistentRead 

func (x *DataCompareParam) GetEnableConsistentRead() bool

func (*DataCompareParam) GetIgnoreConditionFields added in v0.0.7 

func (x *DataCompareParam) GetIgnoreConditionFields() []string

func (*DataCompareParam) GetOnlyCompareRow 

func (x *DataCompareParam) GetOnlyCompareRow() bool

func (*DataCompareParam) GetRepairStmtFlow added in v0.0.7 

func (x *DataCompareParam) GetRepairStmtFlow() string

func (*DataCompareParam) GetSeparator added in v0.0.13 

func (x *DataCompareParam) GetSeparator() string

func (*DataCompareParam) GetSqlHintS 

func (x *DataCompareParam) GetSqlHintS() string

func (*DataCompareParam) GetSqlHintT 

func (x *DataCompareParam) GetSqlHintT() string

func (*DataCompareParam) GetSqlThread 

func (x *DataCompareParam) GetSqlThread() uint64

func (*DataCompareParam) GetTableThread 

func (x *DataCompareParam) GetTableThread() uint64

func (*DataCompareParam) GetWriteThread added in v0.0.6 

func (x *DataCompareParam) GetWriteThread() uint64

func (*DataCompareParam) ProtoMessage 

func (*DataCompareParam) ProtoMessage()

func (*DataCompareParam) ProtoReflect 

func (x *DataCompareParam) ProtoReflect() protoreflect.Message

func (*DataCompareParam) Reset 

func (x *DataCompareParam) Reset()

func (*DataCompareParam) String 

func (x *DataCompareParam) String() string

type DataCompareRule 

type DataCompareRule struct {
	TableNameS             string   `protobuf:"bytes,1,opt,name=tableNameS,proto3" json:"tableNameS,omitempty"`
	CompareConditionField  string   `protobuf:"bytes,2,opt,name=compareConditionField,proto3" json:"compareConditionField,omitempty"`
	CompareConditionRangeS string   `protobuf:"bytes,3,opt,name=compareConditionRangeS,proto3" json:"compareConditionRangeS,omitempty"`
	CompareConditionRangeT string   `protobuf:"bytes,4,opt,name=compareConditionRangeT,proto3" json:"compareConditionRangeT,omitempty"`
	IgnoreSelectFields     []string `protobuf:"bytes,5,rep,name=ignoreSelectFields,proto3" json:"ignoreSelectFields,omitempty"`
	IgnoreConditionFields  []string `protobuf:"bytes,6,rep,name=ignoreConditionFields,proto3" json:"ignoreConditionFields,omitempty"`
	SqlHintS               string   `protobuf:"bytes,7,opt,name=sqlHintS,proto3" json:"sqlHintS,omitempty"`
	SqlHintT               string   `protobuf:"bytes,8,opt,name=sqlHintT,proto3" json:"sqlHintT,omitempty"`
	// contains filtered or unexported fields
}

func (*DataCompareRule) Descriptor deprecated 

func (*DataCompareRule) Descriptor() ([]byte, []int)

Deprecated: Use DataCompareRule.ProtoReflect.Descriptor instead.

func (*DataCompareRule) GetCompareConditionField added in v0.0.7 

func (x *DataCompareRule) GetCompareConditionField() string

func (*DataCompareRule) GetCompareConditionRangeS added in v0.0.9 

func (x *DataCompareRule) GetCompareConditionRangeS() string

func (*DataCompareRule) GetCompareConditionRangeT added in v0.0.9 

func (x *DataCompareRule) GetCompareConditionRangeT() string

func (*DataCompareRule) GetIgnoreConditionFields added in v0.0.7 

func (x *DataCompareRule) GetIgnoreConditionFields() []string

func (*DataCompareRule) GetIgnoreSelectFields added in v0.0.7 

func (x *DataCompareRule) GetIgnoreSelectFields() []string

func (*DataCompareRule) GetSqlHintS added in v0.0.8 

func (x *DataCompareRule) GetSqlHintS() string

func (*DataCompareRule) GetSqlHintT added in v0.0.8 

func (x *DataCompareRule) GetSqlHintT() string

func (*DataCompareRule) GetTableNameS 

func (x *DataCompareRule) GetTableNameS() string

func (*DataCompareRule) ProtoMessage 

func (*DataCompareRule) ProtoMessage()

func (*DataCompareRule) ProtoReflect 

func (x *DataCompareRule) ProtoReflect() protoreflect.Message

func (*DataCompareRule) Reset 

func (x *DataCompareRule) Reset()

func (*DataCompareRule) String 

func (x *DataCompareRule) String() string

type DataMigrateRule 

type DataMigrateRule struct {
	TableNameS          string `protobuf:"bytes,1,opt,name=tableNameS,proto3" json:"tableNameS,omitempty"`
	EnableChunkStrategy bool   `protobuf:"varint,2,opt,name=enableChunkStrategy,proto3" json:"enableChunkStrategy,omitempty"`
	WhereRange          string `protobuf:"bytes,3,opt,name=whereRange,proto3" json:"whereRange,omitempty"`
	SqlHintS            string `protobuf:"bytes,4,opt,name=sqlHintS,proto3" json:"sqlHintS,omitempty"`
	// contains filtered or unexported fields
}

func (*DataMigrateRule) Descriptor deprecated 

func (*DataMigrateRule) Descriptor() ([]byte, []int)

Deprecated: Use DataMigrateRule.ProtoReflect.Descriptor instead.

func (*DataMigrateRule) GetEnableChunkStrategy 

func (x *DataMigrateRule) GetEnableChunkStrategy() bool

func (*DataMigrateRule) GetSqlHintS 

func (x *DataMigrateRule) GetSqlHintS() string

func (*DataMigrateRule) GetTableNameS 

func (x *DataMigrateRule) GetTableNameS() string

func (*DataMigrateRule) GetWhereRange 

func (x *DataMigrateRule) GetWhereRange() string

func (*DataMigrateRule) ProtoMessage 

func (*DataMigrateRule) ProtoMessage()

func (*DataMigrateRule) ProtoReflect 

func (x *DataMigrateRule) ProtoReflect() protoreflect.Message

func (*DataMigrateRule) Reset 

func (x *DataMigrateRule) Reset()

func (*DataMigrateRule) String 

func (x *DataMigrateRule) String() string

type DataScanParam 

type DataScanParam struct {
	TableThread          uint64 `protobuf:"varint,1,opt,name=tableThread,proto3" json:"tableThread,omitempty"`
	BatchSize            uint64 `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	ChunkSize            uint64 `protobuf:"varint,3,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
	SqlThreadS           uint64 `protobuf:"varint,4,opt,name=sqlThreadS,proto3" json:"sqlThreadS,omitempty"`
	SqlHintS             string `protobuf:"bytes,5,opt,name=sqlHintS,proto3" json:"sqlHintS,omitempty"`
	CallTimeout          uint64 `protobuf:"varint,6,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	EnableCheckpoint     bool   `protobuf:"varint,7,opt,name=enableCheckpoint,proto3" json:"enableCheckpoint,omitempty"`
	EnableConsistentRead bool   `protobuf:"varint,8,opt,name=enableConsistentRead,proto3" json:"enableConsistentRead,omitempty"`
	TableSamplerateS     uint64 `protobuf:"varint,9,opt,name=tableSamplerateS,proto3" json:"tableSamplerateS,omitempty"`
	WriteThread          uint64 `protobuf:"varint,10,opt,name=writeThread,proto3" json:"writeThread,omitempty"`
	// contains filtered or unexported fields
}

func (*DataScanParam) Descriptor deprecated 

func (*DataScanParam) Descriptor() ([]byte, []int)

Deprecated: Use DataScanParam.ProtoReflect.Descriptor instead.

func (*DataScanParam) GetBatchSize 

func (x *DataScanParam) GetBatchSize() uint64

func (*DataScanParam) GetCallTimeout 

func (x *DataScanParam) GetCallTimeout() uint64

func (*DataScanParam) GetChunkSize 

func (x *DataScanParam) GetChunkSize() uint64

func (*DataScanParam) GetEnableCheckpoint 

func (x *DataScanParam) GetEnableCheckpoint() bool

func (*DataScanParam) GetEnableConsistentRead 

func (x *DataScanParam) GetEnableConsistentRead() bool

func (*DataScanParam) GetSqlHintS 

func (x *DataScanParam) GetSqlHintS() string

func (*DataScanParam) GetSqlThreadS 

func (x *DataScanParam) GetSqlThreadS() uint64

func (*DataScanParam) GetTableSamplerateS 

func (x *DataScanParam) GetTableSamplerateS() uint64

func (*DataScanParam) GetTableThread 

func (x *DataScanParam) GetTableThread() uint64

func (*DataScanParam) GetWriteThread added in v0.0.9 

func (x *DataScanParam) GetWriteThread() uint64

func (*DataScanParam) ProtoMessage 

func (*DataScanParam) ProtoMessage()

func (*DataScanParam) ProtoReflect 

func (x *DataScanParam) ProtoReflect() protoreflect.Message

func (*DataScanParam) Reset 

func (x *DataScanParam) Reset()

func (*DataScanParam) String 

func (x *DataScanParam) String() string

type DataScanRule 

type DataScanRule struct {
	TableNameS       string `protobuf:"bytes,1,opt,name=tableNameS,proto3" json:"tableNameS,omitempty"`
	SqlHintS         string `protobuf:"bytes,2,opt,name=sqlHintS,proto3" json:"sqlHintS,omitempty"`
	TableSamplerateS uint64 `protobuf:"varint,3,opt,name=tableSamplerateS,proto3" json:"tableSamplerateS,omitempty"`
	// contains filtered or unexported fields
}

func (*DataScanRule) Descriptor deprecated 

func (*DataScanRule) Descriptor() ([]byte, []int)

Deprecated: Use DataScanRule.ProtoReflect.Descriptor instead.

func (*DataScanRule) GetSqlHintS 

func (x *DataScanRule) GetSqlHintS() string

func (*DataScanRule) GetTableNameS 

func (x *DataScanRule) GetTableNameS() string

func (*DataScanRule) GetTableSamplerateS 

func (x *DataScanRule) GetTableSamplerateS() uint64

func (*DataScanRule) ProtoMessage 

func (*DataScanRule) ProtoMessage()

func (*DataScanRule) ProtoReflect 

func (x *DataScanRule) ProtoReflect() protoreflect.Message

func (*DataScanRule) Reset 

func (x *DataScanRule) Reset()

func (*DataScanRule) String 

func (x *DataScanRule) String() string

type Database 

type Database struct {
	Username      string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password      string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Host          string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Port          uint64 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	Schema        string `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	SlowThreshold uint64 `protobuf:"varint,6,opt,name=slowThreshold,proto3" json:"slowThreshold,omitempty"`
	InitThread    uint64 `protobuf:"varint,7,opt,name=initThread,proto3" json:"initThread,omitempty"`
	// contains filtered or unexported fields
}

通用结构体

func (*Database) Descriptor deprecated 

func (*Database) Descriptor() ([]byte, []int)

Deprecated: Use Database.ProtoReflect.Descriptor instead.

func (*Database) GetHost 

func (x *Database) GetHost() string

func (*Database) GetInitThread added in v0.0.6 

func (x *Database) GetInitThread() uint64

func (*Database) GetPassword 

func (x *Database) GetPassword() string

func (*Database) GetPort 

func (x *Database) GetPort() uint64

func (*Database) GetSchema 

func (x *Database) GetSchema() string

func (*Database) GetSlowThreshold 

func (x *Database) GetSlowThreshold() uint64

func (*Database) GetUsername 

func (x *Database) GetUsername() string

func (*Database) ProtoMessage 

func (*Database) ProtoMessage()

func (*Database) ProtoReflect 

func (x *Database) ProtoReflect() protoreflect.Message

func (*Database) Reset 

func (x *Database) Reset()

func (*Database) String 

func (x *Database) String() string

type Datasource 

type Datasource struct {
	DatasourceName string `protobuf:"bytes,1,opt,name=datasourceName,proto3" json:"datasourceName,omitempty"`
	DbType         string `protobuf:"bytes,2,opt,name=dbType,proto3" json:"dbType,omitempty"`
	Username       string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password       string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	Host           string `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	Port           uint64 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	ConnectCharset string `protobuf:"bytes,7,opt,name=connectCharset,proto3" json:"connectCharset,omitempty"`
	ConnectParams  string `protobuf:"bytes,8,opt,name=connectParams,proto3" json:"connectParams,omitempty"`
	ConnectStatus  string `protobuf:"bytes,9,opt,name=connectStatus,proto3" json:"connectStatus,omitempty"`
	ServiceName    string `protobuf:"bytes,10,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	PdbName        string `protobuf:"bytes,11,opt,name=pdbName,proto3" json:"pdbName,omitempty"`
	SessionParams  string `protobuf:"bytes,12,opt,name=sessionParams,proto3" json:"sessionParams,omitempty"`
	DbName         string `protobuf:"bytes,13,opt,name=dbName,proto3" json:"dbName,omitempty"`
	Comment        string `protobuf:"bytes,14,opt,name=comment,proto3" json:"comment,omitempty"`
	// contains filtered or unexported fields
}

func (*Datasource) Descriptor deprecated 

func (*Datasource) Descriptor() ([]byte, []int)

Deprecated: Use Datasource.ProtoReflect.Descriptor instead.

func (*Datasource) GetComment 

func (x *Datasource) GetComment() string

func (*Datasource) GetConnectCharset 

func (x *Datasource) GetConnectCharset() string

func (*Datasource) GetConnectParams 

func (x *Datasource) GetConnectParams() string

func (*Datasource) GetConnectStatus 

func (x *Datasource) GetConnectStatus() string

func (*Datasource) GetDatasourceName 

func (x *Datasource) GetDatasourceName() string

func (*Datasource) GetDbName added in v0.0.7 

func (x *Datasource) GetDbName() string

func (*Datasource) GetDbType 

func (x *Datasource) GetDbType() string

func (*Datasource) GetHost 

func (x *Datasource) GetHost() string

func (*Datasource) GetPassword 

func (x *Datasource) GetPassword() string

func (*Datasource) GetPdbName 

func (x *Datasource) GetPdbName() string

func (*Datasource) GetPort 

func (x *Datasource) GetPort() uint64

func (*Datasource) GetServiceName 

func (x *Datasource) GetServiceName() string

func (*Datasource) GetSessionParams added in v0.0.7 

func (x *Datasource) GetSessionParams() string

func (*Datasource) GetUsername 

func (x *Datasource) GetUsername() string

func (*Datasource) ProtoMessage 

func (*Datasource) ProtoMessage()

func (*Datasource) ProtoReflect 

func (x *Datasource) ProtoReflect() protoreflect.Message

func (*Datasource) Reset 

func (x *Datasource) Reset()

func (*Datasource) String 

func (x *Datasource) String() string

type DeleteAssessMigrateTaskRequest 

type DeleteAssessMigrateTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAssessMigrateTaskRequest) Descriptor deprecated 

func (*DeleteAssessMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAssessMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteAssessMigrateTaskRequest) GetTaskName 

func (x *DeleteAssessMigrateTaskRequest) GetTaskName() []string

func (*DeleteAssessMigrateTaskRequest) ProtoMessage 

func (*DeleteAssessMigrateTaskRequest) ProtoMessage()

func (*DeleteAssessMigrateTaskRequest) ProtoReflect 

func (x *DeleteAssessMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteAssessMigrateTaskRequest) Reset 

func (x *DeleteAssessMigrateTaskRequest) Reset()

func (*DeleteAssessMigrateTaskRequest) String 

func (x *DeleteAssessMigrateTaskRequest) String() string

type DeleteAssessMigrateTaskResponse 

type DeleteAssessMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAssessMigrateTaskResponse) Descriptor deprecated 

func (*DeleteAssessMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAssessMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteAssessMigrateTaskResponse) GetResponse 

func (x *DeleteAssessMigrateTaskResponse) GetResponse() *Response

func (*DeleteAssessMigrateTaskResponse) ProtoMessage 

func (*DeleteAssessMigrateTaskResponse) ProtoMessage()

func (*DeleteAssessMigrateTaskResponse) ProtoReflect 

func (x *DeleteAssessMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteAssessMigrateTaskResponse) Reset 

func (x *DeleteAssessMigrateTaskResponse) Reset()

func (*DeleteAssessMigrateTaskResponse) String 

func (x *DeleteAssessMigrateTaskResponse) String() string

type DeleteCdcConsumeTaskRequest added in v0.0.17 

type DeleteCdcConsumeTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCdcConsumeTaskRequest) Descriptor deprecated added in v0.0.17 

func (*DeleteCdcConsumeTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteCdcConsumeTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteCdcConsumeTaskRequest) GetTaskName added in v0.0.17 

func (x *DeleteCdcConsumeTaskRequest) GetTaskName() []string

func (*DeleteCdcConsumeTaskRequest) ProtoMessage added in v0.0.17 

func (*DeleteCdcConsumeTaskRequest) ProtoMessage()

func (*DeleteCdcConsumeTaskRequest) ProtoReflect added in v0.0.17 

func (x *DeleteCdcConsumeTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteCdcConsumeTaskRequest) Reset added in v0.0.17 

func (x *DeleteCdcConsumeTaskRequest) Reset()

func (*DeleteCdcConsumeTaskRequest) String added in v0.0.17 

func (x *DeleteCdcConsumeTaskRequest) String() string

type DeleteCdcConsumeTaskResponse added in v0.0.17 

type DeleteCdcConsumeTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCdcConsumeTaskResponse) Descriptor deprecated added in v0.0.17 

func (*DeleteCdcConsumeTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteCdcConsumeTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteCdcConsumeTaskResponse) GetResponse added in v0.0.17 

func (x *DeleteCdcConsumeTaskResponse) GetResponse() *Response

func (*DeleteCdcConsumeTaskResponse) ProtoMessage added in v0.0.17 

func (*DeleteCdcConsumeTaskResponse) ProtoMessage()

func (*DeleteCdcConsumeTaskResponse) ProtoReflect added in v0.0.17 

func (x *DeleteCdcConsumeTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteCdcConsumeTaskResponse) Reset added in v0.0.17 

func (x *DeleteCdcConsumeTaskResponse) Reset()

func (*DeleteCdcConsumeTaskResponse) String added in v0.0.17 

func (x *DeleteCdcConsumeTaskResponse) String() string

type DeleteCsvMigrateTaskRequest 

type DeleteCsvMigrateTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCsvMigrateTaskRequest) Descriptor deprecated 

func (*DeleteCsvMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteCsvMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteCsvMigrateTaskRequest) GetTaskName 

func (x *DeleteCsvMigrateTaskRequest) GetTaskName() []string

func (*DeleteCsvMigrateTaskRequest) ProtoMessage 

func (*DeleteCsvMigrateTaskRequest) ProtoMessage()

func (*DeleteCsvMigrateTaskRequest) ProtoReflect 

func (x *DeleteCsvMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteCsvMigrateTaskRequest) Reset 

func (x *DeleteCsvMigrateTaskRequest) Reset()

func (*DeleteCsvMigrateTaskRequest) String 

func (x *DeleteCsvMigrateTaskRequest) String() string

type DeleteCsvMigrateTaskResponse 

type DeleteCsvMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCsvMigrateTaskResponse) Descriptor deprecated 

func (*DeleteCsvMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteCsvMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteCsvMigrateTaskResponse) GetResponse 

func (x *DeleteCsvMigrateTaskResponse) GetResponse() *Response

func (*DeleteCsvMigrateTaskResponse) ProtoMessage 

func (*DeleteCsvMigrateTaskResponse) ProtoMessage()

func (*DeleteCsvMigrateTaskResponse) ProtoReflect 

func (x *DeleteCsvMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteCsvMigrateTaskResponse) Reset 

func (x *DeleteCsvMigrateTaskResponse) Reset()

func (*DeleteCsvMigrateTaskResponse) String 

func (x *DeleteCsvMigrateTaskResponse) String() string

type DeleteDataCompareTaskRequest 

type DeleteDataCompareTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDataCompareTaskRequest) Descriptor deprecated 

func (*DeleteDataCompareTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDataCompareTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteDataCompareTaskRequest) GetTaskName 

func (x *DeleteDataCompareTaskRequest) GetTaskName() []string

func (*DeleteDataCompareTaskRequest) ProtoMessage 

func (*DeleteDataCompareTaskRequest) ProtoMessage()

func (*DeleteDataCompareTaskRequest) ProtoReflect 

func (x *DeleteDataCompareTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteDataCompareTaskRequest) Reset 

func (x *DeleteDataCompareTaskRequest) Reset()

func (*DeleteDataCompareTaskRequest) String 

func (x *DeleteDataCompareTaskRequest) String() string

type DeleteDataCompareTaskResponse 

type DeleteDataCompareTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDataCompareTaskResponse) Descriptor deprecated 

func (*DeleteDataCompareTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDataCompareTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteDataCompareTaskResponse) GetResponse 

func (x *DeleteDataCompareTaskResponse) GetResponse() *Response

func (*DeleteDataCompareTaskResponse) ProtoMessage 

func (*DeleteDataCompareTaskResponse) ProtoMessage()

func (*DeleteDataCompareTaskResponse) ProtoReflect 

func (x *DeleteDataCompareTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteDataCompareTaskResponse) Reset 

func (x *DeleteDataCompareTaskResponse) Reset()

func (*DeleteDataCompareTaskResponse) String 

func (x *DeleteDataCompareTaskResponse) String() string

type DeleteDataScanTaskRequest 

type DeleteDataScanTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDataScanTaskRequest) Descriptor deprecated 

func (*DeleteDataScanTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDataScanTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteDataScanTaskRequest) GetTaskName 

func (x *DeleteDataScanTaskRequest) GetTaskName() []string

func (*DeleteDataScanTaskRequest) ProtoMessage 

func (*DeleteDataScanTaskRequest) ProtoMessage()

func (*DeleteDataScanTaskRequest) ProtoReflect 

func (x *DeleteDataScanTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteDataScanTaskRequest) Reset 

func (x *DeleteDataScanTaskRequest) Reset()

func (*DeleteDataScanTaskRequest) String 

func (x *DeleteDataScanTaskRequest) String() string

type DeleteDataScanTaskResponse 

type DeleteDataScanTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDataScanTaskResponse) Descriptor deprecated 

func (*DeleteDataScanTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDataScanTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteDataScanTaskResponse) GetResponse 

func (x *DeleteDataScanTaskResponse) GetResponse() *Response

func (*DeleteDataScanTaskResponse) ProtoMessage 

func (*DeleteDataScanTaskResponse) ProtoMessage()

func (*DeleteDataScanTaskResponse) ProtoReflect 

func (x *DeleteDataScanTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteDataScanTaskResponse) Reset 

func (x *DeleteDataScanTaskResponse) Reset()

func (*DeleteDataScanTaskResponse) String 

func (x *DeleteDataScanTaskResponse) String() string

type DeleteDatabaseRequest 

type DeleteDatabaseRequest struct {
	// contains filtered or unexported fields
}

func (*DeleteDatabaseRequest) Descriptor deprecated 

func (*DeleteDatabaseRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDatabaseRequest.ProtoReflect.Descriptor instead.

func (*DeleteDatabaseRequest) ProtoMessage 

func (*DeleteDatabaseRequest) ProtoMessage()

func (*DeleteDatabaseRequest) ProtoReflect 

func (x *DeleteDatabaseRequest) ProtoReflect() protoreflect.Message

func (*DeleteDatabaseRequest) Reset 

func (x *DeleteDatabaseRequest) Reset()

func (*DeleteDatabaseRequest) String 

func (x *DeleteDatabaseRequest) String() string

type DeleteDatabaseResponse 

type DeleteDatabaseResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDatabaseResponse) Descriptor deprecated 

func (*DeleteDatabaseResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDatabaseResponse.ProtoReflect.Descriptor instead.

func (*DeleteDatabaseResponse) GetResponse 

func (x *DeleteDatabaseResponse) GetResponse() *Response

func (*DeleteDatabaseResponse) ProtoMessage 

func (*DeleteDatabaseResponse) ProtoMessage()

func (*DeleteDatabaseResponse) ProtoReflect 

func (x *DeleteDatabaseResponse) ProtoReflect() protoreflect.Message

func (*DeleteDatabaseResponse) Reset 

func (x *DeleteDatabaseResponse) Reset()

func (*DeleteDatabaseResponse) String 

func (x *DeleteDatabaseResponse) String() string

type DeleteDatasourceRequest 

type DeleteDatasourceRequest struct {
	DatasourceName []string `protobuf:"bytes,2,rep,name=datasourceName,proto3" json:"datasourceName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDatasourceRequest) Descriptor deprecated 

func (*DeleteDatasourceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDatasourceRequest.ProtoReflect.Descriptor instead.

func (*DeleteDatasourceRequest) GetDatasourceName 

func (x *DeleteDatasourceRequest) GetDatasourceName() []string

func (*DeleteDatasourceRequest) ProtoMessage 

func (*DeleteDatasourceRequest) ProtoMessage()

func (*DeleteDatasourceRequest) ProtoReflect 

func (x *DeleteDatasourceRequest) ProtoReflect() protoreflect.Message

func (*DeleteDatasourceRequest) Reset 

func (x *DeleteDatasourceRequest) Reset()

func (*DeleteDatasourceRequest) String 

func (x *DeleteDatasourceRequest) String() string

type DeleteDatasourceResponse 

type DeleteDatasourceResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDatasourceResponse) Descriptor deprecated 

func (*DeleteDatasourceResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDatasourceResponse.ProtoReflect.Descriptor instead.

func (*DeleteDatasourceResponse) GetResponse 

func (x *DeleteDatasourceResponse) GetResponse() *Response

func (*DeleteDatasourceResponse) ProtoMessage 

func (*DeleteDatasourceResponse) ProtoMessage()

func (*DeleteDatasourceResponse) ProtoReflect 

func (x *DeleteDatasourceResponse) ProtoReflect() protoreflect.Message

func (*DeleteDatasourceResponse) Reset 

func (x *DeleteDatasourceResponse) Reset()

func (*DeleteDatasourceResponse) String 

func (x *DeleteDatasourceResponse) String() string

type DeleteSqlMigrateTaskRequest 

type DeleteSqlMigrateTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSqlMigrateTaskRequest) Descriptor deprecated 

func (*DeleteSqlMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSqlMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteSqlMigrateTaskRequest) GetTaskName 

func (x *DeleteSqlMigrateTaskRequest) GetTaskName() []string

func (*DeleteSqlMigrateTaskRequest) ProtoMessage 

func (*DeleteSqlMigrateTaskRequest) ProtoMessage()

func (*DeleteSqlMigrateTaskRequest) ProtoReflect 

func (x *DeleteSqlMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteSqlMigrateTaskRequest) Reset 

func (x *DeleteSqlMigrateTaskRequest) Reset()

func (*DeleteSqlMigrateTaskRequest) String 

func (x *DeleteSqlMigrateTaskRequest) String() string

type DeleteSqlMigrateTaskResponse 

type DeleteSqlMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSqlMigrateTaskResponse) Descriptor deprecated 

func (*DeleteSqlMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSqlMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteSqlMigrateTaskResponse) GetResponse 

func (x *DeleteSqlMigrateTaskResponse) GetResponse() *Response

func (*DeleteSqlMigrateTaskResponse) ProtoMessage 

func (*DeleteSqlMigrateTaskResponse) ProtoMessage()

func (*DeleteSqlMigrateTaskResponse) ProtoReflect 

func (x *DeleteSqlMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteSqlMigrateTaskResponse) Reset 

func (x *DeleteSqlMigrateTaskResponse) Reset()

func (*DeleteSqlMigrateTaskResponse) String 

func (x *DeleteSqlMigrateTaskResponse) String() string

type DeleteStmtMigrateTaskRequest 

type DeleteStmtMigrateTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStmtMigrateTaskRequest) Descriptor deprecated 

func (*DeleteStmtMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStmtMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteStmtMigrateTaskRequest) GetTaskName 

func (x *DeleteStmtMigrateTaskRequest) GetTaskName() []string

func (*DeleteStmtMigrateTaskRequest) ProtoMessage 

func (*DeleteStmtMigrateTaskRequest) ProtoMessage()

func (*DeleteStmtMigrateTaskRequest) ProtoReflect 

func (x *DeleteStmtMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteStmtMigrateTaskRequest) Reset 

func (x *DeleteStmtMigrateTaskRequest) Reset()

func (*DeleteStmtMigrateTaskRequest) String 

func (x *DeleteStmtMigrateTaskRequest) String() string

type DeleteStmtMigrateTaskResponse 

type DeleteStmtMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStmtMigrateTaskResponse) Descriptor deprecated 

func (*DeleteStmtMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStmtMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteStmtMigrateTaskResponse) GetResponse 

func (x *DeleteStmtMigrateTaskResponse) GetResponse() *Response

func (*DeleteStmtMigrateTaskResponse) ProtoMessage 

func (*DeleteStmtMigrateTaskResponse) ProtoMessage()

func (*DeleteStmtMigrateTaskResponse) ProtoReflect 

func (x *DeleteStmtMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteStmtMigrateTaskResponse) Reset 

func (x *DeleteStmtMigrateTaskResponse) Reset()

func (*DeleteStmtMigrateTaskResponse) String 

func (x *DeleteStmtMigrateTaskResponse) String() string

type DeleteStructCompareTaskRequest 

type DeleteStructCompareTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStructCompareTaskRequest) Descriptor deprecated 

func (*DeleteStructCompareTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStructCompareTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteStructCompareTaskRequest) GetTaskName 

func (x *DeleteStructCompareTaskRequest) GetTaskName() []string

func (*DeleteStructCompareTaskRequest) ProtoMessage 

func (*DeleteStructCompareTaskRequest) ProtoMessage()

func (*DeleteStructCompareTaskRequest) ProtoReflect 

func (x *DeleteStructCompareTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteStructCompareTaskRequest) Reset 

func (x *DeleteStructCompareTaskRequest) Reset()

func (*DeleteStructCompareTaskRequest) String 

func (x *DeleteStructCompareTaskRequest) String() string

type DeleteStructCompareTaskResponse 

type DeleteStructCompareTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStructCompareTaskResponse) Descriptor deprecated 

func (*DeleteStructCompareTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStructCompareTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteStructCompareTaskResponse) GetResponse 

func (x *DeleteStructCompareTaskResponse) GetResponse() *Response

func (*DeleteStructCompareTaskResponse) ProtoMessage 

func (*DeleteStructCompareTaskResponse) ProtoMessage()

func (*DeleteStructCompareTaskResponse) ProtoReflect 

func (x *DeleteStructCompareTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteStructCompareTaskResponse) Reset 

func (x *DeleteStructCompareTaskResponse) Reset()

func (*DeleteStructCompareTaskResponse) String 

func (x *DeleteStructCompareTaskResponse) String() string

type DeleteStructMigrateTaskRequest 

type DeleteStructMigrateTaskRequest struct {
	TaskName []string `protobuf:"bytes,1,rep,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStructMigrateTaskRequest) Descriptor deprecated 

func (*DeleteStructMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStructMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteStructMigrateTaskRequest) GetTaskName 

func (x *DeleteStructMigrateTaskRequest) GetTaskName() []string

func (*DeleteStructMigrateTaskRequest) ProtoMessage 

func (*DeleteStructMigrateTaskRequest) ProtoMessage()

func (*DeleteStructMigrateTaskRequest) ProtoReflect 

func (x *DeleteStructMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteStructMigrateTaskRequest) Reset 

func (x *DeleteStructMigrateTaskRequest) Reset()

func (*DeleteStructMigrateTaskRequest) String 

func (x *DeleteStructMigrateTaskRequest) String() string

type DeleteStructMigrateTaskResponse 

type DeleteStructMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStructMigrateTaskResponse) Descriptor deprecated 

func (*DeleteStructMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStructMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteStructMigrateTaskResponse) GetResponse 

func (x *DeleteStructMigrateTaskResponse) GetResponse() *Response

func (*DeleteStructMigrateTaskResponse) ProtoMessage 

func (*DeleteStructMigrateTaskResponse) ProtoMessage()

func (*DeleteStructMigrateTaskResponse) ProtoReflect 

func (x *DeleteStructMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteStructMigrateTaskResponse) Reset 

func (x *DeleteStructMigrateTaskResponse) Reset()

func (*DeleteStructMigrateTaskResponse) String 

func (x *DeleteStructMigrateTaskResponse) String() string

type MasterClient 

type MasterClient interface {
	UpsertDatabase(ctx context.Context, in *UpsertDatabaseRequest, opts ...grpc.CallOption) (*UpsertDatabaseResponse, error)
	DeleteDatabase(ctx context.Context, in *DeleteDatabaseRequest, opts ...grpc.CallOption) (*DeleteDatabaseResponse, error)
	ShowDatabase(ctx context.Context, in *ShowDatabaseRequest, opts ...grpc.CallOption) (*ShowDatabaseResponse, error)
	UpsertDatasource(ctx context.Context, in *UpsertDatasourceRequest, opts ...grpc.CallOption) (*UpsertDatasourceResponse, error)
	DeleteDatasource(ctx context.Context, in *DeleteDatasourceRequest, opts ...grpc.CallOption) (*DeleteDatasourceResponse, error)
	ShowDatasource(ctx context.Context, in *ShowDatasourceRequest, opts ...grpc.CallOption) (*ShowDatasourceResponse, error)
	UpsertAssessMigrateTask(ctx context.Context, in *UpsertAssessMigrateTaskRequest, opts ...grpc.CallOption) (*UpsertAssessMigrateTaskResponse, error)
	DeleteAssessMigrateTask(ctx context.Context, in *DeleteAssessMigrateTaskRequest, opts ...grpc.CallOption) (*DeleteAssessMigrateTaskResponse, error)
	ShowAssessMigrateTask(ctx context.Context, in *ShowAssessMigrateTaskRequest, opts ...grpc.CallOption) (*ShowAssessMigrateTaskResponse, error)
	UpsertStructMigrateTask(ctx context.Context, in *UpsertStructMigrateTaskRequest, opts ...grpc.CallOption) (*UpsertStructMigrateTaskResponse, error)
	DeleteStructMigrateTask(ctx context.Context, in *DeleteStructMigrateTaskRequest, opts ...grpc.CallOption) (*DeleteStructMigrateTaskResponse, error)
	ShowStructMigrateTask(ctx context.Context, in *ShowStructMigrateTaskRequest, opts ...grpc.CallOption) (*ShowStructMigrateTaskResponse, error)
	UpsertStructCompareTask(ctx context.Context, in *UpsertStructCompareTaskRequest, opts ...grpc.CallOption) (*UpsertStructCompareTaskResponse, error)
	DeleteStructCompareTask(ctx context.Context, in *DeleteStructCompareTaskRequest, opts ...grpc.CallOption) (*DeleteStructCompareTaskResponse, error)
	ShowStructCompareTask(ctx context.Context, in *ShowStructCompareTaskRequest, opts ...grpc.CallOption) (*ShowStructCompareTaskResponse, error)
	UpsertStmtMigrateTask(ctx context.Context, in *UpsertStmtMigrateTaskRequest, opts ...grpc.CallOption) (*UpsertStmtMigrateTaskResponse, error)
	DeleteStmtMigrateTask(ctx context.Context, in *DeleteStmtMigrateTaskRequest, opts ...grpc.CallOption) (*DeleteStmtMigrateTaskResponse, error)
	ShowStmtMigrateTask(ctx context.Context, in *ShowStmtMigrateTaskRequest, opts ...grpc.CallOption) (*ShowStmtMigrateTaskResponse, error)
	UpsertSqlMigrateTask(ctx context.Context, in *UpsertSqlMigrateTaskRequest, opts ...grpc.CallOption) (*UpsertSqlMigrateTaskResponse, error)
	DeleteSqlMigrateTask(ctx context.Context, in *DeleteSqlMigrateTaskRequest, opts ...grpc.CallOption) (*DeleteSqlMigrateTaskResponse, error)
	ShowSqlMigrateTask(ctx context.Context, in *ShowSqlMigrateTaskRequest, opts ...grpc.CallOption) (*ShowSqlMigrateTaskResponse, error)
	UpsertCsvMigrateTask(ctx context.Context, in *UpsertCsvMigrateTaskRequest, opts ...grpc.CallOption) (*UpsertCsvMigrateTaskResponse, error)
	DeleteCsvMigrateTask(ctx context.Context, in *DeleteCsvMigrateTaskRequest, opts ...grpc.CallOption) (*DeleteCsvMigrateTaskResponse, error)
	ShowCsvMigrateTask(ctx context.Context, in *ShowCsvMigrateTaskRequest, opts ...grpc.CallOption) (*ShowCsvMigrateTaskResponse, error)
	UpsertDataCompareTask(ctx context.Context, in *UpsertDataCompareTaskRequest, opts ...grpc.CallOption) (*UpsertDataCompareTaskResponse, error)
	DeleteDataCompareTask(ctx context.Context, in *DeleteDataCompareTaskRequest, opts ...grpc.CallOption) (*DeleteDataCompareTaskResponse, error)
	ShowDataCompareTask(ctx context.Context, in *ShowDataCompareTaskRequest, opts ...grpc.CallOption) (*ShowDataCompareTaskResponse, error)
	UpsertDataScanTask(ctx context.Context, in *UpsertDataScanTaskRequest, opts ...grpc.CallOption) (*UpsertDataScanTaskResponse, error)
	DeleteDataScanTask(ctx context.Context, in *DeleteDataScanTaskRequest, opts ...grpc.CallOption) (*DeleteDataScanTaskResponse, error)
	ShowDataScanTask(ctx context.Context, in *ShowDataScanTaskRequest, opts ...grpc.CallOption) (*ShowDataScanTaskResponse, error)
	UpsertCdcConsumeTask(ctx context.Context, in *UpsertCdcConsumeTaskRequest, opts ...grpc.CallOption) (*UpsertCdcConsumeTaskResponse, error)
	DeleteCdcConsumeTask(ctx context.Context, in *DeleteCdcConsumeTaskRequest, opts ...grpc.CallOption) (*DeleteCdcConsumeTaskResponse, error)
	ShowCdcConsumeTask(ctx context.Context, in *ShowCdcConsumeTaskRequest, opts ...grpc.CallOption) (*ShowCdcConsumeTaskResponse, error)
	OperateTask(ctx context.Context, in *OperateTaskRequest, opts ...grpc.CallOption) (*OperateTaskResponse, error)
}

MasterClient is the client API for Master service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMasterClient 

func NewMasterClient(cc grpc.ClientConnInterface) MasterClient

type MasterServer 

type MasterServer interface {
	UpsertDatabase(context.Context, *UpsertDatabaseRequest) (*UpsertDatabaseResponse, error)
	DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*DeleteDatabaseResponse, error)
	ShowDatabase(context.Context, *ShowDatabaseRequest) (*ShowDatabaseResponse, error)
	UpsertDatasource(context.Context, *UpsertDatasourceRequest) (*UpsertDatasourceResponse, error)
	DeleteDatasource(context.Context, *DeleteDatasourceRequest) (*DeleteDatasourceResponse, error)
	ShowDatasource(context.Context, *ShowDatasourceRequest) (*ShowDatasourceResponse, error)
	UpsertAssessMigrateTask(context.Context, *UpsertAssessMigrateTaskRequest) (*UpsertAssessMigrateTaskResponse, error)
	DeleteAssessMigrateTask(context.Context, *DeleteAssessMigrateTaskRequest) (*DeleteAssessMigrateTaskResponse, error)
	ShowAssessMigrateTask(context.Context, *ShowAssessMigrateTaskRequest) (*ShowAssessMigrateTaskResponse, error)
	UpsertStructMigrateTask(context.Context, *UpsertStructMigrateTaskRequest) (*UpsertStructMigrateTaskResponse, error)
	DeleteStructMigrateTask(context.Context, *DeleteStructMigrateTaskRequest) (*DeleteStructMigrateTaskResponse, error)
	ShowStructMigrateTask(context.Context, *ShowStructMigrateTaskRequest) (*ShowStructMigrateTaskResponse, error)
	UpsertStructCompareTask(context.Context, *UpsertStructCompareTaskRequest) (*UpsertStructCompareTaskResponse, error)
	DeleteStructCompareTask(context.Context, *DeleteStructCompareTaskRequest) (*DeleteStructCompareTaskResponse, error)
	ShowStructCompareTask(context.Context, *ShowStructCompareTaskRequest) (*ShowStructCompareTaskResponse, error)
	UpsertStmtMigrateTask(context.Context, *UpsertStmtMigrateTaskRequest) (*UpsertStmtMigrateTaskResponse, error)
	DeleteStmtMigrateTask(context.Context, *DeleteStmtMigrateTaskRequest) (*DeleteStmtMigrateTaskResponse, error)
	ShowStmtMigrateTask(context.Context, *ShowStmtMigrateTaskRequest) (*ShowStmtMigrateTaskResponse, error)
	UpsertSqlMigrateTask(context.Context, *UpsertSqlMigrateTaskRequest) (*UpsertSqlMigrateTaskResponse, error)
	DeleteSqlMigrateTask(context.Context, *DeleteSqlMigrateTaskRequest) (*DeleteSqlMigrateTaskResponse, error)
	ShowSqlMigrateTask(context.Context, *ShowSqlMigrateTaskRequest) (*ShowSqlMigrateTaskResponse, error)
	UpsertCsvMigrateTask(context.Context, *UpsertCsvMigrateTaskRequest) (*UpsertCsvMigrateTaskResponse, error)
	DeleteCsvMigrateTask(context.Context, *DeleteCsvMigrateTaskRequest) (*DeleteCsvMigrateTaskResponse, error)
	ShowCsvMigrateTask(context.Context, *ShowCsvMigrateTaskRequest) (*ShowCsvMigrateTaskResponse, error)
	UpsertDataCompareTask(context.Context, *UpsertDataCompareTaskRequest) (*UpsertDataCompareTaskResponse, error)
	DeleteDataCompareTask(context.Context, *DeleteDataCompareTaskRequest) (*DeleteDataCompareTaskResponse, error)
	ShowDataCompareTask(context.Context, *ShowDataCompareTaskRequest) (*ShowDataCompareTaskResponse, error)
	UpsertDataScanTask(context.Context, *UpsertDataScanTaskRequest) (*UpsertDataScanTaskResponse, error)
	DeleteDataScanTask(context.Context, *DeleteDataScanTaskRequest) (*DeleteDataScanTaskResponse, error)
	ShowDataScanTask(context.Context, *ShowDataScanTaskRequest) (*ShowDataScanTaskResponse, error)
	UpsertCdcConsumeTask(context.Context, *UpsertCdcConsumeTaskRequest) (*UpsertCdcConsumeTaskResponse, error)
	DeleteCdcConsumeTask(context.Context, *DeleteCdcConsumeTaskRequest) (*DeleteCdcConsumeTaskResponse, error)
	ShowCdcConsumeTask(context.Context, *ShowCdcConsumeTaskRequest) (*ShowCdcConsumeTaskResponse, error)
	OperateTask(context.Context, *OperateTaskRequest) (*OperateTaskResponse, error)
	// contains filtered or unexported methods
}

MasterServer is the server API for Master service. All implementations must embed UnimplementedMasterServer for forward compatibility.

type OperateTaskRequest 

type OperateTaskRequest struct {
	Operate  string `protobuf:"bytes,1,opt,name=operate,proto3" json:"operate,omitempty"`
	TaskName string `protobuf:"bytes,2,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Express  string `protobuf:"bytes,3,opt,name=express,proto3" json:"express,omitempty"`
	HostIP   string `protobuf:"bytes,4,opt,name=hostIP,proto3" json:"hostIP,omitempty"`
	// contains filtered or unexported fields
}

func (*OperateTaskRequest) Descriptor deprecated 

func (*OperateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use OperateTaskRequest.ProtoReflect.Descriptor instead.

func (*OperateTaskRequest) GetExpress 

func (x *OperateTaskRequest) GetExpress() string

func (*OperateTaskRequest) GetHostIP added in v0.0.16 

func (x *OperateTaskRequest) GetHostIP() string

func (*OperateTaskRequest) GetOperate 

func (x *OperateTaskRequest) GetOperate() string

func (*OperateTaskRequest) GetTaskName 

func (x *OperateTaskRequest) GetTaskName() string

func (*OperateTaskRequest) ProtoMessage 

func (*OperateTaskRequest) ProtoMessage()

func (*OperateTaskRequest) ProtoReflect 

func (x *OperateTaskRequest) ProtoReflect() protoreflect.Message

func (*OperateTaskRequest) Reset 

func (x *OperateTaskRequest) Reset()

func (*OperateTaskRequest) String 

func (x *OperateTaskRequest) String() string

type OperateTaskResponse 

type OperateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*OperateTaskResponse) Descriptor deprecated 

func (*OperateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use OperateTaskResponse.ProtoReflect.Descriptor instead.

func (*OperateTaskResponse) GetResponse 

func (x *OperateTaskResponse) GetResponse() *Response

func (*OperateTaskResponse) ProtoMessage 

func (*OperateTaskResponse) ProtoMessage()

func (*OperateTaskResponse) ProtoReflect 

func (x *OperateTaskResponse) ProtoReflect() protoreflect.Message

func (*OperateTaskResponse) Reset 

func (x *OperateTaskResponse) Reset()

func (*OperateTaskResponse) String 

func (x *OperateTaskResponse) String() string

type OperateWorkerRequest 

type OperateWorkerRequest struct {
	Operate  string `protobuf:"bytes,1,opt,name=operate,proto3" json:"operate,omitempty"`
	TaskName string `protobuf:"bytes,2,opt,name=taskName,proto3" json:"taskName,omitempty"`
	// contains filtered or unexported fields
}

func (*OperateWorkerRequest) Descriptor deprecated 

func (*OperateWorkerRequest) Descriptor() ([]byte, []int)

Deprecated: Use OperateWorkerRequest.ProtoReflect.Descriptor instead.

func (*OperateWorkerRequest) GetOperate 

func (x *OperateWorkerRequest) GetOperate() string

func (*OperateWorkerRequest) GetTaskName 

func (x *OperateWorkerRequest) GetTaskName() string

func (*OperateWorkerRequest) ProtoMessage 

func (*OperateWorkerRequest) ProtoMessage()

func (*OperateWorkerRequest) ProtoReflect 

func (x *OperateWorkerRequest) ProtoReflect() protoreflect.Message

func (*OperateWorkerRequest) Reset 

func (x *OperateWorkerRequest) Reset()

func (*OperateWorkerRequest) String 

func (x *OperateWorkerRequest) String() string

type OperateWorkerResponse 

type OperateWorkerResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*OperateWorkerResponse) Descriptor deprecated 

func (*OperateWorkerResponse) Descriptor() ([]byte, []int)

Deprecated: Use OperateWorkerResponse.ProtoReflect.Descriptor instead.

func (*OperateWorkerResponse) GetResponse 

func (x *OperateWorkerResponse) GetResponse() *Response

func (*OperateWorkerResponse) ProtoMessage 

func (*OperateWorkerResponse) ProtoMessage()

func (*OperateWorkerResponse) ProtoReflect 

func (x *OperateWorkerResponse) ProtoReflect() protoreflect.Message

func (*OperateWorkerResponse) Reset 

func (x *OperateWorkerResponse) Reset()

func (*OperateWorkerResponse) String 

func (x *OperateWorkerResponse) String() string

type Response 

type Response struct {
	Result  string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) GetResult 

func (x *Response) GetResult() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type SchemaRouteRule 

type SchemaRouteRule struct {
	SchemaNameS      string            `protobuf:"bytes,1,opt,name=schemaNameS,proto3" json:"schemaNameS,omitempty"`
	SchemaNameT      string            `protobuf:"bytes,2,opt,name=schemaNameT,proto3" json:"schemaNameT,omitempty"`
	IncludeTableS    []string          `protobuf:"bytes,3,rep,name=includeTableS,proto3" json:"includeTableS,omitempty"`
	ExcludeTableS    []string          `protobuf:"bytes,4,rep,name=excludeTableS,proto3" json:"excludeTableS,omitempty"`
	IncludeSequenceS []string          `protobuf:"bytes,5,rep,name=includeSequenceS,proto3" json:"includeSequenceS,omitempty"`
	ExcludeSequenceS []string          `protobuf:"bytes,6,rep,name=excludeSequenceS,proto3" json:"excludeSequenceS,omitempty"`
	TableRouteRules  []*TableRouteRule `protobuf:"bytes,7,rep,name=tableRouteRules,proto3" json:"tableRouteRules,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaRouteRule) Descriptor deprecated 

func (*SchemaRouteRule) Descriptor() ([]byte, []int)

Deprecated: Use SchemaRouteRule.ProtoReflect.Descriptor instead.

func (*SchemaRouteRule) GetExcludeSequenceS added in v0.0.9 

func (x *SchemaRouteRule) GetExcludeSequenceS() []string

func (*SchemaRouteRule) GetExcludeTableS 

func (x *SchemaRouteRule) GetExcludeTableS() []string

func (*SchemaRouteRule) GetIncludeSequenceS added in v0.0.9 

func (x *SchemaRouteRule) GetIncludeSequenceS() []string

func (*SchemaRouteRule) GetIncludeTableS 

func (x *SchemaRouteRule) GetIncludeTableS() []string

func (*SchemaRouteRule) GetSchemaNameS 

func (x *SchemaRouteRule) GetSchemaNameS() string

func (*SchemaRouteRule) GetSchemaNameT 

func (x *SchemaRouteRule) GetSchemaNameT() string

func (*SchemaRouteRule) GetTableRouteRules 

func (x *SchemaRouteRule) GetTableRouteRules() []*TableRouteRule

func (*SchemaRouteRule) ProtoMessage 

func (*SchemaRouteRule) ProtoMessage()

func (*SchemaRouteRule) ProtoReflect 

func (x *SchemaRouteRule) ProtoReflect() protoreflect.Message

func (*SchemaRouteRule) Reset 

func (x *SchemaRouteRule) Reset()

func (*SchemaRouteRule) String 

func (x *SchemaRouteRule) String() string

type SchemaStructRule 

type SchemaStructRule struct {
	SchemaNameS   string `protobuf:"bytes,1,opt,name=schemaNameS,proto3" json:"schemaNameS,omitempty"`
	ColumnTypeS   string `protobuf:"bytes,2,opt,name=columnTypeS,proto3" json:"columnTypeS,omitempty"`
	ColumnTypeT   string `protobuf:"bytes,3,opt,name=columnTypeT,proto3" json:"columnTypeT,omitempty"`
	DefaultValueS string `protobuf:"bytes,4,opt,name=defaultValueS,proto3" json:"defaultValueS,omitempty"`
	DefaultValueT string `protobuf:"bytes,5,opt,name=defaultValueT,proto3" json:"defaultValueT,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaStructRule) Descriptor deprecated 

func (*SchemaStructRule) Descriptor() ([]byte, []int)

Deprecated: Use SchemaStructRule.ProtoReflect.Descriptor instead.

func (*SchemaStructRule) GetColumnTypeS 

func (x *SchemaStructRule) GetColumnTypeS() string

func (*SchemaStructRule) GetColumnTypeT 

func (x *SchemaStructRule) GetColumnTypeT() string

func (*SchemaStructRule) GetDefaultValueS 

func (x *SchemaStructRule) GetDefaultValueS() string

func (*SchemaStructRule) GetDefaultValueT 

func (x *SchemaStructRule) GetDefaultValueT() string

func (*SchemaStructRule) GetSchemaNameS 

func (x *SchemaStructRule) GetSchemaNameS() string

func (*SchemaStructRule) ProtoMessage 

func (*SchemaStructRule) ProtoMessage()

func (*SchemaStructRule) ProtoReflect 

func (x *SchemaStructRule) ProtoReflect() protoreflect.Message

func (*SchemaStructRule) Reset 

func (x *SchemaStructRule) Reset()

func (*SchemaStructRule) String 

func (x *SchemaStructRule) String() string

type ShowAssessMigrateTaskRequest 

type ShowAssessMigrateTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowAssessMigrateTaskRequest) Descriptor deprecated 

func (*ShowAssessMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowAssessMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowAssessMigrateTaskRequest) GetPage 

func (x *ShowAssessMigrateTaskRequest) GetPage() uint64

func (*ShowAssessMigrateTaskRequest) GetPageSize 

func (x *ShowAssessMigrateTaskRequest) GetPageSize() uint64

func (*ShowAssessMigrateTaskRequest) GetTaskName 

func (x *ShowAssessMigrateTaskRequest) GetTaskName() string

func (*ShowAssessMigrateTaskRequest) ProtoMessage 

func (*ShowAssessMigrateTaskRequest) ProtoMessage()

func (*ShowAssessMigrateTaskRequest) ProtoReflect 

func (x *ShowAssessMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowAssessMigrateTaskRequest) Reset 

func (x *ShowAssessMigrateTaskRequest) Reset()

func (*ShowAssessMigrateTaskRequest) String 

func (x *ShowAssessMigrateTaskRequest) String() string

type ShowAssessMigrateTaskResponse 

type ShowAssessMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowAssessMigrateTaskResponse) Descriptor deprecated 

func (*ShowAssessMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowAssessMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowAssessMigrateTaskResponse) GetResponse 

func (x *ShowAssessMigrateTaskResponse) GetResponse() *Response

func (*ShowAssessMigrateTaskResponse) ProtoMessage 

func (*ShowAssessMigrateTaskResponse) ProtoMessage()

func (*ShowAssessMigrateTaskResponse) ProtoReflect 

func (x *ShowAssessMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowAssessMigrateTaskResponse) Reset 

func (x *ShowAssessMigrateTaskResponse) Reset()

func (*ShowAssessMigrateTaskResponse) String 

func (x *ShowAssessMigrateTaskResponse) String() string

type ShowCdcConsumeTaskRequest added in v0.0.17 

type ShowCdcConsumeTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowCdcConsumeTaskRequest) Descriptor deprecated added in v0.0.17 

func (*ShowCdcConsumeTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowCdcConsumeTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowCdcConsumeTaskRequest) GetPage added in v0.0.17 

func (x *ShowCdcConsumeTaskRequest) GetPage() uint64

func (*ShowCdcConsumeTaskRequest) GetPageSize added in v0.0.17 

func (x *ShowCdcConsumeTaskRequest) GetPageSize() uint64

func (*ShowCdcConsumeTaskRequest) GetTaskName added in v0.0.17 

func (x *ShowCdcConsumeTaskRequest) GetTaskName() string

func (*ShowCdcConsumeTaskRequest) ProtoMessage added in v0.0.17 

func (*ShowCdcConsumeTaskRequest) ProtoMessage()

func (*ShowCdcConsumeTaskRequest) ProtoReflect added in v0.0.17 

func (x *ShowCdcConsumeTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowCdcConsumeTaskRequest) Reset added in v0.0.17 

func (x *ShowCdcConsumeTaskRequest) Reset()

func (*ShowCdcConsumeTaskRequest) String added in v0.0.17 

func (x *ShowCdcConsumeTaskRequest) String() string

type ShowCdcConsumeTaskResponse added in v0.0.17 

type ShowCdcConsumeTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowCdcConsumeTaskResponse) Descriptor deprecated added in v0.0.17 

func (*ShowCdcConsumeTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowCdcConsumeTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowCdcConsumeTaskResponse) GetResponse added in v0.0.17 

func (x *ShowCdcConsumeTaskResponse) GetResponse() *Response

func (*ShowCdcConsumeTaskResponse) ProtoMessage added in v0.0.17 

func (*ShowCdcConsumeTaskResponse) ProtoMessage()

func (*ShowCdcConsumeTaskResponse) ProtoReflect added in v0.0.17 

func (x *ShowCdcConsumeTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowCdcConsumeTaskResponse) Reset added in v0.0.17 

func (x *ShowCdcConsumeTaskResponse) Reset()

func (*ShowCdcConsumeTaskResponse) String added in v0.0.17 

func (x *ShowCdcConsumeTaskResponse) String() string

type ShowCsvMigrateTaskRequest 

type ShowCsvMigrateTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowCsvMigrateTaskRequest) Descriptor deprecated 

func (*ShowCsvMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowCsvMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowCsvMigrateTaskRequest) GetPage 

func (x *ShowCsvMigrateTaskRequest) GetPage() uint64

func (*ShowCsvMigrateTaskRequest) GetPageSize 

func (x *ShowCsvMigrateTaskRequest) GetPageSize() uint64

func (*ShowCsvMigrateTaskRequest) GetTaskName 

func (x *ShowCsvMigrateTaskRequest) GetTaskName() string

func (*ShowCsvMigrateTaskRequest) ProtoMessage 

func (*ShowCsvMigrateTaskRequest) ProtoMessage()

func (*ShowCsvMigrateTaskRequest) ProtoReflect 

func (x *ShowCsvMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowCsvMigrateTaskRequest) Reset 

func (x *ShowCsvMigrateTaskRequest) Reset()

func (*ShowCsvMigrateTaskRequest) String 

func (x *ShowCsvMigrateTaskRequest) String() string

type ShowCsvMigrateTaskResponse 

type ShowCsvMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowCsvMigrateTaskResponse) Descriptor deprecated 

func (*ShowCsvMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowCsvMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowCsvMigrateTaskResponse) GetResponse 

func (x *ShowCsvMigrateTaskResponse) GetResponse() *Response

func (*ShowCsvMigrateTaskResponse) ProtoMessage 

func (*ShowCsvMigrateTaskResponse) ProtoMessage()

func (*ShowCsvMigrateTaskResponse) ProtoReflect 

func (x *ShowCsvMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowCsvMigrateTaskResponse) Reset 

func (x *ShowCsvMigrateTaskResponse) Reset()

func (*ShowCsvMigrateTaskResponse) String 

func (x *ShowCsvMigrateTaskResponse) String() string

type ShowDataCompareTaskRequest 

type ShowDataCompareTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDataCompareTaskRequest) Descriptor deprecated 

func (*ShowDataCompareTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowDataCompareTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowDataCompareTaskRequest) GetPage 

func (x *ShowDataCompareTaskRequest) GetPage() uint64

func (*ShowDataCompareTaskRequest) GetPageSize 

func (x *ShowDataCompareTaskRequest) GetPageSize() uint64

func (*ShowDataCompareTaskRequest) GetTaskName 

func (x *ShowDataCompareTaskRequest) GetTaskName() string

func (*ShowDataCompareTaskRequest) ProtoMessage 

func (*ShowDataCompareTaskRequest) ProtoMessage()

func (*ShowDataCompareTaskRequest) ProtoReflect 

func (x *ShowDataCompareTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowDataCompareTaskRequest) Reset 

func (x *ShowDataCompareTaskRequest) Reset()

func (*ShowDataCompareTaskRequest) String 

func (x *ShowDataCompareTaskRequest) String() string

type ShowDataCompareTaskResponse 

type ShowDataCompareTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDataCompareTaskResponse) Descriptor deprecated 

func (*ShowDataCompareTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowDataCompareTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowDataCompareTaskResponse) GetResponse 

func (x *ShowDataCompareTaskResponse) GetResponse() *Response

func (*ShowDataCompareTaskResponse) ProtoMessage 

func (*ShowDataCompareTaskResponse) ProtoMessage()

func (*ShowDataCompareTaskResponse) ProtoReflect 

func (x *ShowDataCompareTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowDataCompareTaskResponse) Reset 

func (x *ShowDataCompareTaskResponse) Reset()

func (*ShowDataCompareTaskResponse) String 

func (x *ShowDataCompareTaskResponse) String() string

type ShowDataScanTaskRequest 

type ShowDataScanTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDataScanTaskRequest) Descriptor deprecated 

func (*ShowDataScanTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowDataScanTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowDataScanTaskRequest) GetPage 

func (x *ShowDataScanTaskRequest) GetPage() uint64

func (*ShowDataScanTaskRequest) GetPageSize 

func (x *ShowDataScanTaskRequest) GetPageSize() uint64

func (*ShowDataScanTaskRequest) GetTaskName 

func (x *ShowDataScanTaskRequest) GetTaskName() string

func (*ShowDataScanTaskRequest) ProtoMessage 

func (*ShowDataScanTaskRequest) ProtoMessage()

func (*ShowDataScanTaskRequest) ProtoReflect 

func (x *ShowDataScanTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowDataScanTaskRequest) Reset 

func (x *ShowDataScanTaskRequest) Reset()

func (*ShowDataScanTaskRequest) String 

func (x *ShowDataScanTaskRequest) String() string

type ShowDataScanTaskResponse 

type ShowDataScanTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDataScanTaskResponse) Descriptor deprecated 

func (*ShowDataScanTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowDataScanTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowDataScanTaskResponse) GetResponse 

func (x *ShowDataScanTaskResponse) GetResponse() *Response

func (*ShowDataScanTaskResponse) ProtoMessage 

func (*ShowDataScanTaskResponse) ProtoMessage()

func (*ShowDataScanTaskResponse) ProtoReflect 

func (x *ShowDataScanTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowDataScanTaskResponse) Reset 

func (x *ShowDataScanTaskResponse) Reset()

func (*ShowDataScanTaskResponse) String 

func (x *ShowDataScanTaskResponse) String() string

type ShowDatabaseRequest 

type ShowDatabaseRequest struct {
	// contains filtered or unexported fields
}

func (*ShowDatabaseRequest) Descriptor deprecated 

func (*ShowDatabaseRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowDatabaseRequest.ProtoReflect.Descriptor instead.

func (*ShowDatabaseRequest) ProtoMessage 

func (*ShowDatabaseRequest) ProtoMessage()

func (*ShowDatabaseRequest) ProtoReflect 

func (x *ShowDatabaseRequest) ProtoReflect() protoreflect.Message

func (*ShowDatabaseRequest) Reset 

func (x *ShowDatabaseRequest) Reset()

func (*ShowDatabaseRequest) String 

func (x *ShowDatabaseRequest) String() string

type ShowDatabaseResponse 

type ShowDatabaseResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDatabaseResponse) Descriptor deprecated 

func (*ShowDatabaseResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowDatabaseResponse.ProtoReflect.Descriptor instead.

func (*ShowDatabaseResponse) GetResponse 

func (x *ShowDatabaseResponse) GetResponse() *Response

func (*ShowDatabaseResponse) ProtoMessage 

func (*ShowDatabaseResponse) ProtoMessage()

func (*ShowDatabaseResponse) ProtoReflect 

func (x *ShowDatabaseResponse) ProtoReflect() protoreflect.Message

func (*ShowDatabaseResponse) Reset 

func (x *ShowDatabaseResponse) Reset()

func (*ShowDatabaseResponse) String 

func (x *ShowDatabaseResponse) String() string

type ShowDatasourceRequest 

type ShowDatasourceRequest struct {
	DatasourceName string `protobuf:"bytes,1,opt,name=datasourceName,proto3" json:"datasourceName,omitempty"`
	Page           uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize       uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDatasourceRequest) Descriptor deprecated 

func (*ShowDatasourceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowDatasourceRequest.ProtoReflect.Descriptor instead.

func (*ShowDatasourceRequest) GetDatasourceName 

func (x *ShowDatasourceRequest) GetDatasourceName() string

func (*ShowDatasourceRequest) GetPage 

func (x *ShowDatasourceRequest) GetPage() uint64

func (*ShowDatasourceRequest) GetPageSize 

func (x *ShowDatasourceRequest) GetPageSize() uint64

func (*ShowDatasourceRequest) ProtoMessage 

func (*ShowDatasourceRequest) ProtoMessage()

func (*ShowDatasourceRequest) ProtoReflect 

func (x *ShowDatasourceRequest) ProtoReflect() protoreflect.Message

func (*ShowDatasourceRequest) Reset 

func (x *ShowDatasourceRequest) Reset()

func (*ShowDatasourceRequest) String 

func (x *ShowDatasourceRequest) String() string

type ShowDatasourceResponse 

type ShowDatasourceResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowDatasourceResponse) Descriptor deprecated 

func (*ShowDatasourceResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowDatasourceResponse.ProtoReflect.Descriptor instead.

func (*ShowDatasourceResponse) GetResponse 

func (x *ShowDatasourceResponse) GetResponse() *Response

func (*ShowDatasourceResponse) ProtoMessage 

func (*ShowDatasourceResponse) ProtoMessage()

func (*ShowDatasourceResponse) ProtoReflect 

func (x *ShowDatasourceResponse) ProtoReflect() protoreflect.Message

func (*ShowDatasourceResponse) Reset 

func (x *ShowDatasourceResponse) Reset()

func (*ShowDatasourceResponse) String 

func (x *ShowDatasourceResponse) String() string

type ShowSqlMigrateTaskRequest 

type ShowSqlMigrateTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowSqlMigrateTaskRequest) Descriptor deprecated 

func (*ShowSqlMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowSqlMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowSqlMigrateTaskRequest) GetPage 

func (x *ShowSqlMigrateTaskRequest) GetPage() uint64

func (*ShowSqlMigrateTaskRequest) GetPageSize 

func (x *ShowSqlMigrateTaskRequest) GetPageSize() uint64

func (*ShowSqlMigrateTaskRequest) GetTaskName 

func (x *ShowSqlMigrateTaskRequest) GetTaskName() string

func (*ShowSqlMigrateTaskRequest) ProtoMessage 

func (*ShowSqlMigrateTaskRequest) ProtoMessage()

func (*ShowSqlMigrateTaskRequest) ProtoReflect 

func (x *ShowSqlMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowSqlMigrateTaskRequest) Reset 

func (x *ShowSqlMigrateTaskRequest) Reset()

func (*ShowSqlMigrateTaskRequest) String 

func (x *ShowSqlMigrateTaskRequest) String() string

type ShowSqlMigrateTaskResponse 

type ShowSqlMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowSqlMigrateTaskResponse) Descriptor deprecated 

func (*ShowSqlMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowSqlMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowSqlMigrateTaskResponse) GetResponse 

func (x *ShowSqlMigrateTaskResponse) GetResponse() *Response

func (*ShowSqlMigrateTaskResponse) ProtoMessage 

func (*ShowSqlMigrateTaskResponse) ProtoMessage()

func (*ShowSqlMigrateTaskResponse) ProtoReflect 

func (x *ShowSqlMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowSqlMigrateTaskResponse) Reset 

func (x *ShowSqlMigrateTaskResponse) Reset()

func (*ShowSqlMigrateTaskResponse) String 

func (x *ShowSqlMigrateTaskResponse) String() string

type ShowStmtMigrateTaskRequest 

type ShowStmtMigrateTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowStmtMigrateTaskRequest) Descriptor deprecated 

func (*ShowStmtMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowStmtMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowStmtMigrateTaskRequest) GetPage 

func (x *ShowStmtMigrateTaskRequest) GetPage() uint64

func (*ShowStmtMigrateTaskRequest) GetPageSize 

func (x *ShowStmtMigrateTaskRequest) GetPageSize() uint64

func (*ShowStmtMigrateTaskRequest) GetTaskName 

func (x *ShowStmtMigrateTaskRequest) GetTaskName() string

func (*ShowStmtMigrateTaskRequest) ProtoMessage 

func (*ShowStmtMigrateTaskRequest) ProtoMessage()

func (*ShowStmtMigrateTaskRequest) ProtoReflect 

func (x *ShowStmtMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowStmtMigrateTaskRequest) Reset 

func (x *ShowStmtMigrateTaskRequest) Reset()

func (*ShowStmtMigrateTaskRequest) String 

func (x *ShowStmtMigrateTaskRequest) String() string

type ShowStmtMigrateTaskResponse 

type ShowStmtMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowStmtMigrateTaskResponse) Descriptor deprecated 

func (*ShowStmtMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowStmtMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowStmtMigrateTaskResponse) GetResponse 

func (x *ShowStmtMigrateTaskResponse) GetResponse() *Response

func (*ShowStmtMigrateTaskResponse) ProtoMessage 

func (*ShowStmtMigrateTaskResponse) ProtoMessage()

func (*ShowStmtMigrateTaskResponse) ProtoReflect 

func (x *ShowStmtMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowStmtMigrateTaskResponse) Reset 

func (x *ShowStmtMigrateTaskResponse) Reset()

func (*ShowStmtMigrateTaskResponse) String 

func (x *ShowStmtMigrateTaskResponse) String() string

type ShowStructCompareTaskRequest 

type ShowStructCompareTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowStructCompareTaskRequest) Descriptor deprecated 

func (*ShowStructCompareTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowStructCompareTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowStructCompareTaskRequest) GetPage 

func (x *ShowStructCompareTaskRequest) GetPage() uint64

func (*ShowStructCompareTaskRequest) GetPageSize 

func (x *ShowStructCompareTaskRequest) GetPageSize() uint64

func (*ShowStructCompareTaskRequest) GetTaskName 

func (x *ShowStructCompareTaskRequest) GetTaskName() string

func (*ShowStructCompareTaskRequest) ProtoMessage 

func (*ShowStructCompareTaskRequest) ProtoMessage()

func (*ShowStructCompareTaskRequest) ProtoReflect 

func (x *ShowStructCompareTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowStructCompareTaskRequest) Reset 

func (x *ShowStructCompareTaskRequest) Reset()

func (*ShowStructCompareTaskRequest) String 

func (x *ShowStructCompareTaskRequest) String() string

type ShowStructCompareTaskResponse 

type ShowStructCompareTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowStructCompareTaskResponse) Descriptor deprecated 

func (*ShowStructCompareTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowStructCompareTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowStructCompareTaskResponse) GetResponse 

func (x *ShowStructCompareTaskResponse) GetResponse() *Response

func (*ShowStructCompareTaskResponse) ProtoMessage 

func (*ShowStructCompareTaskResponse) ProtoMessage()

func (*ShowStructCompareTaskResponse) ProtoReflect 

func (x *ShowStructCompareTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowStructCompareTaskResponse) Reset 

func (x *ShowStructCompareTaskResponse) Reset()

func (*ShowStructCompareTaskResponse) String 

func (x *ShowStructCompareTaskResponse) String() string

type ShowStructMigrateTaskRequest 

type ShowStructMigrateTaskRequest struct {
	TaskName string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Page     uint64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowStructMigrateTaskRequest) Descriptor deprecated 

func (*ShowStructMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowStructMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*ShowStructMigrateTaskRequest) GetPage 

func (x *ShowStructMigrateTaskRequest) GetPage() uint64

func (*ShowStructMigrateTaskRequest) GetPageSize 

func (x *ShowStructMigrateTaskRequest) GetPageSize() uint64

func (*ShowStructMigrateTaskRequest) GetTaskName 

func (x *ShowStructMigrateTaskRequest) GetTaskName() string

func (*ShowStructMigrateTaskRequest) ProtoMessage 

func (*ShowStructMigrateTaskRequest) ProtoMessage()

func (*ShowStructMigrateTaskRequest) ProtoReflect 

func (x *ShowStructMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*ShowStructMigrateTaskRequest) Reset 

func (x *ShowStructMigrateTaskRequest) Reset()

func (*ShowStructMigrateTaskRequest) String 

func (x *ShowStructMigrateTaskRequest) String() string

type ShowStructMigrateTaskResponse 

type ShowStructMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowStructMigrateTaskResponse) Descriptor deprecated 

func (*ShowStructMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowStructMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*ShowStructMigrateTaskResponse) GetResponse 

func (x *ShowStructMigrateTaskResponse) GetResponse() *Response

func (*ShowStructMigrateTaskResponse) ProtoMessage 

func (*ShowStructMigrateTaskResponse) ProtoMessage()

func (*ShowStructMigrateTaskResponse) ProtoReflect 

func (x *ShowStructMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*ShowStructMigrateTaskResponse) Reset 

func (x *ShowStructMigrateTaskResponse) Reset()

func (*ShowStructMigrateTaskResponse) String 

func (x *ShowStructMigrateTaskResponse) String() string

type SqlMigrateParam 

type SqlMigrateParam struct {
	BatchSize            uint64 `protobuf:"varint,1,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	SqlThreadS           uint64 `protobuf:"varint,2,opt,name=sqlThreadS,proto3" json:"sqlThreadS,omitempty"`
	SqlThreadT           uint64 `protobuf:"varint,3,opt,name=sqlThreadT,proto3" json:"sqlThreadT,omitempty"`
	SqlHintT             string `protobuf:"bytes,4,opt,name=sqlHintT,proto3" json:"sqlHintT,omitempty"`
	CallTimeout          uint64 `protobuf:"varint,5,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	EnableConsistentRead bool   `protobuf:"varint,6,opt,name=enableConsistentRead,proto3" json:"enableConsistentRead,omitempty"`
	EnableSafeMode       bool   `protobuf:"varint,7,opt,name=enableSafeMode,proto3" json:"enableSafeMode,omitempty"`
	WriteThread          uint64 `protobuf:"varint,8,opt,name=writeThread,proto3" json:"writeThread,omitempty"`
	EnableCheckpoint     bool   `protobuf:"varint,9,opt,name=enableCheckpoint,proto3" json:"enableCheckpoint,omitempty"`
	EnablePrepareStmt    bool   `protobuf:"varint,10,opt,name=enablePrepareStmt,proto3" json:"enablePrepareStmt,omitempty"`
	// contains filtered or unexported fields
}

func (*SqlMigrateParam) Descriptor deprecated 

func (*SqlMigrateParam) Descriptor() ([]byte, []int)

Deprecated: Use SqlMigrateParam.ProtoReflect.Descriptor instead.

func (*SqlMigrateParam) GetBatchSize 

func (x *SqlMigrateParam) GetBatchSize() uint64

func (*SqlMigrateParam) GetCallTimeout 

func (x *SqlMigrateParam) GetCallTimeout() uint64

func (*SqlMigrateParam) GetEnableCheckpoint added in v0.0.9 

func (x *SqlMigrateParam) GetEnableCheckpoint() bool

func (*SqlMigrateParam) GetEnableConsistentRead 

func (x *SqlMigrateParam) GetEnableConsistentRead() bool

func (*SqlMigrateParam) GetEnablePrepareStmt added in v0.0.15 

func (x *SqlMigrateParam) GetEnablePrepareStmt() bool

func (*SqlMigrateParam) GetEnableSafeMode added in v0.0.4 

func (x *SqlMigrateParam) GetEnableSafeMode() bool

func (*SqlMigrateParam) GetSqlHintT 

func (x *SqlMigrateParam) GetSqlHintT() string

func (*SqlMigrateParam) GetSqlThreadS 

func (x *SqlMigrateParam) GetSqlThreadS() uint64

func (*SqlMigrateParam) GetSqlThreadT 

func (x *SqlMigrateParam) GetSqlThreadT() uint64

func (*SqlMigrateParam) GetWriteThread added in v0.0.9 

func (x *SqlMigrateParam) GetWriteThread() uint64

func (*SqlMigrateParam) ProtoMessage 

func (*SqlMigrateParam) ProtoMessage()

func (*SqlMigrateParam) ProtoReflect 

func (x *SqlMigrateParam) ProtoReflect() protoreflect.Message

func (*SqlMigrateParam) Reset 

func (x *SqlMigrateParam) Reset()

func (*SqlMigrateParam) String 

func (x *SqlMigrateParam) String() string

type SqlMigrateRule 

type SqlMigrateRule struct {
	SqlQueryS        string            `protobuf:"bytes,1,opt,name=sqlQueryS,proto3" json:"sqlQueryS,omitempty"`
	SchemaNameT      string            `protobuf:"bytes,2,opt,name=schemaNameT,proto3" json:"schemaNameT,omitempty"`
	TableNameT       string            `protobuf:"bytes,3,opt,name=tableNameT,proto3" json:"tableNameT,omitempty"`
	SqlHintT         string            `protobuf:"bytes,4,opt,name=sqlHintT,proto3" json:"sqlHintT,omitempty"`
	ColumnRouteRules map[string]string `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SqlMigrateRule) Descriptor deprecated 

func (*SqlMigrateRule) Descriptor() ([]byte, []int)

Deprecated: Use SqlMigrateRule.ProtoReflect.Descriptor instead.

func (*SqlMigrateRule) GetColumnRouteRules 

func (x *SqlMigrateRule) GetColumnRouteRules() map[string]string

func (*SqlMigrateRule) GetSchemaNameT 

func (x *SqlMigrateRule) GetSchemaNameT() string

func (*SqlMigrateRule) GetSqlHintT 

func (x *SqlMigrateRule) GetSqlHintT() string

func (*SqlMigrateRule) GetSqlQueryS 

func (x *SqlMigrateRule) GetSqlQueryS() string

func (*SqlMigrateRule) GetTableNameT 

func (x *SqlMigrateRule) GetTableNameT() string

func (*SqlMigrateRule) ProtoMessage 

func (*SqlMigrateRule) ProtoMessage()

func (*SqlMigrateRule) ProtoReflect 

func (x *SqlMigrateRule) ProtoReflect() protoreflect.Message

func (*SqlMigrateRule) Reset 

func (x *SqlMigrateRule) Reset()

func (*SqlMigrateRule) String 

func (x *SqlMigrateRule) String() string

type StatementMigrateParam 

type StatementMigrateParam struct {
	TableThread          uint64 `protobuf:"varint,1,opt,name=tableThread,proto3" json:"tableThread,omitempty"`
	BatchSize            uint64 `protobuf:"varint,2,opt,name=BatchSize,proto3" json:"BatchSize,omitempty"`
	ChunkSize            uint64 `protobuf:"varint,3,opt,name=ChunkSize,proto3" json:"ChunkSize,omitempty"`
	SqlThreadS           uint64 `protobuf:"varint,4,opt,name=sqlThreadS,proto3" json:"sqlThreadS,omitempty"`
	SqlHintS             string `protobuf:"bytes,5,opt,name=sqlHintS,proto3" json:"sqlHintS,omitempty"`
	SqlThreadT           uint64 `protobuf:"varint,6,opt,name=sqlThreadT,proto3" json:"sqlThreadT,omitempty"`
	SqlHintT             string `protobuf:"bytes,7,opt,name=sqlHintT,proto3" json:"sqlHintT,omitempty"`
	CallTimeout          uint64 `protobuf:"varint,8,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	EnableCheckpoint     bool   `protobuf:"varint,9,opt,name=enableCheckpoint,proto3" json:"enableCheckpoint,omitempty"`
	EnableConsistentRead bool   `protobuf:"varint,10,opt,name=enableConsistentRead,proto3" json:"enableConsistentRead,omitempty"`
	EnableSafeMode       bool   `protobuf:"varint,11,opt,name=enableSafeMode,proto3" json:"enableSafeMode,omitempty"`
	WriteThread          uint64 `protobuf:"varint,12,opt,name=writeThread,proto3" json:"writeThread,omitempty"`
	EnablePrepareStmt    bool   `protobuf:"varint,13,opt,name=enablePrepareStmt,proto3" json:"enablePrepareStmt,omitempty"`
	// contains filtered or unexported fields
}

func (*StatementMigrateParam) Descriptor deprecated 

func (*StatementMigrateParam) Descriptor() ([]byte, []int)

Deprecated: Use StatementMigrateParam.ProtoReflect.Descriptor instead.

func (*StatementMigrateParam) GetBatchSize 

func (x *StatementMigrateParam) GetBatchSize() uint64

func (*StatementMigrateParam) GetCallTimeout 

func (x *StatementMigrateParam) GetCallTimeout() uint64

func (*StatementMigrateParam) GetChunkSize 

func (x *StatementMigrateParam) GetChunkSize() uint64

func (*StatementMigrateParam) GetEnableCheckpoint 

func (x *StatementMigrateParam) GetEnableCheckpoint() bool

func (*StatementMigrateParam) GetEnableConsistentRead 

func (x *StatementMigrateParam) GetEnableConsistentRead() bool

func (*StatementMigrateParam) GetEnablePrepareStmt added in v0.0.15 

func (x *StatementMigrateParam) GetEnablePrepareStmt() bool

func (*StatementMigrateParam) GetEnableSafeMode added in v0.0.4 

func (x *StatementMigrateParam) GetEnableSafeMode() bool

func (*StatementMigrateParam) GetSqlHintS 

func (x *StatementMigrateParam) GetSqlHintS() string

func (*StatementMigrateParam) GetSqlHintT 

func (x *StatementMigrateParam) GetSqlHintT() string

func (*StatementMigrateParam) GetSqlThreadS 

func (x *StatementMigrateParam) GetSqlThreadS() uint64

func (*StatementMigrateParam) GetSqlThreadT 

func (x *StatementMigrateParam) GetSqlThreadT() uint64

func (*StatementMigrateParam) GetTableThread 

func (x *StatementMigrateParam) GetTableThread() uint64

func (*StatementMigrateParam) GetWriteThread added in v0.0.9 

func (x *StatementMigrateParam) GetWriteThread() uint64

func (*StatementMigrateParam) ProtoMessage 

func (*StatementMigrateParam) ProtoMessage()

func (*StatementMigrateParam) ProtoReflect 

func (x *StatementMigrateParam) ProtoReflect() protoreflect.Message

func (*StatementMigrateParam) Reset 

func (x *StatementMigrateParam) Reset()

func (*StatementMigrateParam) String 

func (x *StatementMigrateParam) String() string

type StructCompareParam 

type StructCompareParam struct {
	CompareThread     uint64 `protobuf:"varint,1,opt,name=compareThread,proto3" json:"compareThread,omitempty"`
	EnableCheckpoint  bool   `protobuf:"varint,2,opt,name=enableCheckpoint,proto3" json:"enableCheckpoint,omitempty"`
	CallTimeout       uint64 `protobuf:"varint,3,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	IgnoreCaseCompare bool   `protobuf:"varint,4,opt,name=ignoreCaseCompare,proto3" json:"ignoreCaseCompare,omitempty"`
	// contains filtered or unexported fields
}

func (*StructCompareParam) Descriptor deprecated 

func (*StructCompareParam) Descriptor() ([]byte, []int)

Deprecated: Use StructCompareParam.ProtoReflect.Descriptor instead.

func (*StructCompareParam) GetCallTimeout added in v0.0.8 

func (x *StructCompareParam) GetCallTimeout() uint64

func (*StructCompareParam) GetCompareThread 

func (x *StructCompareParam) GetCompareThread() uint64

func (*StructCompareParam) GetEnableCheckpoint 

func (x *StructCompareParam) GetEnableCheckpoint() bool

func (*StructCompareParam) GetIgnoreCaseCompare added in v0.0.9 

func (x *StructCompareParam) GetIgnoreCaseCompare() bool

func (*StructCompareParam) ProtoMessage 

func (*StructCompareParam) ProtoMessage()

func (*StructCompareParam) ProtoReflect 

func (x *StructCompareParam) ProtoReflect() protoreflect.Message

func (*StructCompareParam) Reset 

func (x *StructCompareParam) Reset()

func (*StructCompareParam) String 

func (x *StructCompareParam) String() string

type StructCompareRule 

type StructCompareRule struct {
	TaskStructRules   []*TaskStructRule   `protobuf:"bytes,1,rep,name=taskStructRules,proto3" json:"taskStructRules,omitempty"`
	SchemaStructRules []*SchemaStructRule `protobuf:"bytes,2,rep,name=schemaStructRules,proto3" json:"schemaStructRules,omitempty"`
	TableStructRules  []*TableStructRule  `protobuf:"bytes,3,rep,name=tableStructRules,proto3" json:"tableStructRules,omitempty"`
	ColumnStructRules []*ColumnStructRule `protobuf:"bytes,4,rep,name=columnStructRules,proto3" json:"columnStructRules,omitempty"`
	// contains filtered or unexported fields
}

func (*StructCompareRule) Descriptor deprecated 

func (*StructCompareRule) Descriptor() ([]byte, []int)

Deprecated: Use StructCompareRule.ProtoReflect.Descriptor instead.

func (*StructCompareRule) GetColumnStructRules 

func (x *StructCompareRule) GetColumnStructRules() []*ColumnStructRule

func (*StructCompareRule) GetSchemaStructRules 

func (x *StructCompareRule) GetSchemaStructRules() []*SchemaStructRule

func (*StructCompareRule) GetTableStructRules 

func (x *StructCompareRule) GetTableStructRules() []*TableStructRule

func (*StructCompareRule) GetTaskStructRules 

func (x *StructCompareRule) GetTaskStructRules() []*TaskStructRule

func (*StructCompareRule) ProtoMessage 

func (*StructCompareRule) ProtoMessage()

func (*StructCompareRule) ProtoReflect 

func (x *StructCompareRule) ProtoReflect() protoreflect.Message

func (*StructCompareRule) Reset 

func (x *StructCompareRule) Reset()

func (*StructCompareRule) String 

func (x *StructCompareRule) String() string

type StructMigrateParam 

type StructMigrateParam struct {
	MigrateThread      uint64 `protobuf:"varint,1,opt,name=migrateThread,proto3" json:"migrateThread,omitempty"`
	CreateIfNotExist   bool   `protobuf:"varint,2,opt,name=createIfNotExist,proto3" json:"createIfNotExist,omitempty"`
	EnableDirectCreate bool   `protobuf:"varint,3,opt,name=enableDirectCreate,proto3" json:"enableDirectCreate,omitempty"`
	EnableCheckpoint   bool   `protobuf:"varint,4,opt,name=enableCheckpoint,proto3" json:"enableCheckpoint,omitempty"`
	CallTimeout        uint64 `protobuf:"varint,5,opt,name=callTimeout,proto3" json:"callTimeout,omitempty"`
	// contains filtered or unexported fields
}

func (*StructMigrateParam) Descriptor deprecated 

func (*StructMigrateParam) Descriptor() ([]byte, []int)

Deprecated: Use StructMigrateParam.ProtoReflect.Descriptor instead.

func (*StructMigrateParam) GetCallTimeout added in v0.0.8 

func (x *StructMigrateParam) GetCallTimeout() uint64

func (*StructMigrateParam) GetCreateIfNotExist 

func (x *StructMigrateParam) GetCreateIfNotExist() bool

func (*StructMigrateParam) GetEnableCheckpoint added in v0.0.1 

func (x *StructMigrateParam) GetEnableCheckpoint() bool

func (*StructMigrateParam) GetEnableDirectCreate 

func (x *StructMigrateParam) GetEnableDirectCreate() bool

func (*StructMigrateParam) GetMigrateThread 

func (x *StructMigrateParam) GetMigrateThread() uint64

func (*StructMigrateParam) ProtoMessage 

func (*StructMigrateParam) ProtoMessage()

func (*StructMigrateParam) ProtoReflect 

func (x *StructMigrateParam) ProtoReflect() protoreflect.Message

func (*StructMigrateParam) Reset 

func (x *StructMigrateParam) Reset()

func (*StructMigrateParam) String 

func (x *StructMigrateParam) String() string

type StructMigrateRule 

type StructMigrateRule struct {
	TaskStructRules   []*TaskStructRule   `protobuf:"bytes,1,rep,name=taskStructRules,proto3" json:"taskStructRules,omitempty"`
	SchemaStructRules []*SchemaStructRule `protobuf:"bytes,2,rep,name=schemaStructRules,proto3" json:"schemaStructRules,omitempty"`
	TableStructRules  []*TableStructRule  `protobuf:"bytes,3,rep,name=tableStructRules,proto3" json:"tableStructRules,omitempty"`
	ColumnStructRules []*ColumnStructRule `protobuf:"bytes,4,rep,name=columnStructRules,proto3" json:"columnStructRules,omitempty"`
	TableAttrsRules   []*TableAttrsRule   `protobuf:"bytes,5,rep,name=tableAttrsRules,proto3" json:"tableAttrsRules,omitempty"`
	// contains filtered or unexported fields
}

func (*StructMigrateRule) Descriptor deprecated 

func (*StructMigrateRule) Descriptor() ([]byte, []int)

Deprecated: Use StructMigrateRule.ProtoReflect.Descriptor instead.

func (*StructMigrateRule) GetColumnStructRules 

func (x *StructMigrateRule) GetColumnStructRules() []*ColumnStructRule

func (*StructMigrateRule) GetSchemaStructRules 

func (x *StructMigrateRule) GetSchemaStructRules() []*SchemaStructRule

func (*StructMigrateRule) GetTableAttrsRules 

func (x *StructMigrateRule) GetTableAttrsRules() []*TableAttrsRule

func (*StructMigrateRule) GetTableStructRules 

func (x *StructMigrateRule) GetTableStructRules() []*TableStructRule

func (*StructMigrateRule) GetTaskStructRules 

func (x *StructMigrateRule) GetTaskStructRules() []*TaskStructRule

func (*StructMigrateRule) ProtoMessage 

func (*StructMigrateRule) ProtoMessage()

func (*StructMigrateRule) ProtoReflect 

func (x *StructMigrateRule) ProtoReflect() protoreflect.Message

func (*StructMigrateRule) Reset 

func (x *StructMigrateRule) Reset()

func (*StructMigrateRule) String 

func (x *StructMigrateRule) String() string

type TableAttrsRule 

type TableAttrsRule struct {
	SchemaNameS string   `protobuf:"bytes,1,opt,name=schemaNameS,proto3" json:"schemaNameS,omitempty"`
	TableNamesS []string `protobuf:"bytes,2,rep,name=tableNamesS,proto3" json:"tableNamesS,omitempty"`
	TableAttrsT string   `protobuf:"bytes,3,opt,name=tableAttrsT,proto3" json:"tableAttrsT,omitempty"`
	// contains filtered or unexported fields
}

func (*TableAttrsRule) Descriptor deprecated 

func (*TableAttrsRule) Descriptor() ([]byte, []int)

Deprecated: Use TableAttrsRule.ProtoReflect.Descriptor instead.

func (*TableAttrsRule) GetSchemaNameS 

func (x *TableAttrsRule) GetSchemaNameS() string

func (*TableAttrsRule) GetTableAttrsT 

func (x *TableAttrsRule) GetTableAttrsT() string

func (*TableAttrsRule) GetTableNamesS 

func (x *TableAttrsRule) GetTableNamesS() []string

func (*TableAttrsRule) ProtoMessage 

func (*TableAttrsRule) ProtoMessage()

func (*TableAttrsRule) ProtoReflect 

func (x *TableAttrsRule) ProtoReflect() protoreflect.Message

func (*TableAttrsRule) Reset 

func (x *TableAttrsRule) Reset()

func (*TableAttrsRule) String 

func (x *TableAttrsRule) String() string

type TableRouteRule 

type TableRouteRule struct {
	TableNameS       string            `protobuf:"bytes,1,opt,name=tableNameS,proto3" json:"tableNameS,omitempty"`
	TableNameT       string            `protobuf:"bytes,2,opt,name=tableNameT,proto3" json:"tableNameT,omitempty"`
	ColumnRouteRules map[string]string `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TableRouteRule) Descriptor deprecated 

func (*TableRouteRule) Descriptor() ([]byte, []int)

Deprecated: Use TableRouteRule.ProtoReflect.Descriptor instead.

func (*TableRouteRule) GetColumnRouteRules 

func (x *TableRouteRule) GetColumnRouteRules() map[string]string

func (*TableRouteRule) GetTableNameS 

func (x *TableRouteRule) GetTableNameS() string

func (*TableRouteRule) GetTableNameT 

func (x *TableRouteRule) GetTableNameT() string

func (*TableRouteRule) ProtoMessage 

func (*TableRouteRule) ProtoMessage()

func (*TableRouteRule) ProtoReflect 

func (x *TableRouteRule) ProtoReflect() protoreflect.Message

func (*TableRouteRule) Reset 

func (x *TableRouteRule) Reset()

func (*TableRouteRule) String 

func (x *TableRouteRule) String() string

type TableStructRule 

type TableStructRule struct {
	SchemaNameS   string `protobuf:"bytes,1,opt,name=schemaNameS,proto3" json:"schemaNameS,omitempty"`
	TableNameS    string `protobuf:"bytes,2,opt,name=tableNameS,proto3" json:"tableNameS,omitempty"`
	ColumnTypeS   string `protobuf:"bytes,3,opt,name=columnTypeS,proto3" json:"columnTypeS,omitempty"`
	ColumnTypeT   string `protobuf:"bytes,4,opt,name=columnTypeT,proto3" json:"columnTypeT,omitempty"`
	DefaultValueS string `protobuf:"bytes,5,opt,name=defaultValueS,proto3" json:"defaultValueS,omitempty"`
	DefaultValueT string `protobuf:"bytes,6,opt,name=defaultValueT,proto3" json:"defaultValueT,omitempty"`
	// contains filtered or unexported fields
}

func (*TableStructRule) Descriptor deprecated 

func (*TableStructRule) Descriptor() ([]byte, []int)

Deprecated: Use TableStructRule.ProtoReflect.Descriptor instead.

func (*TableStructRule) GetColumnTypeS 

func (x *TableStructRule) GetColumnTypeS() string

func (*TableStructRule) GetColumnTypeT 

func (x *TableStructRule) GetColumnTypeT() string

func (*TableStructRule) GetDefaultValueS 

func (x *TableStructRule) GetDefaultValueS() string

func (*TableStructRule) GetDefaultValueT 

func (x *TableStructRule) GetDefaultValueT() string

func (*TableStructRule) GetSchemaNameS 

func (x *TableStructRule) GetSchemaNameS() string

func (*TableStructRule) GetTableNameS 

func (x *TableStructRule) GetTableNameS() string

func (*TableStructRule) ProtoMessage 

func (*TableStructRule) ProtoMessage()

func (*TableStructRule) ProtoReflect 

func (x *TableStructRule) ProtoReflect() protoreflect.Message

func (*TableStructRule) Reset 

func (x *TableStructRule) Reset()

func (*TableStructRule) String 

func (x *TableStructRule) String() string

type TaskStructRule 

type TaskStructRule struct {
	ColumnTypeS     string `protobuf:"bytes,1,opt,name=columnTypeS,proto3" json:"columnTypeS,omitempty"`
	ColumnTypeT     string `protobuf:"bytes,2,opt,name=columnTypeT,proto3" json:"columnTypeT,omitempty"`
	TableAttrOption string `protobuf:"bytes,3,opt,name=TableAttrOption,proto3" json:"TableAttrOption,omitempty"`
	DefaultValueS   string `protobuf:"bytes,4,opt,name=DefaultValueS,proto3" json:"DefaultValueS,omitempty"`
	DefaultValueT   string `protobuf:"bytes,5,opt,name=DefaultValueT,proto3" json:"DefaultValueT,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStructRule) Descriptor deprecated 

func (*TaskStructRule) Descriptor() ([]byte, []int)

Deprecated: Use TaskStructRule.ProtoReflect.Descriptor instead.

func (*TaskStructRule) GetColumnTypeS 

func (x *TaskStructRule) GetColumnTypeS() string

func (*TaskStructRule) GetColumnTypeT 

func (x *TaskStructRule) GetColumnTypeT() string

func (*TaskStructRule) GetDefaultValueS 

func (x *TaskStructRule) GetDefaultValueS() string

func (*TaskStructRule) GetDefaultValueT 

func (x *TaskStructRule) GetDefaultValueT() string

func (*TaskStructRule) GetTableAttrOption 

func (x *TaskStructRule) GetTableAttrOption() string

func (*TaskStructRule) ProtoMessage 

func (*TaskStructRule) ProtoMessage()

func (*TaskStructRule) ProtoReflect 

func (x *TaskStructRule) ProtoReflect() protoreflect.Message

func (*TaskStructRule) Reset 

func (x *TaskStructRule) Reset()

func (*TaskStructRule) String 

func (x *TaskStructRule) String() string

type UnimplementedMasterServer 

type UnimplementedMasterServer struct{}

UnimplementedMasterServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedMasterServer) DeleteAssessMigrateTask 

func (UnimplementedMasterServer) DeleteAssessMigrateTask(context.Context, *DeleteAssessMigrateTaskRequest) (*DeleteAssessMigrateTaskResponse, error)

func (UnimplementedMasterServer) DeleteCdcConsumeTask added in v0.0.17 

func (UnimplementedMasterServer) DeleteCdcConsumeTask(context.Context, *DeleteCdcConsumeTaskRequest) (*DeleteCdcConsumeTaskResponse, error)

func (UnimplementedMasterServer) DeleteCsvMigrateTask 

func (UnimplementedMasterServer) DeleteCsvMigrateTask(context.Context, *DeleteCsvMigrateTaskRequest) (*DeleteCsvMigrateTaskResponse, error)

func (UnimplementedMasterServer) DeleteDataCompareTask 

func (UnimplementedMasterServer) DeleteDataCompareTask(context.Context, *DeleteDataCompareTaskRequest) (*DeleteDataCompareTaskResponse, error)

func (UnimplementedMasterServer) DeleteDataScanTask 

func (UnimplementedMasterServer) DeleteDataScanTask(context.Context, *DeleteDataScanTaskRequest) (*DeleteDataScanTaskResponse, error)

func (UnimplementedMasterServer) DeleteDatabase 

func (UnimplementedMasterServer) DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*DeleteDatabaseResponse, error)

func (UnimplementedMasterServer) DeleteDatasource 

func (UnimplementedMasterServer) DeleteDatasource(context.Context, *DeleteDatasourceRequest) (*DeleteDatasourceResponse, error)

func (UnimplementedMasterServer) DeleteSqlMigrateTask 

func (UnimplementedMasterServer) DeleteSqlMigrateTask(context.Context, *DeleteSqlMigrateTaskRequest) (*DeleteSqlMigrateTaskResponse, error)

func (UnimplementedMasterServer) DeleteStmtMigrateTask 

func (UnimplementedMasterServer) DeleteStmtMigrateTask(context.Context, *DeleteStmtMigrateTaskRequest) (*DeleteStmtMigrateTaskResponse, error)

func (UnimplementedMasterServer) DeleteStructCompareTask 

func (UnimplementedMasterServer) DeleteStructCompareTask(context.Context, *DeleteStructCompareTaskRequest) (*DeleteStructCompareTaskResponse, error)

func (UnimplementedMasterServer) DeleteStructMigrateTask 

func (UnimplementedMasterServer) DeleteStructMigrateTask(context.Context, *DeleteStructMigrateTaskRequest) (*DeleteStructMigrateTaskResponse, error)

func (UnimplementedMasterServer) OperateTask 

func (UnimplementedMasterServer) OperateTask(context.Context, *OperateTaskRequest) (*OperateTaskResponse, error)

func (UnimplementedMasterServer) ShowAssessMigrateTask 

func (UnimplementedMasterServer) ShowAssessMigrateTask(context.Context, *ShowAssessMigrateTaskRequest) (*ShowAssessMigrateTaskResponse, error)

func (UnimplementedMasterServer) ShowCdcConsumeTask added in v0.0.17 

func (UnimplementedMasterServer) ShowCdcConsumeTask(context.Context, *ShowCdcConsumeTaskRequest) (*ShowCdcConsumeTaskResponse, error)

func (UnimplementedMasterServer) ShowCsvMigrateTask 

func (UnimplementedMasterServer) ShowCsvMigrateTask(context.Context, *ShowCsvMigrateTaskRequest) (*ShowCsvMigrateTaskResponse, error)

func (UnimplementedMasterServer) ShowDataCompareTask 

func (UnimplementedMasterServer) ShowDataCompareTask(context.Context, *ShowDataCompareTaskRequest) (*ShowDataCompareTaskResponse, error)

func (UnimplementedMasterServer) ShowDataScanTask 

func (UnimplementedMasterServer) ShowDataScanTask(context.Context, *ShowDataScanTaskRequest) (*ShowDataScanTaskResponse, error)

func (UnimplementedMasterServer) ShowDatabase 

func (UnimplementedMasterServer) ShowDatabase(context.Context, *ShowDatabaseRequest) (*ShowDatabaseResponse, error)

func (UnimplementedMasterServer) ShowDatasource 

func (UnimplementedMasterServer) ShowDatasource(context.Context, *ShowDatasourceRequest) (*ShowDatasourceResponse, error)

func (UnimplementedMasterServer) ShowSqlMigrateTask 

func (UnimplementedMasterServer) ShowSqlMigrateTask(context.Context, *ShowSqlMigrateTaskRequest) (*ShowSqlMigrateTaskResponse, error)

func (UnimplementedMasterServer) ShowStmtMigrateTask 

func (UnimplementedMasterServer) ShowStmtMigrateTask(context.Context, *ShowStmtMigrateTaskRequest) (*ShowStmtMigrateTaskResponse, error)

func (UnimplementedMasterServer) ShowStructCompareTask 

func (UnimplementedMasterServer) ShowStructCompareTask(context.Context, *ShowStructCompareTaskRequest) (*ShowStructCompareTaskResponse, error)

func (UnimplementedMasterServer) ShowStructMigrateTask 

func (UnimplementedMasterServer) ShowStructMigrateTask(context.Context, *ShowStructMigrateTaskRequest) (*ShowStructMigrateTaskResponse, error)

func (UnimplementedMasterServer) UpsertAssessMigrateTask 

func (UnimplementedMasterServer) UpsertAssessMigrateTask(context.Context, *UpsertAssessMigrateTaskRequest) (*UpsertAssessMigrateTaskResponse, error)

func (UnimplementedMasterServer) UpsertCdcConsumeTask added in v0.0.17 

func (UnimplementedMasterServer) UpsertCdcConsumeTask(context.Context, *UpsertCdcConsumeTaskRequest) (*UpsertCdcConsumeTaskResponse, error)

func (UnimplementedMasterServer) UpsertCsvMigrateTask 

func (UnimplementedMasterServer) UpsertCsvMigrateTask(context.Context, *UpsertCsvMigrateTaskRequest) (*UpsertCsvMigrateTaskResponse, error)

func (UnimplementedMasterServer) UpsertDataCompareTask 

func (UnimplementedMasterServer) UpsertDataCompareTask(context.Context, *UpsertDataCompareTaskRequest) (*UpsertDataCompareTaskResponse, error)

func (UnimplementedMasterServer) UpsertDataScanTask 

func (UnimplementedMasterServer) UpsertDataScanTask(context.Context, *UpsertDataScanTaskRequest) (*UpsertDataScanTaskResponse, error)

func (UnimplementedMasterServer) UpsertDatabase 

func (UnimplementedMasterServer) UpsertDatabase(context.Context, *UpsertDatabaseRequest) (*UpsertDatabaseResponse, error)

func (UnimplementedMasterServer) UpsertDatasource 

func (UnimplementedMasterServer) UpsertDatasource(context.Context, *UpsertDatasourceRequest) (*UpsertDatasourceResponse, error)

func (UnimplementedMasterServer) UpsertSqlMigrateTask 

func (UnimplementedMasterServer) UpsertSqlMigrateTask(context.Context, *UpsertSqlMigrateTaskRequest) (*UpsertSqlMigrateTaskResponse, error)

func (UnimplementedMasterServer) UpsertStmtMigrateTask 

func (UnimplementedMasterServer) UpsertStmtMigrateTask(context.Context, *UpsertStmtMigrateTaskRequest) (*UpsertStmtMigrateTaskResponse, error)

func (UnimplementedMasterServer) UpsertStructCompareTask 

func (UnimplementedMasterServer) UpsertStructCompareTask(context.Context, *UpsertStructCompareTaskRequest) (*UpsertStructCompareTaskResponse, error)

func (UnimplementedMasterServer) UpsertStructMigrateTask 

func (UnimplementedMasterServer) UpsertStructMigrateTask(context.Context, *UpsertStructMigrateTaskRequest) (*UpsertStructMigrateTaskResponse, error)

type UnimplementedWorkerServer 

type UnimplementedWorkerServer struct{}

UnimplementedWorkerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedWorkerServer) OperateWorker 

func (UnimplementedWorkerServer) OperateWorker(context.Context, *OperateWorkerRequest) (*OperateWorkerResponse, error)

type UnsafeMasterServer 

type UnsafeMasterServer interface {
	// contains filtered or unexported methods
}

UnsafeMasterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MasterServer will result in compilation errors.

type UnsafeWorkerServer 

type UnsafeWorkerServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServer will result in compilation errors.

type UpsertAssessMigrateTaskRequest 

type UpsertAssessMigrateTaskRequest struct {
	TaskName           string              `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS    string              `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT    string              `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment            string              `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	AssessMigrateParam *AssessMigrateParam `protobuf:"bytes,5,opt,name=assessMigrateParam,proto3" json:"assessMigrateParam,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertAssessMigrateTaskRequest) Descriptor deprecated 

func (*UpsertAssessMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertAssessMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertAssessMigrateTaskRequest) GetAssessMigrateParam 

func (x *UpsertAssessMigrateTaskRequest) GetAssessMigrateParam() *AssessMigrateParam

func (*UpsertAssessMigrateTaskRequest) GetComment 

func (x *UpsertAssessMigrateTaskRequest) GetComment() string

func (*UpsertAssessMigrateTaskRequest) GetDatasourceNameS 

func (x *UpsertAssessMigrateTaskRequest) GetDatasourceNameS() string

func (*UpsertAssessMigrateTaskRequest) GetDatasourceNameT 

func (x *UpsertAssessMigrateTaskRequest) GetDatasourceNameT() string

func (*UpsertAssessMigrateTaskRequest) GetTaskName 

func (x *UpsertAssessMigrateTaskRequest) GetTaskName() string

func (*UpsertAssessMigrateTaskRequest) ProtoMessage 

func (*UpsertAssessMigrateTaskRequest) ProtoMessage()

func (*UpsertAssessMigrateTaskRequest) ProtoReflect 

func (x *UpsertAssessMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertAssessMigrateTaskRequest) Reset 

func (x *UpsertAssessMigrateTaskRequest) Reset()

func (*UpsertAssessMigrateTaskRequest) String 

func (x *UpsertAssessMigrateTaskRequest) String() string

type UpsertAssessMigrateTaskResponse 

type UpsertAssessMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertAssessMigrateTaskResponse) Descriptor deprecated 

func (*UpsertAssessMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertAssessMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertAssessMigrateTaskResponse) GetResponse 

func (x *UpsertAssessMigrateTaskResponse) GetResponse() *Response

func (*UpsertAssessMigrateTaskResponse) ProtoMessage 

func (*UpsertAssessMigrateTaskResponse) ProtoMessage()

func (*UpsertAssessMigrateTaskResponse) ProtoReflect 

func (x *UpsertAssessMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertAssessMigrateTaskResponse) Reset 

func (x *UpsertAssessMigrateTaskResponse) Reset()

func (*UpsertAssessMigrateTaskResponse) String 

func (x *UpsertAssessMigrateTaskResponse) String() string

type UpsertCdcConsumeTaskRequest added in v0.0.17 

type UpsertCdcConsumeTaskRequest struct {
	TaskName        string           `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS string           `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT string           `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment         string           `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CaseFieldRule   *CaseFieldRule   `protobuf:"bytes,5,opt,name=caseFieldRule,proto3" json:"caseFieldRule,omitempty"`
	SchemaRouteRule *SchemaRouteRule `protobuf:"bytes,6,opt,name=schemaRouteRule,proto3" json:"schemaRouteRule,omitempty"`
	CdcConsumeParam *CdcConsumeParam `protobuf:"bytes,7,opt,name=cdcConsumeParam,proto3" json:"cdcConsumeParam,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertCdcConsumeTaskRequest) Descriptor deprecated added in v0.0.17 

func (*UpsertCdcConsumeTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertCdcConsumeTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertCdcConsumeTaskRequest) GetCaseFieldRule added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) GetCaseFieldRule() *CaseFieldRule

func (*UpsertCdcConsumeTaskRequest) GetCdcConsumeParam added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) GetCdcConsumeParam() *CdcConsumeParam

func (*UpsertCdcConsumeTaskRequest) GetComment added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) GetComment() string

func (*UpsertCdcConsumeTaskRequest) GetDatasourceNameS added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) GetDatasourceNameS() string

func (*UpsertCdcConsumeTaskRequest) GetDatasourceNameT added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) GetDatasourceNameT() string

func (*UpsertCdcConsumeTaskRequest) GetSchemaRouteRule added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

func (*UpsertCdcConsumeTaskRequest) GetTaskName added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) GetTaskName() string

func (*UpsertCdcConsumeTaskRequest) ProtoMessage added in v0.0.17 

func (*UpsertCdcConsumeTaskRequest) ProtoMessage()

func (*UpsertCdcConsumeTaskRequest) ProtoReflect added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertCdcConsumeTaskRequest) Reset added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) Reset()

func (*UpsertCdcConsumeTaskRequest) String added in v0.0.17 

func (x *UpsertCdcConsumeTaskRequest) String() string

type UpsertCdcConsumeTaskResponse added in v0.0.17 

type UpsertCdcConsumeTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertCdcConsumeTaskResponse) Descriptor deprecated added in v0.0.17 

func (*UpsertCdcConsumeTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertCdcConsumeTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertCdcConsumeTaskResponse) GetResponse added in v0.0.17 

func (x *UpsertCdcConsumeTaskResponse) GetResponse() *Response

func (*UpsertCdcConsumeTaskResponse) ProtoMessage added in v0.0.17 

func (*UpsertCdcConsumeTaskResponse) ProtoMessage()

func (*UpsertCdcConsumeTaskResponse) ProtoReflect added in v0.0.17 

func (x *UpsertCdcConsumeTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertCdcConsumeTaskResponse) Reset added in v0.0.17 

func (x *UpsertCdcConsumeTaskResponse) Reset()

func (*UpsertCdcConsumeTaskResponse) String added in v0.0.17 

func (x *UpsertCdcConsumeTaskResponse) String() string

type UpsertCsvMigrateTaskRequest 

type UpsertCsvMigrateTaskRequest struct {
	TaskName         string             `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS  string             `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT  string             `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment          string             `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CaseFieldRule    *CaseFieldRule     `protobuf:"bytes,5,opt,name=caseFieldRule,proto3" json:"caseFieldRule,omitempty"`
	SchemaRouteRule  *SchemaRouteRule   `protobuf:"bytes,6,opt,name=schemaRouteRule,proto3" json:"schemaRouteRule,omitempty"`
	DataMigrateRules []*DataMigrateRule `protobuf:"bytes,7,rep,name=DataMigrateRules,proto3" json:"DataMigrateRules,omitempty"`
	CsvMigrateParam  *CsvMigrateParam   `protobuf:"bytes,8,opt,name=CsvMigrateParam,proto3" json:"CsvMigrateParam,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertCsvMigrateTaskRequest) Descriptor deprecated 

func (*UpsertCsvMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertCsvMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertCsvMigrateTaskRequest) GetCaseFieldRule 

func (x *UpsertCsvMigrateTaskRequest) GetCaseFieldRule() *CaseFieldRule

func (*UpsertCsvMigrateTaskRequest) GetComment 

func (x *UpsertCsvMigrateTaskRequest) GetComment() string

func (*UpsertCsvMigrateTaskRequest) GetCsvMigrateParam 

func (x *UpsertCsvMigrateTaskRequest) GetCsvMigrateParam() *CsvMigrateParam

func (*UpsertCsvMigrateTaskRequest) GetDataMigrateRules 

func (x *UpsertCsvMigrateTaskRequest) GetDataMigrateRules() []*DataMigrateRule

func (*UpsertCsvMigrateTaskRequest) GetDatasourceNameS 

func (x *UpsertCsvMigrateTaskRequest) GetDatasourceNameS() string

func (*UpsertCsvMigrateTaskRequest) GetDatasourceNameT 

func (x *UpsertCsvMigrateTaskRequest) GetDatasourceNameT() string

func (*UpsertCsvMigrateTaskRequest) GetSchemaRouteRule 

func (x *UpsertCsvMigrateTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

func (*UpsertCsvMigrateTaskRequest) GetTaskName 

func (x *UpsertCsvMigrateTaskRequest) GetTaskName() string

func (*UpsertCsvMigrateTaskRequest) ProtoMessage 

func (*UpsertCsvMigrateTaskRequest) ProtoMessage()

func (*UpsertCsvMigrateTaskRequest) ProtoReflect 

func (x *UpsertCsvMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertCsvMigrateTaskRequest) Reset 

func (x *UpsertCsvMigrateTaskRequest) Reset()

func (*UpsertCsvMigrateTaskRequest) String 

func (x *UpsertCsvMigrateTaskRequest) String() string

type UpsertCsvMigrateTaskResponse 

type UpsertCsvMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertCsvMigrateTaskResponse) Descriptor deprecated 

func (*UpsertCsvMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertCsvMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertCsvMigrateTaskResponse) GetResponse 

func (x *UpsertCsvMigrateTaskResponse) GetResponse() *Response

func (*UpsertCsvMigrateTaskResponse) ProtoMessage 

func (*UpsertCsvMigrateTaskResponse) ProtoMessage()

func (*UpsertCsvMigrateTaskResponse) ProtoReflect 

func (x *UpsertCsvMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertCsvMigrateTaskResponse) Reset 

func (x *UpsertCsvMigrateTaskResponse) Reset()

func (*UpsertCsvMigrateTaskResponse) String 

func (x *UpsertCsvMigrateTaskResponse) String() string

type UpsertDataCompareTaskRequest 

type UpsertDataCompareTaskRequest struct {
	TaskName         string             `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS  string             `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT  string             `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment          string             `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CaseFieldRule    *CaseFieldRule     `protobuf:"bytes,5,opt,name=caseFieldRule,proto3" json:"caseFieldRule,omitempty"`
	SchemaRouteRule  *SchemaRouteRule   `protobuf:"bytes,6,opt,name=schemaRouteRule,proto3" json:"schemaRouteRule,omitempty"`
	DataCompareRules []*DataCompareRule `protobuf:"bytes,7,rep,name=DataCompareRules,proto3" json:"DataCompareRules,omitempty"`
	DataCompareParam *DataCompareParam  `protobuf:"bytes,8,opt,name=DataCompareParam,proto3" json:"DataCompareParam,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertDataCompareTaskRequest) Descriptor deprecated 

func (*UpsertDataCompareTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertDataCompareTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertDataCompareTaskRequest) GetCaseFieldRule 

func (x *UpsertDataCompareTaskRequest) GetCaseFieldRule() *CaseFieldRule

func (*UpsertDataCompareTaskRequest) GetComment 

func (x *UpsertDataCompareTaskRequest) GetComment() string

func (*UpsertDataCompareTaskRequest) GetDataCompareParam 

func (x *UpsertDataCompareTaskRequest) GetDataCompareParam() *DataCompareParam

func (*UpsertDataCompareTaskRequest) GetDataCompareRules 

func (x *UpsertDataCompareTaskRequest) GetDataCompareRules() []*DataCompareRule

func (*UpsertDataCompareTaskRequest) GetDatasourceNameS 

func (x *UpsertDataCompareTaskRequest) GetDatasourceNameS() string

func (*UpsertDataCompareTaskRequest) GetDatasourceNameT 

func (x *UpsertDataCompareTaskRequest) GetDatasourceNameT() string

func (*UpsertDataCompareTaskRequest) GetSchemaRouteRule 

func (x *UpsertDataCompareTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

func (*UpsertDataCompareTaskRequest) GetTaskName 

func (x *UpsertDataCompareTaskRequest) GetTaskName() string

func (*UpsertDataCompareTaskRequest) ProtoMessage 

func (*UpsertDataCompareTaskRequest) ProtoMessage()

func (*UpsertDataCompareTaskRequest) ProtoReflect 

func (x *UpsertDataCompareTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertDataCompareTaskRequest) Reset 

func (x *UpsertDataCompareTaskRequest) Reset()

func (*UpsertDataCompareTaskRequest) String 

func (x *UpsertDataCompareTaskRequest) String() string

type UpsertDataCompareTaskResponse 

type UpsertDataCompareTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertDataCompareTaskResponse) Descriptor deprecated 

func (*UpsertDataCompareTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertDataCompareTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertDataCompareTaskResponse) GetResponse 

func (x *UpsertDataCompareTaskResponse) GetResponse() *Response

func (*UpsertDataCompareTaskResponse) ProtoMessage 

func (*UpsertDataCompareTaskResponse) ProtoMessage()

func (*UpsertDataCompareTaskResponse) ProtoReflect 

func (x *UpsertDataCompareTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertDataCompareTaskResponse) Reset 

func (x *UpsertDataCompareTaskResponse) Reset()

func (*UpsertDataCompareTaskResponse) String 

func (x *UpsertDataCompareTaskResponse) String() string

type UpsertDataScanTaskRequest 

type UpsertDataScanTaskRequest struct {
	TaskName        string           `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS string           `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT string           `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment         string           `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CaseFieldRule   *CaseFieldRule   `protobuf:"bytes,5,opt,name=caseFieldRule,proto3" json:"caseFieldRule,omitempty"`
	SchemaRouteRule *SchemaRouteRule `protobuf:"bytes,6,opt,name=schemaRouteRule,proto3" json:"schemaRouteRule,omitempty"`
	DataScanRules   []*DataScanRule  `protobuf:"bytes,7,rep,name=DataScanRules,proto3" json:"DataScanRules,omitempty"`
	DataScanParam   *DataScanParam   `protobuf:"bytes,8,opt,name=DataScanParam,proto3" json:"DataScanParam,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertDataScanTaskRequest) Descriptor deprecated 

func (*UpsertDataScanTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertDataScanTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertDataScanTaskRequest) GetCaseFieldRule 

func (x *UpsertDataScanTaskRequest) GetCaseFieldRule() *CaseFieldRule

func (*UpsertDataScanTaskRequest) GetComment 

func (x *UpsertDataScanTaskRequest) GetComment() string

func (*UpsertDataScanTaskRequest) GetDataScanParam 

func (x *UpsertDataScanTaskRequest) GetDataScanParam() *DataScanParam

func (*UpsertDataScanTaskRequest) GetDataScanRules 

func (x *UpsertDataScanTaskRequest) GetDataScanRules() []*DataScanRule

func (*UpsertDataScanTaskRequest) GetDatasourceNameS 

func (x *UpsertDataScanTaskRequest) GetDatasourceNameS() string

func (*UpsertDataScanTaskRequest) GetDatasourceNameT 

func (x *UpsertDataScanTaskRequest) GetDatasourceNameT() string

func (*UpsertDataScanTaskRequest) GetSchemaRouteRule 

func (x *UpsertDataScanTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

func (*UpsertDataScanTaskRequest) GetTaskName 

func (x *UpsertDataScanTaskRequest) GetTaskName() string

func (*UpsertDataScanTaskRequest) ProtoMessage 

func (*UpsertDataScanTaskRequest) ProtoMessage()

func (*UpsertDataScanTaskRequest) ProtoReflect 

func (x *UpsertDataScanTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertDataScanTaskRequest) Reset 

func (x *UpsertDataScanTaskRequest) Reset()

func (*UpsertDataScanTaskRequest) String 

func (x *UpsertDataScanTaskRequest) String() string

type UpsertDataScanTaskResponse 

type UpsertDataScanTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertDataScanTaskResponse) Descriptor deprecated 

func (*UpsertDataScanTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertDataScanTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertDataScanTaskResponse) GetResponse 

func (x *UpsertDataScanTaskResponse) GetResponse() *Response

func (*UpsertDataScanTaskResponse) ProtoMessage 

func (*UpsertDataScanTaskResponse) ProtoMessage()

func (*UpsertDataScanTaskResponse) ProtoReflect 

func (x *UpsertDataScanTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertDataScanTaskResponse) Reset 

func (x *UpsertDataScanTaskResponse) Reset()

func (*UpsertDataScanTaskResponse) String 

func (x *UpsertDataScanTaskResponse) String() string

type UpsertDatabaseRequest 

type UpsertDatabaseRequest struct {
	Database *Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

消息结构体

func (*UpsertDatabaseRequest) Descriptor deprecated 

func (*UpsertDatabaseRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertDatabaseRequest.ProtoReflect.Descriptor instead.

func (*UpsertDatabaseRequest) GetDatabase 

func (x *UpsertDatabaseRequest) GetDatabase() *Database

func (*UpsertDatabaseRequest) ProtoMessage 

func (*UpsertDatabaseRequest) ProtoMessage()

func (*UpsertDatabaseRequest) ProtoReflect 

func (x *UpsertDatabaseRequest) ProtoReflect() protoreflect.Message

func (*UpsertDatabaseRequest) Reset 

func (x *UpsertDatabaseRequest) Reset()

func (*UpsertDatabaseRequest) String 

func (x *UpsertDatabaseRequest) String() string

type UpsertDatabaseResponse 

type UpsertDatabaseResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertDatabaseResponse) Descriptor deprecated 

func (*UpsertDatabaseResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertDatabaseResponse.ProtoReflect.Descriptor instead.

func (*UpsertDatabaseResponse) GetResponse 

func (x *UpsertDatabaseResponse) GetResponse() *Response

func (*UpsertDatabaseResponse) ProtoMessage 

func (*UpsertDatabaseResponse) ProtoMessage()

func (*UpsertDatabaseResponse) ProtoReflect 

func (x *UpsertDatabaseResponse) ProtoReflect() protoreflect.Message

func (*UpsertDatabaseResponse) Reset 

func (x *UpsertDatabaseResponse) Reset()

func (*UpsertDatabaseResponse) String 

func (x *UpsertDatabaseResponse) String() string

type UpsertDatasourceRequest 

type UpsertDatasourceRequest struct {
	Datasource []*Datasource `protobuf:"bytes,1,rep,name=datasource,proto3" json:"datasource,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertDatasourceRequest) Descriptor deprecated 

func (*UpsertDatasourceRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertDatasourceRequest.ProtoReflect.Descriptor instead.

func (*UpsertDatasourceRequest) GetDatasource 

func (x *UpsertDatasourceRequest) GetDatasource() []*Datasource

func (*UpsertDatasourceRequest) ProtoMessage 

func (*UpsertDatasourceRequest) ProtoMessage()

func (*UpsertDatasourceRequest) ProtoReflect 

func (x *UpsertDatasourceRequest) ProtoReflect() protoreflect.Message

func (*UpsertDatasourceRequest) Reset 

func (x *UpsertDatasourceRequest) Reset()

func (*UpsertDatasourceRequest) String 

func (x *UpsertDatasourceRequest) String() string

type UpsertDatasourceResponse 

type UpsertDatasourceResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertDatasourceResponse) Descriptor deprecated 

func (*UpsertDatasourceResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertDatasourceResponse.ProtoReflect.Descriptor instead.

func (*UpsertDatasourceResponse) GetResponse 

func (x *UpsertDatasourceResponse) GetResponse() *Response

func (*UpsertDatasourceResponse) ProtoMessage 

func (*UpsertDatasourceResponse) ProtoMessage()

func (*UpsertDatasourceResponse) ProtoReflect 

func (x *UpsertDatasourceResponse) ProtoReflect() protoreflect.Message

func (*UpsertDatasourceResponse) Reset 

func (x *UpsertDatasourceResponse) Reset()

func (*UpsertDatasourceResponse) String 

func (x *UpsertDatasourceResponse) String() string

type UpsertSqlMigrateTaskRequest 

type UpsertSqlMigrateTaskRequest struct {
	TaskName        string            `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS string            `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT string            `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment         string            `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CaseFieldRule   *CaseFieldRule    `protobuf:"bytes,5,opt,name=caseFieldRule,proto3" json:"caseFieldRule,omitempty"`
	SqlMigrateRules []*SqlMigrateRule `protobuf:"bytes,6,rep,name=SqlMigrateRules,proto3" json:"SqlMigrateRules,omitempty"`
	SqlMigrateParam *SqlMigrateParam  `protobuf:"bytes,7,opt,name=sqlMigrateParam,proto3" json:"sqlMigrateParam,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertSqlMigrateTaskRequest) Descriptor deprecated 

func (*UpsertSqlMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertSqlMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertSqlMigrateTaskRequest) GetCaseFieldRule 

func (x *UpsertSqlMigrateTaskRequest) GetCaseFieldRule() *CaseFieldRule

func (*UpsertSqlMigrateTaskRequest) GetComment 

func (x *UpsertSqlMigrateTaskRequest) GetComment() string

func (*UpsertSqlMigrateTaskRequest) GetDatasourceNameS 

func (x *UpsertSqlMigrateTaskRequest) GetDatasourceNameS() string

func (*UpsertSqlMigrateTaskRequest) GetDatasourceNameT 

func (x *UpsertSqlMigrateTaskRequest) GetDatasourceNameT() string

func (*UpsertSqlMigrateTaskRequest) GetSqlMigrateParam 

func (x *UpsertSqlMigrateTaskRequest) GetSqlMigrateParam() *SqlMigrateParam

func (*UpsertSqlMigrateTaskRequest) GetSqlMigrateRules 

func (x *UpsertSqlMigrateTaskRequest) GetSqlMigrateRules() []*SqlMigrateRule

func (*UpsertSqlMigrateTaskRequest) GetTaskName 

func (x *UpsertSqlMigrateTaskRequest) GetTaskName() string

func (*UpsertSqlMigrateTaskRequest) ProtoMessage 

func (*UpsertSqlMigrateTaskRequest) ProtoMessage()

func (*UpsertSqlMigrateTaskRequest) ProtoReflect 

func (x *UpsertSqlMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertSqlMigrateTaskRequest) Reset 

func (x *UpsertSqlMigrateTaskRequest) Reset()

func (*UpsertSqlMigrateTaskRequest) String 

func (x *UpsertSqlMigrateTaskRequest) String() string

type UpsertSqlMigrateTaskResponse 

type UpsertSqlMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertSqlMigrateTaskResponse) Descriptor deprecated 

func (*UpsertSqlMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertSqlMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertSqlMigrateTaskResponse) GetResponse 

func (x *UpsertSqlMigrateTaskResponse) GetResponse() *Response

func (*UpsertSqlMigrateTaskResponse) ProtoMessage 

func (*UpsertSqlMigrateTaskResponse) ProtoMessage()

func (*UpsertSqlMigrateTaskResponse) ProtoReflect 

func (x *UpsertSqlMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertSqlMigrateTaskResponse) Reset 

func (x *UpsertSqlMigrateTaskResponse) Reset()

func (*UpsertSqlMigrateTaskResponse) String 

func (x *UpsertSqlMigrateTaskResponse) String() string

type UpsertStmtMigrateTaskRequest 

type UpsertStmtMigrateTaskRequest struct {
	TaskName              string                 `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS       string                 `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT       string                 `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment               string                 `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CaseFieldRule         *CaseFieldRule         `protobuf:"bytes,5,opt,name=caseFieldRule,proto3" json:"caseFieldRule,omitempty"`
	SchemaRouteRule       *SchemaRouteRule       `protobuf:"bytes,6,opt,name=schemaRouteRule,proto3" json:"schemaRouteRule,omitempty"`
	DataMigrateRules      []*DataMigrateRule     `protobuf:"bytes,7,rep,name=DataMigrateRules,proto3" json:"DataMigrateRules,omitempty"`
	StatementMigrateParam *StatementMigrateParam `protobuf:"bytes,8,opt,name=statementMigrateParam,proto3" json:"statementMigrateParam,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertStmtMigrateTaskRequest) Descriptor deprecated 

func (*UpsertStmtMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertStmtMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertStmtMigrateTaskRequest) GetCaseFieldRule 

func (x *UpsertStmtMigrateTaskRequest) GetCaseFieldRule() *CaseFieldRule

func (*UpsertStmtMigrateTaskRequest) GetComment 

func (x *UpsertStmtMigrateTaskRequest) GetComment() string

func (*UpsertStmtMigrateTaskRequest) GetDataMigrateRules 

func (x *UpsertStmtMigrateTaskRequest) GetDataMigrateRules() []*DataMigrateRule

func (*UpsertStmtMigrateTaskRequest) GetDatasourceNameS 

func (x *UpsertStmtMigrateTaskRequest) GetDatasourceNameS() string

func (*UpsertStmtMigrateTaskRequest) GetDatasourceNameT 

func (x *UpsertStmtMigrateTaskRequest) GetDatasourceNameT() string

func (*UpsertStmtMigrateTaskRequest) GetSchemaRouteRule 

func (x *UpsertStmtMigrateTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

func (*UpsertStmtMigrateTaskRequest) GetStatementMigrateParam 

func (x *UpsertStmtMigrateTaskRequest) GetStatementMigrateParam() *StatementMigrateParam

func (*UpsertStmtMigrateTaskRequest) GetTaskName 

func (x *UpsertStmtMigrateTaskRequest) GetTaskName() string

func (*UpsertStmtMigrateTaskRequest) ProtoMessage 

func (*UpsertStmtMigrateTaskRequest) ProtoMessage()

func (*UpsertStmtMigrateTaskRequest) ProtoReflect 

func (x *UpsertStmtMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertStmtMigrateTaskRequest) Reset 

func (x *UpsertStmtMigrateTaskRequest) Reset()

func (*UpsertStmtMigrateTaskRequest) String 

func (x *UpsertStmtMigrateTaskRequest) String() string

type UpsertStmtMigrateTaskResponse 

type UpsertStmtMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertStmtMigrateTaskResponse) Descriptor deprecated 

func (*UpsertStmtMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertStmtMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertStmtMigrateTaskResponse) GetResponse 

func (x *UpsertStmtMigrateTaskResponse) GetResponse() *Response

func (*UpsertStmtMigrateTaskResponse) ProtoMessage 

func (*UpsertStmtMigrateTaskResponse) ProtoMessage()

func (*UpsertStmtMigrateTaskResponse) ProtoReflect 

func (x *UpsertStmtMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertStmtMigrateTaskResponse) Reset 

func (x *UpsertStmtMigrateTaskResponse) Reset()

func (*UpsertStmtMigrateTaskResponse) String 

func (x *UpsertStmtMigrateTaskResponse) String() string

type UpsertStructCompareTaskRequest 

type UpsertStructCompareTaskRequest struct {
	TaskName           string              `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS    string              `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT    string              `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment            string              `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CaseFieldRule      *CaseFieldRule      `protobuf:"bytes,5,opt,name=caseFieldRule,proto3" json:"caseFieldRule,omitempty"`
	SchemaRouteRule    *SchemaRouteRule    `protobuf:"bytes,6,opt,name=schemaRouteRule,proto3" json:"schemaRouteRule,omitempty"`
	StructCompareParam *StructCompareParam `protobuf:"bytes,7,opt,name=structCompareParam,proto3" json:"structCompareParam,omitempty"`
	StructCompareRule  *StructCompareRule  `protobuf:"bytes,8,opt,name=structCompareRule,proto3" json:"structCompareRule,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertStructCompareTaskRequest) Descriptor deprecated 

func (*UpsertStructCompareTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertStructCompareTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertStructCompareTaskRequest) GetCaseFieldRule 

func (x *UpsertStructCompareTaskRequest) GetCaseFieldRule() *CaseFieldRule

func (*UpsertStructCompareTaskRequest) GetComment 

func (x *UpsertStructCompareTaskRequest) GetComment() string

func (*UpsertStructCompareTaskRequest) GetDatasourceNameS 

func (x *UpsertStructCompareTaskRequest) GetDatasourceNameS() string

func (*UpsertStructCompareTaskRequest) GetDatasourceNameT 

func (x *UpsertStructCompareTaskRequest) GetDatasourceNameT() string

func (*UpsertStructCompareTaskRequest) GetSchemaRouteRule 

func (x *UpsertStructCompareTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

func (*UpsertStructCompareTaskRequest) GetStructCompareParam 

func (x *UpsertStructCompareTaskRequest) GetStructCompareParam() *StructCompareParam

func (*UpsertStructCompareTaskRequest) GetStructCompareRule 

func (x *UpsertStructCompareTaskRequest) GetStructCompareRule() *StructCompareRule

func (*UpsertStructCompareTaskRequest) GetTaskName 

func (x *UpsertStructCompareTaskRequest) GetTaskName() string

func (*UpsertStructCompareTaskRequest) ProtoMessage 

func (*UpsertStructCompareTaskRequest) ProtoMessage()

func (*UpsertStructCompareTaskRequest) ProtoReflect 

func (x *UpsertStructCompareTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertStructCompareTaskRequest) Reset 

func (x *UpsertStructCompareTaskRequest) Reset()

func (*UpsertStructCompareTaskRequest) String 

func (x *UpsertStructCompareTaskRequest) String() string

type UpsertStructCompareTaskResponse 

type UpsertStructCompareTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertStructCompareTaskResponse) Descriptor deprecated 

func (*UpsertStructCompareTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertStructCompareTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertStructCompareTaskResponse) GetResponse 

func (x *UpsertStructCompareTaskResponse) GetResponse() *Response

func (*UpsertStructCompareTaskResponse) ProtoMessage 

func (*UpsertStructCompareTaskResponse) ProtoMessage()

func (*UpsertStructCompareTaskResponse) ProtoReflect 

func (x *UpsertStructCompareTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertStructCompareTaskResponse) Reset 

func (x *UpsertStructCompareTaskResponse) Reset()

func (*UpsertStructCompareTaskResponse) String 

func (x *UpsertStructCompareTaskResponse) String() string

type UpsertStructMigrateTaskRequest 

type UpsertStructMigrateTaskRequest struct {
	TaskName           string              `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	DatasourceNameS    string              `protobuf:"bytes,2,opt,name=datasourceNameS,proto3" json:"datasourceNameS,omitempty"`
	DatasourceNameT    string              `protobuf:"bytes,3,opt,name=datasourceNameT,proto3" json:"datasourceNameT,omitempty"`
	Comment            string              `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CaseFieldRule      *CaseFieldRule      `protobuf:"bytes,5,opt,name=caseFieldRule,proto3" json:"caseFieldRule,omitempty"`
	SchemaRouteRule    *SchemaRouteRule    `protobuf:"bytes,6,opt,name=schemaRouteRule,proto3" json:"schemaRouteRule,omitempty"`
	StructMigrateParam *StructMigrateParam `protobuf:"bytes,7,opt,name=structMigrateParam,proto3" json:"structMigrateParam,omitempty"`
	StructMigrateRule  *StructMigrateRule  `protobuf:"bytes,8,opt,name=structMigrateRule,proto3" json:"structMigrateRule,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertStructMigrateTaskRequest) Descriptor deprecated 

func (*UpsertStructMigrateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertStructMigrateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertStructMigrateTaskRequest) GetCaseFieldRule 

func (x *UpsertStructMigrateTaskRequest) GetCaseFieldRule() *CaseFieldRule

func (*UpsertStructMigrateTaskRequest) GetComment 

func (x *UpsertStructMigrateTaskRequest) GetComment() string

func (*UpsertStructMigrateTaskRequest) GetDatasourceNameS 

func (x *UpsertStructMigrateTaskRequest) GetDatasourceNameS() string

func (*UpsertStructMigrateTaskRequest) GetDatasourceNameT 

func (x *UpsertStructMigrateTaskRequest) GetDatasourceNameT() string

func (*UpsertStructMigrateTaskRequest) GetSchemaRouteRule 

func (x *UpsertStructMigrateTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

func (*UpsertStructMigrateTaskRequest) GetStructMigrateParam 

func (x *UpsertStructMigrateTaskRequest) GetStructMigrateParam() *StructMigrateParam

func (*UpsertStructMigrateTaskRequest) GetStructMigrateRule 

func (x *UpsertStructMigrateTaskRequest) GetStructMigrateRule() *StructMigrateRule

func (*UpsertStructMigrateTaskRequest) GetTaskName 

func (x *UpsertStructMigrateTaskRequest) GetTaskName() string

func (*UpsertStructMigrateTaskRequest) ProtoMessage 

func (*UpsertStructMigrateTaskRequest) ProtoMessage()

func (*UpsertStructMigrateTaskRequest) ProtoReflect 

func (x *UpsertStructMigrateTaskRequest) ProtoReflect() protoreflect.Message

func (*UpsertStructMigrateTaskRequest) Reset 

func (x *UpsertStructMigrateTaskRequest) Reset()

func (*UpsertStructMigrateTaskRequest) String 

func (x *UpsertStructMigrateTaskRequest) String() string

type UpsertStructMigrateTaskResponse 

type UpsertStructMigrateTaskResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertStructMigrateTaskResponse) Descriptor deprecated 

func (*UpsertStructMigrateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertStructMigrateTaskResponse.ProtoReflect.Descriptor instead.

func (*UpsertStructMigrateTaskResponse) GetResponse 

func (x *UpsertStructMigrateTaskResponse) GetResponse() *Response

func (*UpsertStructMigrateTaskResponse) ProtoMessage 

func (*UpsertStructMigrateTaskResponse) ProtoMessage()

func (*UpsertStructMigrateTaskResponse) ProtoReflect 

func (x *UpsertStructMigrateTaskResponse) ProtoReflect() protoreflect.Message

func (*UpsertStructMigrateTaskResponse) Reset 

func (x *UpsertStructMigrateTaskResponse) Reset()

func (*UpsertStructMigrateTaskResponse) String 

func (x *UpsertStructMigrateTaskResponse) String() string

type WorkerClient 

type WorkerClient interface {
	OperateWorker(ctx context.Context, in *OperateWorkerRequest, opts ...grpc.CallOption) (*OperateWorkerResponse, error)
}

WorkerClient is the client API for Worker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWorkerClient 

func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient

type WorkerServer 

type WorkerServer interface {
	OperateWorker(context.Context, *OperateWorkerRequest) (*OperateWorkerResponse, error)
	// contains filtered or unexported methods
}

WorkerServer is the server API for Worker service. All implementations must embed UnimplementedWorkerServer for forward compatibility.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.