The highest tagged major version is v2.

queryresult

package

v0.7.1-debug.0 Latest Latest Go to latest Published: Aug 4, 2021 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
	ColTypes []*sql.ColumnType
	Duration chan time.Duration
}

func NewQueryResult(colTypes []*sql.ColumnType) *Result

func (r Result) Close()

Close closes the row channel

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) Close()

func (q *ResultStreamer) Done()

Done :: signals that the next Result has been processed

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

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

func (q *ResultStreamer) Wait()

Wait :: waits for the next Result to get processed

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

type SyncQueryResult struct {
	Rows     []interface{}
	ColTypes []*sql.ColumnType
	Duration time.Duration
}