harvester

type CloseChan chan bool

type Config struct {
	Logger               *logger.LoggerConfig
	Writer               map[string]*WriterConfig
	Reader               map[string]*ReaderConfig
	Format_JSON          map[string]*format.JSONConfig
	Format_CSV           map[string]*format.CSVConfig
	Format_RegExp        map[string]*format.RegExpConfig
	Format_Apache2       map[string]*format.Apache2Config
	Format_Nginx         map[string]*format.NginxConfig
	Input_File           map[string]*input.FileConfig
	Input_Tail           map[string]*input.TailConfig
	Input_S3             map[string]*input.S3Config
	Output_HTTP          map[string]*output.HTTPConfig
	Output_Elasticsearch map[string]*output.ElasticsearchConfig
	Output_Mongo         map[string]*output.MongoConfig
	Output_Dummy         map[string]*output.DummyConfig
	Processor_Anonymize  map[string]*processor.AnonymizeConfig
	Processor_Metrics    map[string]*processor.MetricsConfig
	Processor_Mutate     map[string]*processor.MutateConfig
}

type Container struct {
}

type Definition struct {
	Name          string
	AllowMultiple bool
	Fields        []*FieldDefinition
}

type FieldDefinition struct {
	Name        string
	Type        string
	Description string
	Default     string
}

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

type OutputsFactory func() []intf.Output

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

type ReaderConfig struct {
	Input     []string
	Processor []string
}

type RecordsChan chan intf.Record

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

type WriterConfig struct {
	Output  []string
	Reader  []string
	Threads int
}

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