codec

Documentation

Index

• func DeprecatedCodecFields(defaultScanner string) []*service.ConfigField
• type DeprecatedFallbackCodec
  • func DeprecatedCodecFromParsed(conf *service.ParsedConfig) (DeprecatedFallbackCodec, error)
• type DeprecatedFallbackStream

Functions

func DeprecatedCodecFields

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

DeprecatedCodecFields contain definitions for deprecated codec fields that allow backwards compatible migration towards the new scanner field.

New plugins should instead use the new scanner fields.

Types

type DeprecatedFallbackCodec

type DeprecatedFallbackCodec interface {
	Create(rdr io.ReadCloser, aFn service.AckFunc, details *service.ScannerSourceDetails) (DeprecatedFallbackStream, error)
	Close(context.Context) error
}

DeprecatedFallbackCodec provides a common interface that abstracts either an old codec implementation or a new scanner.

func DeprecatedCodecFromParsed

func DeprecatedCodecFromParsed(conf *service.ParsedConfig) (DeprecatedFallbackCodec, error)

DeprecatedCodecFromParsed attempts to create a deprecated fallback codec from a parsed config.

type DeprecatedFallbackStream

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

DeprecatedFallbackStream provides a common interface that abstracts either an old codec implementation or a new scanner.