shape

package

v0.31.0 Latest Latest Go to latest Published: Oct 4, 2021 License: BSD-3-Clause Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var BatchSize = 100

View Source

var MemMaxBytes = 128 * 1024 * 1024

This section is empty.

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

func New(pctx *proc.Context, parent proc.Interface) (*Proc, error)

func (p *Proc) Done()

func (p *Proc) Pull() (zbuf.Batch, error)

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

func NewShaper(zctx *zed.Context, memMaxBytes int) *Shaper

func (s *Shaper) Close() error

Close removes the receiver's temporary file if it created one.

func (s *Shaper) Read() (*zed.Record, error)

func (s *Shaper) Write(rec *zed.Record) error

Write buffers rec. If called after Read, Write panics.