CheckpointOf returns the checkpoint prefix of some store.

CliEnv creates the Env for CLI usage.

GlobalCheckpointOf returns the path to the "global" checkpoint of some task.

IterateRegion creates an iterater over the region range.

LastErrorPrefixOf make the prefix for searching last error by some task.

NewCheckpointAdvancer creates a checkpoint advancer with the env.

NewClusterCollector creates a new cluster collector.

NewSubscriber creates a new subscriber via the environment and optional configs.

NewTask creates a new task with the name.

ParseCheckpoint parses the checkpoint from a key & value pair.

Pause returns the path for pausing the task.

PrefixOfPause returns the prefix for pausing the task.

PrefixOfTask is the prefix of all task It would be `<prefix>/info/`.

RangeKeyOf returns the path for ranges of some task.

RangesOf returns the path prefix for some task.

StorageCheckpointOf get the prefix path of the `storage checkpoint status` of a task.

TaskOf returns the path of tasks.

TiDBEnv creates the Env by TiDB config.

WithMasterContext sets the "master context" for the subscriber, that context would be the "background" context for every subtasks created by the subscription manager.

Checkpoint is the polymorphic checkpoint type.

CheckpointAdvancer is the central node for advancing the checkpoint of log backup.

FlushSubscriber maintains the state of subscribing to the cluster.

MetaDataClient is the client for operations over metadata.

PDRegionScanner is a simple wrapper over PD to adapt the requirement of `RegionScan`.

Task presents a remote "task" object.

TaskInfo is a task info with extra information.

Env is the interface required by the advancer.

StreamMeta connects to the metadata service (normally PD).

Ranges is a vector of [start_key, end_key) pairs.

SubscriberConfig is a config which cloud be applied into the subscriber.