snapshot

type Config struct {
	Position       opencdc.Position
	Tables         []string
	TableKeys      map[string]string
	TXSnapshotID   string
	FetchSize      int
	WithAvroSchema bool
}

type FetchConfig struct {
	Table          string
	Key            string
	TXSnapshotID   string
	FetchSize      int
	Position       position.Position
	WithAvroSchema bool
}

type FetchData struct {
	Key           opencdc.StructuredData
	Payload       opencdc.StructuredData
	Position      position.SnapshotPosition
	Table         string
	PayloadSchema cschema.Schema
	KeySchema     cschema.Schema
}

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

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