source

Feb 4, 2025

Changes in this version

type Source

+ func (s *Source) Config() sdk.SourceConfig

Aug 7, 2024

Changes in this version

+ const ConfigAwsAccessKeyId

+ const ConfigAwsBucket

+ const ConfigAwsRegion

+ const ConfigAwsSecretAccessKey

+ const ConfigPollingPeriod

+ const ConfigPrefix

Apr 11, 2023

Changes in this version

type Config

+ func (Config) Parameters() map[string]sdk.Parameter

Sep 27, 2022

Changes in this version

type Source

+ func (s *Source) Parameters() map[string]sdk.Parameter

Apr 5, 2022

Changes in this version

+ const ConfigKeyPollingPeriod

+ const DefaultPollingPeriod

+ func NewSource() sdk.Source

+ 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) (sdk.Record, error)

+ Stop func()

+ type Source struct

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

+ func (s *Source) Configure(ctx context.Context, cfg map[string]string) error

+ func (s *Source) Open(ctx context.Context, rp sdk.Position) error

+ func (s *Source) Read(ctx context.Context) (sdk.Record, error)

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