source

type CDCMode string

type Config struct {
	URL     string
	Table   string
	Columns []string
	Key     string

	// SnapshotMode determines if and when a snapshot is made.
	SnapshotMode SnapshotMode
	// CDCMode determines how the connector should listen to changes.
	CDCMode CDCMode

	// LogreplPublicationName determines the publication name in case the
	// connector uses logical replication to listen to changes (see CDCMode).
	LogreplPublicationName string
	// LogreplSlotName determines the replication slot name in case the
	// connector uses logical replication to listen to changes (see CDCMode).
	LogreplSlotName string
}

type Iterator interface {
	// Next takes and returns the next record from the queue. Next is allowed to
	// block until either a record is available or the context gets canceled.
	Next(context.Context) (sdk.Record, error)
	// Ack signals that a record at a specific position was successfully
	// processed.
	Ack(context.Context, sdk.Position) error
	// Teardown attempts to gracefully teardown the iterator.
	Teardown(context.Context) error
}

type SnapshotMode string

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