es

Documentation

Index

• Constants
• type ESClient
  • func GetElasticClient(kc kubernetes.Interface, extClient cs.Interface, db *api.Elasticsearch, ...) (ESClient, error)
• type ESClientV5
  • func (c *ESClientV5) CountIndex() (int, error)
  • func (c *ESClientV5) CreateIndex(count int) error
  • func (c *ESClientV5) GetAllNodesInfo() ([]NodeInfo, error)
  • func (c *ESClientV5) GetIndexNames() ([]string, error)
  • func (c *ESClientV5) Stop()
• type ESClientV6
  • func (c *ESClientV6) CountIndex() (int, error)
  • func (c *ESClientV6) CreateIndex(count int) error
  • func (c *ESClientV6) GetAllNodesInfo() ([]NodeInfo, error)
  • func (c *ESClientV6) GetIndexNames() ([]string, error)
  • func (c *ESClientV6) Stop()
• type ESClientV7
  • func (c *ESClientV7) CountIndex() (int, error)
  • func (c *ESClientV7) CreateIndex(count int) error
  • func (c *ESClientV7) GetAllNodesInfo() ([]NodeInfo, error)
  • func (c *ESClientV7) GetIndexNames() ([]string, error)
  • func (c *ESClientV7) Stop()
• type NodeInfo
• type NodeSetting
• type PathSetting
• type Setting

Constants

const (
	KeyAdminUserName = "ADMIN_USERNAME"
	KeyAdminPassword = "ADMIN_PASSWORD"
)

Types

type ESClient

type ESClient interface {
	CreateIndex(count int) error
	CountIndex() (int, error)
	GetIndexNames() ([]string, error)
	GetAllNodesInfo() ([]NodeInfo, error)
	Stop()
}

func GetElasticClient

func GetElasticClient(kc kubernetes.Interface, extClient cs.Interface, db *api.Elasticsearch, url string) (ESClient, error)

type ESClientV5

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

func (*ESClientV5) CountIndex

func (c *ESClientV5) CountIndex() (int, error)

func (*ESClientV5) CreateIndex

func (c *ESClientV5) CreateIndex(count int) error

func (*ESClientV5) GetAllNodesInfo

func (c *ESClientV5) GetAllNodesInfo() ([]NodeInfo, error)

func (*ESClientV5) GetIndexNames

func (c *ESClientV5) GetIndexNames() ([]string, error)

func (*ESClientV5) Stop

func (c *ESClientV5) Stop()

type ESClientV6

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

func (*ESClientV6) CountIndex

func (c *ESClientV6) CountIndex() (int, error)

func (*ESClientV6) CreateIndex

func (c *ESClientV6) CreateIndex(count int) error

func (*ESClientV6) GetAllNodesInfo

func (c *ESClientV6) GetAllNodesInfo() ([]NodeInfo, error)

func (*ESClientV6) GetIndexNames

func (c *ESClientV6) GetIndexNames() ([]string, error)

func (*ESClientV6) Stop

func (c *ESClientV6) Stop()

type ESClientV7

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

func (*ESClientV7) CountIndex

func (c *ESClientV7) CountIndex() (int, error)

func (*ESClientV7) CreateIndex

func (c *ESClientV7) CreateIndex(count int) error

func (*ESClientV7) GetAllNodesInfo

func (c *ESClientV7) GetAllNodesInfo() ([]NodeInfo, error)

func (*ESClientV7) GetIndexNames

func (c *ESClientV7) GetIndexNames() ([]string, error)

func (*ESClientV7) Stop

func (c *ESClientV7) Stop()

type NodeInfo

type NodeInfo struct {
	Name     string   `json:"name,omitempty"`
	Roles    []string `json:"roles,omitempty"`
	Settings *Setting `json:"settings,omitempty"`
}

type NodeSetting

type NodeSetting struct {
	Name   string `json:"name,omitempty"`
	Data   string `json:"data,omitempty"`
	Ingest string `json:"ingest,omitempty"`
	Master string `json:"master,omitempty"`
}

type PathSetting

type PathSetting struct {
	Data []string `json:"data,omitempty"`
	Logs string   `json:"logs,omitempty"`
	Home string   `json:"home,omitempty"`
}

type Setting

type Setting struct {
	Node *NodeSetting `json:"node,omitempty"`
	Path *PathSetting `json:"path,omitempty"`
}