collector

Documentation

Overview

Package collector for agent interface Created by chenguolin 2019-07-12

Package collector entry Created by chenguolin 2019-07-08

Package collector fluentd agent Created by chenguolin 2019-07-08

v1.0 https://docs.fluentd.org/

Index

• Constants
• type Collector
  • func NewCollector(name string) (*Collector, error)
  • func (c *Collector) Run() error
  • func (c *Collector) Stop() error
• type Fluent
  • func (f *Fluent) DestroyContainer(containerID string) error
  • func (f *Fluent) NewContainer(containerID string) error
  • func (f *Fluent) Reload() error
  • func (f *Fluent) Start() error
  • func (f *Fluent) Stop() error

Constants

const (
	// FluentdBin fluentd bin
	FluentdBin = "/usr/bin/fluentd"
	// FluentConf fluent conf
	FluentConf = "/etc/fluent/fluent.conf"
	// FluentPlugins fluent plugins
	FluentPlugins = "/etc/fluent/plugins"
	// FluentBuffer fluent buffer
	FluentBuffer = "/var/log/log-collector-fluent/buffer/"
	// FluentConfD fluent conf.d
	FluentConfD = "/etc/fluent/conf.d/"
	// FluentKafkaTopic kafka topic
	FluentKafkaTopic = "fluent.kafka.topic"
)

const (
	// FluentAgent fluent agent
	FluentAgent = "fluent"
)

const (
	// LogCollector log-collector
	LogCollector = "log-collector"
)

Types

type Collector

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

Collector for log collect

func NewCollector

func NewCollector(name string) (*Collector, error)

NewCollector new collector by name

func (*Collector) Run

func (c *Collector) Run() error

Run collector

func (*Collector) Stop

func (c *Collector) Stop() error

Stop collector agent

type Fluent

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

Fluent agent

func (*Fluent) DestroyContainer

func (f *Fluent) DestroyContainer(containerID string) error

DestroyContainer container

func (*Fluent) NewContainer

func (f *Fluent) NewContainer(containerID string) error

NewContainer new container generate config

func (*Fluent) Reload

func (f *Fluent) Reload() error

Reload fluentd process

func (*Fluent) Start

func (f *Fluent) Start() error

Start fluentd process

func (*Fluent) Stop

func (f *Fluent) Stop() error

Stop fluentd agent