iterator

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

type CDCParams struct {
	Repo           *repository.Oracle
	Position       *Position
	Table          string
	TrackingTable  string
	Trigger        string
	OrderingColumn string
	KeyColumns     []string
	Columns        []string
	BatchSize      int
}

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

type Mode string

type Params struct {
	Position *Position
	URL      string
	Table    string

	SnapshotTable string
	TrackingTable string
	Trigger       string

	OrderingColumn string
	KeyColumns     []string
	Snapshot       bool
	Columns        []string

	BatchSize int
}

type Position struct {
	// Mode represents current iterator mode.
	Mode Mode `json:"mode"`

	// LastProcessedVal represents the last processed value from ordering column.
	LastProcessedVal any    `json:"last_processed_val"`
	TrackingTable    string `json:"tracking_table"`
	Trigger          string `json:"trigger"`
	SnapshotTable    string `json:"snapshot_table"`
}

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

type SnapshotParams struct {
	Repo           *repository.Oracle
	Position       *Position
	Table          string
	SnapshotTable  string
	TrackingTable  string
	Trigger        string
	OrderingColumn string
	KeyColumns     []string
	Columns        []string
	BatchSize      int
	ColumnTypes    map[string]columntypes.ColumnDescription
}