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