vulcanizer

package module
v0.14.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 30, 2024 License: MIT Imports: 13 Imported by: 4

README

vulcanizer

GitHub's ops focused Elasticsearch library

build status GoDoc Go Report Card release

This project is a golang library for interacting with an Elasticsearch cluster. It's goal is to provide a high level API to help with common tasks that are associated with operating an Elasticsearch cluster such as querying health status of the cluster, migrating data off of nodes, updating cluster settings, etc.

This project does not aim to be a fully-featured API client for querying or indexing to Elasticsearch.

Go API

You can perform custom operations in your Go application.

import "github.com/github/vulcanizer"

v = vulcanizer.NewClient("localhost", 9200)
oldSetting, newSetting, err := v.SetSetting("indices.recovery.max_bytes_per_sec", "1000mb")
Command line application

This project produces a vulcanizer binary that is a command line application that can be used to manage your Elasticsearch cluster.

$ vulcanizer help
Usage:
  vulcanizer [command]

Available Commands:
  aliases         Interact with aliases of the cluster.
  allocation      Set shard allocation on the cluster.
  analyze         Analyze text given an analyzer or a field and index.
  drain           Drain a server or see what servers are draining.
  fill            Fill servers with data, removing shard allocation exclusion rules.
  health          Display the health of the cluster.
  heap            Display the node heap stats.
  help            Help about any command
  hotthreads      Display the current hot threads by node in the cluster.
  indices         Display the indices of the cluster.
  mappings        Display the mappings of the specified index.
  nodeallocations Display the nodes of the cluster and their disk usage/allocation.
  nodes           Display the nodes of the cluster.
  repository      Interact with the configured snapshot repositories.
  setting         Interact with cluster settings.
  settings        Display all the settings of the cluster.
  shards          Get shard data by cluster node(s).
  snapshot        Interact with a specific snapshot.

Flags:
      --cacert string       Path to the certificate to check the cluster certificates against
      --cert string         Path to the certificate to use for client certificate authentication
  -c, --cluster string      Cluster to connect to defined in config file
  -f, --configFile string   Configuration file to read in (default to "~/.vulcanizer.yaml")
  -h, --help                help for vulcanizer
      --host string         Host to connect to (default "localhost")
      --key string          Path to the key to use for client certificate authentication
      --password string     Password to use during authentication
      --path string         Path to prepend to queries, in case Elasticsearch is behind a reverse proxy
  -p, --port int            Port to connect to (default 9200)
      --protocol string     Protocol to use when querying the cluster. Either 'http' or 'https'. Defaults to 'http' (default "http")
  -k, --skipverify string   Skip verifying server's TLS certificate. Defaults to 'false', ie. verify the server's certificate (default "false")
      --user string         User to use during authentication

Use "vulcanizer [command] --help" for more information about a command.
Roadmap and future releases

The proposed future for vulcanizer can be found in our ROADMAP.

Configuration and connection information

All commands take --cluster <name> to look up information in a configuration file in ~/.vulcanizer.yaml. The configuration should be in the form of

local:
  host: localhost
  port: 9200
staging:
  host: 10.10.2.1
  port: 9201
production:
  host: 10.10.1.1
  port: 9202

Alternatively, all commands take --host and --port for the connection information.

For example:

# Query for cluster health on the "local" cluster
vulcanizer health --cluster local

# Query for nodes against the node 10.10.2.1 and port 9202
vulcanizer nodes --host 10.10.2.1 --port 9202
Development

./script/build will compile the project and install the vulcanizer binary to $GOPATH/bin.

./script/test will run the tests in the project.

Supported Elasticsearch versions

Integration tests are set up to run against the latest v5 and v6 versions of Elasticsearch.

Name

Vulcanization is the process of making rubber more elastic, so vulcanizer is the library that makes Elasticsearch easier to work with!

Project status

This project is under active development.

Contributing

