queryresult

package

v0.4.0 Latest Latest Go to latest Published: Jun 10, 2024 License: AGPL-3.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Result struct {
	RowChan *chan *RowResult
	Cols    []*queryresult.ColumnDef
	Timing  *TimingMetadata
}

func NewResult(cols []*queryresult.ColumnDef) *Result

func (r *Result) Close()

Close closes the row channel

func (*Result) IsExportSourceData()

IsExportSourceData implements ExportSourceData

func (r *Result) StreamError(err error)

func (r *Result) StreamRow(rowResult []interface{})

type ResultStreamer struct {
	Results chan *Result
	// contains filtered or unexported fields
}

func NewResultStreamer() *ResultStreamer

func (q *ResultStreamer) AllResultsRead()

AllResultsRead is a signal that indicates the all results have been read from the stream

func (q *ResultStreamer) Close()

Close closes the result stream

func (q *ResultStreamer) StreamResult(result *Result)

StreamResult streams result on the Results channel, then waits for them to be read

type RowResult struct {
	Data  []interface{}
	Error error
}

type SyncQueryResult struct {
	Rows []interface{}
	Cols []*queryresult.ColumnDef
}

type TimingMetadata struct {
	Duration time.Duration
}