pb

package

Go to main page

Versions in this module

v0

v0.0.18

Dec 18, 2024

v0.0.17

Dec 16, 2024

Changes in this version

+ const Master_DeleteCdcConsumeTask_FullMethodName

+ const Master_ShowCdcConsumeTask_FullMethodName

+ const Master_UpsertCdcConsumeTask_FullMethodName

+ type CdcConsumeParam struct

+ CallTimeout uint64

+ EnableCheckpoint bool

+ IdleResolvedThreshold uint64

+ MessageCompression string

+ ServerAddress []string

+ SubscribeTopic string

+ TableThread uint64

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

+ func (*CdcConsumeParam) ProtoMessage()

+ func (x *CdcConsumeParam) GetCallTimeout() uint64

+ func (x *CdcConsumeParam) GetEnableCheckpoint() bool

+ func (x *CdcConsumeParam) GetIdleResolvedThreshold() uint64

+ func (x *CdcConsumeParam) GetMessageCompression() string

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

+ func (x *CdcConsumeParam) GetSubscribeTopic() string

+ func (x *CdcConsumeParam) GetTableThread() uint64

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

+ func (x *CdcConsumeParam) Reset()

+ func (x *CdcConsumeParam) String() string

+ type DeleteCdcConsumeTaskRequest struct

+ TaskName []string

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

+ func (*DeleteCdcConsumeTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteCdcConsumeTaskRequest) Reset()

+ func (x *DeleteCdcConsumeTaskRequest) String() string

+ type DeleteCdcConsumeTaskResponse struct

+ Response *Response

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

+ func (*DeleteCdcConsumeTaskResponse) ProtoMessage()

+ func (x *DeleteCdcConsumeTaskResponse) GetResponse() *Response

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

+ func (x *DeleteCdcConsumeTaskResponse) Reset()

+ func (x *DeleteCdcConsumeTaskResponse) String() string

type MasterClient

+ DeleteCdcConsumeTask func(ctx context.Context, in *DeleteCdcConsumeTaskRequest, opts ...grpc.CallOption) (*DeleteCdcConsumeTaskResponse, error)

+ ShowCdcConsumeTask func(ctx context.Context, in *ShowCdcConsumeTaskRequest, opts ...grpc.CallOption) (*ShowCdcConsumeTaskResponse, error)

+ UpsertCdcConsumeTask func(ctx context.Context, in *UpsertCdcConsumeTaskRequest, opts ...grpc.CallOption) (*UpsertCdcConsumeTaskResponse, error)

type MasterServer

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

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

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

+ type ShowCdcConsumeTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowCdcConsumeTaskRequest) ProtoMessage()

+ func (x *ShowCdcConsumeTaskRequest) GetPage() uint64

+ func (x *ShowCdcConsumeTaskRequest) GetPageSize() uint64

+ func (x *ShowCdcConsumeTaskRequest) GetTaskName() string

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

+ func (x *ShowCdcConsumeTaskRequest) Reset()

+ func (x *ShowCdcConsumeTaskRequest) String() string

+ type ShowCdcConsumeTaskResponse struct

+ Response *Response

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

+ func (*ShowCdcConsumeTaskResponse) ProtoMessage()

+ func (x *ShowCdcConsumeTaskResponse) GetResponse() *Response

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

+ func (x *ShowCdcConsumeTaskResponse) Reset()

+ func (x *ShowCdcConsumeTaskResponse) String() string

type UnimplementedMasterServer

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

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

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

+ type UpsertCdcConsumeTaskRequest struct

+ CaseFieldRule *CaseFieldRule

+ CdcConsumeParam *CdcConsumeParam

+ Comment string

+ DatasourceNameS string

+ DatasourceNameT string

+ SchemaRouteRule *SchemaRouteRule

+ TaskName string

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

+ func (*UpsertCdcConsumeTaskRequest) ProtoMessage()

+ func (x *UpsertCdcConsumeTaskRequest) GetCaseFieldRule() *CaseFieldRule

+ func (x *UpsertCdcConsumeTaskRequest) GetCdcConsumeParam() *CdcConsumeParam

+ func (x *UpsertCdcConsumeTaskRequest) GetComment() string

