interop

Documentation

Index

• func OldReaderCodecFields(defaultScanner string) []*service.ConfigField
• type FallbackReaderCodec
  • func OldReaderCodecFromParsed(conf *service.ParsedConfig) (FallbackReaderCodec, error)
• type FallbackReaderStream

Functions

func OldReaderCodecFields

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

Types

type FallbackReaderCodec

type FallbackReaderCodec interface {
	Create(rdr io.ReadCloser, aFn service.AckFunc, details scanner.SourceDetails) (FallbackReaderStream, error)
	Close(context.Context) error
}

func OldReaderCodecFromParsed

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

type FallbackReaderStream

type FallbackReaderStream interface {
	NextBatch(ctx context.Context) (service.MessageBatch, service.AckFunc, error)
	Close(context.Context) error
}