Documentation
¶
Index ¶
- type CloseChan
- type Config
- type Container
- func (c *Container) GetFormat(key string) intf.Format
- func (c *Container) GetInput(key string) intf.Input
- func (c *Container) GetOutput(key string) intf.Output
- func (c *Container) GetPostProcessor(key string) intf.PostProcessor
- func (c *Container) GetReader(key string) *Reader
- func (c *Container) GetWriter(key string) *Writer
- func (c *Container) GetWriterGroup() *WriterGroup
- type Definition
- type FieldDefinition
- type Harvesterd
- type OutputsFactory
- type Reader
- type ReaderConfig
- type RecordsChan
- type Writer
- func (w *Writer) Boot()
- func (w *Writer) GetChannels() (RecordsChan, CloseChan)
- func (w *Writer) GetCounters() (int32, int32, int32, int32)
- func (w *Writer) IsAlive() bool
- func (w *Writer) ResetCounters()
- func (w *Writer) SetOutputsFactory(factory OutputsFactory)
- func (w *Writer) SetReaders(readers []*Reader)
- func (w *Writer) SetThreads(threads int)
- func (w *Writer) Setup()
- func (w *Writer) Teardown()
- type WriterConfig
- type WriterGroup
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
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
}
func (*Config) GetDescription ¶
func (c *Config) GetDescription() []*Definition
type Container ¶
type Container struct {
}
func GetContainer ¶
func GetContainer() *Container
func (*Container) GetPostProcessor ¶
func (c *Container) GetPostProcessor(key string) intf.PostProcessor
func (*Container) GetWriterGroup ¶
func (c *Container) GetWriterGroup() *WriterGroup
type Definition ¶
type Definition struct {
Name string
AllowMultiple bool
Fields []*FieldDefinition
}
type FieldDefinition ¶
type Harvesterd ¶
type Harvesterd struct {
// contains filtered or unexported fields
}
func NewHarvesterd ¶
func NewHarvesterd() *Harvesterd
func (*Harvesterd) Boot ¶
func (h *Harvesterd) Boot()
func (*Harvesterd) Configure ¶
func (h *Harvesterd) Configure(filename string)
func (*Harvesterd) PrintCounters ¶
func (h *Harvesterd) PrintCounters(elapsedSeconds int)
func (*Harvesterd) Run ¶
func (h *Harvesterd) Run()
type OutputsFactory ¶
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
func (*Reader) SetChannels ¶
func (r *Reader) SetChannels(recordsChan RecordsChan, closeChan CloseChan)
func (*Reader) SetProcessors ¶
func (r *Reader) SetProcessors(processors []intf.PostProcessor)
type ReaderConfig ¶
type RecordsChan ¶
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
func (*Writer) GetChannels ¶
func (w *Writer) GetChannels() (RecordsChan, CloseChan)
func (*Writer) ResetCounters ¶
func (w *Writer) ResetCounters()
func (*Writer) SetOutputsFactory ¶
func (w *Writer) SetOutputsFactory(factory OutputsFactory)
func (*Writer) SetReaders ¶
func (*Writer) SetThreads ¶
type WriterConfig ¶
type WriterGroup ¶
type WriterGroup struct {
// contains filtered or unexported fields
}
func NewWriterGroup ¶
func NewWriterGroup() *WriterGroup
func (*WriterGroup) Boot ¶
func (wg *WriterGroup) Boot()
func (*WriterGroup) GetCounters ¶
func (wg *WriterGroup) GetCounters() (int32, int32, int32, int32)
func (*WriterGroup) IsAlive ¶
func (wg *WriterGroup) IsAlive() bool
func (*WriterGroup) ResetCounters ¶
func (wg *WriterGroup) ResetCounters()
func (*WriterGroup) SetWriters ¶
func (wg *WriterGroup) SetWriters(writers []intf.Writer)
func (*WriterGroup) Setup ¶
func (wg *WriterGroup) Setup()
func (*WriterGroup) Teardown ¶
func (wg *WriterGroup) Teardown()
Source Files
¶
Click to show internal directories.
Click to hide internal directories.