+ func (x *UpsertCdcConsumeTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertCdcConsumeTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertCdcConsumeTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

+ func (x *UpsertCdcConsumeTaskRequest) GetTaskName() string

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

+ func (x *UpsertCdcConsumeTaskRequest) Reset()

+ func (x *UpsertCdcConsumeTaskRequest) String() string

+ type UpsertCdcConsumeTaskResponse struct

+ Response *Response

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

+ func (*UpsertCdcConsumeTaskResponse) ProtoMessage()

+ func (x *UpsertCdcConsumeTaskResponse) GetResponse() *Response

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

+ func (x *UpsertCdcConsumeTaskResponse) Reset()

+ func (x *UpsertCdcConsumeTaskResponse) String() string

v0.0.16

Nov 12, 2024

Changes in this version

type OperateTaskRequest

+ HostIP string

+ func (x *OperateTaskRequest) GetHostIP() string

v0.0.15

Oct 25, 2024

Changes in this version

type SqlMigrateParam

+ EnablePrepareStmt bool

+ func (x *SqlMigrateParam) GetEnablePrepareStmt() bool

type StatementMigrateParam

+ EnablePrepareStmt bool

+ func (x *StatementMigrateParam) GetEnablePrepareStmt() bool

v0.0.14

Sep 23, 2024

Changes in this version

type CsvMigrateParam

+ CsvImportParams map[string]string

+ EnableImportFeature bool

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

+ func (x *CsvMigrateParam) GetEnableImportFeature() bool

v0.0.13

Sep 6, 2024

Changes in this version

type DataCompareParam

+ Separator string

+ func (x *DataCompareParam) GetSeparator() string

v0.0.12

Aug 26, 2024

v0.0.11

Aug 24, 2024

v0.0.10

Aug 23, 2024

v0.0.9

Aug 22, 2024

Changes in this version

type CsvMigrateParam

+ WriteThread uint64

+ func (x *CsvMigrateParam) GetWriteThread() uint64

type DataCompareRule

+ CompareConditionRangeS string

+ CompareConditionRangeT string

+ func (x *DataCompareRule) GetCompareConditionRangeS() string

+ func (x *DataCompareRule) GetCompareConditionRangeT() string

type DataScanParam

+ WriteThread uint64

+ func (x *DataScanParam) GetWriteThread() uint64

type SchemaRouteRule

+ ExcludeSequenceS []string

+ IncludeSequenceS []string

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

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

type SqlMigrateParam

+ EnableCheckpoint bool

+ WriteThread uint64

+ func (x *SqlMigrateParam) GetEnableCheckpoint() bool

+ func (x *SqlMigrateParam) GetWriteThread() uint64

type StatementMigrateParam

+ WriteThread uint64

+ func (x *StatementMigrateParam) GetWriteThread() uint64

type StructCompareParam

+ IgnoreCaseCompare bool

+ func (x *StructCompareParam) GetIgnoreCaseCompare() bool

v0.0.8

Aug 8, 2024

Changes in this version

type AssessMigrateParam

+ CallTimeout uint64

+ func (x *AssessMigrateParam) GetCallTimeout() uint64

type DataCompareParam

+ DisableMd5Checksum bool

+ func (x *DataCompareParam) GetDisableMd5Checksum() bool

type DataCompareRule

+ SqlHintS string

+ SqlHintT string

+ func (x *DataCompareRule) GetSqlHintS() string

+ func (x *DataCompareRule) GetSqlHintT() string

type StructCompareParam

+ CallTimeout uint64

+ func (x *StructCompareParam) GetCallTimeout() uint64

type StructMigrateParam

+ CallTimeout uint64

+ func (x *StructMigrateParam) GetCallTimeout() uint64

v0.0.7

Jul 24, 2024

Changes in this version

type DataCompareParam

+ ChunkSize uint64

+ EnableCollationSetting bool

+ IgnoreConditionFields []string

+ RepairStmtFlow string

+ func (x *DataCompareParam) GetChunkSize() uint64

+ func (x *DataCompareParam) GetEnableCollationSetting() bool

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

+ func (x *DataCompareParam) GetRepairStmtFlow() string

type DataCompareRule

+ CompareConditionField string

+ CompareConditionRange string

+ IgnoreConditionFields []string

+ IgnoreSelectFields []string

+ func (x *DataCompareRule) GetCompareConditionField() string

+ func (x *DataCompareRule) GetCompareConditionRange() string

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

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

type Datasource

+ DbName string

+ SessionParams string

+ func (x *Datasource) GetDbName() string

+ func (x *Datasource) GetSessionParams() string

v0.0.6

Jul 8, 2024

Changes in this version

type DataCompareParam

+ WriteThread uint64

+ func (x *DataCompareParam) GetWriteThread() uint64

type Database

+ InitThread uint64

+ func (x *Database) GetInitThread() uint64

v0.0.5

Jun 26, 2024

v0.0.4

Jun 25, 2024

Changes in this version

type DataCompareParam

+ ConsistentReadPointS string

+ ConsistentReadPointT string

+ func (x *DataCompareParam) GetConsistentReadPointS() string

+ func (x *DataCompareParam) GetConsistentReadPointT() string

type SqlMigrateParam

+ EnableSafeMode bool

+ func (x *SqlMigrateParam) GetEnableSafeMode() bool

type StatementMigrateParam

+ EnableSafeMode bool

+ func (x *StatementMigrateParam) GetEnableSafeMode() bool

v0.0.3

Jun 21, 2024

v0.0.2

Jun 18, 2024

v0.0.1

Jun 15, 2024

Changes in this version

type StructMigrateParam

+ EnableCheckpoint bool

+ func (x *StructMigrateParam) GetEnableCheckpoint() bool

v0.0.0

Jun 8, 2024

Changes in this version

+ const Master_DeleteAssessMigrateTask_FullMethodName

+ const Master_DeleteCsvMigrateTask_FullMethodName

+ const Master_DeleteDataCompareTask_FullMethodName

+ const Master_DeleteDataScanTask_FullMethodName

+ const Master_DeleteDatabase_FullMethodName

+ const Master_DeleteDatasource_FullMethodName

+ const Master_DeleteSqlMigrateTask_FullMethodName

+ const Master_DeleteStmtMigrateTask_FullMethodName

+ const Master_DeleteStructCompareTask_FullMethodName

+ const Master_DeleteStructMigrateTask_FullMethodName

+ const Master_OperateTask_FullMethodName

+ const Master_ShowAssessMigrateTask_FullMethodName

+ const Master_ShowCsvMigrateTask_FullMethodName

+ const Master_ShowDataCompareTask_FullMethodName

+ const Master_ShowDataScanTask_FullMethodName

+ const Master_ShowDatabase_FullMethodName

+ const Master_ShowDatasource_FullMethodName

+ const Master_ShowSqlMigrateTask_FullMethodName

+ const Master_ShowStmtMigrateTask_FullMethodName

+ const Master_ShowStructCompareTask_FullMethodName

+ const Master_ShowStructMigrateTask_FullMethodName

+ const Master_UpsertAssessMigrateTask_FullMethodName

+ const Master_UpsertCsvMigrateTask_FullMethodName

+ const Master_UpsertDataCompareTask_FullMethodName

+ const Master_UpsertDataScanTask_FullMethodName

+ const Master_UpsertDatabase_FullMethodName

+ const Master_UpsertDatasource_FullMethodName

+ const Master_UpsertSqlMigrateTask_FullMethodName

+ const Master_UpsertStmtMigrateTask_FullMethodName

+ const Master_UpsertStructCompareTask_FullMethodName

+ const Master_UpsertStructMigrateTask_FullMethodName

+ const Worker_OperateWorker_FullMethodName

+ var File_dbms_master_proto protoreflect.FileDescriptor

+ var File_dbms_worker_proto protoreflect.FileDescriptor

+ var File_response_proto protoreflect.FileDescriptor

+ var Master_ServiceDesc = grpc.ServiceDesc

+ var Worker_ServiceDesc = grpc.ServiceDesc

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

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

+ func RegisterMasterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)

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

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

+ func RegisterWorkerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)

+ type AssessMigrateParam struct

+ CaseFieldRuleS string

+ SchemaNameS string

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

+ func (*AssessMigrateParam) ProtoMessage()

+ func (x *AssessMigrateParam) GetCaseFieldRuleS() string

+ func (x *AssessMigrateParam) GetSchemaNameS() string

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

+ func (x *AssessMigrateParam) Reset()

+ func (x *AssessMigrateParam) String() string

+ type CaseFieldRule struct

+ CaseFieldRuleS string

+ CaseFieldRuleT string

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

+ func (*CaseFieldRule) ProtoMessage()

+ func (x *CaseFieldRule) GetCaseFieldRuleS() string

+ func (x *CaseFieldRule) GetCaseFieldRuleT() string

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

+ func (x *CaseFieldRule) Reset()

+ func (x *CaseFieldRule) String() string

+ type ColumnStructRule struct

+ ColumnNameS string

+ ColumnTypeS string

+ ColumnTypeT string

+ DefaultValueS string

+ DefaultValueT string

+ SchemaNameS string

+ TableNameS string

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

+ func (*ColumnStructRule) ProtoMessage()

+ func (x *ColumnStructRule) GetColumnNameS() string

+ func (x *ColumnStructRule) GetColumnTypeS() string

+ func (x *ColumnStructRule) GetColumnTypeT() string

+ func (x *ColumnStructRule) GetDefaultValueS() string

+ func (x *ColumnStructRule) GetDefaultValueT() string

+ func (x *ColumnStructRule) GetSchemaNameS() string

+ func (x *ColumnStructRule) GetTableNameS() string

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

+ func (x *ColumnStructRule) Reset()

+ func (x *ColumnStructRule) String() string

+ type CsvMigrateParam struct

+ BatchSize uint64

+ CallTimeout uint64

+ ChunkSize uint64

+ DataCharsetT string

+ Delimiter string

+ DiskUsageFactor string

+ EnableCheckpoint bool

+ EnableConsistentRead bool

+ EscapeBackslash bool

+ Header bool

+ NullValue string

+ OutputDir string

+ Separator string

+ SqlHintS string

+ SqlThreadS uint64

+ TableThread uint64

+ Terminator string

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

+ func (*CsvMigrateParam) ProtoMessage()

+ func (x *CsvMigrateParam) GetBatchSize() uint64

+ func (x *CsvMigrateParam) GetCallTimeout() uint64

+ func (x *CsvMigrateParam) GetChunkSize() uint64

+ func (x *CsvMigrateParam) GetDataCharsetT() string

+ func (x *CsvMigrateParam) GetDelimiter() string

+ func (x *CsvMigrateParam) GetDiskUsageFactor() string

+ func (x *CsvMigrateParam) GetEnableCheckpoint() bool

+ func (x *CsvMigrateParam) GetEnableConsistentRead() bool

+ func (x *CsvMigrateParam) GetEscapeBackslash() bool

+ func (x *CsvMigrateParam) GetHeader() bool

+ func (x *CsvMigrateParam) GetNullValue() string

+ func (x *CsvMigrateParam) GetOutputDir() string

+ func (x *CsvMigrateParam) GetSeparator() string

+ func (x *CsvMigrateParam) GetSqlHintS() string

+ func (x *CsvMigrateParam) GetSqlThreadS() uint64

+ func (x *CsvMigrateParam) GetTableThread() uint64

+ func (x *CsvMigrateParam) GetTerminator() string

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

+ func (x *CsvMigrateParam) Reset()

+ func (x *CsvMigrateParam) String() string

+ type DataCompareParam struct

+ BatchSize uint64

+ CallTimeout uint64

+ EnableCheckpoint bool

+ EnableConsistentRead bool

+ OnlyCompareRow bool

