filter

Documentation

Index

• func Filter(predicate []*pbUtils.AttributePredicate, streamRec *pbQPU.ResponseStreamRecord) (bool, error)
• type FQPU
  • func QPU(conf *config.Config) (*FQPU, error)
  • func (q *FQPU) Cleanup()
  • func (q *FQPU) GetConfig() (*pbQPU.ConfigResponse, error)
  • func (q *FQPU) GetDataTransfer() float32
  • func (q *FQPU) Query(streamOut pbQPU.QPU_QueryServer, requestRec *pbQPU.RequestStream) error

Functions

func Filter

func Filter(predicate []*pbUtils.AttributePredicate, streamRec *pbQPU.ResponseStreamRecord) (bool, error)

Filter ...

Types

type FQPU

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

FQPU implements a filter QPU

func QPU

func QPU(conf *config.Config) (*FQPU, error)

QPU creates a filter QPU

func (*FQPU) Cleanup

func (q *FQPU) Cleanup()

Cleanup is called when the QPU receives a SIGTERM signcal

func (*FQPU) GetConfig

func (q *FQPU) GetConfig() (*pbQPU.ConfigResponse, error)

GetConfig implements the GetConfig API for the filter QPU

func (*FQPU) GetDataTransfer

func (q *FQPU) GetDataTransfer() float32

GetDataTransfer ...

func (*FQPU) Query

func (q *FQPU) Query(streamOut pbQPU.QPU_QueryServer, requestRec *pbQPU.RequestStream) error

Query implements the Query API for the filter QPU