ceph/src/pybind/mgr/diskprediction_cloud/common/client_pb2_grpc.py

   1 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
   2 import grpc
   3
   4 import client_pb2 as mainServer__pb2
   5
   6
   7 class GeneralStub(object):
   8   """-------------------------- General -------------------------------------
   9   """
  10
  11   def __init__(self, channel):
  12     """Constructor.
  13
  14     Args:
  15       channel: A grpc.Channel.
  16     """
  17     self.GeneralHeartbeat = channel.unary_unary(
  18         '/proto.General/GeneralHeartbeat',
  19         request_serializer=mainServer__pb2.Empty.SerializeToString,
  20         response_deserializer=mainServer__pb2.GeneralHeartbeatOutput.FromString,
  21         )
  22     self.Ping = channel.unary_unary(
  23         '/proto.General/Ping',
  24         request_serializer=mainServer__pb2.Empty.SerializeToString,
  25         response_deserializer=mainServer__pb2.PingOutout.FromString,
  26         )
  27     self.Test = channel.unary_unary(
  28         '/proto.General/Test',
  29         request_serializer=mainServer__pb2.TestInput.SerializeToString,
  30         response_deserializer=mainServer__pb2.TestOutput.FromString,
  31         )
  32
  33
  34 class GeneralServicer(object):
  35   """-------------------------- General -------------------------------------
  36   """
  37
  38   def GeneralHeartbeat(self, request, context):
  39     # missing associated documentation comment in .proto file
  40     pass
  41     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
  42     context.set_details('Method not implemented!')
  43     raise NotImplementedError('Method not implemented!')
  44
  45   def Ping(self, request, context):
  46     # missing associated documentation comment in .proto file
  47     pass
  48     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
  49     context.set_details('Method not implemented!')
  50     raise NotImplementedError('Method not implemented!')
  51
  52   def Test(self, request, context):
  53     # missing associated documentation comment in .proto file
  54     pass
  55     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
  56     context.set_details('Method not implemented!')
  57     raise NotImplementedError('Method not implemented!')
  58
  59
  60 def add_GeneralServicer_to_server(servicer, server):
  61   rpc_method_handlers = {
  62       'GeneralHeartbeat': grpc.unary_unary_rpc_method_handler(
  63           servicer.GeneralHeartbeat,
  64           request_deserializer=mainServer__pb2.Empty.FromString,
  65           response_serializer=mainServer__pb2.GeneralHeartbeatOutput.SerializeToString,
  66       ),
  67       'Ping': grpc.unary_unary_rpc_method_handler(
  68           servicer.Ping,
  69           request_deserializer=mainServer__pb2.Empty.FromString,
  70           response_serializer=mainServer__pb2.PingOutout.SerializeToString,
  71       ),
  72       'Test': grpc.unary_unary_rpc_method_handler(
  73           servicer.Test,
  74           request_deserializer=mainServer__pb2.TestInput.FromString,
  75           response_serializer=mainServer__pb2.TestOutput.SerializeToString,
  76       ),
  77   }
  78   generic_handler = grpc.method_handlers_generic_handler(
  79       'proto.General', rpc_method_handlers)
  80   server.add_generic_rpc_handlers((generic_handler,))
  81
  82
  83 class AccountStub(object):
  84   """-------------------------- SERVER ACCOUNT ------------------------------
  85   """
  86
  87   def __init__(self, channel):
  88     """Constructor.
  89
  90     Args:
  91       channel: A grpc.Channel.
  92     """
  93     self.AccountHeartbeat = channel.unary_unary(
  94         '/proto.Account/AccountHeartbeat',
  95         request_serializer=mainServer__pb2.Empty.SerializeToString,
  96         response_deserializer=mainServer__pb2.AccountHeartbeatOutput.FromString,
  97         )
  98     self.Login = channel.unary_unary(
  99         '/proto.Account/Login',
 100         request_serializer=mainServer__pb2.LoginInput.SerializeToString,
 101         response_deserializer=mainServer__pb2.UserOutput.FromString,
 102         )
 103     self.Signup = channel.unary_unary(
 104         '/proto.Account/Signup',
 105         request_serializer=mainServer__pb2.SingupInput.SerializeToString,
 106         response_deserializer=mainServer__pb2.SingupOutput.FromString,
 107         )
 108     self.ResendConfirmCode = channel.unary_unary(
 109         '/proto.Account/ResendConfirmCode',
 110         request_serializer=mainServer__pb2.ResendConfirmCodeInput.SerializeToString,
 111         response_deserializer=mainServer__pb2.GeneralMsgOutput.FromString,
 112         )
 113     self.Confirm = channel.unary_unary(
 114         '/proto.Account/Confirm',
 115         request_serializer=mainServer__pb2.ConfirmInput.SerializeToString,
 116         response_deserializer=mainServer__pb2.GeneralMsgOutput.FromString,
 117         )
 118     self.GetUsersByStatus = channel.unary_unary(
 119         '/proto.Account/GetUsersByStatus',
 120         request_serializer=mainServer__pb2.GetUsersByStatusInput.SerializeToString,
 121         response_deserializer=mainServer__pb2.GetUsersByStatusOutput.FromString,
 122         )
 123     self.DeleteUser = channel.unary_unary(
 124         '/proto.Account/DeleteUser',
 125         request_serializer=mainServer__pb2.DeleteUserInput.SerializeToString,
 126         response_deserializer=mainServer__pb2.GeneralMsgOutput.FromString,
 127         )
 128     self.UpdateUserStatus = channel.unary_unary(
 129         '/proto.Account/UpdateUserStatus',
 130         request_serializer=mainServer__pb2.UpdateUserStatusInput.SerializeToString,
 131         response_deserializer=mainServer__pb2.GeneralMsgOutput.FromString,
 132         )
 133
 134
 135 class AccountServicer(object):
 136   """-------------------------- SERVER ACCOUNT ------------------------------
 137   """
 138
 139   def AccountHeartbeat(self, request, context):
 140     # missing associated documentation comment in .proto file
 141     pass
 142     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 143     context.set_details('Method not implemented!')
 144     raise NotImplementedError('Method not implemented!')
 145
 146   def Login(self, request, context):
 147     # missing associated documentation comment in .proto file
 148     pass
 149     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 150     context.set_details('Method not implemented!')
 151     raise NotImplementedError('Method not implemented!')
 152
 153   def Signup(self, request, context):
 154     # missing associated documentation comment in .proto file
 155     pass
 156     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 157     context.set_details('Method not implemented!')
 158     raise NotImplementedError('Method not implemented!')
 159
 160   def ResendConfirmCode(self, request, context):
 161     # missing associated documentation comment in .proto file
 162     pass
 163     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 164     context.set_details('Method not implemented!')
 165     raise NotImplementedError('Method not implemented!')
 166
 167   def Confirm(self, request, context):
 168     # missing associated documentation comment in .proto file
 169     pass
 170     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 171     context.set_details('Method not implemented!')
 172     raise NotImplementedError('Method not implemented!')
 173
 174   def GetUsersByStatus(self, request, context):
 175     # missing associated documentation comment in .proto file
 176     pass
 177     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 178     context.set_details('Method not implemented!')
 179     raise NotImplementedError('Method not implemented!')
 180
 181   def DeleteUser(self, request, context):
 182     # missing associated documentation comment in .proto file
 183     pass
 184     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 185     context.set_details('Method not implemented!')
 186     raise NotImplementedError('Method not implemented!')
 187
 188   def UpdateUserStatus(self, request, context):
 189     # missing associated documentation comment in .proto file
 190     pass
 191     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 192     context.set_details('Method not implemented!')
 193     raise NotImplementedError('Method not implemented!')
 194
 195
 196 def add_AccountServicer_to_server(servicer, server):
 197   rpc_method_handlers = {
 198       'AccountHeartbeat': grpc.unary_unary_rpc_method_handler(
 199           servicer.AccountHeartbeat,
 200           request_deserializer=mainServer__pb2.Empty.FromString,
 201           response_serializer=mainServer__pb2.AccountHeartbeatOutput.SerializeToString,
 202       ),
 203       'Login': grpc.unary_unary_rpc_method_handler(
 204           servicer.Login,
 205           request_deserializer=mainServer__pb2.LoginInput.FromString,
 206           response_serializer=mainServer__pb2.UserOutput.SerializeToString,
 207       ),
 208       'Signup': grpc.unary_unary_rpc_method_handler(
 209           servicer.Signup,
 210           request_deserializer=mainServer__pb2.SingupInput.FromString,
 211           response_serializer=mainServer__pb2.SingupOutput.SerializeToString,
 212       ),
 213       'ResendConfirmCode': grpc.unary_unary_rpc_method_handler(
 214           servicer.ResendConfirmCode,
 215           request_deserializer=mainServer__pb2.ResendConfirmCodeInput.FromString,
 216           response_serializer=mainServer__pb2.GeneralMsgOutput.SerializeToString,
 217       ),
 218       'Confirm': grpc.unary_unary_rpc_method_handler(
 219           servicer.Confirm,
 220           request_deserializer=mainServer__pb2.ConfirmInput.FromString,
 221           response_serializer=mainServer__pb2.GeneralMsgOutput.SerializeToString,
 222       ),
 223       'GetUsersByStatus': grpc.unary_unary_rpc_method_handler(
 224           servicer.GetUsersByStatus,
 225           request_deserializer=mainServer__pb2.GetUsersByStatusInput.FromString,
 226           response_serializer=mainServer__pb2.GetUsersByStatusOutput.SerializeToString,
 227       ),
 228       'DeleteUser': grpc.unary_unary_rpc_method_handler(
 229           servicer.DeleteUser,
 230           request_deserializer=mainServer__pb2.DeleteUserInput.FromString,
 231           response_serializer=mainServer__pb2.GeneralMsgOutput.SerializeToString,
 232       ),
 233       'UpdateUserStatus': grpc.unary_unary_rpc_method_handler(
 234           servicer.UpdateUserStatus,
 235           request_deserializer=mainServer__pb2.UpdateUserStatusInput.FromString,
 236           response_serializer=mainServer__pb2.GeneralMsgOutput.SerializeToString,
 237       ),
 238   }
 239   generic_handler = grpc.method_handlers_generic_handler(
 240       'proto.Account', rpc_method_handlers)
 241   server.add_generic_rpc_handlers((generic_handler,))
 242
 243
 244 class DiskprophetStub(object):
 245   """------------------------ SERVER DISKPROPHET ---------------------------
 246   """
 247
 248   def __init__(self, channel):
 249     """Constructor.
 250
 251     Args:
 252       channel: A grpc.Channel.
 253     """
 254     self.DPHeartbeat = channel.unary_unary(
 255         '/proto.Diskprophet/DPHeartbeat',
 256         request_serializer=mainServer__pb2.Empty.SerializeToString,
 257         response_deserializer=mainServer__pb2.DPHeartbeatOutput.FromString,
 258         )
 259     self.DPGetPhysicalDisks = channel.unary_unary(
 260         '/proto.Diskprophet/DPGetPhysicalDisks',
 261         request_serializer=mainServer__pb2.DPGetPhysicalDisksInput.SerializeToString,
 262         response_deserializer=mainServer__pb2.DPBinaryOutput.FromString,
 263         )
 264     self.DPGetDisksPrediction = channel.unary_unary(
 265         '/proto.Diskprophet/DPGetDisksPrediction',
 266         request_serializer=mainServer__pb2.DPGetDisksPredictionInput.SerializeToString,
 267         response_deserializer=mainServer__pb2.DPBinaryOutput.FromString,
 268         )
 269
 270
 271 class DiskprophetServicer(object):
 272   """------------------------ SERVER DISKPROPHET ---------------------------
 273   """
 274
 275   def DPHeartbeat(self, request, context):
 276     # missing associated documentation comment in .proto file
 277     pass
 278     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 279     context.set_details('Method not implemented!')
 280     raise NotImplementedError('Method not implemented!')
 281
 282   def DPGetPhysicalDisks(self, request, context):
 283     # missing associated documentation comment in .proto file
 284     pass
 285     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 286     context.set_details('Method not implemented!')
 287     raise NotImplementedError('Method not implemented!')
 288
 289   def DPGetDisksPrediction(self, request, context):
 290     # missing associated documentation comment in .proto file
 291     pass
 292     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 293     context.set_details('Method not implemented!')
 294     raise NotImplementedError('Method not implemented!')
 295
 296
 297 def add_DiskprophetServicer_to_server(servicer, server):
 298   rpc_method_handlers = {
 299       'DPHeartbeat': grpc.unary_unary_rpc_method_handler(
 300           servicer.DPHeartbeat,
 301           request_deserializer=mainServer__pb2.Empty.FromString,
 302           response_serializer=mainServer__pb2.DPHeartbeatOutput.SerializeToString,
 303       ),
 304       'DPGetPhysicalDisks': grpc.unary_unary_rpc_method_handler(
 305           servicer.DPGetPhysicalDisks,
 306           request_deserializer=mainServer__pb2.DPGetPhysicalDisksInput.FromString,
 307           response_serializer=mainServer__pb2.DPBinaryOutput.SerializeToString,
 308       ),
 309       'DPGetDisksPrediction': grpc.unary_unary_rpc_method_handler(
 310           servicer.DPGetDisksPrediction,
 311           request_deserializer=mainServer__pb2.DPGetDisksPredictionInput.FromString,
 312           response_serializer=mainServer__pb2.DPBinaryOutput.SerializeToString,
 313       ),
 314   }
 315   generic_handler = grpc.method_handlers_generic_handler(
 316       'proto.Diskprophet', rpc_method_handlers)
 317   server.add_generic_rpc_handlers((generic_handler,))
 318
 319
 320 class CollectionStub(object):
 321   """------------------------ SERVER Collection ---------------------------
 322
 323   """
 324
 325   def __init__(self, channel):
 326     """Constructor.
 327
 328     Args:
 329       channel: A grpc.Channel.
 330     """
 331     self.CollectionHeartbeat = channel.unary_unary(
 332         '/proto.Collection/CollectionHeartbeat',
 333         request_serializer=mainServer__pb2.Empty.SerializeToString,
 334         response_deserializer=mainServer__pb2.CollectionHeartbeatOutput.FromString,
 335         )
 336     self.PostDBRelay = channel.unary_unary(
 337         '/proto.Collection/PostDBRelay',
 338         request_serializer=mainServer__pb2.PostDBRelayInput.SerializeToString,
 339         response_deserializer=mainServer__pb2.CollectionMessageOutput.FromString,
 340         )
 341     self.PostMetrics = channel.unary_unary(
 342         '/proto.Collection/PostMetrics',
 343         request_serializer=mainServer__pb2.PostMetricsInput.SerializeToString,
 344         response_deserializer=mainServer__pb2.CollectionMessageOutput.FromString,
 345         )
 346
 347
 348 class CollectionServicer(object):
 349   """------------------------ SERVER Collection ---------------------------
 350
 351   """
 352
 353   def CollectionHeartbeat(self, request, context):
 354     # missing associated documentation comment in .proto file
 355     pass
 356     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 357     context.set_details('Method not implemented!')
 358     raise NotImplementedError('Method not implemented!')
 359
 360   def PostDBRelay(self, request, context):
 361     # missing associated documentation comment in .proto file
 362     pass
 363     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 364     context.set_details('Method not implemented!')
 365     raise NotImplementedError('Method not implemented!')
 366
 367   def PostMetrics(self, request, context):
 368     # missing associated documentation comment in .proto file
 369     pass
 370     context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 371     context.set_details('Method not implemented!')
 372     raise NotImplementedError('Method not implemented!')
 373
 374
 375 def add_CollectionServicer_to_server(servicer, server):
 376   rpc_method_handlers = {
 377       'CollectionHeartbeat': grpc.unary_unary_rpc_method_handler(
 378           servicer.CollectionHeartbeat,
 379           request_deserializer=mainServer__pb2.Empty.FromString,
 380           response_serializer=mainServer__pb2.CollectionHeartbeatOutput.SerializeToString,
 381       ),
 382       'PostDBRelay': grpc.unary_unary_rpc_method_handler(
 383           servicer.PostDBRelay,
 384           request_deserializer=mainServer__pb2.PostDBRelayInput.FromString,
 385           response_serializer=mainServer__pb2.CollectionMessageOutput.SerializeToString,
 386       ),
 387       'PostMetrics': grpc.unary_unary_rpc_method_handler(
 388           servicer.PostMetrics,
 389           request_deserializer=mainServer__pb2.PostMetricsInput.FromString,
 390           response_serializer=mainServer__pb2.CollectionMessageOutput.SerializeToString,
 391       ),
 392   }
 393   generic_handler = grpc.method_handlers_generic_handler(
 394       'proto.Collection', rpc_method_handlers)
 395   server.add_generic_rpc_handlers((generic_handler,))