queryio

package

v0.33.0 Latest Latest Go to latest Published: Nov 17, 2021 License: BSD-3-Clause Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

func RunClientResponse(ctx context.Context, d driver.Driver, res *client.Response) (zbuf.ScannerStats, error)

type ControlWriter interface {
	zio.WriteCloser
	WriteControl(interface{}) error
}

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

func NewDriver(w io.WriteCloser, format string, ctrl bool) (*Driver, error)

func (d *Driver) ChannelEnd(channelID int) error

func (d *Driver) Close() error

func (d *Driver) Error(err error)

func (d *Driver) Stats(stats zbuf.ScannerStats) error

func (d *Driver) Warn(warning string) error

func (d *Driver) Write(cid int, batch zbuf.Batch) error

func (d *Driver) WriteControl(value interface{}) error

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

func NewZJSONWriter(w io.Writer) *ZJSONWriter

func (w *ZJSONWriter) Close() error

func (w *ZJSONWriter) Write(rec *zed.Value) error

func (w *ZJSONWriter) WriteControl(v interface{}) error

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

func NewZNGReader(r *zngio.Reader) *ZNGReader

func (r *ZNGReader) ReadPayload() (*zed.Value, interface{}, error)

type ZNGWriter struct {
	*zngio.Writer
	// contains filtered or unexported fields
}

func NewZNGWriter(w io.WriteCloser) *ZNGWriter

func (w *ZNGWriter) WriteControl(v interface{}) error