source

type Config struct {
	config.Config

	// OrderingColumn is a name of a column that the connector will use for ordering rows.
	OrderingColumn string `key:"orderingColumn" validate:"required,max=128"`
	// Columns  list of column names that should be included in each Record's payload.
	Columns []string `key:"columns" validate:"contains_or_default=OrderingColumn,dive,max=128"`
	// BatchSize is a size of rows batch.
	BatchSize int `key:"batchSize" validate:"gte=1,lte=100000"`
	// PrimaryKeys list of column names should use for their `Key` fields.
	PrimaryKeys []string `validate:"dive,max=128"`
	// Snapshot whether or not the plugin will take a snapshot of the entire table before starting cdc.
	Snapshot bool
}

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

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