+ SqlHintS string

+ SqlHintT string

+ SqlThread uint64

+ TableThread uint64

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

+ func (*DataCompareParam) ProtoMessage()

+ func (x *DataCompareParam) GetBatchSize() uint64

+ func (x *DataCompareParam) GetCallTimeout() uint64

+ func (x *DataCompareParam) GetEnableCheckpoint() bool

+ func (x *DataCompareParam) GetEnableConsistentRead() bool

+ func (x *DataCompareParam) GetOnlyCompareRow() bool

+ func (x *DataCompareParam) GetSqlHintS() string

+ func (x *DataCompareParam) GetSqlHintT() string

+ func (x *DataCompareParam) GetSqlThread() uint64

+ func (x *DataCompareParam) GetTableThread() uint64

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

+ func (x *DataCompareParam) Reset()

+ func (x *DataCompareParam) String() string

+ type DataCompareRule struct

+ CompareField string

+ CompareRange string

+ IgnoreFields []string

+ TableNameS string

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

+ func (*DataCompareRule) ProtoMessage()

+ func (x *DataCompareRule) GetCompareField() string

+ func (x *DataCompareRule) GetCompareRange() string

+ func (x *DataCompareRule) GetIgnoreFields() []string

+ func (x *DataCompareRule) GetTableNameS() string

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

+ func (x *DataCompareRule) Reset()

+ func (x *DataCompareRule) String() string

+ type DataMigrateRule struct

+ EnableChunkStrategy bool

+ SqlHintS string

+ TableNameS string

+ WhereRange string

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

+ func (*DataMigrateRule) ProtoMessage()

+ func (x *DataMigrateRule) GetEnableChunkStrategy() bool

+ func (x *DataMigrateRule) GetSqlHintS() string

+ func (x *DataMigrateRule) GetTableNameS() string

+ func (x *DataMigrateRule) GetWhereRange() string

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

+ func (x *DataMigrateRule) Reset()

+ func (x *DataMigrateRule) String() string

+ type DataScanParam struct

+ BatchSize uint64

+ CallTimeout uint64

+ ChunkSize uint64

+ EnableCheckpoint bool

+ EnableConsistentRead bool

+ SqlHintS string

+ SqlThreadS uint64

+ TableSamplerateS uint64

+ TableThread uint64

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

+ func (*DataScanParam) ProtoMessage()

+ func (x *DataScanParam) GetBatchSize() uint64

+ func (x *DataScanParam) GetCallTimeout() uint64

+ func (x *DataScanParam) GetChunkSize() uint64

+ func (x *DataScanParam) GetEnableCheckpoint() bool

+ func (x *DataScanParam) GetEnableConsistentRead() bool

+ func (x *DataScanParam) GetSqlHintS() string

+ func (x *DataScanParam) GetSqlThreadS() uint64

+ func (x *DataScanParam) GetTableSamplerateS() uint64

+ func (x *DataScanParam) GetTableThread() uint64

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

+ func (x *DataScanParam) Reset()

+ func (x *DataScanParam) String() string

+ type DataScanRule struct

+ SqlHintS string

+ TableNameS string

+ TableSamplerateS uint64

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

+ func (*DataScanRule) ProtoMessage()

+ func (x *DataScanRule) GetSqlHintS() string

+ func (x *DataScanRule) GetTableNameS() string

+ func (x *DataScanRule) GetTableSamplerateS() uint64

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

+ func (x *DataScanRule) Reset()

+ func (x *DataScanRule) String() string

+ type Database struct

+ Host string

+ Password string

+ Port uint64

+ Schema string

+ SlowThreshold uint64

+ Username string

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

+ func (*Database) ProtoMessage()

+ func (x *Database) GetHost() string

+ func (x *Database) GetPassword() string

+ func (x *Database) GetPort() uint64

+ func (x *Database) GetSchema() string

+ func (x *Database) GetSlowThreshold() uint64

+ func (x *Database) GetUsername() string

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

+ func (x *Database) Reset()

+ func (x *Database) String() string

+ type Datasource struct

+ Comment string

+ ConnectCharset string

+ ConnectParams string

+ ConnectStatus string

+ DatasourceName string

+ DbType string

+ Host string

+ Password string

+ PdbName string

+ Port uint64

+ ServiceName string

+ Username string

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

+ func (*Datasource) ProtoMessage()

+ func (x *Datasource) GetComment() string

+ func (x *Datasource) GetConnectCharset() string

+ func (x *Datasource) GetConnectParams() string

+ func (x *Datasource) GetConnectStatus() string

+ func (x *Datasource) GetDatasourceName() string

+ func (x *Datasource) GetDbType() string

+ func (x *Datasource) GetHost() string

+ func (x *Datasource) GetPassword() string

+ func (x *Datasource) GetPdbName() string

+ func (x *Datasource) GetPort() uint64

+ func (x *Datasource) GetServiceName() string

+ func (x *Datasource) GetUsername() string

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

+ func (x *Datasource) Reset()

+ func (x *Datasource) String() string

+ type DeleteAssessMigrateTaskRequest struct

+ TaskName []string

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

+ func (*DeleteAssessMigrateTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteAssessMigrateTaskRequest) Reset()

+ func (x *DeleteAssessMigrateTaskRequest) String() string

+ type DeleteAssessMigrateTaskResponse struct

+ Response *Response

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

+ func (*DeleteAssessMigrateTaskResponse) ProtoMessage()

+ func (x *DeleteAssessMigrateTaskResponse) GetResponse() *Response

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

+ func (x *DeleteAssessMigrateTaskResponse) Reset()

+ func (x *DeleteAssessMigrateTaskResponse) String() string

+ type DeleteCsvMigrateTaskRequest struct

+ TaskName []string

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

+ func (*DeleteCsvMigrateTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteCsvMigrateTaskRequest) Reset()

+ func (x *DeleteCsvMigrateTaskRequest) String() string

+ type DeleteCsvMigrateTaskResponse struct

+ Response *Response

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

+ func (*DeleteCsvMigrateTaskResponse) ProtoMessage()

+ func (x *DeleteCsvMigrateTaskResponse) GetResponse() *Response

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

+ func (x *DeleteCsvMigrateTaskResponse) Reset()

+ func (x *DeleteCsvMigrateTaskResponse) String() string

+ type DeleteDataCompareTaskRequest struct

+ TaskName []string

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

+ func (*DeleteDataCompareTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteDataCompareTaskRequest) Reset()

+ func (x *DeleteDataCompareTaskRequest) String() string

+ type DeleteDataCompareTaskResponse struct

+ Response *Response

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

+ func (*DeleteDataCompareTaskResponse) ProtoMessage()

+ func (x *DeleteDataCompareTaskResponse) GetResponse() *Response

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

+ func (x *DeleteDataCompareTaskResponse) Reset()

+ func (x *DeleteDataCompareTaskResponse) String() string

+ type DeleteDataScanTaskRequest struct

+ TaskName []string

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

+ func (*DeleteDataScanTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteDataScanTaskRequest) Reset()

+ func (x *DeleteDataScanTaskRequest) String() string

+ type DeleteDataScanTaskResponse struct

+ Response *Response

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

+ func (*DeleteDataScanTaskResponse) ProtoMessage()

+ func (x *DeleteDataScanTaskResponse) GetResponse() *Response

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

+ func (x *DeleteDataScanTaskResponse) Reset()

+ func (x *DeleteDataScanTaskResponse) String() string

+ type DeleteDatabaseRequest struct

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

+ func (*DeleteDatabaseRequest) ProtoMessage()

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

+ func (x *DeleteDatabaseRequest) Reset()

+ func (x *DeleteDatabaseRequest) String() string

+ type DeleteDatabaseResponse struct

+ Response *Response

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

+ func (*DeleteDatabaseResponse) ProtoMessage()

+ func (x *DeleteDatabaseResponse) GetResponse() *Response

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

+ func (x *DeleteDatabaseResponse) Reset()

+ func (x *DeleteDatabaseResponse) String() string

