fluentd

README

fluentd

This module will monitor one or more Fluentd servers depending on configuration.

The module gathers metrics from plugin endpoint provided by in_monitor plugin.

Requirements:

• fluentd with enabled monitoring agent

It produces the following charts:

1. Plugin Retry Count

2. Plugin Buffer Queue Length

3. Plugin Buffer Total Size

configuration

For all available options please see module configuration file.

---

Needs only url.

Here is an example for 2 servers:

jobs:
  - name: local
    url: http://127.0.0.1:24220

  - name: remote
    url: http://10.0.0.1:24220

Without configuration, module attempts to connect to http://127.0.0.1:24220.

---

Filter plugins: by default module collects statistics for all plugins.

To filter unwanted please configure permit_plugin_id:

jobs:
  - name: local
    url: http://10.0.0.1:24220
    permit_plugin_id: '!monitor_agent !dummy *'

Syntax: simple patterns.

---

Documentation

Index

• type Charts
• type Config
• type Dim
• type Fluentd
  • func New() *Fluentd
  • func (f Fluentd) Charts() *Charts
  • func (f Fluentd) Check() bool
  • func (Fluentd) Cleanup()
  • func (f *Fluentd) Collect() map[string]int64
  • func (f *Fluentd) Init() bool

Types

type Charts

type Charts = module.Charts

Charts is an alias for module.Charts

type Config

type Config struct {
	web.HTTP     `yaml:",inline"`
	PermitPlugin string `yaml:"permit_plugin_id"`
}

type Dim

type Dim = module.Dim

Dim is an alias for module.Dim

type Fluentd

type Fluentd struct {
	module.Base
	Config `yaml:",inline"`
	// contains filtered or unexported fields
}

Fluentd Fluentd module.

func New

func New() *Fluentd

New creates Fluentd with default values.

func (Fluentd) Charts

func (f Fluentd) Charts() *Charts

Charts creates Charts.

func (Fluentd) Check

func (f Fluentd) Check() bool

Check makes check.

func (Fluentd) Cleanup

func (Fluentd) Cleanup()

Cleanup makes cleanup.

func (*Fluentd) Collect

func (f *Fluentd) Collect() map[string]int64

Collect collects metrics.

func (*Fluentd) Init

func (f *Fluentd) Init() bool

Init makes initialization.