Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

es

package

Go to main page

Versions in this module

v1

v1.2.4

Nov 4, 2022

v1.2.3

Oct 18, 2022

v1.2.2

Oct 10, 2022

v1.2.1

Sep 12, 2022

v1.2.0

Jun 30, 2022

v1.1.2

Feb 21, 2022

v1.1.1

Oct 8, 2021

v1.1.0

Oct 6, 2021

Changes in this version

type Client

+ GetFlavor func() Flavor

+ type Flavor string

+ const Elasticsearch

+ const OpenSearch

v1.0.0

Aug 24, 2021

Changes in this version

+ const DateFormatEpochMS

+ var NewClient = func(ctx context.Context, ds *backend.DataSourceInstanceSettings, ...) (Client, error)

+ func GetSigV4Config(ds *backend.DataSourceInstanceSettings) (*sigv4.Config, error)

+ type Agg struct

+ Aggregation *aggContainer

+ Key string

+ func (a *Agg) MarshalJSON() ([]byte, error)

+ type AggArray []*Agg

+ func (a AggArray) MarshalJSON() ([]byte, error)

+ type AggBuilder interface

+ Build func() (AggArray, error)

+ DateHistogram func(key, field string, fn func(a *DateHistogramAgg, b AggBuilder)) AggBuilder

+ Filters func(key string, fn func(a *FiltersAggregation, b AggBuilder)) AggBuilder

+ GeoHashGrid func(key, field string, fn func(a *GeoHashGridAggregation, b AggBuilder)) AggBuilder

+ Histogram func(key, field string, fn func(a *HistogramAgg, b AggBuilder)) AggBuilder

+ Metric func(key, metricType, field string, fn func(a *MetricAggregation)) AggBuilder

+ Pipeline func(key, pipelineType string, bucketPath interface{}, ...) AggBuilder

+ Terms func(key, field string, fn func(a *TermsAggregation, b AggBuilder)) AggBuilder

+ type Aggregation interface

+ type BoolQuery struct

+ Filters []Filter

+ func (q *BoolQuery) MarshalJSON() ([]byte, error)

+ type BoolQueryBuilder struct

+ func NewBoolQueryBuilder() *BoolQueryBuilder

+ func (b *BoolQueryBuilder) Build() (*BoolQuery, error)

+ func (b *BoolQueryBuilder) Filter() *FilterQueryBuilder

+ type Client interface

+ EnableDebug func()

+ ExecuteMultisearch func(r *MultiSearchRequest) (*MultiSearchResponse, error)

+ ExecutePPLQuery func(r *PPLRequest) (*PPLResponse, error)

+ GetIndex func() string

+ GetMinInterval func(queryInterval string) (time.Duration, error)

+ GetTimeField func() string

+ GetVersion func() *semver.Version

+ MultiSearch func() *MultiSearchRequestBuilder

+ PPL func() *PPLRequestBuilder

+ type Datarow []interface

+ type DateHistogramAgg struct

+ ExtendedBounds *ExtendedBounds

+ Field string

+ Format string

+ Interval string

+ MinDocCount int

+ Missing *string

+ Offset string

+ type ExtendedBounds struct

+ Max string

+ Min string

+ type FieldSchema struct

+ Name string

+ Type string

+ type Filter interface

+ type FilterQueryBuilder struct

+ func NewFilterQueryBuilder() *FilterQueryBuilder

+ func (b *FilterQueryBuilder) AddDateRangeFilter(timeField, lte, gte, format string) *FilterQueryBuilder

+ func (b *FilterQueryBuilder) AddQueryStringFilter(querystring string, analyseWildcard bool) *FilterQueryBuilder

+ func (b *FilterQueryBuilder) Build() ([]Filter, error)

+ type FiltersAggregation struct

+ Filters map[string]interface{}

+ type GeoHashGridAggregation struct

+ Field string

+ Precision int

+ type HistogramAgg struct

+ Field string

+ Interval int

+ MinDocCount int

+ Missing *int

+ type MetricAggregation struct

+ Field string

