Versions in this module Expand all Collapse all v0 v0.3.0 Sep 27, 2022 Changes in this version + func NewSource() sdk.Source + type Iterator interface + HasNext func(ctx context.Context) bool + Next func(ctx context.Context) (sdk.Record, error) + Stop func() + type Source struct + func (s *Source) Ack(ctx context.Context, pos sdk.Position) error + func (s *Source) Configure(ctx context.Context, cfg map[string]string) error + func (s *Source) Open(ctx context.Context, pos 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