python类unary_unary_rpc_method_handler()的实例源码

def add_SynchronizationServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'BlockFrom': grpc.unary_unary_rpc_method_handler(
          servicer.BlockFrom,
          request_deserializer=grpc__pb2.Message.FromString,
          response_serializer=grpc__pb2.Block.SerializeToString,
      ),
      'BlockTo': grpc.unary_unary_rpc_method_handler(
          servicer.BlockTo,
          request_deserializer=grpc__pb2.Block.FromString,
          response_serializer=grpc__pb2.Message.SerializeToString,
      ),
      'ExchangeBlock': grpc.unary_unary_rpc_method_handler(
          servicer.ExchangeBlock,
          request_deserializer=grpc__pb2.Block.FromString,
          response_serializer=grpc__pb2.Block.SerializeToString,
      ),
      'TransactionTo': grpc.unary_unary_rpc_method_handler(
          servicer.TransactionTo,
          request_deserializer=grpc__pb2.Transaction.FromString,
          response_serializer=grpc__pb2.Message.SerializeToString,
      ),
      'TransactionFrom': grpc.unary_unary_rpc_method_handler(
          servicer.TransactionFrom,
          request_deserializer=grpc__pb2.Message.FromString,
          response_serializer=grpc__pb2.Transaction.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'Synchronization', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))

def add_SynchronizationServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'BlockFrom': grpc.unary_unary_rpc_method_handler(
            servicer.BlockFrom,
            request_deserializer=Message.FromString,
            response_serializer=Block.SerializeToString,
        ),
        'BlockTo': grpc.unary_unary_rpc_method_handler(
            servicer.BlockTo,
            request_deserializer=Block.FromString,
            response_serializer=Message.SerializeToString,
        ),
        'ExchangeBlock': grpc.unary_unary_rpc_method_handler(
            servicer.ExchangeBlock,
            request_deserializer=Block.FromString,
            response_serializer=Block.SerializeToString,
        ),
        'TransactionTo': grpc.unary_unary_rpc_method_handler(
            servicer.TransactionTo,
            request_deserializer=Transaction.FromString,
            response_serializer=Message.SerializeToString,
        ),
        'TransactionFrom': grpc.unary_unary_rpc_method_handler(
            servicer.TransactionFrom,
            request_deserializer=Message.FromString,
            response_serializer=Transaction.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'Synchronization', 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.PredictRequest.FromString,
          response_serializer=predict__pb2.PredictResponse.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'tensorflow.serving.PredictionService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))

def add_WioLinkServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'GetLux': grpc.unary_unary_rpc_method_handler(
          servicer.GetLux,
          request_deserializer=GetLuxRequest.FromString,
          response_serializer=GetLuxReply.SerializeToString,
      ),
      'GetTemperature': grpc.unary_unary_rpc_method_handler(
          servicer.GetTemperature,
          request_deserializer=GetTemperatureRequest.FromString,
          response_serializer=GetTemperatureReply.SerializeToString,
      ),
      'GetSound': grpc.unary_unary_rpc_method_handler(
          servicer.GetSound,
          request_deserializer=GetSoundRequest.FromString,
          response_serializer=GetSoundReply.SerializeToString,
      ),
      'SetLedStrip': grpc.unary_unary_rpc_method_handler(
          servicer.SetLedStrip,
          request_deserializer=SetLedStripRequest.FromString,
          response_serializer=SetLedStripReply.SerializeToString,
      ),
      'GetButtonPressed': grpc.unary_unary_rpc_method_handler(
          servicer.GetButtonPressed,
          request_deserializer=GetButtonPressedRequest.FromString,
          response_serializer=GetButtonPressedReply.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'WioLink', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))

