source

Jan 20, 2022

Changes in this version

+ const ConfigKeyPollingPeriod

+ const DefaultPollingPeriod

+ type Config struct

+ PollingPeriod time.Duration

+ func Parse(cfg map[string]string) (Config, error)

+ type Iterator interface

+ HasNext func(ctx context.Context) bool

+ Next func(ctx context.Context) (record.Record, error)

+ Stop func()

+ type Source struct

+ func (s *Source) Ack(ctx context.Context, position record.Position) error

+ func (s *Source) Open(ctx context.Context, cfg plugins.Config) error

+ func (s *Source) Read(ctx context.Context, rp record.Position) (record.Record, error)

+ func (s *Source) Teardown() error

+ func (s *Source) Validate(cfg plugins.Config) error