Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 Changes in this version + var ReaderDocs = ...("auto", ...) + var WriterDocs = ...("all-bytes", ...) + func GetWriter(codec string) (WriterConstructor, WriterConfig, error) + type Reader interface + Close func(context.Context) error + Next func(context.Context) ([]*message.Part, ReaderAckFn, error) + type ReaderAckFn func(context.Context, error) error + type ReaderConfig struct + MaxScanTokenSize int + func NewReaderConfig() ReaderConfig + type ReaderConstructor func(string, io.ReadCloser, ReaderAckFn) (Reader, error) + func GetReader(codec string, conf ReaderConfig) (ReaderConstructor, error) + type Writer interface + Close func(context.Context) error + Write func(context.Context, *message.Part) error + type WriterConfig struct + Append bool + CloseAfter bool + Truncate bool + type WriterConstructor func(io.WriteCloser) (Writer, error) Other modules containing this package github.com/dafanshu/benthos/v3
Go to main page