queryio

package

v1.18.0 Latest Latest Go to latest Published: Sep 20, 2024 License: BSD-3-Clause Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

func NewScanner(ctx context.Context, rc io.ReadCloser) (zbuf.Scanner, error)

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

func NewWriter(w io.WriteCloser, format string, flusher http.Flusher, ctrl bool) (*Writer, error)

func (w *Writer) Close() error

func (w *Writer) WhiteChannelEnd(channel string) error

func (w *Writer) WriteBatch(channel string, batch zbuf.Batch) error

func (w *Writer) WriteControl(value interface{}) error

func (w *Writer) WriteError(err error)

func (w *Writer) WriteProgress(stats zbuf.Progress) 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 ZNGWriter struct {
	*zngio.Writer
	// contains filtered or unexported fields
}

func NewZNGWriter(w io.Writer) *ZNGWriter

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