Documentation
¶
Index ¶
- Variables
- type Ctx
- func (qc *Ctx) Exec(ctx context.Context, queryContent string) (*Result, error)
- func (qc *Ctx) OnlineReadOnly() *Ctx
- func (qc *Ctx) OnlineReadOnlyInconsistent() *Ctx
- func (qc *Ctx) Query(queryContent string) *Query
- func (qc *Ctx) SerializableReadWrite() *Ctx
- func (qc *Ctx) SnapshotReadOnly() *Ctx
- func (qc *Ctx) StaleReadOnly() *Ctx
- func (qc *Ctx) Tx(ctx context.Context) (*Transaction, error)
- type Query
- type Result
- type Transaction
- type TxQuery
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrPartStatus = errors.New("result part status error") ErrStream = errors.New("result stream error") ErrIssues = errors.New("query result has issues") )
View Source
var (
ErrFinished = errors.New("transaction already finished")
)
View Source
var (
ErrResult = errors.New("result fetch error")
)
Functions ¶
This section is empty.
Types ¶
type Ctx ¶
type Ctx struct {
// contains filtered or unexported fields
}
func (*Ctx) OnlineReadOnly ¶
func (*Ctx) OnlineReadOnlyInconsistent ¶
func (*Ctx) SerializableReadWrite ¶
func (*Ctx) SnapshotReadOnly ¶
func (*Ctx) StaleReadOnly ¶
type Result ¶
type Result struct {
// contains filtered or unexported fields
}
func (*Result) Issues ¶
func (r *Result) Issues() []*Ydb_Issue.IssueMessage
func (*Result) Stats ¶
func (r *Result) Stats() *Ydb_TableStats.QueryStats
type Transaction ¶
type Transaction struct {
// contains filtered or unexported fields
}
func (*Transaction) Query ¶
func (tx *Transaction) Query(queryContent string) *TxQuery
Click to show internal directories.
Click to hide internal directories.