This repository is open to contributions. Please also see code of conduct

To get up and running, install the project into your $GOPATH and run the set up scripts.

go get github.com/github/vulcanizer

cd $GOPATH/src/github.com/github/vulcanizer

./script/bootstrap
./script/test

And the test suite should execute correctly.

License

This project is released under the MIT LICENSE. Please note it includes 3rd party dependencies release under their own licenses; dependencies are listed in our go.mod file. When using the GitHub logos, be sure to follow the GitHub logo guidelines.

Authors

Authored by GitHub Engineering

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrRepositoryNameRequired = errors.New("Repository Name is required")
	ErrRepositoryTypeRequired = errors.New("Repository Type is required")
)

Functions

This section is empty.

Types

type Alias added in v0.5.0 

type Alias struct {
	Name          string `json:"alias"`
	IndexName     string `json:"index"`
	Filter        string `json:"filter"`
	RoutingIndex  string `json:"routing.index"`
	RoutingSearch string `json:"routing.search"`
}

Holds information about an Elasticsearch alias, based on the _cat/aliases API: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cat-alias.html

type AliasAction added in v0.5.0 

type AliasAction struct {
	ActionType AliasActionType
	IndexName  string `json:"index"`
	AliasName  string `json:"alias"`
}

Holds information needed to perform an alias modification, based on the aliases API: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/indices-aliases.html

func (*AliasAction) MarshalJSON added in v0.5.0 

func (ac *AliasAction) MarshalJSON() ([]byte, error)

type AliasActionType added in v0.5.0 

type AliasActionType string

Represent the two possible aliases actions: add or remove 

const (
	AddAlias    AliasActionType = "add"
	RemoveAlias AliasActionType = "remove"
)

type AllocateStalePrimary added in v0.13.0 

type AllocateStalePrimary struct {
	// The node ID or node name of the node to assign the shard to.
	Node string `json:"node,omitempty"`

	// The name of the index containing the shard to be assigned.
	Index string `json:"index,omitempty"`

	// The shard ID of the shard to be assigned.
	Shard *int `json:"shard,omitempty"`

	// If a node which has the good copy of the data rejoins the cluster later on, that data will be deleted or overwritten with the data of the stale copy that was forcefully allocated with this command.
	AcceptDataLoss bool `json:"accept_data_loss,omitempty"`
}

type Auth added in v0.4.0 

type Auth struct {
	User     string
	Password string
}

type Client 

type Client struct {
	Host      string
	Port      int
	Secure    bool
	Path      string
	TLSConfig *tls.Config
	Timeout   time.Duration
	*Auth
}

Hold connection information to a Elasticsearch cluster.

func NewClient 

func NewClient(host string, port int) *Client

Initialize a new vulcanizer client to use. Deprecated: NewClient has been deprecated in favor of using struct initialization.

func (*Client) AllocateStalePrimaryShard added in v0.13.0 

func (c *Client) AllocateStalePrimaryShard(node, index string, shard int) error

AllocateStalePrimary allows to manually allocate a stale primary shard to a specific node

func (*Client) AnalyzeText added in v0.4.0 

func (c *Client) AnalyzeText(analyzer, text string) ([]Token, error)

Call the analyze API with sample text and an analyzer. https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-analyze.html

Use case: You want to see how Elasticsearch will break up sample text given a specific analyzer.

func (*Client) AnalyzeTextWithField added in v0.4.0 

func (c *Client) AnalyzeTextWithField(index, field, text string) ([]Token, error)

Call the analyze API with sample text on an index and a specific field . https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-analyze.html

Use case: You have a particular field that might have custom analyzers and you want to see how this field will tokenize some particular text.

func (*Client) CloseIndex added in v0.5.0 

func (c *Client) CloseIndex(indexName string) error

Close an index on the cluster

Use case: You want to close an opened index

func (*Client) ClusterAllocationExplain added in v0.11.0 

