cacheqpu

Documentation

Index

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

Types

type CacheQPU

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

CacheQPU ...

func InitClass

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

InitClass ...

func (*CacheQPU) ClientQuery

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

ClientQuery ...

func (CacheQPU) GetConfig

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

GetConfig ...

func (*CacheQPU) ProcessQuerySnapshot

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

ProcessQuerySnapshot ...

func (*CacheQPU) ProcessQuerySubscribe

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

ProcessQuerySubscribe ...

func (*CacheQPU) QuerySubscribe

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

QuerySubscribe ...

func (*CacheQPU) RemovePersistentQuery

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

RemovePersistentQuery ...