def add_BridgeServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Init': grpc.unary_unary_rpc_method_handler(
            servicer.Init,
            request_deserializer=NullMessage.FromString,
            response_serializer=NullMessage.SerializeToString,
        ),
        'Run': grpc.stream_stream_rpc_method_handler(
            servicer.Run,
            request_deserializer=Item.FromString,
            response_serializer=Item.SerializeToString,
        ),
        'SetX': grpc.unary_unary_rpc_method_handler(
            servicer.SetX,
            request_deserializer=X.FromString,
            response_serializer=NullMessage.SerializeToString,
        ),
        'StoreMetric': grpc.stream_unary_rpc_method_handler(
            servicer.StoreMetric,
            request_deserializer=Item.FromString,
            response_serializer=NullMessage.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'Bridge', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_BridgeServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Init': grpc.unary_unary_rpc_method_handler(
          servicer.Init,
          request_deserializer=bridge__pb2.NullMessage.FromString,
          response_serializer=bridge__pb2.NullMessage.SerializeToString,
      ),
      'Run': grpc.stream_stream_rpc_method_handler(
          servicer.Run,
          request_deserializer=bridge__pb2.Item.FromString,
          response_serializer=bridge__pb2.Item.SerializeToString,
      ),
      'SetX': grpc.unary_unary_rpc_method_handler(
          servicer.SetX,
          request_deserializer=bridge__pb2.X.FromString,
          response_serializer=bridge__pb2.NullMessage.SerializeToString,
      ),
      'StoreMetric': grpc.stream_unary_rpc_method_handler(
          servicer.StoreMetric,
          request_deserializer=bridge__pb2.Item.FromString,
          response_serializer=bridge__pb2.NullMessage.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'Bridge', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))

def add_SubscriberDBServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'AddSubscriber': grpc.unary_unary_rpc_method_handler(
            servicer.AddSubscriber,
            request_deserializer=SubscriberData.FromString,
            response_serializer=Void.SerializeToString,
        ),
        'DeleteSubscriber': grpc.unary_unary_rpc_method_handler(
            servicer.DeleteSubscriber,
            request_deserializer=SubscriberID.FromString,
            response_serializer=Void.SerializeToString,
        ),
        'UpdateSubscriber': grpc.unary_unary_rpc_method_handler(
            servicer.UpdateSubscriber,
            request_deserializer=SubscriberUpdate.FromString,
            response_serializer=Void.SerializeToString,
        ),
        'GetSubscriberData': grpc.unary_unary_rpc_method_handler(
            servicer.GetSubscriberData,
            request_deserializer=SubscriberID.FromString,
            response_serializer=SubscriberData.SerializeToString,
        ),
        'ListSubscribers': grpc.unary_unary_rpc_method_handler(
            servicer.ListSubscribers,
            request_deserializer=Void.FromString,
            response_serializer=SubscriberIDSet.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'osmocom.SubscriberDB', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_SubscriberDBServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'AddSubscriber': grpc.unary_unary_rpc_method_handler(
          servicer.AddSubscriber,
          request_deserializer=subscriber__pb2.SubscriberData.FromString,
          response_serializer=subscriber__pb2.Void.SerializeToString,
      ),
      'DeleteSubscriber': grpc.unary_unary_rpc_method_handler(
          servicer.DeleteSubscriber,
          request_deserializer=subscriber__pb2.SubscriberID.FromString,
          response_serializer=subscriber__pb2.Void.SerializeToString,
      ),
      'UpdateSubscriber': grpc.unary_unary_rpc_method_handler(
          servicer.UpdateSubscriber,
          request_deserializer=subscriber__pb2.SubscriberUpdate.FromString,
          response_serializer=subscriber__pb2.Void.SerializeToString,
      ),
      'GetSubscriberData': grpc.unary_unary_rpc_method_handler(
          servicer.GetSubscriberData,
          request_deserializer=subscriber__pb2.SubscriberID.FromString,
          response_serializer=subscriber__pb2.SubscriberData.SerializeToString,
      ),
      'ListSubscribers': grpc.unary_unary_rpc_method_handler(
          servicer.ListSubscribers,
          request_deserializer=subscriber__pb2.Void.FromString,
          response_serializer=subscriber__pb2.SubscriberIDSet.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'osmocom.SubscriberDB', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))

def add_CollectorServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'CollectMetrics': grpc.unary_unary_rpc_method_handler(
            servicer.CollectMetrics,
            request_deserializer=MetricsArg.FromString,
            response_serializer=MetricsReply.SerializeToString,
        ),
        'GetMetricTypes': grpc.unary_unary_rpc_method_handler(
            servicer.GetMetricTypes,
            request_deserializer=GetMetricTypesArg.FromString,
            response_serializer=MetricsReply.SerializeToString,
        ),
        'Ping': grpc.unary_unary_rpc_method_handler(
            servicer.Ping,
            request_deserializer=Empty.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'Kill': grpc.unary_unary_rpc_method_handler(
            servicer.Kill,
            request_deserializer=KillArg.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'GetConfigPolicy': grpc.unary_unary_rpc_method_handler(
            servicer.GetConfigPolicy,
            request_deserializer=Empty.FromString,
            response_serializer=GetConfigPolicyReply.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'rpc.Collector', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_ProcessorServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Process': grpc.unary_unary_rpc_method_handler(
            servicer.Process,
            request_deserializer=PubProcArg.FromString,
            response_serializer=MetricsReply.SerializeToString,
        ),
        'Ping': grpc.unary_unary_rpc_method_handler(
            servicer.Ping,
            request_deserializer=Empty.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'Kill': grpc.unary_unary_rpc_method_handler(
            servicer.Kill,
            request_deserializer=KillArg.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'GetConfigPolicy': grpc.unary_unary_rpc_method_handler(
            servicer.GetConfigPolicy,
            request_deserializer=Empty.FromString,
            response_serializer=GetConfigPolicyReply.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'rpc.Processor', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_PublisherServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Publish': grpc.unary_unary_rpc_method_handler(
            servicer.Publish,
            request_deserializer=PubProcArg.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'Ping': grpc.unary_unary_rpc_method_handler(
            servicer.Ping,
            request_deserializer=Empty.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'Kill': grpc.unary_unary_rpc_method_handler(
            servicer.Kill,
            request_deserializer=KillArg.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'GetConfigPolicy': grpc.unary_unary_rpc_method_handler(
            servicer.GetConfigPolicy,
            request_deserializer=Empty.FromString,
            response_serializer=GetConfigPolicyReply.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'rpc.Publisher', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_StreamCollectorServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'StreamMetrics': grpc.stream_stream_rpc_method_handler(
            servicer.StreamMetrics,
            request_deserializer=CollectArg.FromString,
            response_serializer=CollectReply.SerializeToString,
        ),
        'GetMetricTypes': grpc.unary_unary_rpc_method_handler(
            servicer.GetMetricTypes,
            request_deserializer=GetMetricTypesArg.FromString,
            response_serializer=MetricsReply.SerializeToString,
        ),
        'Ping': grpc.unary_unary_rpc_method_handler(
            servicer.Ping,
            request_deserializer=Empty.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'Kill': grpc.unary_unary_rpc_method_handler(
            servicer.Kill,
            request_deserializer=KillArg.FromString,
            response_serializer=ErrReply.SerializeToString,
        ),
        'GetConfigPolicy': grpc.unary_unary_rpc_method_handler(
            servicer.GetConfigPolicy,
            request_deserializer=Empty.FromString,
            response_serializer=GetConfigPolicyReply.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'rpc.StreamCollector', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_KVServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Range': grpc.unary_unary_rpc_method_handler(
            servicer.Range,
            request_deserializer=RangeRequest.FromString,
            response_serializer=RangeResponse.SerializeToString,
        ),
        'Put': grpc.unary_unary_rpc_method_handler(
            servicer.Put,
            request_deserializer=PutRequest.FromString,
            response_serializer=PutResponse.SerializeToString,
        ),
        'DeleteRange': grpc.unary_unary_rpc_method_handler(
            servicer.DeleteRange,
            request_deserializer=DeleteRangeRequest.FromString,
            response_serializer=DeleteRangeResponse.SerializeToString,
        ),
        'Txn': grpc.unary_unary_rpc_method_handler(
            servicer.Txn,
            request_deserializer=TxnRequest.FromString,
            response_serializer=TxnResponse.SerializeToString,
        ),
        'Compact': grpc.unary_unary_rpc_method_handler(
            servicer.Compact,
            request_deserializer=CompactionRequest.FromString,
            response_serializer=CompactionResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'etcdserverpb.KV', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_LeaseServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'LeaseGrant': grpc.unary_unary_rpc_method_handler(
            servicer.LeaseGrant,
            request_deserializer=LeaseGrantRequest.FromString,
            response_serializer=LeaseGrantResponse.SerializeToString,
        ),
        'LeaseRevoke': grpc.unary_unary_rpc_method_handler(
            servicer.LeaseRevoke,
            request_deserializer=LeaseRevokeRequest.FromString,
            response_serializer=LeaseRevokeResponse.SerializeToString,
        ),
        'LeaseKeepAlive': grpc.stream_stream_rpc_method_handler(
            servicer.LeaseKeepAlive,
            request_deserializer=LeaseKeepAliveRequest.FromString,
            response_serializer=LeaseKeepAliveResponse.SerializeToString,
        ),
        'LeaseTimeToLive': grpc.unary_unary_rpc_method_handler(
            servicer.LeaseTimeToLive,
            request_deserializer=LeaseTimeToLiveRequest.FromString,
            response_serializer=LeaseTimeToLiveResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'etcdserverpb.Lease', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_ClusterServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'MemberAdd': grpc.unary_unary_rpc_method_handler(
            servicer.MemberAdd,
            request_deserializer=MemberAddRequest.FromString,
            response_serializer=MemberAddResponse.SerializeToString,
        ),
        'MemberRemove': grpc.unary_unary_rpc_method_handler(
            servicer.MemberRemove,
            request_deserializer=MemberRemoveRequest.FromString,
            response_serializer=MemberRemoveResponse.SerializeToString,
        ),
        'MemberUpdate': grpc.unary_unary_rpc_method_handler(
            servicer.MemberUpdate,
            request_deserializer=MemberUpdateRequest.FromString,
            response_serializer=MemberUpdateResponse.SerializeToString,
        ),
        'MemberList': grpc.unary_unary_rpc_method_handler(
            servicer.MemberList,
            request_deserializer=MemberListRequest.FromString,
            response_serializer=MemberListResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'etcdserverpb.Cluster', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_MaintenanceServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Alarm': grpc.unary_unary_rpc_method_handler(
            servicer.Alarm,
            request_deserializer=AlarmRequest.FromString,
            response_serializer=AlarmResponse.SerializeToString,
        ),
        'Status': grpc.unary_unary_rpc_method_handler(
            servicer.Status,
            request_deserializer=StatusRequest.FromString,
            response_serializer=StatusResponse.SerializeToString,
        ),
        'Defragment': grpc.unary_unary_rpc_method_handler(
            servicer.Defragment,
            request_deserializer=DefragmentRequest.FromString,
            response_serializer=DefragmentResponse.SerializeToString,
        ),
        'Hash': grpc.unary_unary_rpc_method_handler(
            servicer.Hash,
            request_deserializer=HashRequest.FromString,
            response_serializer=HashResponse.SerializeToString,
        ),
        'Snapshot': grpc.unary_stream_rpc_method_handler(
            servicer.Snapshot,
            request_deserializer=SnapshotRequest.FromString,
            response_serializer=SnapshotResponse.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'etcdserverpb.Maintenance', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_AdminServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Request': grpc.unary_unary_rpc_method_handler(
            servicer.Request,
            request_deserializer=Message.FromString,
            response_serializer=Message.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'AdminService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_ContainerServicer_to_server(servicer, server):
    rpc_method_handlers = {
        'Request': grpc.unary_unary_rpc_method_handler(
            servicer.Request,
            request_deserializer=Message.FromString,
            response_serializer=Message.SerializeToString,
        ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
        'Container', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

def add_AdminServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Request': grpc.unary_unary_rpc_method_handler(
          servicer.Request,
          request_deserializer=loopchain__pb2.Message.FromString,
          response_serializer=loopchain__pb2.Message.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'AdminService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))

def add_ContainerServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Request': grpc.unary_unary_rpc_method_handler(
          servicer.Request,
          request_deserializer=loopchain__pb2.Message.FromString,
          response_serializer=loopchain__pb2.Message.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'Container', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))