elasticsearch

Documentation

Index

• Constants
• type Aggregations
• type Aggs
• type Body
• type Bool
• type Bucket
• type Cardinality
• type CardinalityAggregation
• type ContainerCount
• type DateHistogram
• type DateHistogramAggregation
• type Elasticsearch
  • func NewElasticsearch(options *Options) (*Elasticsearch, error)
  • func (es *Elasticsearch) ClearScroll(id string)
  • func (es *Elasticsearch) CountLogsByInterval(sf logging.SearchFilter, interval string) (logging.Histogram, error)
  • func (es *Elasticsearch) ExportLogs(sf logging.SearchFilter, w io.Writer) error
  • func (es *Elasticsearch) GetCurrentStats(sf logging.SearchFilter) (logging.Statistics, error)
  • func (es *Elasticsearch) SearchLogs(sf logging.SearchFilter, f, s int64, o string) (logging.Logs, error)
• type Hit
• type Hits
• type Kubernetes
• type LogCountOverTime
• type Match
• type Options
  • func NewElasticSearchOptions() *Options
  • func (s *Options) AddFlags(fs *pflag.FlagSet, c *Options)
  • func (s *Options) ApplyTo(options *Options)
  • func (s *Options) Validate() []error
• type Query
• type Range
• type Response
• type Source
• type Time

Constants

const (
	ElasticV5 = "5"
	ElasticV6 = "6"
	ElasticV7 = "7"
)

Types

type Aggregations

type Aggregations struct {
	ContainerCount   `json:"container_count"`
	LogCountOverTime `json:"log_count_over_time"`
}

type Aggs

type Aggs struct {
	*CardinalityAggregation   `json:"container_count,omitempty"`
	*DateHistogramAggregation `json:"log_count_over_time,omitempty"`
}

type Body

type Body struct {
	From   int64               `json:"from,omitempty"`
	Size   int64               `json:"size,omitempty"`
	Sorts  []map[string]string `json:"sort,omitempty"`
	*Query `json:"query,omitempty"`
	*Aggs  `json:"aggs,omitempty"`
}

More info: https://www.elastic.co/guide/en/elasticsearch/reference/current/getting-started-search-API.html

type Bool

type Bool struct {
	Filter             []Match `json:"filter,omitempty"`
	Should             []Match `json:"should,omitempty"`
	MinimumShouldMatch int32   `json:"minimum_should_match,omitempty"`
}

Example: {bool: {filter: <[]Match>}} {bool: {should: <[]Match>, minimum_should_match: 1}}

type Bucket

type Bucket struct {
	Time  int64 `json:"key"`
	Count int64 `json:"doc_count"`
}

type Cardinality

type Cardinality struct {
	Field string `json:"field,omitempty"`
}

type CardinalityAggregation

type CardinalityAggregation struct {
	*Cardinality `json:"cardinality,omitempty"`
}

type ContainerCount

type ContainerCount struct {
	Value int64 `json:"value"`
}

type DateHistogram

type DateHistogram struct {
	Field    string `json:"field,omitempty"`
	Interval string `json:"interval,omitempty"`
}

type DateHistogramAggregation

type DateHistogramAggregation struct {
	*DateHistogram `json:"date_histogram,omitempty"`
}

type Elasticsearch

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

Elasticsearch implement logging interface

func NewElasticsearch

func NewElasticsearch(options *Options) (*Elasticsearch, error)

func (*Elasticsearch) ClearScroll

func (es *Elasticsearch) ClearScroll(id string)

func (*Elasticsearch) CountLogsByInterval

func (es *Elasticsearch) CountLogsByInterval(sf logging.SearchFilter, interval string) (logging.Histogram, error)

func (*Elasticsearch) ExportLogs

func (es *Elasticsearch) ExportLogs(sf logging.SearchFilter, w io.Writer) error

func (*Elasticsearch) GetCurrentStats

func (es *Elasticsearch) GetCurrentStats(sf logging.SearchFilter) (logging.Statistics, error)

func (*Elasticsearch) SearchLogs

func (es *Elasticsearch) SearchLogs(sf logging.SearchFilter, f, s int64, o string) (logging.Logs, error)

type Hit

type Hit struct {
	Source `json:"_source"`
	Sort   []int64 `json:"sort"`
}

type Hits

type Hits struct {
	Total   interface{} `json:"total"` // `As of Elasticsearch v7.x, hits.total is changed incompatibly
	AllHits []Hit       `json:"hits"`
}

type Kubernetes

type Kubernetes struct {
	Namespace string `json:"namespace_name"`
	Pod       string `json:"pod_name"`
	Container string `json:"container_name"`
	Host      string `json:"host"`
}

type LogCountOverTime

type LogCountOverTime struct {
	Buckets []Bucket `json:"buckets"`
}

type Match

type Match struct {
	*Bool             `json:"bool,omitempty"`
	MatchPhrase       map[string]string `json:"match_phrase,omitempty"`
	MatchPhrasePrefix map[string]string `json:"match_phrase_prefix,omitempty"`
	Regexp            map[string]string `json:"regexp,omitempty"`
	*Range            `json:"range,omitempty"`
}

Example: []Match [

{
  bool: <Bool>
},
{
  match_phrase: {
    <string>: <string>
  }
},
...

]

type Options

type Options struct {
	Host        string `json:"host" yaml:"host"`
	IndexPrefix string `json:"indexPrefix,omitempty" yaml:"indexPrefix"`
	Version     string `json:"version" yaml:"version"`
}

func NewElasticSearchOptions

func NewElasticSearchOptions() *Options

func (*Options) AddFlags

func (s *Options) AddFlags(fs *pflag.FlagSet, c *Options)

func (*Options) ApplyTo

func (s *Options) ApplyTo(options *Options)

func (*Options) Validate

func (s *Options) Validate() []error

type Query

type Query struct {
	Bool `json:"bool,omitempty"`
}

type Range

type Range struct {
	*Time `json:"time,omitempty"`
}

type Response

type Response struct {
	ScrollId     string `json:"_scroll_id,omitempty"`
	Hits         `json:"hits,omitempty"`
	Aggregations `json:"aggregations,omitempty"`
}

type Source

type Source struct {
	Log        string `json:"log"`
	Time       string `json:"time"`
	Kubernetes `json:"kubernetes"`
}

type Time

type Time struct {
	Gte *time.Time `json:"gte,omitempty"`
	Lte *time.Time `json:"lte,omitempty"`
}