# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!"""Client and server classes corresponding to protobuf-defined services."""importgrpcfrom.importserializerasjina__pb2
[docs]classJinaControlRequestRPCStub(object):"""* jina gRPC service for ControlRequests. """def__init__(self,channel):"""Constructor. Args: channel: A grpc.Channel. """self.process_control=channel.unary_unary('/jina.JinaControlRequestRPC/process_control',request_serializer=jina__pb2.ControlRequestProto.SerializeToString,response_deserializer=jina__pb2.ControlRequestProto.FromString,)
[docs]classJinaControlRequestRPCServicer(object):"""* jina gRPC service for ControlRequests. """
[docs]defprocess_control(self,request,context):"""Used for passing ControlRequests to the Executors """context.set_code(grpc.StatusCode.UNIMPLEMENTED)context.set_details('Method not implemented!')raiseNotImplementedError('Method not implemented!')
[docs]classJinaDataRequestRPCStub(object):"""* jina gRPC service for DataRequests. """def__init__(self,channel):"""Constructor. Args: channel: A grpc.Channel. """self.process_data=channel.unary_unary('/jina.JinaDataRequestRPC/process_data',request_serializer=jina__pb2.DataRequestListProto.SerializeToString,response_deserializer=jina__pb2.DataRequestProto.FromString,)
[docs]classJinaDataRequestRPCServicer(object):"""* jina gRPC service for DataRequests. """
[docs]defprocess_data(self,request,context):"""Used for passing DataRequests to the Executors """context.set_code(grpc.StatusCode.UNIMPLEMENTED)context.set_details('Method not implemented!')raiseNotImplementedError('Method not implemented!')
[docs]classJinaSingleDataRequestRPCStub(object):"""* jina gRPC service for DataRequests. This is used to send requests to Executors when a list of requests is not needed """def__init__(self,channel):"""Constructor. Args: channel: A grpc.Channel. """self.process_single_data=channel.unary_unary('/jina.JinaSingleDataRequestRPC/process_single_data',request_serializer=jina__pb2.DataRequestProto.SerializeToString,response_deserializer=jina__pb2.DataRequestProto.FromString,)
[docs]classJinaSingleDataRequestRPCServicer(object):"""* jina gRPC service for DataRequests. This is used to send requests to Executors when a list of requests is not needed """
[docs]defprocess_single_data(self,request,context):"""Used for passing DataRequests to the Executors """context.set_code(grpc.StatusCode.UNIMPLEMENTED)context.set_details('Method not implemented!')raiseNotImplementedError('Method not implemented!')
[docs]classJinaSingleDataRequestRPC(object):"""* jina gRPC service for DataRequests. This is used to send requests to Executors when a list of requests is not needed """
[docs]classJinaRPCStub(object):"""* jina Gateway gRPC service. """def__init__(self,channel):"""Constructor. Args: channel: A grpc.Channel. """self.Call=channel.stream_stream('/jina.JinaRPC/Call',request_serializer=jina__pb2.DataRequestProto.SerializeToString,response_deserializer=jina__pb2.DataRequestProto.FromString,)
[docs]classJinaRPCServicer(object):"""* jina Gateway gRPC service. """
[docs]defCall(self,request_iterator,context):"""Pass in a Request and a filled Request with matches will be returned. """context.set_code(grpc.StatusCode.UNIMPLEMENTED)context.set_details('Method not implemented!')raiseNotImplementedError('Method not implemented!')