ztail

package

v1.0.2 Latest Latest Go to latest Published: Aug 23, 2021 License: BSD-3-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/brimdata/brimcap

Links

Open Source Insights

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 ¶

type Tailer
- func New(zctx *zson.Context, dir string, opts anyio.ReaderOpts, warner zio.Warner, ...) (*Tailer, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 *zng.Records and returned on a first-come-first serve basis.

func New ¶

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

func (*Tailer) Close ¶

func (t *Tailer) Close() error

func (*Tailer) Read ¶

func (t *Tailer) Read() (*zng.Record, 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.

Source Files ¶

View all Source files

ztail.go

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