codec

type Reader ¶

type Reader interface {
	Next(context.Context) ([]*message.Part, ReaderAckFn, error)
	Close(context.Context) error
}

Reader is a codec type that reads message parts from a source.

type ReaderAckFn ¶

type ReaderAckFn func(context.Context, error) error

ReaderAckFn is a function provided to a reader codec that it should call once the underlying io.ReadCloser is fully consumed.

type ReaderConfig ¶

type ReaderConfig struct {
	MaxScanTokenSize int
}

ReaderConfig is a general configuration struct that covers all reader codecs.

func NewReaderConfig() ReaderConfig

type ReaderConstructor ¶

type ReaderConstructor func(string, io.ReadCloser, ReaderAckFn) (Reader, error)

ReaderConstructor creates a reader from a filename, an io.ReadCloser and an ack func which is called by the reader once the io.ReadCloser is finished with. The filename can be empty and is usually ignored, but might be necessary for certain codecs.

func GetReader(codec string, conf ReaderConfig) (ReaderConstructor, error)

type SuffixFn ¶ added in v4.25.0

type SuffixFn func(data []byte) ([]byte, bool)

func GetWriter(codec string) (sFn SuffixFn, appendMode bool, err error)

type WriterConfig ¶

type WriterConfig struct {
	Append bool
}