python类method_handlers_generic_handler()的实例源码

ems_grpc_pb2.py 文件源码 项目:ios-xr-grpc-python 作者: cisco-grpc-connection-libs 项目源码 文件源码 阅读 24 收藏 0 点赞 0 评论 0
def add_gRPCExecServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'ShowCmdTextOutput': grpc.unary_stream_rpc_method_handler(
          servicer.ShowCmdTextOutput,
          request_deserializer=ShowCmdArgs.FromString,
          response_serializer=ShowCmdTextReply.SerializeToString,
      ),
      'ShowCmdJSONOutput': grpc.unary_stream_rpc_method_handler(
          servicer.ShowCmdJSONOutput,
          request_deserializer=ShowCmdArgs.FromString,
          response_serializer=ShowCmdJSONReply.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'IOSXRExtensibleManagabilityService.gRPCExec', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
ab_pb2_grpc.py 文件源码 项目:fabric-sdk-py 作者: hyperledger 项目源码 文件源码 阅读 17 收藏 0 点赞 0 评论 0
def add_AtomicBroadcastServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Broadcast': grpc.stream_stream_rpc_method_handler(
          servicer.Broadcast,
          request_deserializer=hfc_dot_protos_dot_common_dot_common__pb2.Envelope.FromString,
          response_serializer=hfc_dot_protos_dot_orderer_dot_ab__pb2.BroadcastResponse.SerializeToString,
      ),
      'Deliver': grpc.stream_stream_rpc_method_handler(
          servicer.Deliver,
          request_deserializer=hfc_dot_protos_dot_common_dot_common__pb2.Envelope.FromString,
          response_serializer=hfc_dot_protos_dot_orderer_dot_ab__pb2.DeliverResponse.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'orderer.AtomicBroadcast', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
ab_pb2.py 文件源码 项目:fabric-sdk-py 作者: hyperledger 项目源码 文件源码 阅读 21 收藏 0 点赞 0 评论 0
def add_AtomicBroadcastServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Broadcast': grpc.stream_stream_rpc_method_handler(
            servicer.Broadcast,
            request_deserializer=hfc_dot_protos_dot_common_dot_common__pb2.Envelope.FromString,
            response_serializer=BroadcastResponse.SerializeToString,
        ),
        'Deliver': grpc.stream_stream_rpc_method_handler(
            servicer.Deliver,
            request_deserializer=hfc_dot_protos_dot_common_dot_common__pb2.Envelope.FromString,
            response_serializer=DeliverResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'orderer.AtomicBroadcast', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
experiment_pb2.py 文件源码 项目:experiment 作者: blueCat1301 项目源码 文件源码 阅读 19 收藏 0 点赞 0 评论 0
def add_ExperimentServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'StartExperiment': grpc.unary_unary_rpc_method_handler(
          servicer.StartExperiment,
          request_deserializer=Experiment.FromString,
          response_serializer=ExperimentStatus.SerializeToString,
      ),
      'StopExperiment': grpc.unary_unary_rpc_method_handler(
          servicer.StopExperiment,
          request_deserializer=Experiment.FromString,
          response_serializer=ExperimentStatus.SerializeToString,
      ),
      'GetExperimentStatus': grpc.unary_unary_rpc_method_handler(
          servicer.GetExperimentStatus,
          request_deserializer=ExperimentId.FromString,
          response_serializer=ExperimentStatus.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'experiment.ExperimentService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
grpc_pb2_grpc.py 文件源码 项目:p2p_grpc_blockchain_package 作者: Lursun 项目源码 文件源码 阅读 21 收藏 0 点赞 0 评论 0
def add_DiscoveryServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'ExchangeNode': grpc.unary_unary_rpc_method_handler(
          servicer.ExchangeNode,
          request_deserializer=grpc__pb2.Node.FromString,
          response_serializer=grpc__pb2.Node.SerializeToString,
      ),
      'Hello': grpc.unary_unary_rpc_method_handler(
          servicer.Hello,
          request_deserializer=grpc__pb2.Message.FromString,
          response_serializer=grpc__pb2.Message.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'Discovery', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
grpc_pb2.py 文件源码 项目:p2p_grpc_blockchain_package 作者: Lursun 项目源码 文件源码 阅读 21 收藏 0 点赞 0 评论 0
def add_DiscoveryServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'ExchangeNode': grpc.unary_unary_rpc_method_handler(
            servicer.ExchangeNode,
            request_deserializer=Node.FromString,
            response_serializer=Node.SerializeToString,
        ),
        'Hello': grpc.unary_unary_rpc_method_handler(
            servicer.Hello,
            request_deserializer=Message.FromString,
            response_serializer=Message.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'Discovery', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
sensors_pb2.py 文件源码 项目:gRPC-Makerboards 作者: PeridotYouClod 项目源码 文件源码 阅读 21 收藏 0 点赞 0 评论 0
def add_PushFrontEndServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Subscribe': grpc.unary_unary_rpc_method_handler(
          servicer.Subscribe,
          request_deserializer=SubscribeRequest.FromString,
          response_serializer=SubscribeReply.SerializeToString,
      ),
      'StreamButtonPressed': grpc.unary_stream_rpc_method_handler(
          servicer.StreamButtonPressed,
          request_deserializer=GetButtonPressedRequest.FromString,
          response_serializer=GetButtonPressedReply.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'PushFrontEnd', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
sensors_pb2.py 文件源码 项目:gRPC-Makerboards 作者: PeridotYouClod 项目源码 文件源码 阅读 26 收藏 0 点赞 0 评论 0
def add_ArduinoServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'GetIrButtonPressed': grpc.unary_unary_rpc_method_handler(
          servicer.GetIrButtonPressed,
          request_deserializer=GetIrButtonPressedRequest.FromString,
          response_serializer=GetIrButtonPressedReply.SerializeToString,
      ),
      'GetSonar': grpc.unary_unary_rpc_method_handler(
          servicer.GetSonar,
          request_deserializer=GetSonarRequest.FromString,
          response_serializer=GetSonarReply.SerializeToString,
      ),
      'SendToRfBlaster': grpc.unary_unary_rpc_method_handler(
          servicer.SendToRfBlaster,
          request_deserializer=SendToRfBlasterRequest.FromString,
          response_serializer=SendToRfBlasterReply.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'Arduino', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
sensors_pb2.py 文件源码 项目:gRPC-Makerboards 作者: PeridotYouClod 项目源码 文件源码 阅读 23 收藏 0 点赞 0 评论 0
def add_PushServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Subscribe': grpc.unary_unary_rpc_method_handler(
          servicer.Subscribe,
          request_deserializer=SubscribeRequest.FromString,
          response_serializer=SubscribeReply.SerializeToString,
      ),
      'StreamButtonPressed': grpc.unary_stream_rpc_method_handler(
          servicer.StreamButtonPressed,
          request_deserializer=GetButtonPressedRequest.FromString,
          response_serializer=GetButtonPressedReply.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'Push', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
thegame_pb2_grpc.py 文件源码 项目:thegame 作者: afg984 项目源码 文件源码 阅读 19 收藏 0 点赞 0 评论 0
def add_TheGameServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Game': grpc.stream_stream_rpc_method_handler(
          servicer.Game,
          request_deserializer=thegame_dot_thegame__pb2.Controls.FromString,
          response_serializer=thegame_dot_thegame__pb2.GameState.SerializeToString,
      ),
      'View': grpc.unary_stream_rpc_method_handler(
          servicer.View,
          request_deserializer=thegame_dot_thegame__pb2.ViewRequest.FromString,
          response_serializer=thegame_dot_thegame__pb2.GameState.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'TheGame', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
thegame_pb2.py 文件源码 项目:thegame 作者: afg984 项目源码 文件源码 阅读 22 收藏 0 点赞 0 评论 0
def add_TheGameServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Game': grpc.stream_stream_rpc_method_handler(
            servicer.Game,
            request_deserializer=Controls.FromString,
            response_serializer=GameState.SerializeToString,
        ),
        'View': grpc.unary_stream_rpc_method_handler(
            servicer.View,
            request_deserializer=ViewRequest.FromString,
            response_serializer=GameState.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'TheGame', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
messages_pb2_grpc.py 文件源码 项目:experiment-manager 作者: softfire-eu 项目源码 文件源码 阅读 20 收藏 0 点赞 0 评论 0
def add_RegistrationServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'register': grpc.unary_unary_rpc_method_handler(
          servicer.register,
          request_deserializer=messages__pb2.RegisterMessage.FromString,
          response_serializer=messages__pb2.ResponseMessage.SerializeToString,
      ),
      'unregister': grpc.unary_unary_rpc_method_handler(
          servicer.unregister,
          request_deserializer=messages__pb2.UnregisterMessage.FromString,
          response_serializer=messages__pb2.ResponseMessage.SerializeToString,
      ),
      'update_status': grpc.unary_unary_rpc_method_handler(
          servicer.update_status,
          request_deserializer=messages__pb2.StatusMessage.FromString,
          response_serializer=messages__pb2.ResponseMessage.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'RegistrationService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
messages_pb2.py 文件源码 项目:experiment-manager 作者: softfire-eu 项目源码 文件源码 阅读 26 收藏 0 点赞 0 评论 0
def add_RegistrationServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'register': grpc.unary_unary_rpc_method_handler(
            servicer.register,
            request_deserializer=RegisterMessage.FromString,
            response_serializer=ResponseMessage.SerializeToString,
        ),
        'unregister': grpc.unary_unary_rpc_method_handler(
            servicer.unregister,
            request_deserializer=UnregisterMessage.FromString,
            response_serializer=ResponseMessage.SerializeToString,
        ),
        'update_status': grpc.unary_unary_rpc_method_handler(
            servicer.update_status,
            request_deserializer=StatusMessage.FromString,
            response_serializer=ResponseMessage.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'RegistrationService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
clusterspecgenerator_pb2.py 文件源码 项目:yarntf 作者: tobiajo 项目源码 文件源码 阅读 22 收藏 0 点赞 0 评论 0
def add_ClusterSpecGeneratorServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'RegisterContainer': grpc.unary_unary_rpc_method_handler(
            servicer.RegisterContainer,
            request_deserializer=RegisterContainerRequest.FromString,
            response_serializer=RegisterContainerReply.SerializeToString,
        ),
        'GetClusterSpec': grpc.unary_unary_rpc_method_handler(
            servicer.GetClusterSpec,
            request_deserializer=GetClusterSpecRequest.FromString,
            response_serializer=GetClusterSpecReply.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'clusterspecgenerator.ClusterSpecGenerator', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
clusterspecgenerator_pb2_grpc.py 文件源码 项目:yarntf 作者: tobiajo 项目源码 文件源码 阅读 20 收藏 0 点赞 0 评论 0
def add_ClusterSpecGeneratorServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'RegisterContainer': grpc.unary_unary_rpc_method_handler(
          servicer.RegisterContainer,
          request_deserializer=clusterspecgenerator__pb2.RegisterContainerRequest.FromString,
          response_serializer=clusterspecgenerator__pb2.RegisterContainerReply.SerializeToString,
      ),
      'GetClusterSpec': grpc.unary_unary_rpc_method_handler(
          servicer.GetClusterSpec,
          request_deserializer=clusterspecgenerator__pb2.GetClusterSpecRequest.FromString,
          response_serializer=clusterspecgenerator__pb2.GetClusterSpecReply.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'clusterspecgenerator.ClusterSpecGenerator', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
ab_pb2_grpc.py 文件源码 项目:fabric-test 作者: hyperledger 项目源码 文件源码 阅读 23 收藏 0 点赞 0 评论 0
def add_AtomicBroadcastServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Broadcast': grpc.stream_stream_rpc_method_handler(
          servicer.Broadcast,
          request_deserializer=common_dot_common__pb2.Envelope.FromString,
          response_serializer=orderer_dot_ab__pb2.BroadcastResponse.SerializeToString,
      ),
      'Deliver': grpc.stream_stream_rpc_method_handler(
          servicer.Deliver,
          request_deserializer=common_dot_common__pb2.Envelope.FromString,
          response_serializer=orderer_dot_ab__pb2.DeliverResponse.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'orderer.AtomicBroadcast', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
ab_pb2.py 文件源码 项目:fabric-test 作者: hyperledger 项目源码 文件源码 阅读 21 收藏 0 点赞 0 评论 0
def add_AtomicBroadcastServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Broadcast': grpc.stream_stream_rpc_method_handler(
            servicer.Broadcast,
            request_deserializer=common_dot_common__pb2.Envelope.FromString,
            response_serializer=BroadcastResponse.SerializeToString,
        ),
        'Deliver': grpc.stream_stream_rpc_method_handler(
            servicer.Deliver,
            request_deserializer=common_dot_common__pb2.Envelope.FromString,
            response_serializer=DeliverResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'orderer.AtomicBroadcast', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
location_service_pb2.py 文件源码 项目:object-tracking 作者: athenian-robotics 项目源码 文件源码 阅读 19 收藏 0 点赞 0 评论 0
def add_LocationServiceServicer_to_server(servicer, server):
        rpc_method_handlers = {
            'registerClient': grpc.unary_unary_rpc_method_handler(
                servicer.registerClient,
                request_deserializer=ClientInfo.FromString,
                response_serializer=ServerInfo.SerializeToString,
            ),
            'getLocations': grpc.unary_stream_rpc_method_handler(
                servicer.getLocations,
                request_deserializer=ClientInfo.FromString,
                response_serializer=Location.SerializeToString,
            ),
        }
        generic_handler = grpc.method_handlers_generic_handler(
            'opencv_object_tracking.LocationService', rpc_method_handlers)
        server.add_generic_rpc_handlers((generic_handler,))
location_service_pb2_grpc.py 文件源码 项目:object-tracking 作者: athenian-robotics 项目源码 文件源码 阅读 27 收藏 0 点赞 0 评论 0
def add_LocationServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'registerClient': grpc.unary_unary_rpc_method_handler(
            servicer.registerClient,
            request_deserializer=proto_dot_location__service__pb2.ClientInfo.FromString,
            response_serializer=proto_dot_location__service__pb2.ServerInfo.SerializeToString,
        ),
        'getLocations': grpc.unary_stream_rpc_method_handler(
            servicer.getLocations,
            request_deserializer=proto_dot_location__service__pb2.ClientInfo.FromString,
            response_serializer=proto_dot_location__service__pb2.Location.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'opencv_object_tracking.LocationService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
worldhello_pb2.py 文件源码 项目:sea 作者: shanbay 项目源码 文件源码 阅读 22 收藏 0 点赞 0 评论 0
def add_GreeterServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'SayHello': grpc.unary_unary_rpc_method_handler(
            servicer.SayHello,
            request_deserializer=HelloRequest.FromString,
            response_serializer=HelloReply.SerializeToString,
        ),
        'SayHelloAgain': grpc.unary_unary_rpc_method_handler(
            servicer.SayHelloAgain,
            request_deserializer=HelloRequest.FromString,
            response_serializer=HelloReply.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'worldhello.Greeter', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
worldhello_pb2_grpc.py 文件源码 项目:sea 作者: shanbay 项目源码 文件源码 阅读 21 收藏 0 点赞 0 评论 0
def add_GreeterServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'SayHello': grpc.unary_unary_rpc_method_handler(
          servicer.SayHello,
          request_deserializer=worldhello__pb2.HelloRequest.FromString,
          response_serializer=worldhello__pb2.HelloReply.SerializeToString,
      ),
      'SayHelloAgain': grpc.unary_unary_rpc_method_handler(
          servicer.SayHelloAgain,
          request_deserializer=worldhello__pb2.HelloRequest.FromString,
          response_serializer=worldhello__pb2.HelloReply.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'worldhello.Greeter', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
clusterspecgenerator_pb2.py 文件源码 项目:hops-tensorflow 作者: hopshadoop 项目源码 文件源码 阅读 22 收藏 0 点赞 0 评论 0
def add_ClusterSpecGeneratorServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'RegisterContainer': grpc.unary_unary_rpc_method_handler(
            servicer.RegisterContainer,
            request_deserializer=RegisterContainerRequest.FromString,
            response_serializer=RegisterContainerReply.SerializeToString,
        ),
        'GetClusterSpec': grpc.unary_unary_rpc_method_handler(
            servicer.GetClusterSpec,
            request_deserializer=GetClusterSpecRequest.FromString,
            response_serializer=GetClusterSpecReply.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'clusterspecgenerator.ClusterSpecGenerator', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
clusterspecgenerator_pb2_grpc.py 文件源码 项目:hops-tensorflow 作者: hopshadoop 项目源码 文件源码 阅读 19 收藏 0 点赞 0 评论 0
def add_ClusterSpecGeneratorServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'RegisterContainer': grpc.unary_unary_rpc_method_handler(
          servicer.RegisterContainer,
          request_deserializer=clusterspecgenerator__pb2.RegisterContainerRequest.FromString,
          response_serializer=clusterspecgenerator__pb2.RegisterContainerReply.SerializeToString,
      ),
      'GetClusterSpec': grpc.unary_unary_rpc_method_handler(
          servicer.GetClusterSpec,
          request_deserializer=clusterspecgenerator__pb2.GetClusterSpecRequest.FromString,
          response_serializer=clusterspecgenerator__pb2.GetClusterSpecReply.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'clusterspecgenerator.ClusterSpecGenerator', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
qrl_pb2_grpc.py 文件源码 项目:QRL 作者: theQRL 项目源码 文件源码 阅读 26 收藏 0 点赞 0 评论 0
def add_P2PAPIServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'GetNodeState': grpc.unary_unary_rpc_method_handler(
          servicer.GetNodeState,
          request_deserializer=qrl__pb2.GetNodeStateReq.FromString,
          response_serializer=qrl__pb2.GetNodeStateResp.SerializeToString,
      ),
      'GetKnownPeers': grpc.unary_unary_rpc_method_handler(
          servicer.GetKnownPeers,
          request_deserializer=qrl__pb2.GetKnownPeersReq.FromString,
          response_serializer=qrl__pb2.GetKnownPeersResp.SerializeToString,
      ),
      'GetBlock': grpc.unary_unary_rpc_method_handler(
          servicer.GetBlock,
          request_deserializer=qrl__pb2.GetBlockReq.FromString,
          response_serializer=qrl__pb2.GetBlockResp.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'qrl.P2PAPI', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
api_pb2_grpc.py 文件源码 项目:python-cri 作者: feiskyer 项目源码 文件源码 阅读 18 收藏 0 点赞 0 评论 0
def add_ImageServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'ListImages': grpc.unary_unary_rpc_method_handler(
          servicer.ListImages,
          request_deserializer=api__pb2.ListImagesRequest.FromString,
          response_serializer=api__pb2.ListImagesResponse.SerializeToString,
      ),
      'ImageStatus': grpc.unary_unary_rpc_method_handler(
          servicer.ImageStatus,
          request_deserializer=api__pb2.ImageStatusRequest.FromString,
          response_serializer=api__pb2.ImageStatusResponse.SerializeToString,
      ),
      'PullImage': grpc.unary_unary_rpc_method_handler(
          servicer.PullImage,
          request_deserializer=api__pb2.PullImageRequest.FromString,
          response_serializer=api__pb2.PullImageResponse.SerializeToString,
      ),
      'RemoveImage': grpc.unary_unary_rpc_method_handler(
          servicer.RemoveImage,
          request_deserializer=api__pb2.RemoveImageRequest.FromString,
          response_serializer=api__pb2.RemoveImageResponse.SerializeToString,
      ),
      'ImageFsInfo': grpc.unary_unary_rpc_method_handler(
          servicer.ImageFsInfo,
          request_deserializer=api__pb2.ImageFsInfoRequest.FromString,
          response_serializer=api__pb2.ImageFsInfoResponse.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'runtime.ImageService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
api_pb2.py 文件源码 项目:python-cri 作者: feiskyer 项目源码 文件源码 阅读 19 收藏 0 点赞 0 评论 0
def add_ImageServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'ListImages': grpc.unary_unary_rpc_method_handler(
            servicer.ListImages,
            request_deserializer=ListImagesRequest.FromString,
            response_serializer=ListImagesResponse.SerializeToString,
        ),
        'ImageStatus': grpc.unary_unary_rpc_method_handler(
            servicer.ImageStatus,
            request_deserializer=ImageStatusRequest.FromString,
            response_serializer=ImageStatusResponse.SerializeToString,
        ),
        'PullImage': grpc.unary_unary_rpc_method_handler(
            servicer.PullImage,
            request_deserializer=PullImageRequest.FromString,
            response_serializer=PullImageResponse.SerializeToString,
        ),
        'RemoveImage': grpc.unary_unary_rpc_method_handler(
            servicer.RemoveImage,
            request_deserializer=RemoveImageRequest.FromString,
            response_serializer=RemoveImageResponse.SerializeToString,
        ),
        'ImageFsInfo': grpc.unary_unary_rpc_method_handler(
            servicer.ImageFsInfo,
            request_deserializer=ImageFsInfoRequest.FromString,
            response_serializer=ImageFsInfoResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'runtime.ImageService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
events_pb2_grpc.py 文件源码 项目:fabric-sdk-py 作者: hyperledger 项目源码 文件源码 阅读 25 收藏 0 点赞 0 评论 0
def add_EventsServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Chat': grpc.stream_stream_rpc_method_handler(
          servicer.Chat,
          request_deserializer=hfc_dot_protos_dot_peer_dot_events__pb2.SignedEvent.FromString,
          response_serializer=hfc_dot_protos_dot_peer_dot_events__pb2.Event.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'protos.Events', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
events_pb2.py 文件源码 项目:fabric-sdk-py 作者: hyperledger 项目源码 文件源码 阅读 21 收藏 0 点赞 0 评论 0
def add_EventsServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Chat': grpc.stream_stream_rpc_method_handler(
            servicer.Chat,
            request_deserializer=SignedEvent.FromString,
            response_serializer=Event.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'protos.Events', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
admin_pb2.py 文件源码 项目:fabric-sdk-py 作者: hyperledger 项目源码 文件源码 阅读 18 收藏 0 点赞 0 评论 0
def add_AdminServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'GetStatus': grpc.unary_unary_rpc_method_handler(
            servicer.GetStatus,
            request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            response_serializer=ServerStatus.SerializeToString,
        ),
        'StartServer': grpc.unary_unary_rpc_method_handler(
            servicer.StartServer,
            request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            response_serializer=ServerStatus.SerializeToString,
        ),
        'GetModuleLogLevel': grpc.unary_unary_rpc_method_handler(
            servicer.GetModuleLogLevel,
            request_deserializer=LogLevelRequest.FromString,
            response_serializer=LogLevelResponse.SerializeToString,
        ),
        'SetModuleLogLevel': grpc.unary_unary_rpc_method_handler(
            servicer.SetModuleLogLevel,
            request_deserializer=LogLevelRequest.FromString,
            response_serializer=LogLevelResponse.SerializeToString,
        ),
        'RevertLogLevels': grpc.unary_unary_rpc_method_handler(
            servicer.RevertLogLevels,
            request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'protos.Admin', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
admin_pb2_grpc.py 文件源码 项目:fabric-sdk-py 作者: hyperledger 项目源码 文件源码 阅读 20 收藏 0 点赞 0 评论 0
def add_AdminServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'GetStatus': grpc.unary_unary_rpc_method_handler(
          servicer.GetStatus,
          request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
          response_serializer=hfc_dot_protos_dot_peer_dot_admin__pb2.ServerStatus.SerializeToString,
      ),
      'StartServer': grpc.unary_unary_rpc_method_handler(
          servicer.StartServer,
          request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
          response_serializer=hfc_dot_protos_dot_peer_dot_admin__pb2.ServerStatus.SerializeToString,
      ),
      'GetModuleLogLevel': grpc.unary_unary_rpc_method_handler(
          servicer.GetModuleLogLevel,
          request_deserializer=hfc_dot_protos_dot_peer_dot_admin__pb2.LogLevelRequest.FromString,
          response_serializer=hfc_dot_protos_dot_peer_dot_admin__pb2.LogLevelResponse.SerializeToString,
      ),
      'SetModuleLogLevel': grpc.unary_unary_rpc_method_handler(
          servicer.SetModuleLogLevel,
          request_deserializer=hfc_dot_protos_dot_peer_dot_admin__pb2.LogLevelRequest.FromString,
          response_serializer=hfc_dot_protos_dot_peer_dot_admin__pb2.LogLevelResponse.SerializeToString,
      ),
      'RevertLogLevels': grpc.unary_unary_rpc_method_handler(
          servicer.RevertLogLevels,
          request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
          response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'protos.Admin', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))


问题


面经


文章

微信
公众号

扫码关注公众号