emitter

Documentation

Index

• func IsTerminal(w io.Writer) bool
• func NewFileFromPath(ctx context.Context, engine storage.Engine, path string, unbuffered bool, ...) (zio.WriteCloser, error)
• func NewFileFromURI(ctx context.Context, engine storage.Engine, path *storage.URI, unbuffered bool, ...) (zio.WriteCloser, error)
• func NewSizeSplitter(ctx context.Context, engine storage.Engine, dir *storage.URI, prefix string, ...) (zio.WriteCloser, error)
• type Bytes
  • func NewBytes(opts anyio.WriterOpts) (*Bytes, error)
  • func (b *Bytes) Bytes() []byte
• type Split
  • func NewSplit(ctx context.Context, engine storage.Engine, dir *storage.URI, prefix string, ...) (*Split, error)
  • func (s *Split) Close() error
  • func (s *Split) Write(r zed.Value) error

Functions

func IsTerminal

func IsTerminal(w io.Writer) bool

func NewFileFromPath

func NewFileFromPath(ctx context.Context, engine storage.Engine, path string, unbuffered bool, opts anyio.WriterOpts) (zio.WriteCloser, error)

func NewFileFromURI

func NewFileFromURI(ctx context.Context, engine storage.Engine, path *storage.URI, unbuffered bool, opts anyio.WriterOpts) (zio.WriteCloser, error)

func NewSizeSplitter

func NewSizeSplitter(ctx context.Context, engine storage.Engine, dir *storage.URI, prefix string, unbuffered bool,
	opts anyio.WriterOpts, size int64) (zio.WriteCloser, error)

NewSizeSplitter returns a zio.WriteCloser that writes to sequentially numbered files created by engine in dir with optional prefix and with opts, creating a new file after the current one reaches size bytes. Files may exceed size substantially due to buffering in the underlying writer as determined by opts.Format.

Types

type Bytes

type Bytes struct {
	zio.Writer
	// contains filtered or unexported fields
}

func NewBytes

func NewBytes(opts anyio.WriterOpts) (*Bytes, error)

func (*Bytes) Bytes

func (b *Bytes) Bytes() []byte

type Split

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

func NewSplit

func NewSplit(ctx context.Context, engine storage.Engine, dir *storage.URI, prefix string, unbuffered bool, opts anyio.WriterOpts) (*Split, error)

func (*Split) Close

func (s *Split) Close() error

func (*Split) Write

func (s *Split) Write(r zed.Value) error