package
5.0.0-rc+incompatible
Repository: https://github.com/pingcap/tidb-lightning.git
Documentation: pkg.go.dev
# Functions
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`.
No description provided by the author
No description provided by the author
MakeRowFromKvPairs converts a KvPair slice into a Row instance.
MakeRowsFromKvPairs converts a KvPair slice into a Rows instance.
No description provided by the author
NewImporter creates a new connection to tikv-importer.
NewLocalBackend creates new connections to tikv.
NewMockImporter creates an *unconnected* importer based on a custom ImportKVClient.
NewPanickingAllocator creates a PanickingAllocator shared by all allocation types.
No description provided by the author
NewTiDBBackend creates a new TiDB backend using the given database.
No description provided by the author
SwitchMode changes the TiKV node at the given address to a particular mode.
VerifyRLimit checks whether the open-file limit is large enough.
# Constants
No description provided by the author
No description provided by the author
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.
# Structs
Backend is the delivery target for Lightning.
ClosedEngine represents a closed engine, allowing ingestion into the target.
No description provided by the author
OpenedEngine is an opened engine, allowing data to be written via WriteRows.
Range record start and end key for localStoreDir.DB so we can write it to tikv in streaming.
No description provided by the author
SessionOptions is the initial configuration of the session.
Store contains metadata about a TiKV store.
# Interfaces
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.
# Type aliases
StoreState is the state of a TiKV store.