elasticsearch

Documentation

Index

• Constants
• type ClientV5
  • func (c *ClientV5) ExSearch(r *Request) (*Response, error)
  • func (c *ClientV5) Version() (string, error)
• type ClientV6
  • func (c *ClientV6) ExSearch(r *Request) (*Response, error)
• type ClientV7
  • func (c *ClientV7) ExSearch(r *Request) (*Response, error)
• type Elasticsearch
  • func NewClient(options *Options) (*Elasticsearch, error)
  • func (es *Elasticsearch) CountOverTime(filter *auditing.Filter, interval string) (*auditing.Histogram, error)
  • func (es *Elasticsearch) SearchAuditingEvent(filter *auditing.Filter, from, size int64, sort string) (*auditing.Events, error)
  • func (es *Elasticsearch) StatisticsOnResources(filter *auditing.Filter) (*auditing.Statistics, error)
• type Error
  • func (e Error) Error() string
• type Hits
• 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 Request
• type Response

Constants

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

Types

type ClientV5

type ClientV5 es5.Client

func (*ClientV5) ExSearch

func (c *ClientV5) ExSearch(r *Request) (*Response, error)

func (*ClientV5) Version

func (c *ClientV5) Version() (string, error)

type ClientV6

type ClientV6 es6.Client

func (*ClientV6) ExSearch

func (c *ClientV6) ExSearch(r *Request) (*Response, error)

type ClientV7

type ClientV7 es7.Client

func (*ClientV7) ExSearch

func (c *ClientV7) ExSearch(r *Request) (*Response, error)

type Elasticsearch

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

func NewClient

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

func (*Elasticsearch) CountOverTime

func (es *Elasticsearch) CountOverTime(filter *auditing.Filter, interval string) (*auditing.Histogram, error)

func (*Elasticsearch) SearchAuditingEvent

func (es *Elasticsearch) SearchAuditingEvent(filter *auditing.Filter, from, size int64,
	sort string) (*auditing.Events, error)

func (*Elasticsearch) StatisticsOnResources

func (es *Elasticsearch) StatisticsOnResources(filter *auditing.Filter) (*auditing.Statistics, error)

type Error

type Error struct {
	Type   string `json:"type"`
	Reason string `json:"reason"`
	Status int    `json:"status"`
}

func (Error) Error

func (e Error) Error() string

type Hits

type Hits struct {
	Total int64               `json:"total"`
	Hits  jsoniter.RawMessage `json:"hits"`
}

type Options

type Options struct {
	Enable      bool   `json:"enable" yaml:"enable"`
	WebhookUrl  string `json:"webhookUrl" yaml:"webhookUrl"`
	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 Request

type Request struct {
	Index string
	Body  io.Reader
}

type Response

type Response struct {
	Hits         Hits                           `json:"hits"`
	Aggregations map[string]jsoniter.RawMessage `json:"aggregations"`
}