taillog

Documentation

Index

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

Functions

func Init

func Init(logEntryConf []*etcd.LogEntry)

func NewConfChan

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

NewConfChan 一个函数,向外暴露tskMgr的newConfChan 内部私有字段 向外暴露

func PushNewConf

func PushNewConf(newConf []*etcd.LogEntry)

PushNewConf 一个函数,向外暴露tskMgr的newConfChan 内部私有字段 向外暴露

Types

type TailTask

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

TailTask 一个日志收集的任务

func NewTailTask

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

func (*TailTask) ReadChan

func (t *TailTask) ReadChan() <-chan *tail.Line