BuildObserveDataRanges builds key ranges to observe data KV.

BuildObserveMetaRange specifies build key ranges to observe meta KV(contains all of metas).

DecodeKVEntry decodes kv-entry from buff.

EncodeKVEntry gets a entry-event from input: k, v.

FastUnmarshalMetaData used a 128 worker pool to speed up read metadata content from external_storage.

GetTSFromFile gets the current truncate safepoint.

MaybeQPS get a number like the QPS of last seconds for each store via the prometheus interface.

Merge merges two migrations.

MigrateionExtnsion installs the extension methods to an `ExternalStorage`.

MMOptAlwaysRunTruncate forces the merge and migrate to always run the truncating.

MMOptAppendPhantomMigration appends a phantom migration to the merge and migrate to operation.

NewDBReplace creates a DBReplace struct.

NewEventIterator creates a Iterator to read kv-event.

NewSchemasReplace creates a SchemasReplace struct.

NewStartWithComparator create a comparator to compare whether src starts with dst.

NewStatusContorller make a status controller via some resource accessors.

NewStreamBackupSearch creates an instance of StreamBackupSearch.

NewTableReplace creates a TableReplace struct.

ParseTxnMetaKeyFrom gets a `RawMetaKey` struct by parsing transaction meta key.

PrintTaskByTable make a TaskPrinter, which prints the task by the `Table` implement of the console.

PrintTaskWithJSON make a TaskPrinter, which prints tasks as json to the console directly.

replace the filegroups and update the ts of the replaced metadata.

SetTSToFile overrides the current truncate safepoint.

Default columnFamily and write columnFamily.

TruncateSafePointFileName is the filename that the ts(the log have been truncated) is saved into.

Default columnFamily and write columnFamily.

WriteType.

WriteType.

WriteType.

WriteType.

DBReplace specifies database information mapping from up-stream cluster to up-stream cluster.

EventIterator is used for reading kv-event from buffer by iterator.

keep these meta-information for statistics and filtering.

MergeAndMigratedTo is the result of a call to `MergeAndMigrateTo`.

MetadataHelper make restore/truncate compatible with metadataV1 and metadataV2.

keep these meta-information for statistics and filtering.

MigratedTo is the result of trying to "migrate to" a migration.

MigrationExt is an extension to the `ExternalStorage` type.

Migrations represents living migrations from the storage.

NoHooks is used for non-interactive secnarios.

OrderedMigration is a migration with its path and sequence number.

RawMetaKey specified a transaction meta key.

RawWriteCFValue represents the value in write columnFamily.

SchemasReplace specifies schemas information mapping from up-stream cluster to up-stream cluster.

StatusController is the controller type (or context type) for the command `stream status`.

StreamBackupSearch is used for searching key from log data files.

StreamKVInfo stores kv info searched from log data files.

TableMappingManager iterates on log backup meta kvs and generate new id for DB, table and partition for downstream cluster.

TableReplace specifies table information mapping from up-stream cluster to up-stream cluster.

Comparator is used for comparing the relationship of src and dst.

Iterator specifies a read iterator Interface.

WriteType defines a write type.