func (c *Client) ClusterAllocationExplain(req *ClusterAllocationExplainRequest, prettyOutput bool) (string, error)

ClusterAllocationExplain provides an explanation for a shard’s current allocation. For more info, please check https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-allocation-explain.html

func (*Client) ClusterAllocationExplainWithQueryParams added in v0.14.3 

func (c *Client) ClusterAllocationExplainWithQueryParams(req *ClusterAllocationExplainRequest, params map[string]string) (string, error)

ClusterAllocationExplainWithQueryParams provides an explanation for a shard’s current allocation with optional query parameters. For more info, please check https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-allocation-explain.html

func (*Client) DeleteIndex added in v0.4.0 

func (c *Client) DeleteIndex(indexName string) error

Delete an index in the cluster.

Use case: You want to remove an index and all of its data.

func (*Client) DeleteIndexWithQueryParameters added in v0.14.0 

func (c *Client) DeleteIndexWithQueryParameters(indexName string, queryParamMap map[string][]string) error

Delete an index in the cluster with query parameters.

Use case: You want to remove an index and all of its data. You also want to specify query parameters such as timeout.

func (*Client) DeleteSnapshot added in v0.2.0 

func (c *Client) DeleteSnapshot(repository string, snapshot string) error

Delete a snapshot

Use case: You want to delete older snapshots so that they don't take up extra space.

func (*Client) DrainServer 

func (c *Client) DrainServer(serverToDrain string) (ExcludeSettings, error)

Set shard allocation exclusion rules such that the Elasticsearch node with the name `serverToDrain` is excluded. This should cause Elasticsearch to migrate shards away from that node.

Use case: You need to restart an Elasticsearch node. In order to do so safely, you should migrate data away from it. Calling `DrainServer` with the node name will move data off of the specified node.

func (*Client) FillAll 

func (c *Client) FillAll() (ExcludeSettings, error)

Removes all shard allocation exclusion rules.

Use case: You had been performing maintenance on a number of Elasticsearch nodes. They are all ready to receive data again. Calling `FillAll` will remove all the allocation exclusion rules on the cluster, allowing Elasticsearch to freely allocate shards on the previously excluded nodes.

func (*Client) FillOneServer 

func (c *Client) FillOneServer(serverToFill string) (ExcludeSettings, error)

Set shard allocation exclusion rules such that the Elasticsearch node with the name `serverToFill` is no longer being excluded. This should cause Elasticsearch to migrate shards to that node.

Use case: You have completed maintenance on an Elasticsearch node and it's ready to hold data again. Calling `FillOneServer` with the node name will remove that node name from the shard exclusion rules and allow data to be relocated onto the node.

func (*Client) GetAliases added in v0.5.0 

func (c *Client) GetAliases(alias string) ([]Alias, error)

Get a subset the aliases in the cluster.

Use case: You want to see some basic info on a subset of the aliases of the cluster

func (*Client) GetAllAliases added in v0.5.0 

func (c *Client) GetAllAliases() ([]Alias, error)

Get all the aliases in the cluster.

Use case: You want to see some basic info on all the aliases of the cluster

func (*Client) GetAllIndices added in v0.5.0 

func (c *Client) GetAllIndices() ([]Index, error)

Get all the indices in the cluster.

Use case: You want to see some basic info on all the indices of the cluster.

func (*Client) GetClusterExcludeSettings 

func (c *Client) GetClusterExcludeSettings() (ExcludeSettings, error)

Get current cluster settings for shard allocation exclusion rules.

func (*Client) GetClusterSettings added in v0.4.0 

func (c *Client) GetClusterSettings() (ClusterSettings, error)

Get all the persistent and transient cluster settings.

Use case: You want to see the current settings in the cluster.

func (*Client) GetHealth 

func (c *Client) GetHealth() (ClusterHealth, error)

Get the health of the cluster.

Use case: You want to see information needed to determine if the Elasticsearch cluster is healthy (green) or not (yellow/red).

