Versions in this module Expand all Collapse all v1 v1.0.0 Aug 7, 2019 Changes in this version + var ErrInconsistentNodes = errors.New("got inconsistent nodes from Elasticsearch") + type ElasticsearchCommandService struct + func NewElasticsearchCommandService(client *elastic.Client) *ElasticsearchCommandService + func (s *ElasticsearchCommandService) Drain(ctx context.Context, nodeName string) error + func (s *ElasticsearchCommandService) Undrain(ctx context.Context, nodeName string) error + type ElasticsearchQueryService struct + func NewElasticsearchQueryService(client *elastic.Client) *ElasticsearchQueryService + func (s *ElasticsearchQueryService) Node(ctx context.Context, name string) (*Node, error) + func (s *ElasticsearchQueryService) Nodes(ctx context.Context, names ...string) (map[string]*Node, error) + type Node struct + ClusterName string + ElectedMaster bool + ExcludedShardAllocation bool + Shards es.CatShardsResponse + Stats elastic.NodesStatsNode + func (n *Node) Indices() []string Other modules containing this package github.com/mintel/elasticsearch-asg/v2