elasticsearch: kubedb.dev/elasticsearch/pkg/util/es Index | Files

package es

import "kubedb.dev/elasticsearch/pkg/util/es"

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

Package Files

api.go es_client_v5.go es_client_v6.go es_client_v7.go

Constants

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

type ESClient Uses

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 Uses

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

type ESClientV5 Uses

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

func (*ESClientV5) CountIndex Uses

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

func (*ESClientV5) CreateIndex Uses

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

func (*ESClientV5) GetAllNodesInfo Uses

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

func (*ESClientV5) GetIndexNames Uses

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

func (*ESClientV5) Ping Uses

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

func (*ESClientV5) Stop Uses

func (c *ESClientV5) Stop()

func (*ESClientV5) WaitForGreenStatus Uses

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

func (*ESClientV5) WaitForYellowStatus Uses

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

type ESClientV6 Uses

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

func (*ESClientV6) CountIndex Uses

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

func (*ESClientV6) CreateIndex Uses

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

func (*ESClientV6) GetAllNodesInfo Uses

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

func (*ESClientV6) GetIndexNames Uses

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

func (*ESClientV6) Ping Uses

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

func (*ESClientV6) Stop Uses

func (c *ESClientV6) Stop()

func (*ESClientV6) WaitForGreenStatus Uses

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

func (*ESClientV6) WaitForYellowStatus Uses

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

type ESClientV7 Uses

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

func (*ESClientV7) CountIndex Uses

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

func (*ESClientV7) CreateIndex Uses

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

func (*ESClientV7) GetAllNodesInfo Uses

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

func (*ESClientV7) GetIndexNames Uses

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

func (*ESClientV7) Ping Uses

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

func (*ESClientV7) Stop Uses

func (c *ESClientV7) Stop()

func (*ESClientV7) WaitForGreenStatus Uses

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

func (*ESClientV7) WaitForYellowStatus Uses

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

type NodeInfo Uses

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

type NodeSetting Uses

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 Uses

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

type Setting Uses

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

Package es imports 15 packages (graph) and is imported by 2 packages. Updated 2020-07-03. Refresh now. Tools for package owners.