func (*Client) GetHiddenIndices added in v0.14.0 

func (c *Client) GetHiddenIndices(index string) ([]Index, error)

Get a subset of indices including hidden ones

func (*Client) GetHotThreads added in v0.9.0 

func (c *Client) GetHotThreads() (string, error)

GetHotThreads allows to get the current hot threads on each node on the cluster

func (*Client) GetIndexSettings added in v0.4.0 

func (c *Client) GetIndexSettings(index string) ([]Setting, error)

Get the settings of an index in a machine-oriented format.

Use case: You can view the custom settings that are set on a particular index.

func (*Client) GetIndices 

func (c *Client) GetIndices(index string) ([]Index, error)

Get a subset of indices

func (*Client) GetNodeAllocations added in v0.6.0 

func (c *Client) GetNodeAllocations() ([]Node, error)

Get all the nodes and their allocation/disk usage in the cluster.

Use case: You want to see how much disk is being used by the nodes in the cluster.

func (*Client) GetNodeJVMStats added in v0.6.0 

func (c *Client) GetNodeJVMStats() ([]NodeStats, error)

func (*Client) GetNodes 

func (c *Client) GetNodes() ([]Node, error)

Get all the nodes in the cluster.

Use case: You want to see what nodes Elasticsearch considers part of the cluster.

func (*Client) GetNodesHotThreads added in v0.10.0 

func (c *Client) GetNodesHotThreads(nodesIDs []string) (string, error)

GetNodesHotThreads allows to get the current hot threads on given nodes on the cluster

func (*Client) GetPrettyIndexMappings added in v0.4.0 

func (c *Client) GetPrettyIndexMappings(index string) (string, error)

Get the mappings of an index in a pretty-printed format.

Use case: You can view the custom mappings that are set on a particular index.

func (*Client) GetPrettyIndexSegments added in v0.6.1 

func (c *Client) GetPrettyIndexSegments(index string) (string, error)

Get the segments of an index in a pretty-printed format

Use case: you can view the segments of a particular index

func (*Client) GetPrettyIndexSettings added in v0.4.0 

func (c *Client) GetPrettyIndexSettings(index string) (string, error)

Get the settings of an index in a pretty-printed format.

Use case: You can view the custom settings that are set on a particular index.

func (*Client) GetRepositories added in v0.3.0 

func (c *Client) GetRepositories() ([]Repository, error)

List snapshot repositories on the cluster

Use case: You want to see all of the configured backup repositories on the given cluster, what types they are and if they are verified.

func (*Client) GetShardOverlap added in v0.5.0 

func (c *Client) GetShardOverlap(nodes []string) (map[string]ShardOverlap, error)

Get details regarding shard distribution across a given set of cluster nodes.

Use case: You can leverage this information to determine if it's safe to remove cluster nodes without losing data.

func (*Client) GetShardRecovery added in v0.5.0 

func (c *Client) GetShardRecovery(nodes []string, onlyActive bool) ([]ShardRecovery, error)

Get details regarding shard recovery operations across a set of cluster nodes.

Use case: You can view the shard recovery progress of the cluster.

func (*Client) GetShardRecoveryWithQueryParams added in v0.14.1 

func (c *Client) GetShardRecoveryWithQueryParams(nodes []string, params map[string]string) ([]ShardRecovery, error)

Get details regarding shard recovery operations across a set of cluster nodes sending the desired query parameters

Use case: You can view the shard recovery progress of the cluster with the bytes=b parameter.

func (*Client) GetShards added in v0.5.0 

func (c *Client) GetShards(nodes []string) ([]Shard, error)

Get shard data for all or a subset of nodes

Use case: You can view shard information on all nodes or a subset.

func (*Client) GetSnapshotStatus 

func (c *Client) GetSnapshotStatus(repository string, snapshot string) (Snapshot, error)

