input

type Config interface {
	Validate(parsers map[string]parser.Config, log *logrus.Entry) error
	GetName() string
	ShouldDieOnInputChange() bool
}

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

type CsvColumnConfig struct {
	Name   string `yaml:"name"`
	Parser string `yaml:"parser"`
}

type CsvConfig struct {
	Name              string             `yaml:"name"`
	Type              string             `yaml:"type"`
	Path              string             `yaml:"path"`
	DieOnInputChange  *bool              `yaml:"dieOnInputChange"`
	IgnoreFirstRow    bool               `yaml:"ignoreFirstRow"`
	AutodetectColumns bool               `yaml:"autodetectColumns"`
	Delimiter         string             `yaml:"delimiter"`
	Columns           []*CsvColumnConfig `yaml:"columns"`
	ColumnIndexByName map[string]int
	Logger            *logrus.Entry
}

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

type Input interface {
	Name() string
	Get(position record.Position) (record.Record, error)
	Size() (int64, error)
	ModTime() (time.Time, error)

	// Iterates all the records in the input, ordered
	// from the smallest to the biggest position
	// The second returned parameter is a callback that
	// must be used to close the relevant resources
	IterateAll() (record.Iterator, func() error, error)

	Close() error
}

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

type JsonConfig struct {
	Name             string `yaml:"name"`
	Type             string `yaml:"type"`
	Path             string `yaml:"path"`
	DieOnInputChange *bool  `yaml:"dieOnInputChange"`
	Logger           *logrus.Entry
}

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

type List = map[string]Input

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

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

type XmlConfig struct {
	Name             string               `yaml:"name"`
	Type             string               `yaml:"type"`
	Path             string               `yaml:"path"`
	DieOnInputChange *bool                `yaml:"dieOnInputChange"`
	Properties       []*XmlPropertyConfig `yaml:"properties"`
	RecordXPath      string               `yaml:"recordXpath"`
	Logger           *logrus.Entry
}

type XmlInputPropertyType string

type XmlPropertyConfig struct {
	Name          string               `yaml:"name"`
	Type          XmlInputPropertyType `yaml:"type"`
	Parser        string               `yaml:"parser"`
	XPath         string               `yaml:"xpath"`
	Items         *XmlPropertyConfig   `yaml:"items"`
	Properties    []*XmlPropertyConfig `yaml:"properties"`
	CompiledXPath *xpath.Expr
}

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