longpoll

Sep 27, 2022

Changes in this version

+ const MetadataPostgresTable

Apr 5, 2022

Changes in this version

+ var ErrNoRows = fmt.Errorf("no more rows")

+ var ErrSnapshotInterrupt = fmt.Errorf("interrupted snapshot")

+ type SnapshotIterator struct

+ func NewSnapshotIterator(ctx context.Context, conn *pgx.Conn, table string, columns []string, ...) (*SnapshotIterator, error)

+ func (s *SnapshotIterator) Ack(context.Context, sdk.Position) error

+ func (s *SnapshotIterator) Next(ctx context.Context) (sdk.Record, error)

+ func (s *SnapshotIterator) Teardown(ctx context.Context) error