es

Documentation

Overview

Copyright The KubeDB Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The KubeDB Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The KubeDB Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The KubeDB Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

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) Ping(url string) (int, error)
  • func (c *ESClientV5) Stop()
  • func (c *ESClientV5) WaitForGreenStatus(timeout string) error
  • func (c *ESClientV5) WaitForYellowStatus(timeout string) error
• 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) Ping(url string) (int, error)
  • func (c *ESClientV6) Stop()
  • func (c *ESClientV6) WaitForGreenStatus(timeout string) error
  • func (c *ESClientV6) WaitForYellowStatus(timeout string) error
• 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) Ping(url string) (int, error)
  • func (c *ESClientV7) Stop()
  • func (c *ESClientV7) WaitForGreenStatus(timeout string) error
  • func (c *ESClientV7) WaitForYellowStatus(timeout string) error
• 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()
	Ping(string) (int, error)
	WaitForGreenStatus(string) error
	WaitForYellowStatus(string) error
}

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) Ping

func (c *ESClientV5) Ping(url string) (int, error)

func (*ESClientV5) Stop

func (c *ESClientV5) Stop()

func (*ESClientV5) WaitForGreenStatus

func (c *ESClientV5) WaitForGreenStatus(timeout string) error

func (*ESClientV5) WaitForYellowStatus

func (c *ESClientV5) WaitForYellowStatus(timeout string) error

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) Ping

func (c *ESClientV6) Ping(url string) (int, error)

func (*ESClientV6) Stop

func (c *ESClientV6) Stop()

func (*ESClientV6) WaitForGreenStatus

func (c *ESClientV6) WaitForGreenStatus(timeout string) error

func (*ESClientV6) WaitForYellowStatus

func (c *ESClientV6) WaitForYellowStatus(timeout string) error

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) Ping

func (c *ESClientV7) Ping(url string) (int, error)

func (*ESClientV7) Stop

func (c *ESClientV7) Stop()

func (*ESClientV7) WaitForGreenStatus

func (c *ESClientV7) WaitForGreenStatus(timeout string) error

func (*ESClientV7) WaitForYellowStatus

func (c *ESClientV7) WaitForYellowStatus(timeout string) error

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"`
}