main.go

package main

import (
	"fmt"
	"github.com/astaxie/beego/logs"
	"github.com/rh01/logagent/kafka"
)

func main() {

	// 读取配置
	filename := "./conf/logcollect.conf"
	err := LoadConf("ini", filename)
	if err != nil {
		fmt.Printf("load conf failed, err: %v\n", err)
		panic("load conf failed")
	}

	//初始化配置
	err = InitLogger()
	if err != nil {
		fmt.Printf("load conf failed, err: %v\n", err)
		panic(err)
		return
	}

	logs.Debug("initial success!")
	logs.Debug("logs filename: %v", AppConfig)



	// 初始化kafka配置
	// 参考：
	err = kafka.InitKafka(AppConfig.kafkaAddr)
	if err != nil {
		logs.Error("init kafka failed, error %v", err)
		return
	}

	collectConf, err := initEtcd(AppConfig.etcdAddrr, AppConfig.configKey)

	if err != nil {
		logs.Error("init etcd failed, err %v", err)
		return
	}

	// 初始化tailf配置
	// Refer this document： https://github.com/hpcloud/tail
	err = InitTail(collectConf, AppConfig.ChanSize)
	if err != nil {
		logs.Error("init tail failed, error %v", err)
		return
	}// 初始化tailf配置
	// Refer this document： https://github.com/hpcloud/tail
	err = InitTail(AppConfig.collectConf, AppConfig.ChanSize)
	if err != nil {
		logs.Error("init tail failed, error %v", err)
		return
	}

	logs.Debug("init all success...")

	// 测试
	/*go func() {
		var count int
		for {
			logs.Debug("test for logger %d", count)
			count++
			time.Sleep(time.Millisecond * 10)
		}
	}()*/

	// 真正的业务逻辑处理函数
	err = ServerRun()
	if err != nil {
		logs.Error("server run failed ...")
	}

	logs.Info("program exited...")

}