source

type Config struct {
	config.Config

	// OrderingColumn is a name of a column that the connector will use for ordering rows.
	OrderingColumn string `json:"orderingColumn" validate:"required"`
	// Columns  list of column names that should be included in each Record's payload.
	Columns []string `json:"columns"`
	// BatchSize is the size of rows batch.
	BatchSize int `json:"batchSize" default:"1000" validate:"gt=1,lt=100000"`
	// Key - Column name that records should use for their `Key` fields.
	Key string `json:"primaryKey"`
	// Snapshot whether the plugin will take a snapshot of the entire table before starting cdc.
	Snapshot bool `default:"true"`
}

type Iterator interface {
	HasNext(ctx context.Context) (bool, error)
	Next(ctx context.Context) (sdk.Record, error)
	Stop(ctx context.Context) error
	Ack(ctx context.Context, rp sdk.Position) error
}

type Source struct {
	sdk.UnimplementedSource
	// contains filtered or unexported fields
}