csv

Documentation

Index

• type CSVParser
  • func (r *CSVParser) Process(ctx context.Context, entry *entry.Entry) error
• type CSVParserConfig
  • func NewCSVParserConfig(operatorID string) *CSVParserConfig
  • func (c CSVParserConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Types

type CSVParser

type CSVParser struct {
	helper.ParserOperator
	// contains filtered or unexported fields
}

CSVParser is an operator that parses csv in an entry.

func (*CSVParser) Process

func (r *CSVParser) Process(ctx context.Context, entry *entry.Entry) error

Process will parse an entry for csv.

type CSVParserConfig

type CSVParserConfig struct {
	helper.ParserConfig `yaml:",inline"`

	Header         string `json:"header" yaml:"header"`
	FieldDelimiter string `json:"delimiter,omitempty" yaml:"delimiter,omitempty"`
}

CSVParserConfig is the configuration of a csv parser operator.

func NewCSVParserConfig

func NewCSVParserConfig(operatorID string) *CSVParserConfig

NewCSVParserConfig creates a new csv parser config with default values

func (CSVParserConfig) Build

func (c CSVParserConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Build will build a csv parser operator.