telegraf

Documentation

Index

• type Config
• type Manager
  • func GetTelegrafManager(agentDirPath string) *Manager
  • func (tm *Manager) RegisterConfig(c *Config)
  • func (tm *Manager) UnregisterConfig(c *Config)
• type ServiceTelegraf
  • func (s *ServiceTelegraf) Collect(collector ilogtail.Collector) error
  • func (s *ServiceTelegraf) Description() string
  • func (s *ServiceTelegraf) Init(ctx ilogtail.Context) (int, error)
  • func (s *ServiceTelegraf) Start(collector ilogtail.Collector) error
  • func (s *ServiceTelegraf) Stop() error

Types

type Config

type Config struct {
	Name   string
	Detail string
}

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) RegisterConfig

func (tm *Manager) RegisterConfig(c *Config)

func (*Manager) UnregisterConfig

func (tm *Manager) UnregisterConfig(c *Config)

type ServiceTelegraf

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

func (*ServiceTelegraf) Collect

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

func (*ServiceTelegraf) Description

func (s *ServiceTelegraf) Description() string

func (*ServiceTelegraf) Init

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

func (*ServiceTelegraf) Start

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

func (*ServiceTelegraf) Stop

func (s *ServiceTelegraf) Stop() error