header

Documentation

Index

• Variables
• type Config
  • func NewConfig(matchRegex string, metadataOperators []operator.Config, enc encoding.Encoding) (*Config, error)
• type Reader
  • func NewReader(logger *zap.SugaredLogger, cfg Config) (*Reader, error)
  • func (r *Reader) Process(ctx context.Context, token []byte, fileAttributes map[string]any) error
  • func (r *Reader) Stop() error

Variables

var ErrEndOfHeader = errors.New("end of header")

Types

type Config

type Config struct {
	SplitFunc bufio.SplitFunc
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(matchRegex string, metadataOperators []operator.Config, enc encoding.Encoding) (*Config, error)

type Reader

type Reader struct {
	// contains filtered or unexported fields
}

func NewReader

func NewReader(logger *zap.SugaredLogger, cfg Config) (*Reader, error)

func (*Reader) Process

func (r *Reader) Process(ctx context.Context, token []byte, fileAttributes map[string]any) error

Process checks if the given token is a line of the header, and consumes it if it is. An EndOfHeaderError is returned if the given line was not a header line.

func (*Reader) Stop

func (r *Reader) Stop() error