package
8.2.0+incompatible
Repository: https://github.com/pingcap/tiflow.git
Documentation: pkg.go.dev

# Functions

IsErrNetClosing checks whether is an ErrNetClosing error.
NoSubTaskMsg returns a formatted string for subtask not started.

# Variables

ClusterIDKey is used to store the cluster id of the whole dm cluster.
ClusterTopologyKey is used to store the cluster topo info of the whole dm cluster, and this info is maintained by tiup.
ClusterVersionKey is used to store the version of the cluster.
LightningCoordinationKeyAdapter is used to store the coordination information of lightning.
LoadTaskKeyAdapter is used to store the worker which in load stage for the source of the subtask.
OpenAPITaskTemplateKeyAdapter is used to store the openapi task-config-template (openapi.Task), now it's only used for WebUI.
ShardDDLOptimismInitSchemaKeyAdapter is used to store the initial schema (before constructed the lock) of merged tables.
ShardDDLOptimismInfoKeyAdapter is used to store shard DDL info in optimistic model.
ShardDDLOptimismOperationKeyAdapter is used to store shard DDL operation in optimistic model.
ShardDDLOptimismSourceTablesKeyAdapter is used to store INITIAL upstream schema & table names when starting the subtask.
ShardDDLPessimismInfoKeyAdapter is used to store shard DDL info in pessimistic model.
ShardDDLPessimismOperationKeyAdapter is used to store shard DDL operation in pessimistic model.
StageRelayKeyAdapter is used to store the running stage of the relay.
StageRelayKeyAdapterV1 is used to store the running stage of the relay.
StageSubTaskKeyAdapter is used to store the running stage of the subtask.
StageValidatorKeyAdapter is used to store the running stage of the validator.
TaskCliArgsKeyAdapter is used to store the command line arguments of task.
UpstreamBoundWorkerKeyAdapter is used to store address of worker in which MySQL-tasks which are running.
UpstreamConfigKeyAdapter stores all config of which MySQL-task has not stopped.
UpstreamConfigKeyAdapterV1 stores all config of which MySQL-task has not stopped.
UpstreamLastBoundWorkerKeyAdapter is used to store address of worker in which MySQL-tasks which are running.
UpstreamRelayWorkerKeyAdapter is used to store the upstream which this worker needs to pull relay log k/v: Encode(worker-name) -> source-id.
UpstreamSubTaskKeyAdapter is used to store SubTask which are subscribing data from MySQL source.
WorkerKeepAliveKeyAdapter is used to encode and decode keepalive key.
WorkerRegisterKeyAdapter is used to encode and decode register key.

# Interfaces

KeyAdapter is used to construct etcd key.