query

Documentation

Index

• Constants
• type ElasticClient
  • func CreateElasticSearchClient(addrs []string) (*ElasticClient, error)
  • func (es *ElasticClient) Close()
  • func (es *ElasticClient) DeleteIndex(indexName string) error
  • func (es *ElasticClient) GetHitsForInListWithHystrix(startTime time.Time, indexName string, key string, whiteList ...interface{}) (chan *QueryHitResult, chan error)
  • func (es *ElasticClient) GetHitsForItem(startTime time.Time, indexName string, key string, value string) (int64, error)
  • func (es *ElasticClient) GetHitsForItemWithHystrix(startTime time.Time, indexName string, key string, value string) (chan *QueryHitResult, chan error)
  • func (es *ElasticClient) GetHitsForNotInListWithHystrix(startTime time.Time, indexName string, key string, blackList ...interface{}) (chan *QueryHitResult, chan error)
  • func (es *ElasticClient) GetHitsForQueryString(startTime time.Time, indexName string, msg string) (int64, error)
  • func (es *ElasticClient) GetHitsForQueryStringWithHystrix(startTime time.Time, indexName string, msg string) (chan *QueryHitResult, chan error)
  • func (es *ElasticClient) GetIndex() ([]string, error)
  • func (es *ElasticClient) GetIndexByPrefix(name string) ([]string, error)
• type QueryHitResult

Constants

const (
	DefaultHystrixTimeout    = 5000
	DefaultHystrixMaxRequest = 3
)

Types

type ElasticClient

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

func CreateElasticSearchClient

func CreateElasticSearchClient(addrs []string) (*ElasticClient, error)

func (*ElasticClient) Close

func (es *ElasticClient) Close()

func (*ElasticClient) DeleteIndex

func (es *ElasticClient) DeleteIndex(indexName string) error

func (*ElasticClient) GetHitsForInListWithHystrix

func (es *ElasticClient) GetHitsForInListWithHystrix(startTime time.Time,
	indexName string, key string, whiteList ...interface{}) (chan *QueryHitResult, chan error)

func (*ElasticClient) GetHitsForItem

func (es *ElasticClient) GetHitsForItem(startTime time.Time, indexName string, key string, value string) (int64, error)

func (*ElasticClient) GetHitsForItemWithHystrix

func (es *ElasticClient) GetHitsForItemWithHystrix(startTime time.Time,
	indexName string, key string, value string) (chan *QueryHitResult, chan error)

func (*ElasticClient) GetHitsForNotInListWithHystrix

func (es *ElasticClient) GetHitsForNotInListWithHystrix(startTime time.Time,
	indexName string, key string, blackList ...interface{}) (chan *QueryHitResult, chan error)

func (*ElasticClient) GetHitsForQueryString

func (es *ElasticClient) GetHitsForQueryString(startTime time.Time, indexName string, msg string) (int64, error)

func (*ElasticClient) GetHitsForQueryStringWithHystrix

func (es *ElasticClient) GetHitsForQueryStringWithHystrix(startTime time.Time,
	indexName string, msg string) (chan *QueryHitResult, chan error)

func (*ElasticClient) GetIndex

func (es *ElasticClient) GetIndex() ([]string, error)

func (*ElasticClient) GetIndexByPrefix

func (es *ElasticClient) GetIndexByPrefix(name string) ([]string, error)

GetIndexByPrefix Get Index by prefix

type QueryHitResult

type QueryHitResult struct {
	Hits int64
	Took int64
}