Versions in this module Expand all Collapse all v4 v4.27.1 May 31, 2024 v4.27.0 May 31, 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
Go to main page