ztail

Documentation

Overview

Package ztail provides facilities for watching a directory of logs, tailing all the files created within it and transforming the data into zng data.

Index

• func NewWarningReader(zr zio.Reader, w Warner) zio.Reader
• type Tailer
  • func New(zctx *zed.Context, dir string, opts anyio.ReaderOpts, warner Warner, ...) (*Tailer, error)
  • func (t *Tailer) Close() error
  • func (t *Tailer) Read() (*zed.Value, error)
  • func (t *Tailer) Stop() error
• type Warner
• type WarningReader
  • func (w *WarningReader) Read() (*zed.Value, error)

Functions

func NewWarningReader

func NewWarningReader(zr zio.Reader, w Warner) zio.Reader

NewWarningReader returns a Reader that reads from zr. Any error encountered results in a call to w with the warning as prameter, and then a nil *zed.Record and nil error are returned.

Types

type Tailer

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

Tailer is a zio.Reader that watches a specified directory and starts tailing existing and newly created files in the directory for new logs. Newly written log data are transformed into *zed.Values and returned on a first-come-first serve basis.

func New

func New(zctx *zed.Context, dir string, opts anyio.ReaderOpts, warner Warner, globs ...string) (*Tailer, error)

func (*Tailer) Close

func (t *Tailer) Close() error

func (*Tailer) Read

func (t *Tailer) Read() (*zed.Value, error)

func (*Tailer) Stop

func (t *Tailer) Stop() error

Stop instructs the directory watcher and indiviual file watchers to stop watching for changes. Read will emit EOS when the remaining unread data in files has been read.

type Warner

type Warner interface {
	Warn(msg string) error
}

type WarningReader

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

func (*WarningReader) Read

func (w *WarningReader) Read() (*zed.Value, error)