Documentation ¶
Index ¶
Constants ¶
View Source
const (
TelegrafAlarmType = "TELEGRAF_ALARM"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogCollector ¶ added in v1.1.0
type LogCollector struct {
// contains filtered or unexported fields
}
func NewLogCollector ¶ added in v1.1.0
func NewLogCollector(agentDirPath string) *LogCollector
NewLogCollector create a log collector to read telegraf log.
func (*LogCollector) Run ¶ added in v1.1.0
func (l *LogCollector) Run()
func (*LogCollector) TelegrafStart ¶ added in v1.1.0
func (l *LogCollector) TelegrafStart()
func (*LogCollector) TelegrafStop ¶ added in v1.1.0
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 (*Manager) GetContext ¶ added in v1.1.0
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) Stop ¶
func (s *ServiceTelegraf) Stop() error
Click to show internal directories.
Click to hide internal directories.