Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

harvester

package

Go to main page

Versions in this module

v1

v1.1.0

Jan 20, 2016

Changes in this version

type Config

+ Input_Mongo map[string]*input.MongoConfig

v1.0.0

Jan 15, 2016

Changes in this version

+ type CloseChan chan bool

+ type Config struct

+ Format_Apache2 map[string]*format.Apache2Config

+ Format_CSV map[string]*format.CSVConfig

+ Format_JSON map[string]*format.JSONConfig

+ Format_Nginx map[string]*format.NginxConfig

+ Format_RegExp map[string]*format.RegExpConfig

+ Input_File map[string]*input.FileConfig

+ Input_S3 map[string]*input.S3Config

+ Input_Tail map[string]*input.TailConfig

+ Logger *logger.LoggerConfig

+ Output_Dummy map[string]*output.DummyConfig

+ Output_Elasticsearch map[string]*output.ElasticsearchConfig

+ Output_HTTP map[string]*output.HTTPConfig

+ Output_Mongo map[string]*output.MongoConfig

+ Processor_Anonymize map[string]*processor.AnonymizeConfig

+ Processor_Metrics map[string]*processor.MetricsConfig

+ Processor_Mutate map[string]*processor.MutateConfig

+ Reader map[string]*ReaderConfig

+ Writer map[string]*WriterConfig

+ func GetConfig() *Config

+ func (c *Config) GetDescription() []*Definition

+ func (c *Config) Load(ini string)

+ func (c *Config) LoadFile(filename string)

+ type Container struct

+ func GetContainer() *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 struct

+ AllowMultiple bool

+ Fields []*FieldDefinition

+ Name string

+ type FieldDefinition struct

+ Default string

+ Description string

+ Name string

+ Type string

+ type Harvester struct

+ func NewHarvester() *Harvester

+ func (h *Harvester) Boot()

+ func (h *Harvester) Configure(filename string)

+ func (h *Harvester) PrintCounters(elapsedSeconds int)

+ func (h *Harvester) Run()

+ type OutputsFactory func() []intf.Output

+ type Reader struct

+ func NewReader() *Reader

+ func (r *Reader) GoRead()

+ func (r *Reader) SetChannels(recordsChan RecordsChan, closeChan CloseChan)

+ func (r *Reader) SetInputs(inputs []intf.Input)

+ func (r *Reader) SetProcessors(processors []intf.PostProcessor)

+ func (r *Reader) Teardown()

+ type ReaderConfig struct

+ Input []string

+ Processor []string

+ type RecordsChan chan intf.Record

+ type Writer struct

+ func NewWriter() *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 struct

+ Output []string

+ Reader []string

+ Threads int

+ type WriterGroup struct

+ func NewWriterGroup() *WriterGroup

+ func (wg *WriterGroup) Boot()

+ func (wg *WriterGroup) GetCounters() (int32, int32, int32, int32)

+ func (wg *WriterGroup) IsAlive() bool

+ func (wg *WriterGroup) ResetCounters()

+ func (wg *WriterGroup) SetWriters(writers []intf.Writer)

+ func (wg *WriterGroup) Setup()

+ func (wg *WriterGroup) Teardown()

v0

v0.0.5-rc2

Oct 15, 2015

v0.0.4-rc1

Jun 18, 2015