Documentation
¶
Index ¶
- Constants
- func StartReplicateIncrement(ctx context.Context, dwConnector coreinterfaces.Connector, tableFQN string, ...) error
- func StartReplicateSnapshot(ctx context.Context, dwConnector coreinterfaces.Connector, tableFQN string, ...) error
- type IncrementReplicateSession
- type SnapshotReplicateSession
Constants ¶
View Source
const (
CSVFileExtension = ".csv"
)
View Source
const (
DataWarehouseLoadConcurrency = 16
)
Variables ¶
This section is empty.
Functions ¶
func StartReplicateIncrement ¶
func StartReplicateSnapshot ¶
Types ¶
type IncrementReplicateSession ¶ added in v0.0.3
type IncrementReplicateSession struct {
// contains filtered or unexported fields
}
func NewIncrementReplicateSession ¶ added in v0.0.3
func (*IncrementReplicateSession) CheckpointExists ¶ added in v0.0.3
func (sess *IncrementReplicateSession) CheckpointExists(filePath string) bool
type SnapshotReplicateSession ¶
type SnapshotReplicateSession struct {
TiDBConfig *tidbsql.TiDBConfig
DataWarehousePool coreinterfaces.Connector
TiDBPool *sql.DB
SourceDatabase string
SourceTable string
StorageWorkspaceUri url.URL
ParrallelLoad bool
// contains filtered or unexported fields
}
func NewSnapshotReplicateSession ¶
func NewSnapshotReplicateSession( ctx context.Context, dwConnector coreinterfaces.Connector, tidbConfig *tidbsql.TiDBConfig, sourceDatabase, sourceTable string, storageUri *url.URL, parrallelLoad bool, logger *zap.Logger, ) (*SnapshotReplicateSession, error)
func (*SnapshotReplicateSession) Close ¶
func (sess *SnapshotReplicateSession) Close()
func (*SnapshotReplicateSession) Run ¶
func (sess *SnapshotReplicateSession) Run() error
Source Files
Click to show internal directories.
Click to hide internal directories.