datasync

type Runner struct {
	// contains filtered or unexported fields
}

type Sync struct {
	// MaxConnections limits each SQL pool; worker counts do not expand it.
	MaxConnections int    `` /* 147-byte string literal not displayed */
	SourceDSN      string `name:"source-dsn" help:"Where to sync the tables from." default:"spirit:spirit@tcp(127.0.0.1:3306)/src"`
	TargetDSN      string `name:"target-dsn" help:"Where to sync the tables to." default:"spirit:spirit@tcp(127.0.0.1:3306)/dest"`
	// TargetChunkSize is the in-memory byte budget the buffered copier sizes each
	// copy chunk against (see table.DefaultTargetChunkBytes). Sync always uses the
	// buffered copier. A zero value means "use the default" (the runner fills it
	// in). The Kong default below must stay equal to table.DefaultTargetChunkBytes.
	TargetChunkSize uint64 `name:"target-chunk-size" help:"In-memory byte budget per copy chunk (in bytes)." default:"16777216"`
	Threads         int    `name:"threads" help:"How many chunks to copy in parallel during the initial copy." default:"4"`
	WriteThreads    int    `name:"write-threads" help:"How many concurrent write threads to use on the target." default:"4"`
	// FlushInterval controls how often buffered changes are applied to the
	// target during continuous sync — i.e. the replication latency vs.
	// batching trade-off. Defaults to change.DefaultFlushInterval.
	FlushInterval time.Duration `name:"flush-interval" help:"How often to flush buffered changes to the target during continuous sync." default:"30s"`

	// DeferSecondaryIndexes creates the target tables without their secondary
	// indexes, then adds the indexes back once the initial copy has completed.
	// Bulk-loading an index-free table is faster and lighter on temporary
	// space; the indexes are rebuilt in one ALTER per table afterwards. Only
	// safe when the target is not yet serving reads, because the tables briefly
	// lack their secondary indexes. UNIQUE/FULLTEXT/SPATIAL indexes are kept on
	// the initial CREATE (only regular secondary indexes are deferred), the
	// same as `move --defer-secondary-indexes`.
	DeferSecondaryIndexes bool `` /* 139-byte string literal not displayed */

	// Force, when set, makes the runner wipe the sync-owned objects on the
	// target at startup — the target copies of the source tables plus the sync
	// checkpoint table — *unless* a resumable checkpoint exists, i.e. it only
	// wipes when the copy could not have resumed anyway. A resumable run
	// (checkpoint present) is left intact and resumes as normal. The wipe is
	// per-table, never DROP DATABASE: sync tolerates a target database shared
	// with unrelated tables, and --force must not destroy tables the sync
	// never owned. Intended for testing/iterating, where a previous partial
	// run can leave the target non-empty with no usable checkpoint, otherwise
	// tripping the fresh-sync target-empty guard.
	Force bool `` /* 159-byte string literal not displayed */

	// Source optionally provides a pre-constructed change.Source to use
	// for replication instead of constructing a built-in MySQL-binlog
	// client from SourceDSN. When set, the runner uses this as the change
	// feed. SourceDSN is still required for source-side SQL (SHOW TABLES,
	// SHOW CREATE TABLE, the initial-copy SELECTs). Setting Source requires
	// setting Applier (see below).
	//
	// Intended for callers (e.g. strata's Vitess/PlanetScale import) that
	// need a non-MySQL-binlog change source.
	Source change.Source `kong:"-"`

	// Applier optionally provides a pre-constructed applier.Applier. When
	// set, the runner uses this instead of constructing a MySQL
	// SingleTargetApplier from the target. Required when Source is set: the
	// injected change.Source needs the same applier instance the copier
	// uses, so all writes flow through one logical apply path.
	Applier applier.Applier `kong:"-"`

	// Target optionally supplies a pre-opened target. When nil, a single
	// MySQL target is opened from TargetDSN (auto-creating the database if
	// it does not exist). Sync writes to exactly one logical target — there
	// is no N:M fan-out.
	Target *applier.Target `kong:"-"`
}