telegraf

Documentation

Index

• Constants
• type BindingMeta
  • func NewBindMeta() *BindingMeta
  • func (b *BindingMeta) Add(prj, logstore, cfg string)
  • func (b *BindingMeta) Delete(prj, logstore, cfg string)
  • func (b *BindingMeta) UpdateAlarm()
• 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 ilogtail.Context, c *Config)
  • func (tm *Manager) UnregisterConfig(ctx ilogtail.Context, c *Config)
• type Processor
  • func (p *Processor) Process(fileBlock []byte, noChangeInterval time.Duration) int
• 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

Constants

const (
	TelegrafAlarmType = "TELEGRAF_ALARM"
)

Types

type BindingMeta

type BindingMeta struct {
	Metas map[string]map[string]map[string]struct{}
	// contains filtered or unexported fields
}

func NewBindMeta

func NewBindMeta() *BindingMeta

func (*BindingMeta) Add

func (b *BindingMeta) Add(prj, logstore, cfg string)

func (*BindingMeta) Delete

func (b *BindingMeta) Delete(prj, logstore, cfg string)

func (*BindingMeta) UpdateAlarm

func (b *BindingMeta) UpdateAlarm()

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 ilogtail.Context, c *Config)

func (*Manager) UnregisterConfig

func (tm *Manager) UnregisterConfig(ctx ilogtail.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 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