interop

Mar 1, 2024

Changes in this version

+ func OldReaderCodecFields(defaultScanner string) []*service.ConfigField

+ type FallbackReaderCodec interface

+ Close func(context.Context) error

+ Create func(rdr io.ReadCloser, aFn service.AckFunc, details scanner.SourceDetails) (FallbackReaderStream, error)

+ func OldReaderCodecFromParsed(conf *service.ParsedConfig) (FallbackReaderCodec, error)

+ type FallbackReaderStream interface

+ Close func(context.Context) error

+ NextBatch func(ctx context.Context) (service.MessageBatch, service.AckFunc, error)