@@ -30,6 +30,11 @@ def __init__(self, channel):
3030 request_serializer = imrpc_dot_disk__pb2 .DiskGetRequest .SerializeToString ,
3131 response_deserializer = imrpc_dot_disk__pb2 .Disk .FromString ,
3232 )
33+ self .DiskHealthGet = channel .unary_unary (
34+ '/imrpc.DiskService/DiskHealthGet' ,
35+ request_serializer = imrpc_dot_disk__pb2 .DiskHealthGetRequest .SerializeToString ,
36+ response_deserializer = imrpc_dot_disk__pb2 .DiskHealthGetResponse .FromString ,
37+ )
3338 self .DiskReplicaInstanceList = channel .unary_unary (
3439 '/imrpc.DiskService/DiskReplicaInstanceList' ,
3540 request_serializer = imrpc_dot_disk__pb2 .DiskReplicaInstanceListRequest .SerializeToString ,
@@ -73,6 +78,12 @@ def DiskGet(self, request, context):
7378 context .set_details ('Method not implemented!' )
7479 raise NotImplementedError ('Method not implemented!' )
7580
81+ def DiskHealthGet (self , request , context ):
82+ """Missing associated documentation comment in .proto file."""
83+ context .set_code (grpc .StatusCode .UNIMPLEMENTED )
84+ context .set_details ('Method not implemented!' )
85+ raise NotImplementedError ('Method not implemented!' )
86+
7687 def DiskReplicaInstanceList (self , request , context ):
7788 """Missing associated documentation comment in .proto file."""
7889 context .set_code (grpc .StatusCode .UNIMPLEMENTED )
@@ -115,6 +126,11 @@ def add_DiskServiceServicer_to_server(servicer, server):
115126 request_deserializer = imrpc_dot_disk__pb2 .DiskGetRequest .FromString ,
116127 response_serializer = imrpc_dot_disk__pb2 .Disk .SerializeToString ,
117128 ),
129+ 'DiskHealthGet' : grpc .unary_unary_rpc_method_handler (
130+ servicer .DiskHealthGet ,
131+ request_deserializer = imrpc_dot_disk__pb2 .DiskHealthGetRequest .FromString ,
132+ response_serializer = imrpc_dot_disk__pb2 .DiskHealthGetResponse .SerializeToString ,
133+ ),
118134 'DiskReplicaInstanceList' : grpc .unary_unary_rpc_method_handler (
119135 servicer .DiskReplicaInstanceList ,
120136 request_deserializer = imrpc_dot_disk__pb2 .DiskReplicaInstanceListRequest .FromString ,
@@ -196,6 +212,23 @@ def DiskGet(request,
196212 options , channel_credentials ,
197213 insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
198214
215+ @staticmethod
216+ def DiskHealthGet (request ,
217+ target ,
218+ options = (),
219+ channel_credentials = None ,
220+ call_credentials = None ,
221+ insecure = False ,
222+ compression = None ,
223+ wait_for_ready = None ,
224+ timeout = None ,
225+ metadata = None ):
226+ return grpc .experimental .unary_unary (request , target , '/imrpc.DiskService/DiskHealthGet' ,
227+ imrpc_dot_disk__pb2 .DiskHealthGetRequest .SerializeToString ,
228+ imrpc_dot_disk__pb2 .DiskHealthGetResponse .FromString ,
229+ options , channel_credentials ,
230+ insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
231+
199232 @staticmethod
200233 def DiskReplicaInstanceList (request ,
201234 target ,
0 commit comments