elastic

Documentation

Index

• type Elastic
  • func NewClient(host, schema string) (*Elastic, error)
  • func (e *Elastic) PushRecords(data []events.KinesisEventRecord) error

Types

type Elastic

type Elastic struct {
	Client *elastic.Client
}

Elastic is our default struct for connecting through to elasticsearch

func NewClient

func NewClient(host, schema string) (*Elastic, error)

NewClient instantiates a connection to elasticsearch for direct push

func (*Elastic) PushRecords

func (e *Elastic) PushRecords(data []events.KinesisEventRecord) error

PushRecords sends a particular batch of docs over to elasticsearch endpoint