fetch

type Config struct {
	FlushSize            int
	FlushRows            int
	Cleanup              bool
	UseCopy              bool
	TableConcurrency     int
	Shards               int
	FetchID              string
	ContinuationToken    string
	ContinuationFileName string
	// TestOnly means this fetch attempt is just for test, and hence all time/duration
	// stats are deterministic.
	TestOnly bool

	// The target table handling configs.
	Truncate bool

	DropAndRecreateNewSchema bool
	CustomizedTypeMapPath    string

	// NonInteractive relates to if user input should be prompted. If false,
	// user prompting is initiating before certain actions like wiping data.
	// If true, user prompting will be skipped and actions will be confirmed automatically.
	NonInteractive bool

	Compression        compression.Flag
	ExportSettings     dataexport.Settings
	OngoingReplication bool

	// AllowCockroachReplication gates Cockroach source replication using CDC sink.
	// TODO (rluu): remove this gate when feature is mature.
	AllowCockroachReplication bool

	// UsingDockerBackend lets fetch know if a docker backend is used
	// for the database spin up. This will affect URL pathing for
	// localstore and changefeed setup.
	UsingDockerBackend bool

	// IsTableConcurrencySet marks whether a user set the table concurrency flag.
	IsTableConcurrencySet bool
	// IsExportConcurrencySet marks whether a user set the export concurrency flag.
	IsExportConcurrencySet bool

	// ReplicatorFlags are the flags that can be passed into the replicator command.
	ReplicatorFlags string
}

type CopyResult struct {
	StartTime time.Time
	EndTime   time.Time
}

type PGIface interface {
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
}

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