sinker

package
Version: v0.0.0-...-b042743 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 12, 2017 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL