node_stats

Documentation

Index

• func New(base mb.BaseMetricSet) (mb.MetricSet, error)
• type LogstashStats
• type MetricSet
  • func (m *MetricSet) Fetch(r mb.ReporterV2) error
• type NodeStats
• type PipelineStats

Functions

func New

func New(base mb.BaseMetricSet) (mb.MetricSet, error)

New create a new instance of the MetricSet

Types

type LogstashStats

type LogstashStats struct {
	Process   process         `json:"process"`
	OS        os              `json:"os"`
	Pipelines []PipelineStats `json:"pipelines"`
	Logstash  nodeInfo        `json:"logstash"`
	Timestamp common.Time     `json:"timestamp"`
	// contains filtered or unexported fields
}

LogstashStats represents the logstash_stats sub-document indexed into .monitoring-logstash-*

type MetricSet

type MetricSet struct {
	*logstash.MetricSet
}

MetricSet type defines all fields of the MetricSet

func (*MetricSet) Fetch

func (m *MetricSet) Fetch(r mb.ReporterV2) error

Fetch methods implements the data gathering and data conversion to the right format It returns the event which is then forward to the output. In case of an error, a descriptive error must be returned.

type NodeStats

type NodeStats struct {
	Process   process                  `json:"process"`
	OS        os                       `json:"os"`
	Pipelines map[string]PipelineStats `json:"pipelines"`
	// contains filtered or unexported fields
}

NodeStats represents the stats of a Logstash node

type PipelineStats

type PipelineStats struct {
	ID          string                   `json:"id"`
	Hash        string                   `json:"hash"`
	EphemeralID string                   `json:"ephemeral_id"`
	Events      map[string]interface{}   `json:"events"`
	Reloads     reloads                  `json:"reloads"`
	Queue       map[string]interface{}   `json:"queue"`
	Vertices    []map[string]interface{} `json:"vertices"`
}

PipelineStats represents the stats of a Logstash pipeline