vngio

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 11, 2023 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultColumnThresh = 5 * 1024 * 1024
	DefaultSkewThresh   = 25 * 1024 * 1024
)

Variables

This section is empty.

Functions

func NewReader 

func NewReader(zctx *zed.Context, r io.Reader, demandOut demand.Demand) (zio.Reader, error)

func NewWriter 

func NewWriter(w io.WriteCloser) (*vng.Writer, error)

NewWriter returns a writer to w with reasonable default options.

func NewWriterWithOpts added in v1.11.0 

func NewWriterWithOpts(w io.WriteCloser, opts WriterOpts) (*vng.Writer, error)

Types

type Reader added in v1.11.0 

type Reader struct {

	// TODO Demand should not be public but currently needed for testing.
	Demand demand.Demand
	// contains filtered or unexported fields
}

func (*Reader) Read added in v1.11.0 

func (r *Reader) Read() (*zed.Value, error)

type WriterOpts 

type WriterOpts struct {
	ColumnThresh units.Bytes
	SkewThresh   units.Bytes
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.