+ type DeleteDatasourceRequest struct

+ DatasourceName []string

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

+ func (*DeleteDatasourceRequest) ProtoMessage()

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

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

+ func (x *DeleteDatasourceRequest) Reset()

+ func (x *DeleteDatasourceRequest) String() string

+ type DeleteDatasourceResponse struct

+ Response *Response

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

+ func (*DeleteDatasourceResponse) ProtoMessage()

+ func (x *DeleteDatasourceResponse) GetResponse() *Response

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

+ func (x *DeleteDatasourceResponse) Reset()

+ func (x *DeleteDatasourceResponse) String() string

+ type DeleteSqlMigrateTaskRequest struct

+ TaskName []string

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

+ func (*DeleteSqlMigrateTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteSqlMigrateTaskRequest) Reset()

+ func (x *DeleteSqlMigrateTaskRequest) String() string

+ type DeleteSqlMigrateTaskResponse struct

+ Response *Response

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

+ func (*DeleteSqlMigrateTaskResponse) ProtoMessage()

+ func (x *DeleteSqlMigrateTaskResponse) GetResponse() *Response

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

+ func (x *DeleteSqlMigrateTaskResponse) Reset()

+ func (x *DeleteSqlMigrateTaskResponse) String() string

+ type DeleteStmtMigrateTaskRequest struct

+ TaskName []string

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

+ func (*DeleteStmtMigrateTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteStmtMigrateTaskRequest) Reset()

+ func (x *DeleteStmtMigrateTaskRequest) String() string

+ type DeleteStmtMigrateTaskResponse struct

+ Response *Response

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

+ func (*DeleteStmtMigrateTaskResponse) ProtoMessage()

+ func (x *DeleteStmtMigrateTaskResponse) GetResponse() *Response

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

+ func (x *DeleteStmtMigrateTaskResponse) Reset()

+ func (x *DeleteStmtMigrateTaskResponse) String() string

+ type DeleteStructCompareTaskRequest struct

+ TaskName []string

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

+ func (*DeleteStructCompareTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteStructCompareTaskRequest) Reset()

+ func (x *DeleteStructCompareTaskRequest) String() string

+ type DeleteStructCompareTaskResponse struct

+ Response *Response

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

+ func (*DeleteStructCompareTaskResponse) ProtoMessage()

+ func (x *DeleteStructCompareTaskResponse) GetResponse() *Response

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

+ func (x *DeleteStructCompareTaskResponse) Reset()

+ func (x *DeleteStructCompareTaskResponse) String() string

+ type DeleteStructMigrateTaskRequest struct

+ TaskName []string

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

+ func (*DeleteStructMigrateTaskRequest) ProtoMessage()

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

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

+ func (x *DeleteStructMigrateTaskRequest) Reset()

+ func (x *DeleteStructMigrateTaskRequest) String() string

+ type DeleteStructMigrateTaskResponse struct

+ Response *Response

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

+ func (*DeleteStructMigrateTaskResponse) ProtoMessage()

+ func (x *DeleteStructMigrateTaskResponse) GetResponse() *Response

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

+ func (x *DeleteStructMigrateTaskResponse) Reset()

+ func (x *DeleteStructMigrateTaskResponse) String() string

+ type MasterClient interface

+ DeleteAssessMigrateTask func(ctx context.Context, in *DeleteAssessMigrateTaskRequest, ...) (*DeleteAssessMigrateTaskResponse, error)

+ DeleteCsvMigrateTask func(ctx context.Context, in *DeleteCsvMigrateTaskRequest, opts ...grpc.CallOption) (*DeleteCsvMigrateTaskResponse, error)

+ DeleteDataCompareTask func(ctx context.Context, in *DeleteDataCompareTaskRequest, opts ...grpc.CallOption) (*DeleteDataCompareTaskResponse, error)

+ DeleteDataScanTask func(ctx context.Context, in *DeleteDataScanTaskRequest, opts ...grpc.CallOption) (*DeleteDataScanTaskResponse, error)

+ DeleteDatabase func(ctx context.Context, in *DeleteDatabaseRequest, opts ...grpc.CallOption) (*DeleteDatabaseResponse, error)

+ DeleteDatasource func(ctx context.Context, in *DeleteDatasourceRequest, opts ...grpc.CallOption) (*DeleteDatasourceResponse, error)

+ DeleteSqlMigrateTask func(ctx context.Context, in *DeleteSqlMigrateTaskRequest, opts ...grpc.CallOption) (*DeleteSqlMigrateTaskResponse, error)

+ DeleteStmtMigrateTask func(ctx context.Context, in *DeleteStmtMigrateTaskRequest, opts ...grpc.CallOption) (*DeleteStmtMigrateTaskResponse, error)

+ DeleteStructCompareTask func(ctx context.Context, in *DeleteStructCompareTaskRequest, ...) (*DeleteStructCompareTaskResponse, error)

+ DeleteStructMigrateTask func(ctx context.Context, in *DeleteStructMigrateTaskRequest, ...) (*DeleteStructMigrateTaskResponse, error)

+ OperateTask func(ctx context.Context, in *OperateTaskRequest, opts ...grpc.CallOption) (*OperateTaskResponse, error)

+ ShowAssessMigrateTask func(ctx context.Context, in *ShowAssessMigrateTaskRequest, opts ...grpc.CallOption) (*ShowAssessMigrateTaskResponse, error)

+ ShowCsvMigrateTask func(ctx context.Context, in *ShowCsvMigrateTaskRequest, opts ...grpc.CallOption) (*ShowCsvMigrateTaskResponse, error)

+ ShowDataCompareTask func(ctx context.Context, in *ShowDataCompareTaskRequest, opts ...grpc.CallOption) (*ShowDataCompareTaskResponse, error)

+ ShowDataScanTask func(ctx context.Context, in *ShowDataScanTaskRequest, opts ...grpc.CallOption) (*ShowDataScanTaskResponse, error)

+ ShowDatabase func(ctx context.Context, in *ShowDatabaseRequest, opts ...grpc.CallOption) (*ShowDatabaseResponse, error)

+ ShowDatasource func(ctx context.Context, in *ShowDatasourceRequest, opts ...grpc.CallOption) (*ShowDatasourceResponse, error)

+ ShowSqlMigrateTask func(ctx context.Context, in *ShowSqlMigrateTaskRequest, opts ...grpc.CallOption) (*ShowSqlMigrateTaskResponse, error)

+ ShowStmtMigrateTask func(ctx context.Context, in *ShowStmtMigrateTaskRequest, opts ...grpc.CallOption) (*ShowStmtMigrateTaskResponse, error)

+ ShowStructCompareTask func(ctx context.Context, in *ShowStructCompareTaskRequest, opts ...grpc.CallOption) (*ShowStructCompareTaskResponse, error)

+ ShowStructMigrateTask func(ctx context.Context, in *ShowStructMigrateTaskRequest, opts ...grpc.CallOption) (*ShowStructMigrateTaskResponse, error)

+ UpsertAssessMigrateTask func(ctx context.Context, in *UpsertAssessMigrateTaskRequest, ...) (*UpsertAssessMigrateTaskResponse, error)

+ UpsertCsvMigrateTask func(ctx context.Context, in *UpsertCsvMigrateTaskRequest, opts ...grpc.CallOption) (*UpsertCsvMigrateTaskResponse, error)

+ UpsertDataCompareTask func(ctx context.Context, in *UpsertDataCompareTaskRequest, opts ...grpc.CallOption) (*UpsertDataCompareTaskResponse, error)

+ UpsertDataScanTask func(ctx context.Context, in *UpsertDataScanTaskRequest, opts ...grpc.CallOption) (*UpsertDataScanTaskResponse, error)

+ UpsertDatabase func(ctx context.Context, in *UpsertDatabaseRequest, opts ...grpc.CallOption) (*UpsertDatabaseResponse, error)

+ UpsertDatasource func(ctx context.Context, in *UpsertDatasourceRequest, opts ...grpc.CallOption) (*UpsertDatasourceResponse, error)

