updates

Documentation

Index

• type Elasticsearch
  • func (u *Elasticsearch) Handle(event interface{}) interface{}
  • func (u *Elasticsearch) Listen() string
  • func (u *Elasticsearch) Priority() int

Types

type Elasticsearch

type Elasticsearch struct {
	Service       string
	Elasticsearch *elastic.Client
}

func (*Elasticsearch) Handle

func (u *Elasticsearch) Handle(event interface{}) interface{}

func (*Elasticsearch) Listen

func (u *Elasticsearch) Listen() string

func (*Elasticsearch) Priority

func (u *Elasticsearch) Priority() int