Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Result ¶
type Result struct {
RowChan *chan *RowResult
ColTypes []*sql.ColumnType
TimingResult chan *TimingResult
}
func NewQueryResult ¶
func NewQueryResult(colTypes []*sql.ColumnType) *Result
func (Result) StreamError ¶
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) StreamResult ¶
func (q *ResultStreamer) StreamResult(result *Result)
StreamResult streams result on the Results channel, then waits for them to be read
type SyncQueryResult ¶
type SyncQueryResult struct {
Rows []interface{}
ColTypes []*sql.ColumnType
TimingResult *TimingResult
}
type TimingMetadata ¶
type TimingResult ¶
type TimingResult struct {
Duration time.Duration
Metadata *TimingMetadata
}
Click to show internal directories.
Click to hide internal directories.