dataexport

type PGReplicationSlotSettings struct {
	SlotName     string
	Plugin       string
	DropIfExists bool
}

type Settings struct {
	RowBatchSize int

	PG PGReplicationSlotSettings

	CRDBPTSExtensionFreq     time.Duration
	CRDBPTSExtensionLifetime time.Duration
}

type Source interface {
	CDCCursor() string
	Conn(ctx context.Context) (SourceConn, error)
	Close(ctx context.Context) error

	// HistoryRetention means to extend the expiration of a protected timestamp (PTS). A
	// SELECT ... AS OF SYSTEM TIME command with a PTS will not be invalidated by garbage collection.
	// A PTS is created when creating the
	// cockroachdb datasource (i.e. NewCRDBSource()) via the crdb_internal.protect_mvcc_history(<timestamp>, <lifetime>,
	// <description>).
	// At time t, if extend the history retention job, the job's expiration timestamp will be updated to {t + <lifetime>}.
	HistoryRetentionJobManagement(ctx context.Context, logger zerolog.Logger, exportFinished chan struct{}, renewInterval time.Duration, extensionCnt *int64, testOnly bool, ts *testutils.FetchTestingKnobs) (jobManagementFinished *errgroup.Group)
	ReplicatorCommand(bin string, target dbconn.Conn, db tree.Name, sc tree.Name, replicatorArgs string) (*exec.Cmd, error)
}

type SourceConn interface {
	Export(ctx context.Context, writer io.Writer, table dbtable.VerifiedTable, shard rowverify.TableShard) error
	Close(ctx context.Context) error
}