+ UpsertSqlMigrateTask func(ctx context.Context, in *UpsertSqlMigrateTaskRequest, opts ...grpc.CallOption) (*UpsertSqlMigrateTaskResponse, error)

+ UpsertStmtMigrateTask func(ctx context.Context, in *UpsertStmtMigrateTaskRequest, opts ...grpc.CallOption) (*UpsertStmtMigrateTaskResponse, error)

+ UpsertStructCompareTask func(ctx context.Context, in *UpsertStructCompareTaskRequest, ...) (*UpsertStructCompareTaskResponse, error)

+ UpsertStructMigrateTask func(ctx context.Context, in *UpsertStructMigrateTaskRequest, ...) (*UpsertStructMigrateTaskResponse, error)

+ func NewMasterClient(cc grpc.ClientConnInterface) MasterClient

+ type MasterServer interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type OperateTaskRequest struct

+ Express string

+ Operate string

+ TaskName string

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

+ func (*OperateTaskRequest) ProtoMessage()

+ func (x *OperateTaskRequest) GetExpress() string

+ func (x *OperateTaskRequest) GetOperate() string

+ func (x *OperateTaskRequest) GetTaskName() string

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

+ func (x *OperateTaskRequest) Reset()

+ func (x *OperateTaskRequest) String() string

+ type OperateTaskResponse struct

+ Response *Response

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

+ func (*OperateTaskResponse) ProtoMessage()

+ func (x *OperateTaskResponse) GetResponse() *Response

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

+ func (x *OperateTaskResponse) Reset()

+ func (x *OperateTaskResponse) String() string

+ type OperateWorkerRequest struct

+ Operate string

+ TaskName string

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

+ func (*OperateWorkerRequest) ProtoMessage()

+ func (x *OperateWorkerRequest) GetOperate() string

+ func (x *OperateWorkerRequest) GetTaskName() string

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

+ func (x *OperateWorkerRequest) Reset()

+ func (x *OperateWorkerRequest) String() string

+ type OperateWorkerResponse struct

+ Response *Response

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

+ func (*OperateWorkerResponse) ProtoMessage()

+ func (x *OperateWorkerResponse) GetResponse() *Response

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

+ func (x *OperateWorkerResponse) Reset()

+ func (x *OperateWorkerResponse) String() string

+ type Response struct

+ Message string

+ Result string

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

+ func (*Response) ProtoMessage()

+ func (x *Response) GetMessage() string

+ func (x *Response) GetResult() string

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

+ func (x *Response) Reset()

+ func (x *Response) String() string

+ type SchemaRouteRule struct

+ ExcludeTableS []string

+ IncludeTableS []string

+ SchemaNameS string

+ SchemaNameT string

+ TableRouteRules []*TableRouteRule

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

+ func (*SchemaRouteRule) ProtoMessage()

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

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

+ func (x *SchemaRouteRule) GetSchemaNameS() string

+ func (x *SchemaRouteRule) GetSchemaNameT() string

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

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

+ func (x *SchemaRouteRule) Reset()

+ func (x *SchemaRouteRule) String() string

+ type SchemaStructRule struct

+ ColumnTypeS string

+ ColumnTypeT string

+ DefaultValueS string

+ DefaultValueT string

+ SchemaNameS string

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

+ func (*SchemaStructRule) ProtoMessage()

+ func (x *SchemaStructRule) GetColumnTypeS() string

+ func (x *SchemaStructRule) GetColumnTypeT() string

+ func (x *SchemaStructRule) GetDefaultValueS() string

+ func (x *SchemaStructRule) GetDefaultValueT() string

+ func (x *SchemaStructRule) GetSchemaNameS() string

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

+ func (x *SchemaStructRule) Reset()

+ func (x *SchemaStructRule) String() string

+ type ShowAssessMigrateTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowAssessMigrateTaskRequest) ProtoMessage()

+ func (x *ShowAssessMigrateTaskRequest) GetPage() uint64

+ func (x *ShowAssessMigrateTaskRequest) GetPageSize() uint64

+ func (x *ShowAssessMigrateTaskRequest) GetTaskName() string

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

+ func (x *ShowAssessMigrateTaskRequest) Reset()

+ func (x *ShowAssessMigrateTaskRequest) String() string

+ type ShowAssessMigrateTaskResponse struct

+ Response *Response

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

+ func (*ShowAssessMigrateTaskResponse) ProtoMessage()

+ func (x *ShowAssessMigrateTaskResponse) GetResponse() *Response

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

+ func (x *ShowAssessMigrateTaskResponse) Reset()

+ func (x *ShowAssessMigrateTaskResponse) String() string

+ type ShowCsvMigrateTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowCsvMigrateTaskRequest) ProtoMessage()

+ func (x *ShowCsvMigrateTaskRequest) GetPage() uint64

+ func (x *ShowCsvMigrateTaskRequest) GetPageSize() uint64

+ func (x *ShowCsvMigrateTaskRequest) GetTaskName() string

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

+ func (x *ShowCsvMigrateTaskRequest) Reset()

+ func (x *ShowCsvMigrateTaskRequest) String() string

+ type ShowCsvMigrateTaskResponse struct

+ Response *Response

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

+ func (*ShowCsvMigrateTaskResponse) ProtoMessage()

+ func (x *ShowCsvMigrateTaskResponse) GetResponse() *Response

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

+ func (x *ShowCsvMigrateTaskResponse) Reset()

+ func (x *ShowCsvMigrateTaskResponse) String() string

+ type ShowDataCompareTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowDataCompareTaskRequest) ProtoMessage()

+ func (x *ShowDataCompareTaskRequest) GetPage() uint64

+ func (x *ShowDataCompareTaskRequest) GetPageSize() uint64

+ func (x *ShowDataCompareTaskRequest) GetTaskName() string

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

+ func (x *ShowDataCompareTaskRequest) Reset()

+ func (x *ShowDataCompareTaskRequest) String() string

+ type ShowDataCompareTaskResponse struct

+ Response *Response

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

+ func (*ShowDataCompareTaskResponse) ProtoMessage()

+ func (x *ShowDataCompareTaskResponse) GetResponse() *Response

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

+ func (x *ShowDataCompareTaskResponse) Reset()

+ func (x *ShowDataCompareTaskResponse) String() string

+ type ShowDataScanTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowDataScanTaskRequest) ProtoMessage()

+ func (x *ShowDataScanTaskRequest) GetPage() uint64

+ func (x *ShowDataScanTaskRequest) GetPageSize() uint64

+ func (x *ShowDataScanTaskRequest) GetTaskName() string

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

+ func (x *ShowDataScanTaskRequest) Reset()

+ func (x *ShowDataScanTaskRequest) String() string

+ type ShowDataScanTaskResponse struct

+ Response *Response

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

+ func (*ShowDataScanTaskResponse) ProtoMessage()

+ func (x *ShowDataScanTaskResponse) GetResponse() *Response

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

+ func (x *ShowDataScanTaskResponse) Reset()

+ func (x *ShowDataScanTaskResponse) String() string

+ type ShowDatabaseRequest struct

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

+ func (*ShowDatabaseRequest) ProtoMessage()

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

+ func (x *ShowDatabaseRequest) Reset()

+ func (x *ShowDatabaseRequest) String() string

+ type ShowDatabaseResponse struct

+ Response *Response

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

+ func (*ShowDatabaseResponse) ProtoMessage()

+ func (x *ShowDatabaseResponse) GetResponse() *Response

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

+ func (x *ShowDatabaseResponse) Reset()

+ func (x *ShowDatabaseResponse) String() string

+ type ShowDatasourceRequest struct

+ DatasourceName string

+ Page uint64

+ PageSize uint64

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

+ func (*ShowDatasourceRequest) ProtoMessage()

+ func (x *ShowDatasourceRequest) GetDatasourceName() string

+ func (x *ShowDatasourceRequest) GetPage() uint64

