telegraf

Documentation

Index

• Constants
• type Config
• type LogCollector
  • func NewLogCollector(agentDirPath string) *LogCollector
  • func (l *LogCollector) Run()
  • func (l *LogCollector) TelegrafStart()
  • func (l *LogCollector) TelegrafStop()
• type Manager
  • func GetTelegrafManager(agentDirPath string) *Manager
  • func (tm *Manager) GetContext() context.Context
  • func (tm *Manager) RegisterConfig(ctx pipeline.Context, c *Config)
  • func (tm *Manager) UnregisterConfig(ctx pipeline.Context, c *Config)
• type Processor
  • func (p *Processor) Process(fileBlock []byte, noChangeInterval time.Duration) int
• type ServiceTelegraf
  • func (s *ServiceTelegraf) Collect(collector pipeline.Collector) error
  • func (s *ServiceTelegraf) Description() string
  • func (s *ServiceTelegraf) Init(ctx pipeline.Context) (int, error)
  • func (s *ServiceTelegraf) Start(collector pipeline.Collector) error
  • func (s *ServiceTelegraf) Stop() error

Constants

const (
	TelegrafAlarmType = "TELEGRAF_ALARM"
)

Types

type Config

type Config struct {
	Name   string
	Detail string
}

type LogCollector

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

func NewLogCollector

func NewLogCollector(agentDirPath string) *LogCollector

NewLogCollector create a log collector to read telegraf log.

func (*LogCollector) Run

func (l *LogCollector) Run()

func (*LogCollector) TelegrafStart

func (l *LogCollector) TelegrafStart()

func (*LogCollector) TelegrafStop

func (l *LogCollector) TelegrafStop()

type Manager

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

Telegraf supervisor for agent start, stop, config reload...

Because Telegraf will send all inputs' data to all outputs, so only ONE Logtail config will be passed to Telegraf simultaneously.

Data link: Telegraf ------ HTTP ------> Logtail ----- Protobuf ------> SLS. Logtail will work as an InfluxDB server to receive data from telegraf by HTTP protocol.

func GetTelegrafManager

func GetTelegrafManager(agentDirPath string) *Manager

func (*Manager) GetContext

func (tm *Manager) GetContext() context.Context

func (*Manager) RegisterConfig

func (tm *Manager) RegisterConfig(ctx pipeline.Context, c *Config)

func (*Manager) UnregisterConfig

func (tm *Manager) UnregisterConfig(ctx pipeline.Context, c *Config)

type Processor

type Processor struct {
}

func (*Processor) Process

func (p *Processor) Process(fileBlock []byte, noChangeInterval time.Duration) int

type ServiceTelegraf

type ServiceTelegraf struct {
	Detail string
	// contains filtered or unexported fields
}

func (*ServiceTelegraf) Collect

func (s *ServiceTelegraf) Collect(collector pipeline.Collector) error

func (*ServiceTelegraf) Description

func (s *ServiceTelegraf) Description() string

func (*ServiceTelegraf) Init

func (s *ServiceTelegraf) Init(ctx pipeline.Context) (int, error)

func (*ServiceTelegraf) Start

func (s *ServiceTelegraf) Start(collector pipeline.Collector) error

func (*ServiceTelegraf) Stop

func (s *ServiceTelegraf) Stop() error