30 lines
484 B
Go
30 lines
484 B
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"logagent/kafka"
|
|
"logagent/taillog"
|
|
)
|
|
|
|
//logagent的入口程序
|
|
|
|
func run() {
|
|
//1.读取日志
|
|
//2.发送给kafka
|
|
}
|
|
|
|
func main() {
|
|
//1.初始化kafka连接
|
|
err := kafka.Init([]string{"152.136.226.203:9093"})
|
|
if err != nil {
|
|
fmt.Printf("init kafka failed,error:%v\n", err)
|
|
return
|
|
}
|
|
//2.打开日志文件准备收集日志
|
|
err = taillog.Init("./mylog.log")
|
|
if err != nil {
|
|
fmt.Printf("taillog init failed,error:%v\n", err)
|
|
return
|
|
}
|
|
}
|