iterator

Documentation

Index

• Variables
• type CDCIterator
  • func NewCDCIterator(pollingPeriod time.Duration, client *container.Client, from time.Time, ...) (*CDCIterator, error)
  • func (w *CDCIterator) HasNext(_ context.Context) bool
  • func (w *CDCIterator) Next(ctx context.Context) (opencdc.Record, error)
  • func (w *CDCIterator) Stop()
• type CombinedIterator
  • func NewCombinedIterator(pollingPeriod time.Duration, client *container.Client, maxResults int32, ...) (c *CombinedIterator, err error)
  • func (c *CombinedIterator) HasNext(ctx context.Context) bool
  • func (c *CombinedIterator) Next(ctx context.Context) (opencdc.Record, error)
  • func (c *CombinedIterator) Stop()
• type Iterator
• type SnapshotIterator
  • func NewSnapshotIterator(client *container.Client, p position.Position, maxResults int32) (*SnapshotIterator, error)
  • func (w *SnapshotIterator) HasNext(_ context.Context) bool
  • func (w *SnapshotIterator) Next(ctx context.Context) (opencdc.Record, error)
  • func (w *SnapshotIterator) Stop()

Variables

var ErrCDCIteratorIsStopped = errors.New("CDC iterator is stopped")

var ErrSnapshotIteratorIsStopped = errors.New("snapshot iterator is stopped")

var ErrUnsupportedIterator = errors.New("unsupported iterator")

Types

type CDCIterator

type CDCIterator struct {
	// contains filtered or unexported fields
}

func NewCDCIterator

func NewCDCIterator(
	pollingPeriod time.Duration,
	client *container.Client,
	from time.Time,
	maxResults int32,
) (*CDCIterator, error)

func (*CDCIterator) HasNext

func (w *CDCIterator) HasNext(_ context.Context) bool

func (*CDCIterator) Next

func (w *CDCIterator) Next(ctx context.Context) (opencdc.Record, error)

func (*CDCIterator) Stop

func (w *CDCIterator) Stop()

type CombinedIterator

type CombinedIterator struct {
	// contains filtered or unexported fields
}

func NewCombinedIterator

func NewCombinedIterator(
	pollingPeriod time.Duration,
	client *container.Client,
	maxResults int32,
	p position.Position,
) (c *CombinedIterator, err error)

func (*CombinedIterator) HasNext

func (c *CombinedIterator) HasNext(ctx context.Context) bool

func (*CombinedIterator) Next

func (c *CombinedIterator) Next(ctx context.Context) (opencdc.Record, error)

func (*CombinedIterator) Stop

func (c *CombinedIterator) Stop()

type Iterator

type Iterator interface {
	// HasNext indicates whether there is new opencdc.Record available (`true`) or not (`false`)
	HasNext(ctx context.Context) bool

	// Next returns new opencdc.Record while reading the container or error when operation failed
	Next(ctx context.Context) (opencdc.Record, error)

	// Stop informs the iterator to stop processing new records.
	// All currently ongoing operations should be gracefully shut down.
	Stop()
}

type SnapshotIterator

type SnapshotIterator struct {
	// contains filtered or unexported fields
}

func NewSnapshotIterator

func NewSnapshotIterator(
	client *container.Client,
	p position.Position,
	maxResults int32,
) (*SnapshotIterator, error)

func (*SnapshotIterator) HasNext

func (w *SnapshotIterator) HasNext(_ context.Context) bool

func (*SnapshotIterator) Next

func (w *SnapshotIterator) Next(ctx context.Context) (opencdc.Record, error)

func (*SnapshotIterator) Stop

func (w *SnapshotIterator) Stop()