core

type Config struct {
	Input      PluginConfig   `json:"input" yaml:"input"`
	Processors []PluginConfig `json:"processors" yaml:"processors"`
	Outputs    []PluginConfig `json:"outputs" yaml:"outputs"`
}

type ErrorHandler func(criticalFailure bool, err error)

type Input interface {
	Run(errorHandler ErrorHandler, state State, processPipe chan<- PipelineResults)
	Stop()
}

type InputHandler func(config []byte) (Input, error)

type LineProcessor func(string)

type LoadStateFunc func(id string) State

type Logger interface {
	Debugf(format string, args ...interface{})
	Infof(format string, args ...interface{})
	Warnf(format string, args ...interface{})
	Errorf(format string, args ...interface{})
	Fatalf(format string, args ...interface{})
	Panicf(format string, args ...interface{})

	Debug(args ...interface{})
	Info(args ...interface{})
	Warn(args ...interface{})
	Error(args ...interface{})
	Fatal(args ...interface{})
	Panic(args ...interface{})

	Debugln(args ...interface{})
	Infoln(args ...interface{})
	Warnln(args ...interface{})
	Errorln(args ...interface{})
	Fatalln(args ...interface{})
	Panicln(args ...interface{})
}

type Output interface {
	Write(inputFile string) (int, error)
}

type OutputHandler func(config []byte) (Output, error)

type PipelineResults struct {
	FilePath    string
	ResultCount int
	State       State
	RetryCount  int
}

type PluginConfig struct {
	Name     string          `json:"name" yaml:"name"`
	Settings json.RawMessage `json:"settings,omitempty" yaml:"settings,omitempty"`
}

type ProcessHandler func(config []byte) (Processor, error)

type Processor interface {
	Process(inputFile string, writer io.Writer) error
}

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

type SaveStateFunc func(id string, state State) error

type State []byte

type TmpWriter struct {
	WriteCount int
	// contains filtered or unexported fields
}