indexqpu

Documentation

Index

• type IndexQPU
  • func InitClass(qpu *libqpu.QPU, catchUpDoneCh chan int) (*IndexQPU, error)
  • func (q *IndexQPU) ClientQuery(query libqpu.ASTQuery, queryStr string, parentSpan opentracing.Span) (*qpuextapi.QueryResp, error)
  • func (q *IndexQPU) GetConfig() *qpuapi.ConfigResponse
  • func (q *IndexQPU) ProcessQuerySnapshot(query libqpu.ASTQuery, md map[string]string, sync bool, ...) (<-chan libqpu.LogOperation, <-chan error)
  • func (q *IndexQPU) ProcessQuerySubscribe(query libqpu.ASTQuery, md map[string]string, sync bool) (int, <-chan libqpu.LogOperation, <-chan error)
  • func (q *IndexQPU) QuerySubscribe(query libqpu.ASTQuery, req *qpuextapi.QueryReq) (chan libqpu.LogOperation, chan bool, chan error)
  • func (q *IndexQPU) RemovePersistentQuery(table string, queryID int)

Types

type IndexQPU

type IndexQPU struct {
	// contains filtered or unexported fields
}

IndexQPU ...

func InitClass

func InitClass(qpu *libqpu.QPU, catchUpDoneCh chan int) (*IndexQPU, error)

InitClass ...

func (*IndexQPU) ClientQuery

func (q *IndexQPU) ClientQuery(query libqpu.ASTQuery, queryStr string, parentSpan opentracing.Span) (*qpuextapi.QueryResp, error)

ClientQuery ...

func (*IndexQPU) GetConfig

func (q *IndexQPU) GetConfig() *qpuapi.ConfigResponse

GetConfig ...

func (*IndexQPU) ProcessQuerySnapshot

func (q *IndexQPU) ProcessQuerySnapshot(query libqpu.ASTQuery, md map[string]string, sync bool, parentSpan opentracing.Span) (<-chan libqpu.LogOperation, <-chan error)

ProcessQuerySnapshot ...

func (*IndexQPU) ProcessQuerySubscribe

func (q *IndexQPU) ProcessQuerySubscribe(query libqpu.ASTQuery, md map[string]string, sync bool) (int, <-chan libqpu.LogOperation, <-chan error)

ProcessQuerySubscribe ...

func (*IndexQPU) QuerySubscribe

func (q *IndexQPU) QuerySubscribe(query libqpu.ASTQuery, req *qpuextapi.QueryReq) (chan libqpu.LogOperation, chan bool, chan error)

QuerySubscribe ...

func (*IndexQPU) RemovePersistentQuery

func (q *IndexQPU) RemovePersistentQuery(table string, queryID int)

RemovePersistentQuery ...