Documentation ¶
Index ¶
- type SumQPU
- func (q *SumQPU) ClientQuery(query libqpu.ASTQuery, queryStr string, parentSpan opentracing.Span) (*qpuextapi.QueryResp, error)
- func (q *SumQPU) GetConfig() *qpuapi.ConfigResponse
- func (q *SumQPU) ProcessQuerySnapshot(query libqpu.ASTQuery, md map[string]string, sync bool, ...) (<-chan libqpu.LogOperation, <-chan error)
- func (q *SumQPU) ProcessQuerySubscribe(query libqpu.ASTQuery, md map[string]string, sync bool) (int, <-chan libqpu.LogOperation, <-chan error)
- func (q *SumQPU) QuerySubscribe(libqpu.ASTQuery, *qpuextapi.QueryReq) (chan libqpu.LogOperation, chan bool, chan error)
- func (q *SumQPU) RemovePersistentQuery(table string, queryID int)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SumQPU ¶
type SumQPU struct {
// contains filtered or unexported fields
}
SumQPU ...
func (*SumQPU) ClientQuery ¶
func (q *SumQPU) ClientQuery(query libqpu.ASTQuery, queryStr string, parentSpan opentracing.Span) (*qpuextapi.QueryResp, error)
ClientQuery ...
func (*SumQPU) ProcessQuerySnapshot ¶
func (q *SumQPU) ProcessQuerySnapshot(query libqpu.ASTQuery, md map[string]string, sync bool, parentSpan opentracing.Span) (<-chan libqpu.LogOperation, <-chan error)
ProcessQuerySnapshot ...
func (*SumQPU) ProcessQuerySubscribe ¶
func (q *SumQPU) ProcessQuerySubscribe(query libqpu.ASTQuery, md map[string]string, sync bool) (int, <-chan libqpu.LogOperation, <-chan error)
ProcessQuerySubscribe ...
func (*SumQPU) QuerySubscribe ¶
func (q *SumQPU) QuerySubscribe(libqpu.ASTQuery, *qpuextapi.QueryReq) (chan libqpu.LogOperation, chan bool, chan error)
QuerySubscribe ...
func (*SumQPU) RemovePersistentQuery ¶
RemovePersistentQuery ...
Click to show internal directories.
Click to hide internal directories.