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