Get detailed information about a particular snapshot.

Use case: You had a snapshot fail and you want to see the reason why and what shards/nodes the error occurred on.

func (*Client) GetSnapshots 

func (c *Client) GetSnapshots(repository string) ([]Snapshot, error)

List the snapshots of the given repository.

Use case: You want to see information on snapshots in a repository.

func (*Client) LicenseCluster added in v0.14.3 

func (c *Client) LicenseCluster(license string) error

LicenseCluster takes in the Elasticsearch license encoded as a string

func (*Client) ModifyAliases added in v0.5.0 

func (c *Client) ModifyAliases(actions []AliasAction) error

Interact with aliases in the cluster.

Use case: You want to add, delete or update an index alias

func (*Client) OpenIndex added in v0.5.0 

func (c *Client) OpenIndex(indexName string) error

Open an index on the cluster

Use case: You want to open a closed index

func (*Client) RegisterRepository added in v0.7.0 

func (c *Client) RegisterRepository(repository Repository) error

Register a snapshot repository

Use case: Register a snapshot repository in Elasticsearch

func (*Client) ReloadSecureSettings added in v0.7.0 

func (c *Client) ReloadSecureSettings() (ReloadSecureSettingsResponse, error)

Reload secure node settings

Use case: Call the reload secure settings API https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-nodes-reload-secure-settings.html

func (*Client) ReloadSecureSettingsWithPassword added in v0.7.0 

func (c *Client) ReloadSecureSettingsWithPassword(password string) (ReloadSecureSettingsResponse, error)

Reload secure node settings with password

Use case: Call the reload secure settings API with a supplied password https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-nodes-reload-secure-settings.html

func (*Client) RemoveIndexILMPolicy added in v0.14.0 

func (c *Client) RemoveIndexILMPolicy(index string) error

RemoveIndexILMPolicy removes the ILM policy from the index

func (*Client) RemoveRepository added in v0.7.0 

func (c *Client) RemoveRepository(name string) error

Remove a snapshot repository

Use case: Remove a snapshot repository in Elasticsearch

func (*Client) RerouteWithRetryFailed added in v0.13.1 

func (c *Client) RerouteWithRetryFailed() error

RerouteWithRetryFailed retries allocation of shards that are blocked due to too many subsequent allocation failures.

func (*Client) RestoreSnapshotIndices added in v0.3.0 

func (c *Client) RestoreSnapshotIndices(repository string, snapshot string, indices []string, restoredIndexPrefix string, indexSettings map[string]interface{}) error

Restore an index or indices on the cluster

Use case: You want to restore a particular index or indices onto your cluster with a new name.

func (*Client) SetAllocation 

func (c *Client) SetAllocation(allocation string) (string, error)

Enables or disables allocation for the cluster.

Use case: You are performing an operation the cluster where nodes may be dropping in and out. Elasticsearch will typically try to rebalance immediately but you want the cluster to hold off rebalancing until you complete your task. Calling `SetAllocation("disable")` will disable allocation so Elasticsearch won't move/relocate any shards. Once you complete your task, calling `SetAllocation("enable")` will allow Elasticsearch to relocate shards again.

func (*Client) SetClusterSetting added in v0.4.0 

func (c *Client) SetClusterSetting(setting string, value *string) (*string, *string, error)

