Struct Query

runtime/exec/query.go:12–16

Query runs a flowgraph as a sbuf.Puller and implements a Close() method that gracefully tears down the flowgraph. Its AsReader() and AsProgressReader() methods provide a convenient means to run a flowgraph as sio.Reader.

// that gracefully tears down the flowgraph.  Its AsReader() and AsProgressReader()
// methods provide a convenient means to run a flowgraph as sio.Reader.
type Query struct {
	vio.Puller
	rctx  *runtime.Context
	meter vio.Meter
}

var _ runtime.Query = (*Query)(nil)