elasticsearch

Documentation

Index

• func Save(client *elastic.Client, index string, item event.Event) (err error)
• func Search(client *elastic.Client, ...) (items []event.Event, err error)
• type ElasticClt
  • func (e *ElasticClt) GetEvents(namespace, kind, kindName string)
  • func (e *ElasticClt) Init(c config.Config) (err error)
  • func (e *ElasticClt) ObjectCreated(obj event.Event)
  • func (e *ElasticClt) ObjectDeleted(obj event.Event)
  • func (e *ElasticClt) ObjectUpdated(obj event.Event)

Functions

func Save

func Save(client *elastic.Client, index string, item event.Event) (err error)

func Search

func Search(client *elastic.Client, index, InvolvedNamespace, InvolvedKind, InvolvedName string, limit int) (items []event.Event, err error)

Search 根据条件查询ES中的event，此处用于查询pod事件，通常参数为namespace，podname,limit

Types

type ElasticClt

type ElasticClt struct {
	Client *elastic.Client
	Conf   config.ElasticsearchConf
}

func (*ElasticClt) GetEvents

func (e *ElasticClt) GetEvents(namespace, kind, kindName string)

func (*ElasticClt) Init

func (e *ElasticClt) Init(c config.Config) (err error)

func (*ElasticClt) ObjectCreated

func (e *ElasticClt) ObjectCreated(obj event.Event)

func (*ElasticClt) ObjectDeleted

func (e *ElasticClt) ObjectDeleted(obj event.Event)

func (*ElasticClt) ObjectUpdated

func (e *ElasticClt) ObjectUpdated(obj event.Event)