node_stats

Documentation

Index

• type Config
• type NodeStats
  • func (p *NodeStats) Collect(k string, v *elastic.ElasticsearchMetadata) error
  • func (p *NodeStats) Name() string
  • func (p *NodeStats) Process(c *pipeline.Context) error
  • func (p *NodeStats) SaveNodeStats(clusterId, clusterUUID, nodeID string, f, shardInfo interface{}, ...)
  • func (p *NodeStats) SaveShardStats(clusterId, clusterUUID, nodeID, host, indexName, indexUUID, shardID string, ...)

Types

type Config

type Config struct {
	Elasticsearch string                 `config:"elasticsearch,omitempty"`
	NodeUUIDs     []string               `config:"node_uuids,omitempty" json:"node_uuids"`
	Labels        map[string]interface{} `config:"labels,omitempty"`
	Level         string                 `config:"level,omitempty"`
}

type NodeStats

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

func (*NodeStats) Collect

func (p *NodeStats) Collect(k string, v *elastic.ElasticsearchMetadata) error

func (*NodeStats) Name

func (p *NodeStats) Name() string

func (*NodeStats) Process

func (p *NodeStats) Process(c *pipeline.Context) error

func (*NodeStats) SaveNodeStats

func (p *NodeStats) SaveNodeStats(clusterId, clusterUUID, nodeID string, f, shardInfo interface{}, timestamp time.Time)

func (*NodeStats) SaveShardStats

func (p *NodeStats) SaveShardStats(clusterId, clusterUUID, nodeID, host, indexName, indexUUID, shardID string, f interface{}, timestamp time.Time)