+ func (x *ShowDatasourceRequest) GetPageSize() uint64

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

+ func (x *ShowDatasourceRequest) Reset()

+ func (x *ShowDatasourceRequest) String() string

+ type ShowDatasourceResponse struct

+ Response *Response

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

+ func (*ShowDatasourceResponse) ProtoMessage()

+ func (x *ShowDatasourceResponse) GetResponse() *Response

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

+ func (x *ShowDatasourceResponse) Reset()

+ func (x *ShowDatasourceResponse) String() string

+ type ShowSqlMigrateTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowSqlMigrateTaskRequest) ProtoMessage()

+ func (x *ShowSqlMigrateTaskRequest) GetPage() uint64

+ func (x *ShowSqlMigrateTaskRequest) GetPageSize() uint64

+ func (x *ShowSqlMigrateTaskRequest) GetTaskName() string

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

+ func (x *ShowSqlMigrateTaskRequest) Reset()

+ func (x *ShowSqlMigrateTaskRequest) String() string

+ type ShowSqlMigrateTaskResponse struct

+ Response *Response

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

+ func (*ShowSqlMigrateTaskResponse) ProtoMessage()

+ func (x *ShowSqlMigrateTaskResponse) GetResponse() *Response

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

+ func (x *ShowSqlMigrateTaskResponse) Reset()

+ func (x *ShowSqlMigrateTaskResponse) String() string

+ type ShowStmtMigrateTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowStmtMigrateTaskRequest) ProtoMessage()

+ func (x *ShowStmtMigrateTaskRequest) GetPage() uint64

+ func (x *ShowStmtMigrateTaskRequest) GetPageSize() uint64

+ func (x *ShowStmtMigrateTaskRequest) GetTaskName() string

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

+ func (x *ShowStmtMigrateTaskRequest) Reset()

+ func (x *ShowStmtMigrateTaskRequest) String() string

+ type ShowStmtMigrateTaskResponse struct

+ Response *Response

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

+ func (*ShowStmtMigrateTaskResponse) ProtoMessage()

+ func (x *ShowStmtMigrateTaskResponse) GetResponse() *Response

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

+ func (x *ShowStmtMigrateTaskResponse) Reset()

+ func (x *ShowStmtMigrateTaskResponse) String() string

+ type ShowStructCompareTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowStructCompareTaskRequest) ProtoMessage()

+ func (x *ShowStructCompareTaskRequest) GetPage() uint64

+ func (x *ShowStructCompareTaskRequest) GetPageSize() uint64

+ func (x *ShowStructCompareTaskRequest) GetTaskName() string

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

+ func (x *ShowStructCompareTaskRequest) Reset()

+ func (x *ShowStructCompareTaskRequest) String() string

+ type ShowStructCompareTaskResponse struct

+ Response *Response

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

+ func (*ShowStructCompareTaskResponse) ProtoMessage()

+ func (x *ShowStructCompareTaskResponse) GetResponse() *Response

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

+ func (x *ShowStructCompareTaskResponse) Reset()

+ func (x *ShowStructCompareTaskResponse) String() string

+ type ShowStructMigrateTaskRequest struct

+ Page uint64

+ PageSize uint64

+ TaskName string

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

+ func (*ShowStructMigrateTaskRequest) ProtoMessage()

+ func (x *ShowStructMigrateTaskRequest) GetPage() uint64

+ func (x *ShowStructMigrateTaskRequest) GetPageSize() uint64

+ func (x *ShowStructMigrateTaskRequest) GetTaskName() string

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

+ func (x *ShowStructMigrateTaskRequest) Reset()

+ func (x *ShowStructMigrateTaskRequest) String() string

+ type ShowStructMigrateTaskResponse struct

+ Response *Response

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

+ func (*ShowStructMigrateTaskResponse) ProtoMessage()

+ func (x *ShowStructMigrateTaskResponse) GetResponse() *Response

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

+ func (x *ShowStructMigrateTaskResponse) Reset()

+ func (x *ShowStructMigrateTaskResponse) String() string

+ type SqlMigrateParam struct

+ BatchSize uint64

+ CallTimeout uint64

+ EnableConsistentRead bool

+ SqlHintT string

+ SqlThreadS uint64

+ SqlThreadT uint64

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

+ func (*SqlMigrateParam) ProtoMessage()

+ func (x *SqlMigrateParam) GetBatchSize() uint64

+ func (x *SqlMigrateParam) GetCallTimeout() uint64

+ func (x *SqlMigrateParam) GetEnableConsistentRead() bool

+ func (x *SqlMigrateParam) GetSqlHintT() string

+ func (x *SqlMigrateParam) GetSqlThreadS() uint64

+ func (x *SqlMigrateParam) GetSqlThreadT() uint64

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

+ func (x *SqlMigrateParam) Reset()

+ func (x *SqlMigrateParam) String() string

+ type SqlMigrateRule struct

+ ColumnRouteRules map[string]string

+ SchemaNameT string

+ SqlHintT string

+ SqlQueryS string

+ TableNameT string

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

+ func (*SqlMigrateRule) ProtoMessage()

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

+ func (x *SqlMigrateRule) GetSchemaNameT() string

+ func (x *SqlMigrateRule) GetSqlHintT() string

+ func (x *SqlMigrateRule) GetSqlQueryS() string

+ func (x *SqlMigrateRule) GetTableNameT() string

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

+ func (x *SqlMigrateRule) Reset()

+ func (x *SqlMigrateRule) String() string

+ type StatementMigrateParam struct

+ BatchSize uint64

+ CallTimeout uint64

+ ChunkSize uint64

+ EnableCheckpoint bool

+ EnableConsistentRead bool

+ SqlHintS string

+ SqlHintT string

+ SqlThreadS uint64

+ SqlThreadT uint64

+ TableThread uint64

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

+ func (*StatementMigrateParam) ProtoMessage()

+ func (x *StatementMigrateParam) GetBatchSize() uint64

+ func (x *StatementMigrateParam) GetCallTimeout() uint64

+ func (x *StatementMigrateParam) GetChunkSize() uint64

+ func (x *StatementMigrateParam) GetEnableCheckpoint() bool

+ func (x *StatementMigrateParam) GetEnableConsistentRead() bool

+ func (x *StatementMigrateParam) GetSqlHintS() string

+ func (x *StatementMigrateParam) GetSqlHintT() string

+ func (x *StatementMigrateParam) GetSqlThreadS() uint64

+ func (x *StatementMigrateParam) GetSqlThreadT() uint64

+ func (x *StatementMigrateParam) GetTableThread() uint64

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

+ func (x *StatementMigrateParam) Reset()

+ func (x *StatementMigrateParam) String() string

+ type StructCompareParam struct

+ CompareThread uint64

+ EnableCheckpoint bool

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

+ func (*StructCompareParam) ProtoMessage()

+ func (x *StructCompareParam) GetCompareThread() uint64

+ func (x *StructCompareParam) GetEnableCheckpoint() bool

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

+ func (x *StructCompareParam) Reset()

+ func (x *StructCompareParam) String() string

+ type StructCompareRule struct

+ ColumnStructRules []*ColumnStructRule

+ SchemaStructRules []*SchemaStructRule

+ TableStructRules []*TableStructRule

+ TaskStructRules []*TaskStructRule

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

+ func (*StructCompareRule) ProtoMessage()

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

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

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

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

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

+ func (x *StructCompareRule) Reset()

+ func (x *StructCompareRule) String() string

+ type StructMigrateParam struct

+ CreateIfNotExist bool

+ EnableDirectCreate bool

+ MigrateThread uint64

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

+ func (*StructMigrateParam) ProtoMessage()

+ func (x *StructMigrateParam) GetCreateIfNotExist() bool

+ func (x *StructMigrateParam) GetEnableDirectCreate() bool

+ func (x *StructMigrateParam) GetMigrateThread() uint64

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

+ func (x *StructMigrateParam) Reset()

+ func (x *StructMigrateParam) String() string

+ type StructMigrateRule struct

