Versions in this module Expand all Collapse all v0 v0.1.14 Sep 7, 2017 v0.1.13 Aug 31, 2017 Changes in this version + type Logstash struct + Mappings interface{} + Settings interface{} + func NewLogstash(shards, replicas int) Logstash + func (l *Logstash) GetConfig() (interface{}, error) + type Plugin struct + KVtoFields map[string]string + SkipKV []string + func New(qChan qtypes_qchannel.QChan, cfg *config.Config, name string) (Plugin, error) + func (p *Plugin) ParseKVtoFields() + func (p *Plugin) ParseSkipKV() + func (p *Plugin) Run() + type Settings struct + NumReplicas int + NumShards int
Go to main page