osm_lcm/frontend_grpc.py

   1 ##
   2 # Copyright 2020 Telefonica Investigacion y Desarrollo, S.A.U.
   3 #
   4 # Licensed under the Apache License, Version 2.0 (the "License");
   5 # you may not use this file except in compliance with the License.
   6 # You may obtain a copy of the License at
   7 #
   8 #    http://www.apache.org/licenses/LICENSE-2.0
   9 #
  10 # Unless required by applicable law or agreed to in writing, software
  11 # distributed under the License is distributed on an "AS IS" BASIS,
  12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
  13 # implied.
  14 # See the License for the specific language governing permissions and
  15 # limitations under the License.
  16 #
  17 ##
  18 # Generated by the Protocol Buffers compiler. DO NOT EDIT!
  19 # source: osm_lcm/frontend.proto
  20 # plugin: grpclib.plugin.main
  21 import abc
  22 import typing
  23
  24 import grpclib.const
  25 import grpclib.client
  26 if typing.TYPE_CHECKING:
  27     import grpclib.server
  28
  29 import osm_lcm.frontend_pb2
  30
  31
  32 class FrontendExecutorBase(abc.ABC):
  33
  34     @abc.abstractmethod
  35     async def RunPrimitive(self, stream: 'grpclib.server.Stream[osm_lcm.frontend_pb2.PrimitiveRequest, osm_lcm.frontend_pb2.PrimitiveReply]') -> None:
  36         pass
  37
  38     @abc.abstractmethod
  39     async def GetSshKey(self, stream: 'grpclib.server.Stream[osm_lcm.frontend_pb2.SshKeyRequest, osm_lcm.frontend_pb2.SshKeyReply]') -> None:
  40         pass
  41
  42     def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
  43         return {
  44             '/osm_ee.FrontendExecutor/RunPrimitive': grpclib.const.Handler(
  45                 self.RunPrimitive,
  46                 grpclib.const.Cardinality.UNARY_STREAM,
  47                 osm_lcm.frontend_pb2.PrimitiveRequest,
  48                 osm_lcm.frontend_pb2.PrimitiveReply,
  49             ),
  50             '/osm_ee.FrontendExecutor/GetSshKey': grpclib.const.Handler(
  51                 self.GetSshKey,
  52                 grpclib.const.Cardinality.UNARY_UNARY,
  53                 osm_lcm.frontend_pb2.SshKeyRequest,
  54                 osm_lcm.frontend_pb2.SshKeyReply,
  55             ),
  56         }
  57
  58
  59 class FrontendExecutorStub:
  60
  61     def __init__(self, channel: grpclib.client.Channel) -> None:
  62         self.RunPrimitive = grpclib.client.UnaryStreamMethod(
  63             channel,
  64             '/osm_ee.FrontendExecutor/RunPrimitive',
  65             osm_lcm.frontend_pb2.PrimitiveRequest,
  66             osm_lcm.frontend_pb2.PrimitiveReply,
  67         )
  68         self.GetSshKey = grpclib.client.UnaryUnaryMethod(
  69             channel,
  70             '/osm_ee.FrontendExecutor/GetSshKey',
  71             osm_lcm.frontend_pb2.SshKeyRequest,
  72             osm_lcm.frontend_pb2.SshKeyReply,
  73         )