collector

Documentation

Index

• func Setup(l *loggerpkg.Logger, a *alarm.Alarm)
• type Collector
  • func New(path, name string, outputMaker func(*loggerpkg.Logger) outputs.Output) *Collector
  • func (c *Collector) NotifyClose()
  • func (c *Collector) NotifyWrite()
  • func (c *Collector) OpenedSameFile(fi os.FileInfo) bool
  • func (c *Collector) Printf(format string, v ...interface{})
• type Reader

Functions

func Setup

func Setup(l *loggerpkg.Logger, a *alarm.Alarm)

Types

type Collector

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

func New

func New(path, name string, outputMaker func(*loggerpkg.Logger) outputs.Output) *Collector

func (*Collector) NotifyClose

func (c *Collector) NotifyClose()

func (*Collector) NotifyWrite

func (c *Collector) NotifyWrite()

func (*Collector) OpenedSameFile

func (c *Collector) OpenedSameFile(fi os.FileInfo) bool

func (*Collector) Printf

func (c *Collector) Printf(format string, v ...interface{})

type Reader

type Reader interface {
	Read() (rows []map[string]interface{}, drain bool)
	SaveOffset() string
	SameFile(os.FileInfo) bool
	Close()
}