Versions in this module Expand all Collapse all v0 v0.1.0 Aug 14, 2023 Changes in this version + const KeyBatchSize + const KeyColumns + const KeyOrderingColumn + const KeyPrimaryKey + const KeySnapshot + func New() sdk.Source + type Config struct + BatchSize int + Columns []string + Key string + OrderingColumn string + Snapshot bool + func (Config) Parameters() map[string]sdk.Parameter + type Iterator interface + Ack func(ctx context.Context, rp sdk.Position) error + HasNext func(ctx context.Context) (bool, error) + Next func(ctx context.Context) (sdk.Record, error) + Stop func(ctx context.Context) error + type Source struct + func (s *Source) Ack(ctx context.Context, p sdk.Position) error + func (s *Source) Configure(_ context.Context, cfg map[string]string) error + func (s *Source) Open(ctx context.Context, rp sdk.Position) error + func (s *Source) Parameters() map[string]sdk.Parameter + func (s *Source) Read(ctx context.Context) (sdk.Record, error) + func (s *Source) Teardown(ctx context.Context) error
Go to main page