tailLog

Documentation

Index

• Variables
• func ExposeChan() chan<- []*etcd.LogEntries
• func Init(fileName string) (err error)
• func NewTailMgr(logConfList []*etcd.LogEntries)
• func ReadChan() <-chan *tail.Line
• type TailMgr
• type TailTask
  • func NewTailTask(path, topic string) (tailObj *TailTask)
  • func (t *TailTask) ReadChan() <-chan *tail.Line
  • func (t *TailTask) ReadSendMsg()

Variables

var (
	Tails *tail.Tail
)

Functions

func ExposeChan

func ExposeChan() chan<- []*etcd.LogEntries

向外暴露通道newConfChan

func Init

func Init(fileName string) (err error)

以下用不到

func NewTailMgr

func NewTailMgr(logConfList []*etcd.LogEntries)

func ReadChan

func ReadChan() <-chan *tail.Line

Types

type TailMgr

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

管理所有tails-->tailObj

type TailTask

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

一个日志收集的任务

func NewTailTask

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

func (*TailTask) ReadChan

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

func (*TailTask) ReadSendMsg

func (t *TailTask) ReadSendMsg()