scanner

Documentation

Index

• type AckFn
• type Config
  • func FromAny(prov docs.Provider, value any) (conf Config, err error)
• type Creator
• type Scanner
• type SourceDetails

Types

type AckFn

type AckFn func(context.Context, error) error

AckFn is a function provided to a scanner that it should call once the derived io.ReadCloser is fully consumed.

type Config

type Config struct {
	Type   string
	Plugin any
}

func FromAny

func FromAny(prov docs.Provider, value any) (conf Config, err error)

type Creator

type Creator interface {
	Create(rdr io.ReadCloser, aFn AckFn, details SourceDetails) (Scanner, error)
	Close(context.Context) error
}

Creator is an interface implemented by all scanners, which allows components to construct a scanner from an unbounded io.ReadCloser.

type Scanner

type Scanner interface {
	Next(context.Context) (message.Batch, AckFn, error)
	Close(context.Context) error
}

Scanner is an interface implemented by all scanner implementations once a creator has instantiated it on a byte stream.

type SourceDetails

type SourceDetails struct {
	Name string
}

SourceDetails contains exclusively optional information which could be used by codec implementations in order to determine the underlying data format.