qhandler_elasticsearch

package module

v0.1.14 Latest Latest Go to latest Published: Sep 7, 2017 License: Apache-2.0 Imports: 14 Imported by: 1

Details

QFrame handler to push messages to elasticsearch

This section is empty.

This section is empty.

This section is empty.

type Logstash struct {
	Settings interface{} `json:"settings"`
	Mappings interface{} `json:"mappings"`
}

func NewLogstash(shards, replicas int) Logstash

func (l *Logstash) GetConfig() (interface{}, error)

type Plugin struct {
	*qtypes_plugin.Plugin

	KVtoFields map[string]string
	SkipKV     []string
	// contains filtered or unexported fields
}

Plugin holds a buffer and the initial information from the server

func New(qChan qtypes_qchannel.QChan, cfg *config.Config, name string) (Plugin, error)

New returns an initial instance

func (p *Plugin) ParseKVtoFields()

func (p *Plugin) ParseSkipKV()

func (p *Plugin) Run()

Run pushes the logs to elasticsearch

type Settings struct {
	NumShards   int "json:`index.number_of_shards`"
	NumReplicas int "json:`index.number_of_replicas`"
}

Path	Synopsis
cmd
qhandler-elasticsearch command