rpcserver

Documentation

Index

• type Server
  • func NewServer(port string, tracing bool, api libqpu.APIProcessor, state libqpu.QPUState, ...) (*Server, error)
  • func (s *Server) GetConfig(ctx context.Context, req *qpuapi.ConfigRequest) (*qpuapi.ConfigResponse, error)
  • func (s *Server) Query(stream qpuapi.QPUAPI_QueryServer) error
  • func (s *Server) QuerySubscribe(req *qpuextapi.QueryReq, stream qpuapi.QPUAPI_QuerySubscribeServer) error
  • func (s *Server) QueryUnary(ctx context.Context, req *qpuextapi.QueryReq) (*qpuextapi.QueryResp, error)
  • func (s *Server) Serve() error

Types

type Server

type Server struct {
	qpuapi.UnimplementedQPUAPIServer
	// contains filtered or unexported fields
}

Server represents the QPU's API server.

func NewServer

func NewServer(port string, tracing bool, api libqpu.APIProcessor, state libqpu.QPUState, conf *libqpu.QPUConfig) (*Server, error)

NewServer initializes a grpc server.

func (*Server) GetConfig

func (s *Server) GetConfig(ctx context.Context, req *qpuapi.ConfigRequest) (*qpuapi.ConfigResponse, error)

GetConfig implements the QPU's low level GetConfig API.

func (*Server) Query

func (s *Server) Query(stream qpuapi.QPUAPI_QueryServer) error

Query implements the QPU's low level Query API.

func (*Server) QuerySubscribe

func (s *Server) QuerySubscribe(req *qpuextapi.QueryReq, stream qpuapi.QPUAPI_QuerySubscribeServer) error

QuerySubscribe ...

func (*Server) QueryUnary

func (s *Server) QueryUnary(ctx context.Context, req *qpuextapi.QueryReq) (*qpuextapi.QueryResp, error)

QueryUnary ...

func (*Server) Serve

func (s *Server) Serve() error

Serve starts the server and listents for connections. It returns only when an error occurs.