RegisterMasterHandler registers the http handlers for service Master to "mux".

RegisterMasterHandlerClient registers the http handlers for service Master to "mux".

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

RegisterMasterHandlerServer registers the http handlers for service Master to "mux".

CheckError represents error for check unit adds fields later.

CheckStatus represents status for check unit adds fields later.

DDLLock represents a DDL lock info (I known the name confused with DDLLockInfo, any suggestion?) it been sent from dm-master to dmctl ID: DDL lock generated ID task: lock's corresponding task name mode: the shard DDL mode, `pessimistic` or `optimistic`.

DumpError represents error for dump unit add fields later.

DumpStatus represents status for dump unit add fields later.

LoadError represents error for load unit.

LoadStatus represents status for load unit.

OperateWorkerRelayRequest represents a request for some dm-workers to operate relay unit.

ProcessError is same as terror used in dm NOTE: currently stack trace is not supported, `Message` is the `terror.Error.getMsg` result and `RawCause` is the `Error` result of error from `terror.Error.Cause()`.

ProcessResult represents results produced by a dm unit isCanceled: indicates whether the process is canceled from external when Stop or Pause is requested from external, isCanceled will be true errors: includes all (potential) errors occured when processing.

PurgeRelayRequest represents a request to purge relay log files for this dm-worker inactive: whether purge inactive relay log files time: whether purge relay log files before this time, the number of seconds elapsed since January 1, 1970 UTC filename: whether purge relay log files before this filename subDir: specify relay sub directory for @filename.

PurgeWorkerRelayRequest represents a request to purge relay log files for some dm-workers workers: dm-workers need to purge relay log files inactive: whether purge inactive relay log files time: whether purge relay log files before this time, the number of seconds elapsed since January 1, 1970 UTC filename: whether purge relay log files before this filename subDir: specify relay sub directory for @filename.

QueryStatusResponse represents status response for query on a dm-worker status: dm-worker's current sub tasks' status.

RelayError represents error for relay unit.

RelayStatus represents status for relay unit.

ShardingGroup represents a DDL sharding group, this is used by SyncStatus, and is differ from ShardingGroup in syncer pkg target: target table name DDL: in syncing DDL firstPos: first DDL binlog pos for this group synced: synced source tables unsynced: unsynced source tables.

ShowDDLLocksRequest used to query DDL locks which are un-resolved task: task's name, empty for all tasks sources: source need to query, empty for all sources any DDL lock in which the source is synced or unsynced will return if specify task and sources both, and sources not doing the task , it will return empty DDL locks.

SourceError represents error for start/stop source on dm-worker.

SourceStatus represents status for source runing on dm-worker.

SubTaskError represents error for a sub task during running name: sub task'name, when starting a sub task the name should be unique stage: sub task's current stage unit: sub task's current dm unit's UnitType error: current unit's error information for Sync, includes failed sql, failed sql pos in binlog, etc.

SubTaskErrorList used for internal jsonpb marshal.

SubTaskStatus represents status for a sub task name: sub task'name, when starting a sub task the name should be unique stage: sub task's current stage unit: sub task's current dm unit's UnitType result: current unit's process result, when the stage is Running, no result unresolvedDDLLockID: un-resolved sharding DDL lock ID (ref DDLLockInfo) if needed, we can put this to SyncStatus status: current unit's statistics for Load, includes total bytes, progress, etc.

SubTaskStatusList used for internal jsonpb marshal.

SyncError represents error list for sync unit.

SyncSQLError represents a sql error in sync unit.

SyncStatus represents status for sync unit.

UnimplementedMasterServer can be embedded to have forward compatible implementations.

UnimplementedWorkerServer can be embedded to have forward compatible implementations.

UnlockDDLLockRequest used to unlock (resolve) DDL lock manually ID: DDL lock ID replaceOwner: dm-worker used to replace the original DDL lock's owner forceRemove: force to remove the DDL lock even fail to execute the DDL for the owner.

UpdateTaskRequest used to update task after it has beed started task: task's configuration, yaml format now, only support to update config for routes, filters, column-mappings, block-allow-list support update partial config for syncer, loader, etc later sources need to do update, empty for all sources in processing the task.

copied `TaskMeta` from release-1.0 branch.

MasterClient is the client API for Master service.

MasterServer is the server API for Master service.

WorkerClient is the client API for Worker service.

WorkerServer is the server API for Worker service.

RelayOp differs from TaskOp.

Stage represents current stage for a (sub) task a (sub) task should be always in one stage of the following stages (sub) task can transfer from on stage to some special other stages New: initial stage when a sub task is created can not transfered from other stages transfer to Running when initialize with no error Running: indicates the sub task is processing transfered from New when created successfully transfered from Paused when resuming is requested transfer to Paused when error occured or requested from external transfer to Stopped when requested from external transfer to Finished when sub task processing completed (no Syncer used) Paused: indicates the processing is paused, and can be resume from external request transfered from Running when error occured or requested from external transfer to Running when resuming is requested from external transfer to Stopped when requested from external Stopped: indicates the processing is stopped, and can not be resume (or re-run) again transfered from Running / Paused when requested from external can not transfer to any stages Finished: indicates the processing is finished, and no need to re-run transfered from Running when processing completed should not transfer to any stages.

UnitType represents the dm unit's type.