tailf

Documentation

Index

• Constants
• func InitTailf(collects []Collect, chanSize int, ip string) (err error)
• func UpdateTailfTask(collectConfig []Collect) (err error)
• type Collect
• type KafkaMsg
• type TailObj
• type TailsObjMgr
• type TextMsg
  • func GetOneLine() (msg *TextMsg)

Constants

const (
	StatusNormal = 1
	StatusDelete = 2
)

Functions

func InitTailf

func InitTailf(collects []Collect, chanSize int, ip string) (err error)

初始化tailf

func UpdateTailfTask

func UpdateTailfTask(collectConfig []Collect) (err error)

更新tailf任务

Types

type Collect

type Collect struct {
	Topic   string `json:"topic"`
	LogPath string `json:"logPath"`
}

日志收集任务定义

type KafkaMsg

type KafkaMsg struct {
	// Msg *tail.Line `json:"msg"`
	Msg string `json:"msg"`
	Ip  string `json:"ip"`
}

发送到kafka的消息

type TailObj

type TailObj struct {
	// contains filtered or unexported fields
}

tailf任务对象

type TailsObjMgr

type TailsObjMgr struct {
	// contains filtered or unexported fields
}

tailf任务对象管理

type TextMsg

type TextMsg struct {
	Msg   KafkaMsg
	Topic string
}

发送消息结构体

func GetOneLine

func GetOneLine() (msg *TextMsg)

从chan中获取一行数据