elasticsearch

May 7, 2021

Changes in this version

+ func New(options map[string]interface{}) (collector.Client, error)

+ type Client struct

+ Options map[string]interface{}

+ func (esClient *Client) ClientType() collector.ClientType

+ func (esClient *Client) Exit() (err error)

+ func (esClient *Client) Poll(timestamp time.Time, resultsChannel chan<- string, pollOffset int) (count int, currentTimestamp time.Time, err error)

+ func (esClient *Client) Stream(streamChannel chan<- string) (cancelFunc func(), err error)