datastoredriver

Documentation

Index

• type DsDriverQPU
  • func InitClass(qpu *libqpu.QPU, catchUpDoneCh chan int) (*DsDriverQPU, error)
  • 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)

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 ...