Versions in this module Expand all Collapse all v0 v0.1.0 Aug 14, 2023 Changes in this version + var ErrKeyIsNotExist = errors.New("key is not exist") + var ErrNoInitializedIterator = errors.New("not initialized iterator") + var ErrOrderingColumnIsNotExist = errors.New("ordering column is not exist") + var ErrUnknownOperatorType = errors.New("unknown iterator type") + var ErrWrongTrackingIDType = errors.New("tracking id wrong type") + type CDCIterator struct + func NewCDCIterator(ctx context.Context, db *sqlx.DB, table, trackingTable, key string, ...) (*CDCIterator, error) + func (i *CDCIterator) Ack(_ context.Context, pos *position.Position) error + func (i *CDCIterator) ClearTrackingTable(ctx context.Context) + func (i *CDCIterator) DeleteRows(ctx context.Context, ids []any) error + func (i *CDCIterator) HasNext(ctx context.Context) (bool, error) + func (i *CDCIterator) Next(ctx context.Context) (sdk.Record, error) + func (i *CDCIterator) Stop(ctx context.Context) error + type CombinedIterator struct + func NewCombinedIterator(ctx context.Context, db *sqlx.DB, conn, table, key, orderingColumn string, ...) (*CombinedIterator, error) + func (c *CombinedIterator) Ack(ctx context.Context, rp sdk.Position) error + func (c *CombinedIterator) HasNext(ctx context.Context) (bool, error) + func (c *CombinedIterator) Next(ctx context.Context) (sdk.Record, error) + func (c *CombinedIterator) SetupCDC(ctx context.Context, db *sqlx.DB) error + func (c *CombinedIterator) Stop(ctx context.Context) error + type SnapshotIterator struct + func NewSnapshotIterator(ctx context.Context, db *sqlx.DB, table, orderingColumn, key string, ...) (*SnapshotIterator, error) + func (i *SnapshotIterator) Ack(ctx context.Context, p sdk.Position) error + func (i *SnapshotIterator) HasNext(ctx context.Context) (bool, error) + func (i *SnapshotIterator) Next(ctx context.Context) (sdk.Record, error) + func (i *SnapshotIterator) Stop(context.Context) error
Go to main page