Documentation ¶
Index ¶
- type APIProcessor
- func (s *APIProcessor) GetConfig(ctx context.Context, in *qpuapi.ConfigRequest) (*qpuapi.ConfigResponse, error)
- func (s *APIProcessor) Query(queryReq libqpu.QueryRequest, stream libqpu.RequestStream) error
- func (s *APIProcessor) QuerySubscribe(queryReq *qpuextapi.QueryReq, stream qpuapi.QPUAPI_QuerySubscribeServer) error
- func (s *APIProcessor) QueryUnary(req libqpu.QueryRequest, parentSpan opentracing.Span) (*qpuextapi.QueryResp, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIProcessor ¶
type APIProcessor struct {
// contains filtered or unexported fields
}
APIProcessor implements the libqpu.APIProcessor interface. It provides access to the methods implemented by libqpu.QPUClass.
func NewProcessor ¶
func NewProcessor(qpu *libqpu.QPU, catchUpDoneCh chan int) (*APIProcessor, error)
NewProcessor creates an instance of APIProcessor. It initiates the libqpu.QPUClass corresponding to the QPU's class.
func (*APIProcessor) GetConfig ¶
func (s *APIProcessor) GetConfig(ctx context.Context, in *qpuapi.ConfigRequest) (*qpuapi.ConfigResponse, error)
GetConfig is responsible for the top-level processing of invocation of the GetConfig API.
func (*APIProcessor) Query ¶
func (s *APIProcessor) Query(queryReq libqpu.QueryRequest, stream libqpu.RequestStream) error
Query is responsible for the top-level processing of invocation of the Query API.
func (*APIProcessor) QuerySubscribe ¶
func (s *APIProcessor) QuerySubscribe(queryReq *qpuextapi.QueryReq, stream qpuapi.QPUAPI_QuerySubscribeServer) error
QuerySubscribe ...
func (*APIProcessor) QueryUnary ¶
func (s *APIProcessor) QueryUnary(req libqpu.QueryRequest, parentSpan opentracing.Span) (*qpuextapi.QueryResp, error)
QueryUnary ...
Click to show internal directories.
Click to hide internal directories.