taillog

Documentation

Index

• func Init(logEntryConf []*etcd.LogEntry)
• func NewConfChan() chan<- []*etcd.LogEntry
• type TailTask
  • func NewTailTask(path, topic string) (tailObj *TailTask)

Functions

func Init

func Init(logEntryConf []*etcd.LogEntry)

Init 初始化

func NewConfChan

func NewConfChan() chan<- []*etcd.LogEntry

NewConfChan 一个函数，向外暴露taskMgr的newConfChan

Types

type TailTask

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

TailTask 一个日志收集的任务

func NewTailTask

func NewTailTask(path, topic string) (tailObj *TailTask)

NewTailTask 新建task