queryresult

Documentation

Index

• type Result
  • func NewResult(cols []*queryresult.ColumnDef) *Result
  • func (r *Result) Close()
  • func (*Result) IsExportSourceData()
  • func (r *Result) StreamError(err error)
  • func (r *Result) StreamRow(rowResult []interface{})
• type ResultStreamer
  • func NewResultStreamer() *ResultStreamer
  • func (q *ResultStreamer) AllResultsRead()
  • func (q *ResultStreamer) Close()
  • func (q *ResultStreamer) StreamResult(result *Result)
• type RowResult
• type SyncQueryResult
• type TimingMetadata

Types

type Result

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

func NewResult

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

func (*Result) Close

func (r *Result) Close()

Close closes the row channel

func (*Result) IsExportSourceData

func (*Result) IsExportSourceData()

IsExportSourceData implements ExportSourceData

func (*Result) StreamError

func (r *Result) StreamError(err error)

func (*Result) StreamRow

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

type ResultStreamer

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

func NewResultStreamer

func NewResultStreamer() *ResultStreamer

func (*ResultStreamer) AllResultsRead

func (q *ResultStreamer) AllResultsRead()

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

func (*ResultStreamer) Close

func (q *ResultStreamer) Close()

Close closes the result stream

func (*ResultStreamer) StreamResult

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

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

type RowResult

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

type SyncQueryResult

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

type TimingMetadata

type TimingMetadata struct {
	Duration time.Duration
}