313 lines
11 KiB
Go
313 lines
11 KiB
Go
// Copyright 2012-present Oliver Eilhard. All rights reserved.
|
|
// Use of this source code is governed by a MIT-license.
|
|
// See http://olivere.mit-license.org/license.txt for details.
|
|
|
|
package elastic
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/url"
|
|
"strings"
|
|
"time"
|
|
|
|
"gopkg.in/olivere/elastic.v5/uritemplates"
|
|
)
|
|
|
|
// NodesInfoService allows to retrieve one or more or all of the
|
|
// cluster nodes information.
|
|
// It is documented at https://www.elastic.co/guide/en/elasticsearch/reference/5.2/cluster-nodes-info.html.
|
|
type NodesInfoService struct {
|
|
client *Client
|
|
pretty bool
|
|
nodeId []string
|
|
metric []string
|
|
flatSettings *bool
|
|
human *bool
|
|
}
|
|
|
|
// NewNodesInfoService creates a new NodesInfoService.
|
|
func NewNodesInfoService(client *Client) *NodesInfoService {
|
|
return &NodesInfoService{
|
|
client: client,
|
|
nodeId: []string{"_all"},
|
|
metric: []string{"_all"},
|
|
}
|
|
}
|
|
|
|
// NodeId is a list of node IDs or names to limit the returned information.
|
|
// Use "_local" to return information from the node you're connecting to,
|
|
// leave empty to get information from all nodes.
|
|
func (s *NodesInfoService) NodeId(nodeId ...string) *NodesInfoService {
|
|
s.nodeId = append(s.nodeId, nodeId...)
|
|
return s
|
|
}
|
|
|
|
// Metric is a list of metrics you wish returned. Leave empty to return all.
|
|
// Valid metrics are: settings, os, process, jvm, thread_pool, network,
|
|
// transport, http, and plugins.
|
|
func (s *NodesInfoService) Metric(metric ...string) *NodesInfoService {
|
|
s.metric = append(s.metric, metric...)
|
|
return s
|
|
}
|
|
|
|
// FlatSettings returns settings in flat format (default: false).
|
|
func (s *NodesInfoService) FlatSettings(flatSettings bool) *NodesInfoService {
|
|
s.flatSettings = &flatSettings
|
|
return s
|
|
}
|
|
|
|
// Human indicates whether to return time and byte values in human-readable format.
|
|
func (s *NodesInfoService) Human(human bool) *NodesInfoService {
|
|
s.human = &human
|
|
return s
|
|
}
|
|
|
|
// Pretty indicates whether to indent the returned JSON.
|
|
func (s *NodesInfoService) Pretty(pretty bool) *NodesInfoService {
|
|
s.pretty = pretty
|
|
return s
|
|
}
|
|
|
|
// buildURL builds the URL for the operation.
|
|
func (s *NodesInfoService) buildURL() (string, url.Values, error) {
|
|
// Build URL
|
|
path, err := uritemplates.Expand("/_nodes/{node_id}/{metric}", map[string]string{
|
|
"node_id": strings.Join(s.nodeId, ","),
|
|
"metric": strings.Join(s.metric, ","),
|
|
})
|
|
if err != nil {
|
|
return "", url.Values{}, err
|
|
}
|
|
|
|
// Add query string parameters
|
|
params := url.Values{}
|
|
if s.flatSettings != nil {
|
|
params.Set("flat_settings", fmt.Sprintf("%v", *s.flatSettings))
|
|
}
|
|
if s.human != nil {
|
|
params.Set("human", fmt.Sprintf("%v", *s.human))
|
|
}
|
|
if s.pretty {
|
|
params.Set("pretty", "1")
|
|
}
|
|
return path, params, nil
|
|
}
|
|
|
|
// Validate checks if the operation is valid.
|
|
func (s *NodesInfoService) Validate() error {
|
|
return nil
|
|
}
|
|
|
|
// Do executes the operation.
|
|
func (s *NodesInfoService) Do(ctx context.Context) (*NodesInfoResponse, error) {
|
|
// Check pre-conditions
|
|
if err := s.Validate(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Get URL for request
|
|
path, params, err := s.buildURL()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Get HTTP response
|
|
res, err := s.client.PerformRequest(ctx, "GET", path, params, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Return operation response
|
|
ret := new(NodesInfoResponse)
|
|
if err := s.client.decoder.Decode(res.Body, ret); err != nil {
|
|
return nil, err
|
|
}
|
|
return ret, nil
|
|
}
|
|
|
|
// NodesInfoResponse is the response of NodesInfoService.Do.
|
|
type NodesInfoResponse struct {
|
|
ClusterName string `json:"cluster_name"`
|
|
Nodes map[string]*NodesInfoNode `json:"nodes"`
|
|
}
|
|
|
|
type NodesInfoNode struct {
|
|
// Name of the node, e.g. "Mister Fear"
|
|
Name string `json:"name"`
|
|
// TransportAddress, e.g. "127.0.0.1:9300"
|
|
TransportAddress string `json:"transport_address"`
|
|
// Host is the host name, e.g. "macbookair"
|
|
Host string `json:"host"`
|
|
// IP is the IP address, e.g. "192.168.1.2"
|
|
IP string `json:"ip"`
|
|
// Version is the Elasticsearch version running on the node, e.g. "1.4.3"
|
|
Version string `json:"version"`
|
|
// Build is the Elasticsearch build, e.g. "36a29a7"
|
|
Build string `json:"build"`
|
|
// HTTPAddress, e.g. "127.0.0.1:9200"
|
|
HTTPAddress string `json:"http_address"`
|
|
// HTTPSAddress, e.g. "127.0.0.1:9200"
|
|
HTTPSAddress string `json:"https_address"`
|
|
|
|
// Roles of the node, e.g. [master, ingest, data]
|
|
Roles []string `json:"roles"`
|
|
|
|
// Attributes of the node.
|
|
Attributes map[string]interface{} `json:"attributes"`
|
|
|
|
// Settings of the node, e.g. paths and pidfile.
|
|
Settings map[string]interface{} `json:"settings"`
|
|
|
|
// OS information, e.g. CPU and memory.
|
|
OS *NodesInfoNodeOS `json:"os"`
|
|
|
|
// Process information, e.g. max file descriptors.
|
|
Process *NodesInfoNodeProcess `json:"process"`
|
|
|
|
// JVM information, e.g. VM version.
|
|
JVM *NodesInfoNodeJVM `json:"jvm"`
|
|
|
|
// ThreadPool information.
|
|
ThreadPool *NodesInfoNodeThreadPool `json:"thread_pool"`
|
|
|
|
// Network information.
|
|
Network *NodesInfoNodeNetwork `json:"network"`
|
|
|
|
// Network information.
|
|
Transport *NodesInfoNodeTransport `json:"transport"`
|
|
|
|
// HTTP information.
|
|
HTTP *NodesInfoNodeHTTP `json:"http"`
|
|
|
|
// Plugins information.
|
|
Plugins []*NodesInfoNodePlugin `json:"plugins"`
|
|
}
|
|
|
|
type NodesInfoNodeOS struct {
|
|
RefreshInterval string `json:"refresh_interval"` // e.g. 1s
|
|
RefreshIntervalInMillis int `json:"refresh_interval_in_millis"` // e.g. 1000
|
|
AvailableProcessors int `json:"available_processors"` // e.g. 4
|
|
|
|
// CPU information
|
|
CPU struct {
|
|
Vendor string `json:"vendor"` // e.g. Intel
|
|
Model string `json:"model"` // e.g. iMac15,1
|
|
MHz int `json:"mhz"` // e.g. 3500
|
|
TotalCores int `json:"total_cores"` // e.g. 4
|
|
TotalSockets int `json:"total_sockets"` // e.g. 4
|
|
CoresPerSocket int `json:"cores_per_socket"` // e.g. 16
|
|
CacheSizeInBytes int `json:"cache_size_in_bytes"` // e.g. 256
|
|
} `json:"cpu"`
|
|
|
|
// Mem information
|
|
Mem struct {
|
|
Total string `json:"total"` // e.g. 16gb
|
|
TotalInBytes int `json:"total_in_bytes"` // e.g. 17179869184
|
|
} `json:"mem"`
|
|
|
|
// Swap information
|
|
Swap struct {
|
|
Total string `json:"total"` // e.g. 1gb
|
|
TotalInBytes int `json:"total_in_bytes"` // e.g. 1073741824
|
|
} `json:"swap"`
|
|
}
|
|
|
|
type NodesInfoNodeProcess struct {
|
|
RefreshInterval string `json:"refresh_interval"` // e.g. 1s
|
|
RefreshIntervalInMillis int `json:"refresh_interval_in_millis"` // e.g. 1000
|
|
ID int `json:"id"` // process id, e.g. 87079
|
|
MaxFileDescriptors int `json:"max_file_descriptors"` // e.g. 32768
|
|
Mlockall bool `json:"mlockall"` // e.g. false
|
|
}
|
|
|
|
type NodesInfoNodeJVM struct {
|
|
PID int `json:"pid"` // process id, e.g. 87079
|
|
Version string `json:"version"` // e.g. "1.8.0_25"
|
|
VMName string `json:"vm_name"` // e.g. "Java HotSpot(TM) 64-Bit Server VM"
|
|
VMVersion string `json:"vm_version"` // e.g. "25.25-b02"
|
|
VMVendor string `json:"vm_vendor"` // e.g. "Oracle Corporation"
|
|
StartTime time.Time `json:"start_time"` // e.g. "2015-01-03T15:18:30.982Z"
|
|
StartTimeInMillis int64 `json:"start_time_in_millis"`
|
|
|
|
// Mem information
|
|
Mem struct {
|
|
HeapInit string `json:"heap_init"` // e.g. 1gb
|
|
HeapInitInBytes int `json:"heap_init_in_bytes"`
|
|
HeapMax string `json:"heap_max"` // e.g. 4gb
|
|
HeapMaxInBytes int `json:"heap_max_in_bytes"`
|
|
NonHeapInit string `json:"non_heap_init"` // e.g. 2.4mb
|
|
NonHeapInitInBytes int `json:"non_heap_init_in_bytes"`
|
|
NonHeapMax string `json:"non_heap_max"` // e.g. 0b
|
|
NonHeapMaxInBytes int `json:"non_heap_max_in_bytes"`
|
|
DirectMax string `json:"direct_max"` // e.g. 4gb
|
|
DirectMaxInBytes int `json:"direct_max_in_bytes"`
|
|
} `json:"mem"`
|
|
|
|
GCCollectors []string `json:"gc_collectors"` // e.g. ["ParNew"]
|
|
MemoryPools []string `json:"memory_pools"` // e.g. ["Code Cache", "Metaspace"]
|
|
}
|
|
|
|
type NodesInfoNodeThreadPool struct {
|
|
Percolate *NodesInfoNodeThreadPoolSection `json:"percolate"`
|
|
Bench *NodesInfoNodeThreadPoolSection `json:"bench"`
|
|
Listener *NodesInfoNodeThreadPoolSection `json:"listener"`
|
|
Index *NodesInfoNodeThreadPoolSection `json:"index"`
|
|
Refresh *NodesInfoNodeThreadPoolSection `json:"refresh"`
|
|
Suggest *NodesInfoNodeThreadPoolSection `json:"suggest"`
|
|
Generic *NodesInfoNodeThreadPoolSection `json:"generic"`
|
|
Warmer *NodesInfoNodeThreadPoolSection `json:"warmer"`
|
|
Search *NodesInfoNodeThreadPoolSection `json:"search"`
|
|
Flush *NodesInfoNodeThreadPoolSection `json:"flush"`
|
|
Optimize *NodesInfoNodeThreadPoolSection `json:"optimize"`
|
|
Management *NodesInfoNodeThreadPoolSection `json:"management"`
|
|
Get *NodesInfoNodeThreadPoolSection `json:"get"`
|
|
Merge *NodesInfoNodeThreadPoolSection `json:"merge"`
|
|
Bulk *NodesInfoNodeThreadPoolSection `json:"bulk"`
|
|
Snapshot *NodesInfoNodeThreadPoolSection `json:"snapshot"`
|
|
}
|
|
|
|
type NodesInfoNodeThreadPoolSection struct {
|
|
Type string `json:"type"` // e.g. fixed
|
|
Min int `json:"min"` // e.g. 4
|
|
Max int `json:"max"` // e.g. 4
|
|
KeepAlive string `json:"keep_alive"` // e.g. "5m"
|
|
QueueSize interface{} `json:"queue_size"` // e.g. "1k" or -1
|
|
}
|
|
|
|
type NodesInfoNodeNetwork struct {
|
|
RefreshInterval string `json:"refresh_interval"` // e.g. 1s
|
|
RefreshIntervalInMillis int `json:"refresh_interval_in_millis"` // e.g. 1000
|
|
PrimaryInterface struct {
|
|
Address string `json:"address"` // e.g. 192.168.1.2
|
|
Name string `json:"name"` // e.g. en0
|
|
MACAddress string `json:"mac_address"` // e.g. 11:22:33:44:55:66
|
|
} `json:"primary_interface"`
|
|
}
|
|
|
|
type NodesInfoNodeTransport struct {
|
|
BoundAddress []string `json:"bound_address"`
|
|
PublishAddress string `json:"publish_address"`
|
|
Profiles map[string]*NodesInfoNodeTransportProfile `json:"profiles"`
|
|
}
|
|
|
|
type NodesInfoNodeTransportProfile struct {
|
|
BoundAddress []string `json:"bound_address"`
|
|
PublishAddress string `json:"publish_address"`
|
|
}
|
|
|
|
type NodesInfoNodeHTTP struct {
|
|
BoundAddress []string `json:"bound_address"` // e.g. ["127.0.0.1:9200", "[fe80::1]:9200", "[::1]:9200"]
|
|
PublishAddress string `json:"publish_address"` // e.g. "127.0.0.1:9300"
|
|
MaxContentLength string `json:"max_content_length"` // e.g. "100mb"
|
|
MaxContentLengthInBytes int64 `json:"max_content_length_in_bytes"`
|
|
}
|
|
|
|
type NodesInfoNodePlugin struct {
|
|
Name string `json:"name"`
|
|
Description string `json:"description"`
|
|
Site bool `json:"site"`
|
|
JVM bool `json:"jvm"`
|
|
URL string `json:"url"` // e.g. /_plugin/dummy/
|
|
}
|