elastic

Documentation

Index

• type Elastic
  • func NewElasticStorage() *Elastic
  • func (e *Elastic) GetMessage(msgId string) (doc map[string]interface{}, err error)
  • func (e *Elastic) GetMessages(q *storage.SearchQuery) (result *storage.SearchResult, err error)
  • func (e *Elastic) HandleMessage(msg *gelf.Message)
  • func (e *Elastic) PeriodicFlush(die chan bool)
  • func (e *Elastic) ValidateQuery(query string) (err error)

Types

type Elastic

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

func NewElasticStorage

func NewElasticStorage() *Elastic

Returns object to work with bleve

func (*Elastic) GetMessage

func (e *Elastic) GetMessage(msgId string) (doc map[string]interface{}, err error)

Returns message from elastic index

func (*Elastic) GetMessages

func (e *Elastic) GetMessages(q *storage.SearchQuery) (result *storage.SearchResult, err error)

Searches for mssages

func (*Elastic) HandleMessage

func (e *Elastic) HandleMessage(msg *gelf.Message)

Handles GELF-message received through UDP

func (*Elastic) PeriodicFlush

func (e *Elastic) PeriodicFlush(die chan bool)

Periodically flushes messages to elastic

func (*Elastic) ValidateQuery

func (e *Elastic) ValidateQuery(query string) (err error)

Validates search query