v5

Documentation

Index

• type Client
  • func NewClient(clusterURL string, httpClient *http.Client) (*Client, error)
  • func (c *Client) DisableReallocation() error
  • func (c *Client) EnableReallocation() error
  • func (c *Client) ExcludeNodeFromAllocation(nodeName string) error
  • func (c *Client) ListNodes() ([]string, error)
  • func (c *Client) ListShardsOnNode(nodeName string) ([]string, error)
  • func (c *Client) Shutdown(nodeName string) error

Types

type Client

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

Client represents Elasticsearch API client

func NewClient

func NewClient(clusterURL string, httpClient *http.Client) (*Client, error)

NewClient creates new Client object

func (*Client) DisableReallocation

func (c *Client) DisableReallocation() error

DisableReallocation enables shard reallocation Modifies cluster.routing.allocation.enable to "none" https://www.elastic.co/guide/en/elasticsearch/reference/1.5/cluster-update-settings.html

func (*Client) EnableReallocation

func (c *Client) EnableReallocation() error

EnableReallocation enables shard reallocation Modifies cluster.routing.allocation.enable to "all" https://www.elastic.co/guide/en/elasticsearch/reference/1.5/cluster-update-settings.html

func (*Client) ExcludeNodeFromAllocation

func (c *Client) ExcludeNodeFromAllocation(nodeName string) error

ExcludeNodeFromAllocation excludes the given node from shard allocation group https://www.elastic.co/guide/en/elasticsearch/reference/current/allocation-filtering.html

func (*Client) ListNodes

func (c *Client) ListNodes() ([]string, error)

ListNodes returns the list of node names

func (*Client) ListShardsOnNode

func (c *Client) ListShardsOnNode(nodeName string) ([]string, error)

ListShardsOnNode returns the list of shards on the given node

func (*Client) Shutdown

func (c *Client) Shutdown(nodeName string) error

Shutdown does nothing, because Elasticsearch 2.x does not have shutdown API