+ ColumnStructRules []*ColumnStructRule

+ SchemaStructRules []*SchemaStructRule

+ TableAttrsRules []*TableAttrsRule

+ TableStructRules []*TableStructRule

+ TaskStructRules []*TaskStructRule

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

+ func (*StructMigrateRule) ProtoMessage()

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

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

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

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

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

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

+ func (x *StructMigrateRule) Reset()

+ func (x *StructMigrateRule) String() string

+ type TableAttrsRule struct

+ SchemaNameS string

+ TableAttrsT string

+ TableNamesS []string

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

+ func (*TableAttrsRule) ProtoMessage()

+ func (x *TableAttrsRule) GetSchemaNameS() string

+ func (x *TableAttrsRule) GetTableAttrsT() string

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

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

+ func (x *TableAttrsRule) Reset()

+ func (x *TableAttrsRule) String() string

+ type TableRouteRule struct

+ ColumnRouteRules map[string]string

+ TableNameS string

+ TableNameT string

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

+ func (*TableRouteRule) ProtoMessage()

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

+ func (x *TableRouteRule) GetTableNameS() string

+ func (x *TableRouteRule) GetTableNameT() string

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

+ func (x *TableRouteRule) Reset()

+ func (x *TableRouteRule) String() string

+ type TableStructRule struct

+ ColumnTypeS string

+ ColumnTypeT string

+ DefaultValueS string

+ DefaultValueT string

+ SchemaNameS string

+ TableNameS string

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

+ func (*TableStructRule) ProtoMessage()

+ func (x *TableStructRule) GetColumnTypeS() string

+ func (x *TableStructRule) GetColumnTypeT() string

+ func (x *TableStructRule) GetDefaultValueS() string

+ func (x *TableStructRule) GetDefaultValueT() string

+ func (x *TableStructRule) GetSchemaNameS() string

+ func (x *TableStructRule) GetTableNameS() string

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

+ func (x *TableStructRule) Reset()

+ func (x *TableStructRule) String() string

+ type TaskStructRule struct

+ ColumnTypeS string

+ ColumnTypeT string

+ DefaultValueS string

+ DefaultValueT string

+ TableAttrOption string

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

+ func (*TaskStructRule) ProtoMessage()

+ func (x *TaskStructRule) GetColumnTypeS() string

+ func (x *TaskStructRule) GetColumnTypeT() string

+ func (x *TaskStructRule) GetDefaultValueS() string

+ func (x *TaskStructRule) GetDefaultValueT() string

+ func (x *TaskStructRule) GetTableAttrOption() string

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

+ func (x *TaskStructRule) Reset()

+ func (x *TaskStructRule) String() string

+ type UnimplementedMasterServer struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type UnimplementedWorkerServer struct

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

+ type UnsafeMasterServer interface

+ type UnsafeWorkerServer interface

+ type UpsertAssessMigrateTaskRequest struct

+ AssessMigrateParam *AssessMigrateParam

+ Comment string

+ DatasourceNameS string

+ DatasourceNameT string

+ TaskName string

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

+ func (*UpsertAssessMigrateTaskRequest) ProtoMessage()

+ func (x *UpsertAssessMigrateTaskRequest) GetAssessMigrateParam() *AssessMigrateParam

+ func (x *UpsertAssessMigrateTaskRequest) GetComment() string

+ func (x *UpsertAssessMigrateTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertAssessMigrateTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertAssessMigrateTaskRequest) GetTaskName() string

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

+ func (x *UpsertAssessMigrateTaskRequest) Reset()

+ func (x *UpsertAssessMigrateTaskRequest) String() string

+ type UpsertAssessMigrateTaskResponse struct

+ Response *Response

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

+ func (*UpsertAssessMigrateTaskResponse) ProtoMessage()

+ func (x *UpsertAssessMigrateTaskResponse) GetResponse() *Response

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

+ func (x *UpsertAssessMigrateTaskResponse) Reset()

+ func (x *UpsertAssessMigrateTaskResponse) String() string

+ type UpsertCsvMigrateTaskRequest struct

+ CaseFieldRule *CaseFieldRule

+ Comment string

+ CsvMigrateParam *CsvMigrateParam

+ DataMigrateRules []*DataMigrateRule

+ DatasourceNameS string

+ DatasourceNameT string

+ SchemaRouteRule *SchemaRouteRule

+ TaskName string

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

+ func (*UpsertCsvMigrateTaskRequest) ProtoMessage()

+ func (x *UpsertCsvMigrateTaskRequest) GetCaseFieldRule() *CaseFieldRule

+ func (x *UpsertCsvMigrateTaskRequest) GetComment() string

+ func (x *UpsertCsvMigrateTaskRequest) GetCsvMigrateParam() *CsvMigrateParam

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

