sinker

Documentation

Index

• type SinkWorker
  • func NewSinkWorker(filePath string, fileName string, fileMaxSize int64, flushDuration uint32) *SinkWorker
  • func (worker *SinkWorker) Close() error
  • func (worker *SinkWorker) LogQueue() *queue.LogQueue
  • func (worker *SinkWorker) Run() error
• type Sinker
  • func NewSinker(path string, fileMaxSize int64, flushDuration uint32, logQueue *queue.LogQueue) *Sinker
  • func (sinker *Sinker) Close() error
  • func (sinker *Sinker) Run() error

Types

type SinkWorker

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

Sink worker

func NewSinkWorker

func NewSinkWorker(filePath string, fileName string, fileMaxSize int64, flushDuration uint32) *SinkWorker

New sink worker function

func (*SinkWorker) Close

func (worker *SinkWorker) Close() error

Close function

func (*SinkWorker) LogQueue

func (worker *SinkWorker) LogQueue() *queue.LogQueue

Get log queue

func (*SinkWorker) Run

func (worker *SinkWorker) Run() error

Run to sink log to file

type Sinker

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

Log sinker

func NewSinker

func NewSinker(path string, fileMaxSize int64, flushDuration uint32, logQueue *queue.LogQueue) *Sinker

New sinker function

func (*Sinker) Close

func (sinker *Sinker) Close() error

Close and flush file buffer

func (*Sinker) Run

func (sinker *Sinker) Run() error

Run to sink