Compact performs a leveled compaction with the given minimum level.

FetchMode obtains the import mode status of the TiKV node.

FetchMode obtains the import mode status from the Prometheus metrics of a TiKV node.

ForAllStores executes `action` in parallel for all TiKV stores connected to a PD server given by the HTTPS client `tls`.

MakeRowFromKvPairs converts a KvPair slice into a Row instance.

MakeRowsFromKvPairs converts a KvPair slice into a Rows instance.

NewImporter creates a new connection to tikv-importer.

NewMockImporter creates an *unconnected* importer based on a custom ImportKVClient.

NewPanickingAllocator creates a PanickingAllocator shared by all allocation types.

NewTiDBBackend creates a new TiDB backend using the given database.

SwitchMode changes the TiKV node at the given address to a particular mode.

StoreStateDisconnected means the TiKV store does not respond to PD.

StoreStateDown means the TiKV store does not respond to PD for a long time (> 30 minutes).

StoreStateOffline means the TiKV store is in the process of being taken offline (but is still accessible).

StoreStateTombstone means the TiKV store is shut down and the data has been evacuated.

StoreStateUp means the TiKV store is in service.

Backend is the delivery target for Lightning.

ClosedEngine represents a closed engine, allowing ingestion into the target.

OpenedEngine is an opened engine, allowing data to be written via WriteRows.

SessionOptions is the initial configuration of the session.

Store contains metadata about a TiKV store.

AbstractBackend is the abstract interface behind Backend.

Encoder encodes a row of SQL values into some opaque type which can be consumed by OpenEngine.WriteEncoded.

Row represents a single encoded row.

Rows represents a collection of encoded rows.

StoreState is the state of a TiKV store.