Set a new value for a cluster setting. Returns existing value and new value as well as error, in that order If the setting is not set in Elasticsearch (it's falling back to default configuration) SetClusterSetting's existingValue will be nil. If the value provided is nil, SetClusterSetting will remove the setting so that Elasticsearch falls back on default configuration for that setting.

Use case: You've doubled the number of nodes in your cluster and you want to increase the number of shards the cluster can relocate at one time. Calling `SetClusterSetting("cluster.routing.allocation.cluster_concurrent_rebalance", "100")` will update that value with the cluster. Once data relocation is complete you can decrease the setting by calling `SetClusterSetting("cluster.routing.allocation.cluster_concurrent_rebalance", "20")`.

func (*Client) SetIndexSetting added in v0.4.0 

func (c *Client) SetIndexSetting(index, setting, value string) (string, string, error)

Set a setting on an index.

Use case: Set or update an index setting for a particular index.

func (*Client) SnapshotAllIndices added in v0.3.0 

func (c *Client) SnapshotAllIndices(repository string, snapshot string) error

Take a snapshot of all indices on the cluster to the given repository

Use case: You want to backup all of the indices on the cluster to the given repository.

func (*Client) SnapshotAllIndicesWithBodyParams added in v0.14.4 

func (c *Client) SnapshotAllIndicesWithBodyParams(repository string, snapshot string, bodyParams map[string]interface{}) error

Take a snapshot of all indices on the cluster to the given repository with body params

Use case: You want to backup all of the indices on the cluster to the given repository with body params

func (*Client) SnapshotIndices added in v0.3.0 

func (c *Client) SnapshotIndices(repository string, snapshot string, indices []string) error

Take a snapshot of specific indices on the cluster to the given repository

Use case: You want to backup certain indices on the cluster to the given repository.

func (*Client) VerifyRepository added in v0.2.0 

func (c *Client) VerifyRepository(repository string) (bool, error)

Verify a snapshot repository

Use case: Have Elasticsearch verify a repository to make sure that all nodes can access the snapshot location correctly.

type ClusterAllocationExplainRequest added in v0.11.0 

type ClusterAllocationExplainRequest struct {
	// Specifies the node ID or the name of the node to only explain a shard that
	// is currently located on the specified node.
	CurrentNode string `json:"current_node,omitempty"`

	// Specifies the name of the index that you would like an explanation for.
	Index string `json:"index,omitempty"`

	// If true, returns explanation for the primary shard for the given shard ID.
	Primary bool `json:"primary,omitempty"`

	// Specifies the ID of the shard that you would like an explanation for.
	Shard *int `json:"shard,omitempty"`
}

ClusterAllocationExplainRequest represents request data that can be sent to `_cluster/allocation/explain` calls

type ClusterHealth added in v0.1.0 

type ClusterHealth struct {
	Cluster                string  `json:"cluster_name"`
	Status                 string  `json:"status"`
	ActiveShards           int     `json:"active_shards"`
	RelocatingShards       int     `json:"relocating_shards"`
	InitializingShards     int     `json:"initializing_shards"`
	UnassignedShards       int     `json:"unassigned_shards"`
	ActiveShardsPercentage float64 `json:"active_shards_percent_as_number"`
	Message                string
	RawIndices             map[string]IndexHealth `json:"indices"`
	HealthyIndices         []IndexHealth
	UnhealthyIndices       []IndexHealth
}

Holds information about the health of an Elasticsearch cluster, based on the cluster health API: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cluster-health.html

type ClusterSettings added in v0.1.0 

type ClusterSettings struct {
	PersistentSettings []Setting
	TransientSettings  []Setting
}

Holds slices for persistent and transient cluster settings.

type DiskAllocation added in v0.6.0 

type DiskAllocation struct {
	Name        string `json:"name"`
	IP          string `json:"ip"`
	Node        string `json:"node"`
	Shards      string `json:"shards"`
	DiskIndices string `json:"disk.indices"`
	DiskUsed    string `json:"disk.used"`
	DiskAvail   string `json:"disk.avail"`
	DiskTotal   string `json:"disk.total"`
	DiskPercent string `json:"disk.percent"`
}

DiskAllocation holds disk allocation information per node, based on _cat/allocation API: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cat-allocation.html

type ExcludeSettings 

type ExcludeSettings struct {
	Ips, Hosts, Names []string
}

Hold the values for what values are in the cluster.allocation.exclude settings. Relevant Elasticsearch documentation: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/allocation-filtering.html

type Index added in v0.1.0 

type Index struct {
	Health        string `json:"health"`
	Status        string `json:"status"`
	Name          string `json:"index"`
	PrimaryShards int    `json:"pri,string"`
	ReplicaCount  int    `json:"rep,string"`
	IndexSize     string `json:"store.size"`
	DocumentCount int    `json:"docs.count,string"`
}

Holds information about an Elasticsearch index, based on the _cat/indices API: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cat-indices.html

type IndexHealth added in v0.3.0 

type IndexHealth struct {
	Name               string
	Status             string `json:"status"`
	ActiveShards       int    `json:"active_shards"`
	RelocatingShards   int    `json:"relocating_shards"`
	InitializingShards int    `json:"initializing_shards"`
	UnassignedShards   int    `json:"unassigned_shards"`
}

Holds information about the health of an Elasticsearch index, based on the index level of the cluster health API: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cluster-health.html

type Node added in v0.1.0 

type Node struct {
	Name        string `json:"name"`
	IP          string `json:"ip"`
	ID          string `json:"id"`
	Role        string `json:"role"`
	Master      string `json:"master"`
	Jdk         string `json:"jdk"`
	Version     string `json:"version"`
	Shards      string
	DiskIndices string
	DiskUsed    string
	DiskAvail   string
	DiskTotal   string
	DiskPercent string
}

Holds information about an Elasticsearch node, based on a combination of the _cat/nodes and _cat/allocationAPI: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cat-nodes.html, https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cat-allocation.html

type NodeJVM added in v0.6.0 

type NodeJVM struct {
	HeapUsedBytes         int `json:"heap_used_in_bytes"`
	HeapUsedPercentage    int `json:"heap_used_percent"`
	HeapMaxBytes          int `json:"heap_max_in_bytes"`
	NonHeapUsedBytes      int `json:"non_heap_used_in_bytes"`
	NonHeapCommittedBytes int `json:"non_heap_committed_in_bytes"`
}

Holds information about an Elasticsearch node's JVM settings. From _nodes/stats/jvm: https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-nodes-stats.html

type NodeStats added in v0.6.0 

type NodeStats struct {
	Name     string
	Role     string
	JVMStats NodeJVM
}

Holds a subset of information from the _nodes/stats endpoint: https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-nodes-stats.html

type ReloadSecureSettingsResponse added in v0.7.0 

type ReloadSecureSettingsResponse struct {
	Summary struct {
		Total      int `json:"total"`
		Failed     int `json:"failed"`
		Successful int `json:"successful"`
	} `json:"_nodes"`
	ClusterName string `json:"cluster_name"`
	Nodes       map[string]struct {
		Name            string `json:"name"`
		ReloadException *struct {
			Type   string `json:"type"`
			Reason string `json:"reason"`
		} `json:"reload_exception"`
	} `json:"nodes"`
}

type Repository added in v0.3.0 

type Repository struct {
	Name     string
	Type     string
	Settings map[string]interface{}
}

Holds information about an Elasticsearch snapshot repository.

type RerouteCommand added in v0.13.0 

type RerouteCommand struct {
	AllocateStalePrimary AllocateStalePrimary `json:"allocate_stale_primary,omitempty"`
}

type RerouteRequest added in v0.13.0 

type RerouteRequest struct {
	// The commands to perform (move, cancel, allocate, etc)
	Commands []RerouteCommand `json:"commands,omitempty"`
}

type Setting added in v0.4.0 

type Setting struct {
	Setting string
	Value   string
}

A setting name and value with the setting name to be a "collapsed" version of the setting. A setting of: 

{ "indices": { "recovery" : { "max_bytes_per_sec": "10mb" } } }

would be represented by: 

ClusterSetting{ Setting: "indices.recovery.max_bytes_per_sec", Value: "10mb" }

type Shard added in v0.5.0 

type Shard struct {
	Index string `json:"index"`
	Shard string `json:"shard"`
	Type  string `json:"prirep"`
	State string `json:"state"`
	Docs  string `json:"docs"`
	Store string `json:"store"`
	IP    string `json:"ip"`
	Node  string `json:"node"`
}

Holds information about an index shard, based on the _cat/shards API: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cat-shards.html

type ShardOverlap added in v0.5.0 

type ShardOverlap struct {
	Index         string
	Shard         string
	PrimaryFound  bool
	ReplicasFound int
	ReplicasTotal int
}

Holds information about overlapping shards for a given set of cluster nodes

func (ShardOverlap) SafeToRemove added in v0.5.0 

func (s ShardOverlap) SafeToRemove() bool

Can we safely remove nodes without data loss?

type ShardRecovery added in v0.5.0 

type ShardRecovery struct {
	Index                string `json:"index"`
	Shard                string `json:"shard"`
	Time                 string `json:"time"`
	Type                 string `json:"type"`
	Stage                string `json:"stage"`
	SourceHost           string `json:"source_host"`
	SourceNode           string `json:"source_node"`
	TargetHost           string `json:"target_host"`
	TargetNode           string `json:"target_node"`
	Repository           string `json:"repository"`
	Snapshot             string `json:"snapshot"`
	Files                int    `json:"files,string"`
	FilesRecovered       int    `json:"files_recovered,string"`
	FilesPercent         string `json:"files_percent"`
	FilesTotal           int    `json:"files_total,string"`
	Bytes                int    `json:"bytes,string"`
	BytesRecovered       int    `json:"bytes_recovered,string"`
	BytesPercent         string `json:"bytes_percent"`
	BytesTotal           int    `json:"bytes_total,string"`
	TranslogOps          int    `json:"translog_ops,string"`
	TranslogOpsRecovered int    `json:"translog_ops_recovered,string"`
	TranslogOpsPercent   string `json:"translog_ops_percent"`
}

Holds information about shard recovery based on the _cat/recovery API: https://www.elastic.co/guide/en/elasticsearch/reference/5.6/cat-recovery.html

func (ShardRecovery) TimeRemaining added in v0.5.0 

func (s ShardRecovery) TimeRemaining() (time.Duration, error)

Estimate time remaining for recovery

type Snapshot added in v0.1.0 

type Snapshot struct {
	State          string    `json:"state"`
	Name           string    `json:"snapshot"`
	StartTime      time.Time `json:"start_time"`
	EndTime        time.Time `json:"end_time"`
	DurationMillis int       `json:"duration_in_millis"`
	Indices        []string  `json:"indices"`
	Shards         struct {
		Total      int `json:"total"`
		Failed     int `json:"failed"`
		Successful int `json:"successful"`
	} `json:"shards"`
	Failures []struct {
		Index   string `json:"index"`
		ShardID int    `json:"shard_id"`
		Reason  string `json:"reason"`
		NodeID  string `json:"node_id"`
		Status  string `json:"status"`
	} `json:"failures"`
}

Holds information about an Elasticsearch snapshot, based on the snapshot API: https://www.elastic.co/guide/en/elasticsearch/reference/current/modules-snapshots.html

func (*Snapshot) GetDuration added in v0.5.0 

func (s *Snapshot) GetDuration() int

GetDuration gets the total duration of a snapshot

func (*Snapshot) GetEndTime added in v0.5.0 

func (s *Snapshot) GetEndTime() string

GetEndTime gets the time when a snapshot ended

type Token added in v0.4.0 

type Token struct {
	Text        string `json:"token"`
	StartOffset int    `json:"start_offset"`
	EndOffset   int    `json:"end_offset"`
	Type        string `json:"type"`
	Position    int    `json:"position"`
}

Holds information about the tokens that Elasticsearch analyzes

Source Files

View all Source files

Directories

Path Synopsis
cmd
vulcanizer
pkg
cli

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.