elastic_search_utils

Documentation

Index

• func AddToIndex(indexName string, id string, body string, es7 *elasticSearch7.Client) error
• func UnwrapElasticSearchResponse(response *esapi.Response) (map[string]interface{}, error)
• func WaitForElasticSearch() *elasticSearch7.Client
• type ElasticSearchTokenStore
  • func OpenTokenStore(processorName string) *ElasticSearchTokenStore
  • func (tokenStore *ElasticSearchTokenStore) ReadToken() *int64
  • func (tokenStore *ElasticSearchTokenStore) WriteToken(token int64) error

Functions

func AddToIndex

func AddToIndex(indexName string, id string, body string, es7 *elasticSearch7.Client) error

func UnwrapElasticSearchResponse

func UnwrapElasticSearchResponse(response *esapi.Response) (map[string]interface{}, error)

func WaitForElasticSearch

func WaitForElasticSearch() *elasticSearch7.Client

Types

type ElasticSearchTokenStore

type ElasticSearchTokenStore struct {
	ProcessorName string
	ES7           *elasticSearch7.Client
}

func OpenTokenStore

func OpenTokenStore(processorName string) *ElasticSearchTokenStore

func (*ElasticSearchTokenStore) ReadToken

func (tokenStore *ElasticSearchTokenStore) ReadToken() *int64

func (*ElasticSearchTokenStore) WriteToken

func (tokenStore *ElasticSearchTokenStore) WriteToken(token int64) error