+ func (x *UpsertCsvMigrateTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertCsvMigrateTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertCsvMigrateTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

+ func (x *UpsertCsvMigrateTaskRequest) GetTaskName() string

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

+ func (x *UpsertCsvMigrateTaskRequest) Reset()

+ func (x *UpsertCsvMigrateTaskRequest) String() string

+ type UpsertCsvMigrateTaskResponse struct

+ Response *Response

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

+ func (*UpsertCsvMigrateTaskResponse) ProtoMessage()

+ func (x *UpsertCsvMigrateTaskResponse) GetResponse() *Response

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

+ func (x *UpsertCsvMigrateTaskResponse) Reset()

+ func (x *UpsertCsvMigrateTaskResponse) String() string

+ type UpsertDataCompareTaskRequest struct

+ CaseFieldRule *CaseFieldRule

+ Comment string

+ DataCompareParam *DataCompareParam

+ DataCompareRules []*DataCompareRule

+ DatasourceNameS string

+ DatasourceNameT string

+ SchemaRouteRule *SchemaRouteRule

+ TaskName string

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

+ func (*UpsertDataCompareTaskRequest) ProtoMessage()

+ func (x *UpsertDataCompareTaskRequest) GetCaseFieldRule() *CaseFieldRule

+ func (x *UpsertDataCompareTaskRequest) GetComment() string

+ func (x *UpsertDataCompareTaskRequest) GetDataCompareParam() *DataCompareParam

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

+ func (x *UpsertDataCompareTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertDataCompareTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertDataCompareTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

+ func (x *UpsertDataCompareTaskRequest) GetTaskName() string

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

+ func (x *UpsertDataCompareTaskRequest) Reset()

+ func (x *UpsertDataCompareTaskRequest) String() string

+ type UpsertDataCompareTaskResponse struct

+ Response *Response

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

+ func (*UpsertDataCompareTaskResponse) ProtoMessage()

+ func (x *UpsertDataCompareTaskResponse) GetResponse() *Response

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

+ func (x *UpsertDataCompareTaskResponse) Reset()

+ func (x *UpsertDataCompareTaskResponse) String() string

+ type UpsertDataScanTaskRequest struct

+ CaseFieldRule *CaseFieldRule

+ Comment string

+ DataScanParam *DataScanParam

+ DataScanRules []*DataScanRule

+ DatasourceNameS string

+ DatasourceNameT string

+ SchemaRouteRule *SchemaRouteRule

+ TaskName string

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

+ func (*UpsertDataScanTaskRequest) ProtoMessage()

+ func (x *UpsertDataScanTaskRequest) GetCaseFieldRule() *CaseFieldRule

+ func (x *UpsertDataScanTaskRequest) GetComment() string

+ func (x *UpsertDataScanTaskRequest) GetDataScanParam() *DataScanParam

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

+ func (x *UpsertDataScanTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertDataScanTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertDataScanTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

+ func (x *UpsertDataScanTaskRequest) GetTaskName() string

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

+ func (x *UpsertDataScanTaskRequest) Reset()

+ func (x *UpsertDataScanTaskRequest) String() string

+ type UpsertDataScanTaskResponse struct

+ Response *Response

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

+ func (*UpsertDataScanTaskResponse) ProtoMessage()

+ func (x *UpsertDataScanTaskResponse) GetResponse() *Response

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

+ func (x *UpsertDataScanTaskResponse) Reset()

+ func (x *UpsertDataScanTaskResponse) String() string

+ type UpsertDatabaseRequest struct

+ Database *Database

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

+ func (*UpsertDatabaseRequest) ProtoMessage()

+ func (x *UpsertDatabaseRequest) GetDatabase() *Database

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

+ func (x *UpsertDatabaseRequest) Reset()

+ func (x *UpsertDatabaseRequest) String() string

+ type UpsertDatabaseResponse struct

+ Response *Response

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

+ func (*UpsertDatabaseResponse) ProtoMessage()

+ func (x *UpsertDatabaseResponse) GetResponse() *Response

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

+ func (x *UpsertDatabaseResponse) Reset()

+ func (x *UpsertDatabaseResponse) String() string

+ type UpsertDatasourceRequest struct

+ Datasource []*Datasource

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

+ func (*UpsertDatasourceRequest) ProtoMessage()

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

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

+ func (x *UpsertDatasourceRequest) Reset()

+ func (x *UpsertDatasourceRequest) String() string

+ type UpsertDatasourceResponse struct

+ Response *Response

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

+ func (*UpsertDatasourceResponse) ProtoMessage()

+ func (x *UpsertDatasourceResponse) GetResponse() *Response

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

+ func (x *UpsertDatasourceResponse) Reset()

+ func (x *UpsertDatasourceResponse) String() string

+ type UpsertSqlMigrateTaskRequest struct

+ CaseFieldRule *CaseFieldRule

+ Comment string

+ DatasourceNameS string

+ DatasourceNameT string

+ SqlMigrateParam *SqlMigrateParam

+ SqlMigrateRules []*SqlMigrateRule

+ TaskName string

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

+ func (*UpsertSqlMigrateTaskRequest) ProtoMessage()

+ func (x *UpsertSqlMigrateTaskRequest) GetCaseFieldRule() *CaseFieldRule

+ func (x *UpsertSqlMigrateTaskRequest) GetComment() string

+ func (x *UpsertSqlMigrateTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertSqlMigrateTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertSqlMigrateTaskRequest) GetSqlMigrateParam() *SqlMigrateParam

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

+ func (x *UpsertSqlMigrateTaskRequest) GetTaskName() string

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

+ func (x *UpsertSqlMigrateTaskRequest) Reset()

+ func (x *UpsertSqlMigrateTaskRequest) String() string

+ type UpsertSqlMigrateTaskResponse struct

+ Response *Response

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

+ func (*UpsertSqlMigrateTaskResponse) ProtoMessage()

+ func (x *UpsertSqlMigrateTaskResponse) GetResponse() *Response

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

+ func (x *UpsertSqlMigrateTaskResponse) Reset()

+ func (x *UpsertSqlMigrateTaskResponse) String() string

+ type UpsertStmtMigrateTaskRequest struct

+ CaseFieldRule *CaseFieldRule

+ Comment string

+ DataMigrateRules []*DataMigrateRule

+ DatasourceNameS string

+ DatasourceNameT string

+ SchemaRouteRule *SchemaRouteRule

+ StatementMigrateParam *StatementMigrateParam

+ TaskName string

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

+ func (*UpsertStmtMigrateTaskRequest) ProtoMessage()

+ func (x *UpsertStmtMigrateTaskRequest) GetCaseFieldRule() *CaseFieldRule

+ func (x *UpsertStmtMigrateTaskRequest) GetComment() string

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

+ func (x *UpsertStmtMigrateTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertStmtMigrateTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertStmtMigrateTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

+ func (x *UpsertStmtMigrateTaskRequest) GetStatementMigrateParam() *StatementMigrateParam

+ func (x *UpsertStmtMigrateTaskRequest) GetTaskName() string

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

+ func (x *UpsertStmtMigrateTaskRequest) Reset()

+ func (x *UpsertStmtMigrateTaskRequest) String() string

+ type UpsertStmtMigrateTaskResponse struct

+ Response *Response

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

+ func (*UpsertStmtMigrateTaskResponse) ProtoMessage()

+ func (x *UpsertStmtMigrateTaskResponse) GetResponse() *Response

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

+ func (x *UpsertStmtMigrateTaskResponse) Reset()

+ func (x *UpsertStmtMigrateTaskResponse) String() string

+ type UpsertStructCompareTaskRequest struct

+ CaseFieldRule *CaseFieldRule

+ Comment string

+ DatasourceNameS string

+ DatasourceNameT string

+ SchemaRouteRule *SchemaRouteRule

+ StructCompareParam *StructCompareParam

+ StructCompareRule *StructCompareRule

+ TaskName string

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

+ func (*UpsertStructCompareTaskRequest) ProtoMessage()

+ func (x *UpsertStructCompareTaskRequest) GetCaseFieldRule() *CaseFieldRule

+ func (x *UpsertStructCompareTaskRequest) GetComment() string

+ func (x *UpsertStructCompareTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertStructCompareTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertStructCompareTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

+ func (x *UpsertStructCompareTaskRequest) GetStructCompareParam() *StructCompareParam

+ func (x *UpsertStructCompareTaskRequest) GetStructCompareRule() *StructCompareRule

+ func (x *UpsertStructCompareTaskRequest) GetTaskName() string

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

+ func (x *UpsertStructCompareTaskRequest) Reset()

+ func (x *UpsertStructCompareTaskRequest) String() string

+ type UpsertStructCompareTaskResponse struct

+ Response *Response

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

+ func (*UpsertStructCompareTaskResponse) ProtoMessage()

+ func (x *UpsertStructCompareTaskResponse) GetResponse() *Response

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

+ func (x *UpsertStructCompareTaskResponse) Reset()

+ func (x *UpsertStructCompareTaskResponse) String() string

+ type UpsertStructMigrateTaskRequest struct

+ CaseFieldRule *CaseFieldRule

+ Comment string

+ DatasourceNameS string

+ DatasourceNameT string

+ SchemaRouteRule *SchemaRouteRule

+ StructMigrateParam *StructMigrateParam

+ StructMigrateRule *StructMigrateRule

+ TaskName string

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

+ func (*UpsertStructMigrateTaskRequest) ProtoMessage()

+ func (x *UpsertStructMigrateTaskRequest) GetCaseFieldRule() *CaseFieldRule

+ func (x *UpsertStructMigrateTaskRequest) GetComment() string

+ func (x *UpsertStructMigrateTaskRequest) GetDatasourceNameS() string

+ func (x *UpsertStructMigrateTaskRequest) GetDatasourceNameT() string

+ func (x *UpsertStructMigrateTaskRequest) GetSchemaRouteRule() *SchemaRouteRule

+ func (x *UpsertStructMigrateTaskRequest) GetStructMigrateParam() *StructMigrateParam

+ func (x *UpsertStructMigrateTaskRequest) GetStructMigrateRule() *StructMigrateRule

+ func (x *UpsertStructMigrateTaskRequest) GetTaskName() string

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

+ func (x *UpsertStructMigrateTaskRequest) Reset()

+ func (x *UpsertStructMigrateTaskRequest) String() string

+ type UpsertStructMigrateTaskResponse struct

+ Response *Response

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

+ func (*UpsertStructMigrateTaskResponse) ProtoMessage()

+ func (x *UpsertStructMigrateTaskResponse) GetResponse() *Response

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

+ func (x *UpsertStructMigrateTaskResponse) Reset()

+ func (x *UpsertStructMigrateTaskResponse) String() string

+ type WorkerClient interface

+ OperateWorker func(ctx context.Context, in *OperateWorkerRequest, opts ...grpc.CallOption) (*OperateWorkerResponse, error)

+ func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient

+ type WorkerServer interface

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

v0.0.0-beta.3

Jun 7, 2024

v0.0.0-beta.2

Jun 7, 2024

v0.0.0-beta.1

Jun 7, 2024

v0.0.0-beta

May 23, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL