beats 组件的开发

看了一下filebeat源码,提取了主干,但是还是不知道filebeat到底如何加载配置文件,如何采集日志文件,请问我该从哪入手好切入,求大神指导。感激不尽。。。

已邀请:

duanquanyong

赞同来自: KSpeer

如果只是增加一个processor或者output的话。
只需要注册进去就可以了


package main

import (
_ "processor/command"
_ "output/nsq"
"github.com/elastic/beats/filebeat/cmd"
"os"
)

func main() {
if err := cmd.RootCmd.Execute(); err != nil {
os.Exit(1)
}
}

package command

import (
"github.com/elastic/beats/libbeat/processors"
)

func init() {
processors.RegisterPlugin("command",
processor.ConfigChecked(New,
processor.RequireFields("cwd"),
processor.RequireFields("name"),
processor.RequireFields("args"),
processor.AllowedFields("cwd", "name", "args"),
))
}

如果不是,看看文档吧
https://www.elastic.co/guide/en/beats/libbeat/current/new-beat.html

要回复问题请先登录注册