+ Settings map[string]interface{}

+ func (a *MetricAggregation) MarshalJSON() ([]byte, error)

+ type MultiSearchRequest struct

+ Requests []*SearchRequest

+ type MultiSearchRequestBuilder struct

+ func NewMultiSearchRequestBuilder(version *semver.Version) *MultiSearchRequestBuilder

+ func (m *MultiSearchRequestBuilder) Build() (*MultiSearchRequest, error)

+ func (m *MultiSearchRequestBuilder) Search(interval tsdb.Interval) *SearchRequestBuilder

+ type MultiSearchResponse struct

+ DebugInfo *SearchDebugInfo

+ Responses []*SearchResponse

+ Status int

+ type PPLDebugInfo struct

+ Request *PPLRequestInfo

+ Response *PPLResponseInfo

+ type PPLRequest struct

+ Query string

+ func (req *PPLRequest) MarshalJSON() ([]byte, error)

+ type PPLRequestBuilder struct

+ func NewPPLRequestBuilder(index string) *PPLRequestBuilder

+ func (b *PPLRequestBuilder) AddPPLQueryString(timeField, to, from, querystring string) *PPLRequestBuilder

+ func (b *PPLRequestBuilder) Build() (*PPLRequest, error)

+ type PPLRequestInfo struct

+ Data string

+ Method string

+ URL string

+ type PPLResponse struct

+ Datarows []Datarow

+ DebugInfo *PPLDebugInfo

+ Error map[string]interface{}

+ Schema []FieldSchema

+ Status int

+ type PPLResponseInfo struct

+ Data *simplejson.Json

+ Status int

+ type PipelineAggregation struct

+ BucketPath interface{}

+ Settings map[string]interface{}

+ func (a *PipelineAggregation) MarshalJSON() ([]byte, error)

+ type Query struct

+ Bool *BoolQuery

+ type QueryBuilder struct

+ func NewQueryBuilder() *QueryBuilder

+ func (b *QueryBuilder) Bool() *BoolQueryBuilder

+ func (b *QueryBuilder) Build() (*Query, error)

+ type QueryStringFilter struct

+ AnalyzeWildcard bool

+ Query string

+ func (f *QueryStringFilter) MarshalJSON() ([]byte, error)

+ type RangeFilter struct

+ Format string

+ Gte string

+ Key string

+ Lte string

+ func (f *RangeFilter) MarshalJSON() ([]byte, error)

+ type SearchDebugInfo struct

+ Request *SearchRequestInfo

+ Response *SearchResponseInfo

+ type SearchRequest struct

+ Aggs AggArray

+ CustomProps map[string]interface{}

+ Index string

+ Interval tsdb.Interval

+ Query *Query

+ Size int

+ Sort map[string]interface{}

+ func (r *SearchRequest) MarshalJSON() ([]byte, error)

+ type SearchRequestBuilder struct

+ func NewSearchRequestBuilder(version *semver.Version, interval tsdb.Interval) *SearchRequestBuilder

+ func (b *SearchRequestBuilder) AddDocValueField(field string) *SearchRequestBuilder

+ func (b *SearchRequestBuilder) Agg() AggBuilder

+ func (b *SearchRequestBuilder) Build() (*SearchRequest, error)

+ func (b *SearchRequestBuilder) Query() *QueryBuilder

+ func (b *SearchRequestBuilder) Size(size int) *SearchRequestBuilder

+ func (b *SearchRequestBuilder) SortDesc(field, unmappedType string) *SearchRequestBuilder

+ type SearchRequestInfo struct

+ Data string

+ Method string

+ Url string

+ type SearchResponse struct

+ Aggregations map[string]interface{}

+ Error map[string]interface{}

+ Hits *SearchResponseHits

+ type SearchResponseHits struct

+ Hits []map[string]interface{}

+ type SearchResponseInfo struct

+ Data *simplejson.Json

+ Status int

+ type TermsAggregation struct

+ Field string

+ MinDocCount *int

+ Missing *string

+ Order map[string]interface{}

+ Size int