client

package

v1.0.2 Latest Latest Go to latest Published: Sep 30, 2026 License: GPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	Client http.Client
	URLs   []*url.URL
}

func NewClient(urls []*url.URL, rt http.RoundTripper) *Client

func (c *Client) Health() (*es.HealthResponse, error)

Health retrieves the Cluster's health state

func (c *Client) NodeStats() (*es.ClusterStats, error)

NodeStats retrieves the Cluster's node statistics

func (c *Client) Perform(req *http.Request) (*http.Response, error)

Perform wraps the Client's HTTP call so that we can try all given nodes in case one node is not reachable

func (c *Client) SearchMessages(index string, query string, messageKey string) (uint, []string, error)

SearchMessages runs a query_string query and returns the count of documents and the requesed values via messageKey

func (c *Client) Snapshot(repository string, snapshot string) (*es.SnapshotResponse, error)

Snapshot retrieves the cluster's snapshot states