collector

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 12, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// SelfMountInfo /proc/self/mountinfo
	SelfMountInfo = "/proc/self/mountinfo"
	// LogCollector log-collector
	LogCollector = "log-collector"
)
View Source
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"
)
View Source
const (
	// FluentAgent fluent agent
	FluentAgent = "fluent"
)

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL