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,))
python类unary_unary_rpc_method_handler()的实例源码
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,))
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,))
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,))
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,))
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,))
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,))
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,))
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,))
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,))
location_service_pb2.py 文件源码
项目:object-tracking
作者: athenian-robotics
项目源码
文件源码
阅读 23
收藏 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
项目源码
文件源码
阅读 21
收藏 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,))
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,))
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,))
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
项目源码
文件源码
阅读 23
收藏 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,))
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,))
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,))
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,))
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,))
def add_EndorserServicer_to_server(servicer, server):
rpc_method_handlers = {
'ProcessProposal': grpc.unary_unary_rpc_method_handler(
servicer.ProcessProposal,
request_deserializer=hfc_dot_protos_dot_peer_dot_proposal__pb2.SignedProposal.FromString,
response_serializer=hfc_dot_protos_dot_peer_dot_proposal__response__pb2.ProposalResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'protos.Endorser', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
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,))
def add_EndorserServicer_to_server(servicer, server):
rpc_method_handlers = {
'ProcessProposal': grpc.unary_unary_rpc_method_handler(
servicer.ProcessProposal,
request_deserializer=hfc_dot_protos_dot_peer_dot_proposal__pb2.SignedProposal.FromString,
response_serializer=hfc_dot_protos_dot_peer_dot_proposal__response__pb2.ProposalResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'protos.Endorser', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
def add_PredictionServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'Predict': grpc.unary_unary_rpc_method_handler(
servicer.Predict,
request_deserializer=predict__pb2.PredictionRequest.FromString,
response_serializer=predict__pb2.PredictionResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'skl.PredictionService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
def add_HelloServicer_to_server(servicer, server):
rpc_method_handlers = {
'Greeter': grpc.unary_unary_rpc_method_handler(
servicer.Greeter,
request_deserializer=hello__pb2.HelloRequest.FromString,
response_serializer=hello__pb2.HelloResponse.SerializeToString,
),
'GreeterResponseStream': grpc.unary_stream_rpc_method_handler(
servicer.GreeterResponseStream,
request_deserializer=hello__pb2.HelloRequest.FromString,
response_serializer=hello__pb2.HelloResponse.SerializeToString,
),
'StreamGreeter': grpc.stream_unary_rpc_method_handler(
servicer.StreamGreeter,
request_deserializer=hello__pb2.HelloRequest.FromString,
response_serializer=hello__pb2.HelloResponse.SerializeToString,
),
'StreamGreeterResponseStream': grpc.stream_stream_rpc_method_handler(
servicer.StreamGreeterResponseStream,
request_deserializer=hello__pb2.HelloRequest.FromString,
response_serializer=hello__pb2.HelloResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'grpcresolver.hello.Hello', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
def add_HelloServicer_to_server(servicer, server):
rpc_method_handlers = {
'Greeter': grpc.unary_unary_rpc_method_handler(
servicer.Greeter,
request_deserializer=HelloRequest.FromString,
response_serializer=HelloResponse.SerializeToString,
),
'GreeterResponseStream': grpc.unary_stream_rpc_method_handler(
servicer.GreeterResponseStream,
request_deserializer=HelloRequest.FromString,
response_serializer=HelloResponse.SerializeToString,
),
'StreamGreeter': grpc.stream_unary_rpc_method_handler(
servicer.StreamGreeter,
request_deserializer=HelloRequest.FromString,
response_serializer=HelloResponse.SerializeToString,
),
'StreamGreeterResponseStream': grpc.stream_stream_rpc_method_handler(
servicer.StreamGreeterResponseStream,
request_deserializer=HelloRequest.FromString,
response_serializer=HelloResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'grpcresolver.hello.Hello', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
def add_RouteGuideServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetFeature': grpc.unary_unary_rpc_method_handler(
servicer.GetFeature,
request_deserializer=Point.FromString,
response_serializer=Feature.SerializeToString,
),
'ListFeatures': grpc.unary_stream_rpc_method_handler(
servicer.ListFeatures,
request_deserializer=Rectangle.FromString,
response_serializer=Feature.SerializeToString,
),
'RecordRoute': grpc.stream_unary_rpc_method_handler(
servicer.RecordRoute,
request_deserializer=Point.FromString,
response_serializer=RouteSummary.SerializeToString,
),
'RouteChat': grpc.stream_stream_rpc_method_handler(
servicer.RouteChat,
request_deserializer=RouteNote.FromString,
response_serializer=RouteNote.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'routeguide.RouteGuide', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
def add_StructServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'create': grpc.unary_unary_rpc_method_handler(
servicer.create,
request_deserializer=Structure.FromString,
response_serializer=Response.SerializeToString,
),
'retrieve': grpc.unary_unary_rpc_method_handler(
servicer.retrieve,
request_deserializer=Empty.FromString,
response_serializer=Structure.SerializeToString,
),
'many': grpc.unary_unary_rpc_method_handler(
servicer.many,
request_deserializer=Empty.FromString,
response_serializer=StructureList.SerializeToString,
),
'bulk': grpc.unary_unary_rpc_method_handler(
servicer.bulk,
request_deserializer=StructureList.FromString,
response_serializer=Response.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'structure.StructService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
def add_HetrServicer_to_server(servicer, server):
rpc_method_handlers = {
'BuildTransformer': grpc.unary_unary_rpc_method_handler(
servicer.BuildTransformer,
request_deserializer=BuildTransformerRequest.FromString,
response_serializer=BuildTransformerReply.SerializeToString,
),
'CloseTransformer': grpc.unary_unary_rpc_method_handler(
servicer.CloseTransformer,
request_deserializer=CloseTransformerRequest.FromString,
response_serializer=CloseTransformerReply.SerializeToString,
),
'Computation': grpc.stream_unary_rpc_method_handler(
servicer.Computation,
request_deserializer=ComputationRequest.FromString,
response_serializer=ComputationReply.SerializeToString,
),
'FeedInput': grpc.unary_unary_rpc_method_handler(
servicer.FeedInput,
request_deserializer=FeedInputRequest.FromString,
response_serializer=FeedInputReply.SerializeToString,
),
'GetResults': grpc.unary_unary_rpc_method_handler(
servicer.GetResults,
request_deserializer=GetResultsRequest.FromString,
response_serializer=GetResultsReply.SerializeToString,
),
'Close': grpc.unary_unary_rpc_method_handler(
servicer.Close,
request_deserializer=CloseRequest.FromString,
response_serializer=CloseReply.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'Hetr', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
def add_HetrServicer_to_server(servicer, server):
rpc_method_handlers = {
'BuildTransformer': grpc.unary_unary_rpc_method_handler(
servicer.BuildTransformer,
request_deserializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.BuildTransformerRequest.FromString,
response_serializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.BuildTransformerReply.SerializeToString,
),
'CloseTransformer': grpc.unary_unary_rpc_method_handler(
servicer.CloseTransformer,
request_deserializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.CloseTransformerRequest.FromString,
response_serializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.CloseTransformerReply.SerializeToString,
),
'Computation': grpc.stream_unary_rpc_method_handler(
servicer.Computation,
request_deserializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.ComputationRequest.FromString,
response_serializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.ComputationReply.SerializeToString,
),
'FeedInput': grpc.unary_unary_rpc_method_handler(
servicer.FeedInput,
request_deserializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.FeedInputRequest.FromString,
response_serializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.FeedInputReply.SerializeToString,
),
'GetResults': grpc.unary_unary_rpc_method_handler(
servicer.GetResults,
request_deserializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.GetResultsRequest.FromString,
response_serializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.GetResultsReply.SerializeToString,
),
'Close': grpc.unary_unary_rpc_method_handler(
servicer.Close,
request_deserializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.CloseRequest.FromString,
response_serializer=ngraph_dot_transformers_dot_hetr_dot_hetr__pb2.CloseReply.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'Hetr', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))