logstash

README

logstash

logstash 监控采集插件，由telegraf改造而来。

Configuration

请参考配置示例

监控大盘和告警规则

同级目录下的 logstash-dash 是示例的监控面板， 可以直接导入夜莺使用。

Documentation

Index

• type Instance
  • func (ins *Instance) Gather(slist *types.SampleList)
  • func (ins *Instance) Init() error
• type JVMStats
• type Logstash
  • func (l *Logstash) Clone() inputs.Input
  • func (l *Logstash) GetInstances() []inputs.Instance
  • func (l *Logstash) Name() string
• type Pipeline
• type PipelinePlugins
• type PipelineQueue
• type PipelineStats
• type PipelinesStats
• type Plugin
• type ProcessStats

Types

type Instance

type Instance struct {
	config.InstanceConfig

	URL            string            `toml:"url"`
	SinglePipeline bool              `toml:"single_pipeline"`
	Collect        []string          `toml:"collect"`
	Username       string            `toml:"username"`
	Password       string            `toml:"password"`
	Headers        map[string]string `toml:"headers"`
	Timeout        config.Duration   `toml:"timeout"`

	tls.ClientConfig
	// contains filtered or unexported fields
}

func (*Instance) Gather

func (ins *Instance) Gather(slist *types.SampleList)

func (*Instance) Init

func (ins *Instance) Init() error

type JVMStats

type JVMStats struct {
	ID      string      `json:"id"`
	JVM     interface{} `json:"jvm"`
	Name    string      `json:"name"`
	Host    string      `json:"host"`
	Version string      `json:"version"`
}

type Logstash

type Logstash struct {
	config.PluginConfig
	Instances []*Instance `toml:"instances"`
}

func (*Logstash) Clone

func (l *Logstash) Clone() inputs.Input

func (*Logstash) GetInstances

func (l *Logstash) GetInstances() []inputs.Instance

func (*Logstash) Name

func (l *Logstash) Name() string

type Pipeline

type Pipeline struct {
	Events  interface{}     `json:"events"`
	Plugins PipelinePlugins `json:"plugins"`
	Reloads interface{}     `json:"reloads"`
	Queue   PipelineQueue   `json:"queue"`
}

type PipelinePlugins

type PipelinePlugins struct {
	Inputs  []Plugin `json:"inputs"`
	Filters []Plugin `json:"filters"`
	Outputs []Plugin `json:"outputs"`
}

type PipelineQueue

type PipelineQueue struct {
	Events              float64     `json:"events"`
	EventsCount         *float64    `json:"events_count"`
	Type                string      `json:"type"`
	Capacity            interface{} `json:"capacity"`
	Data                interface{} `json:"data"`
	QueueSizeInBytes    *float64    `json:"queue_size_in_bytes"`
	MaxQueueSizeInBytes *float64    `json:"max_queue_size_in_bytes"`
}

type PipelineStats

type PipelineStats struct {
	ID       string   `json:"id"`
	Pipeline Pipeline `json:"pipeline"`
	Name     string   `json:"name"`
	Host     string   `json:"host"`
	Version  string   `json:"version"`
}

type PipelinesStats

type PipelinesStats struct {
	ID        string              `json:"id"`
	Pipelines map[string]Pipeline `json:"pipelines"`
	Name      string              `json:"name"`
	Host      string              `json:"host"`
	Version   string              `json:"version"`
}

type Plugin

type Plugin struct {
	ID           string                 `json:"id"`
	Events       interface{}            `json:"events"`
	Name         string                 `json:"name"`
	BulkRequests map[string]interface{} `json:"bulk_requests"`
	Documents    map[string]interface{} `json:"documents"`
}

type ProcessStats

type ProcessStats struct {
	ID      string      `json:"id"`
	Process interface{} `json:"process"`
	Name    string      `json:"name"`
	Host    string      `json:"host"`
	Version string      `json:"version"`
}