emitter

Documentation

Index

• func IsTerminal(w io.Writer) bool
• func NewFileFromPath(ctx context.Context, engine storage.Engine, path string, opts anyio.WriterOpts) (zio.WriteCloser, error)
• func NewFileFromURI(ctx context.Context, engine storage.Engine, path *storage.URI, ...) (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, opts anyio.WriterOpts) (zio.WriteCloser, error)

func NewFileFromURI

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

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, opts anyio.WriterOpts) (*Split, error)

func (*Split) Close

func (s *Split) Close() error

func (*Split) Write

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