py-modules/common/proto/BluePrintProcessing_pb2_grpc.py

   1 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
   2 """Client and server classes corresponding to protobuf-defined services."""
   3 import grpc
   4
   5 import proto.BluePrintProcessing_pb2 as BluePrintProcessing__pb2
   6
   7
   8 class BluePrintProcessingServiceStub(object):
   9   """Missing associated documentation comment in .proto file."""
  10
  11   def __init__(self, channel):
  12     """Constructor.
  13
  14     Args:
  15         channel: A grpc.Channel.
  16     """
  17     self.process = channel.stream_stream(
  18         '/org.onap.ccsdk.cds.controllerblueprints.processing.api.BluePrintProcessingService/process',
  19         request_serializer=BluePrintProcessing__pb2.ExecutionServiceInput.SerializeToString,
  20         response_deserializer=BluePrintProcessing__pb2.ExecutionServiceOutput.FromString,
  21     )
  22
  23
  24 class BluePrintProcessingServiceServicer(object):
  25   """Missing associated documentation comment in .proto file."""
  26
  27   def process(self, request_iterator, context):
  28     """Missing associated documentation comment in .proto file."""
  29     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
  30     context.set_details('Method not implemented!')
  31     raise NotImplementedError('Method not implemented!')
  32
  33
  34 def add_BluePrintProcessingServiceServicer_to_server(servicer, server):
  35   rpc_method_handlers = {
  36     'process': grpc.stream_stream_rpc_method_handler(
  37         servicer.process,
  38         request_deserializer=BluePrintProcessing__pb2.ExecutionServiceInput.FromString,
  39         response_serializer=BluePrintProcessing__pb2.ExecutionServiceOutput.SerializeToString,
  40     ),
  41   }
  42   generic_handler = grpc.method_handlers_generic_handler(
  43       'org.onap.ccsdk.cds.controllerblueprints.processing.api.BluePrintProcessingService', rpc_method_handlers)
  44   server.add_generic_rpc_handlers((generic_handler,))
  45
  46
  47 # This class is part of an EXPERIMENTAL API.
  48 class BluePrintProcessingService(object):
  49   """Missing associated documentation comment in .proto file."""
  50
  51   @staticmethod
  52   def process(request_iterator,
  53       target,
  54       options=(),
  55       channel_credentials=None,
  56       call_credentials=None,
  57       insecure=False,
  58       compression=None,
  59       wait_for_ready=None,
  60       timeout=None,
  61       metadata=None):
  62     return grpc.experimental.stream_stream(request_iterator, target, '/org.onap.ccsdk.cds.controllerblueprints.processing.api.BluePrintProcessingService/process',
  63                                            BluePrintProcessing__pb2.ExecutionServiceInput.SerializeToString,
  64                                            BluePrintProcessing__pb2.ExecutionServiceOutput.FromString,
  65                                            options, channel_credentials,
  66                                            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)