scanner

May 29, 2024

Changes in this version

+ type AckFn func(context.Context, error) error

+ type Config struct

+ Plugin any

+ Type string

+ func FromAny(prov docs.Provider, value any) (conf Config, err error)

+ type Creator interface

+ Close func(context.Context) error

+ Create func(rdr io.ReadCloser, aFn AckFn, details SourceDetails) (Scanner, error)

+ type Scanner interface

+ Close func(context.Context) error

+ Next func(context.Context) (message.Batch, AckFn, error)

+ type SourceDetails struct

+ Name string