joinqpu

Documentation

Index

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

Types

type JoinQPU

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

JoinQPU ...

func InitClass

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

InitClass ...

func (*JoinQPU) ClientQuery

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

ClientQuery ...

func (*JoinQPU) GetConfig

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

GetConfig ...

func (*JoinQPU) ProcessQuerySnapshot

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

ProcessQuerySnapshot ...

func (*JoinQPU) ProcessQuerySubscribe

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

ProcessQuerySubscribe ...

func (*JoinQPU) QuerySubscribe

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

QuerySubscribe ...

func (*JoinQPU) RemovePersistentQuery

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

RemovePersistentQuery ...