elasticsearch

Documentation

Index

• func Setup(logger *loggerpkg.Logger)
• type ElasticSearch
  • func New(collectorId string, conf map[string]interface{}, logger *loggerpkg.Logger) *ElasticSearch
  • func (es *ElasticSearch) Write(rows []map[string]interface{}) bool
• type Timer
  • func (t *Timer) Sleep()

Functions

func Setup

func Setup(logger *loggerpkg.Logger)

Types

type ElasticSearch

type ElasticSearch struct {
	// contains filtered or unexported fields
}

func New

func New(collectorId string, conf map[string]interface{}, logger *loggerpkg.Logger) *ElasticSearch

func (*ElasticSearch) Write

func (es *ElasticSearch) Write(rows []map[string]interface{}) bool

return false to stop collector.

type Timer

type Timer struct {
	// contains filtered or unexported fields
}

func (*Timer) Sleep

func (t *Timer) Sleep()