qhandler_elasticsearch

README

handler-elasticsearch

QFrame handler to push messages to elasticsearch

Documentation

Index

• type Logstash
  • func NewLogstash(shards, replicas int) Logstash
  • func (l *Logstash) GetConfig() (interface{}, error)
• type Plugin
  • 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

Types

type Logstash

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

func NewLogstash

func NewLogstash(shards, replicas int) Logstash

func (*Logstash) GetConfig

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

type Plugin

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

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

New returns an initial instance

func (*Plugin) ParseKVtoFields

func (p *Plugin) ParseKVtoFields()

func (*Plugin) ParseSkipKV

func (p *Plugin) ParseSkipKV()

func (*Plugin) Run

func (p *Plugin) Run()

Run pushes the logs to elasticsearch

type Settings

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