feat(engine, replica): add rpc ReplicaExpand() and EngineExpand #8022

Signed-off-by: David Cheng <davidcheng0922@gmail.com>

Author: davidcheng0922

generated-py/spdkrpc/spdk_pb2.py

@@ -30,6 +30,11 @@ def __init__(self, channel):
                 request_serializer=spdkrpc_dot_spdk__pb2.ReplicaGetRequest.SerializeToString,
                 response_deserializer=spdkrpc_dot_spdk__pb2.Replica.FromString,
                 )
+        self.ReplicaExpand = channel.unary_unary(
+                '/spdkrpc.SPDKService/ReplicaExpand',
+                request_serializer=spdkrpc_dot_spdk__pb2.ReplicaExpandRequest.SerializeToString,
+                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
+                )
         self.ReplicaSnapshotCreate = channel.unary_unary(
                 '/spdkrpc.SPDKService/ReplicaSnapshotCreate',
                 request_serializer=spdkrpc_dot_spdk__pb2.SnapshotRequest.SerializeToString,
@@ -210,6 +215,11 @@ def __init__(self, channel):
                 request_serializer=spdkrpc_dot_spdk__pb2.EngineResumeRequest.SerializeToString,
                 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                 )
+        self.EngineExpand = channel.unary_unary(
+                '/spdkrpc.SPDKService/EngineExpand',
+                request_serializer=spdkrpc_dot_spdk__pb2.EngineExpandRequest.SerializeToString,
+                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
+                )
         self.EngineSwitchOverTarget = channel.unary_unary(
                 '/spdkrpc.SPDKService/EngineSwitchOverTarget',
                 request_serializer=spdkrpc_dot_spdk__pb2.EngineSwitchOverTargetRequest.SerializeToString,
@@ -418,6 +428,12 @@ def ReplicaGet(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def ReplicaExpand(self, request, context):
+        """Missing associated documentation comment in .proto file."""
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def ReplicaSnapshotCreate(self, request, context):
         """Missing associated documentation comment in .proto file."""
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@@ -634,6 +650,12 @@ def EngineResume(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def EngineExpand(self, request, context):
+        """Missing associated documentation comment in .proto file."""
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def EngineSwitchOverTarget(self, request, context):
         """Missing associated documentation comment in .proto file."""
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@@ -874,6 +896,11 @@ def add_SPDKServiceServicer_to_server(servicer, server):
                     request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaGetRequest.FromString,
                     response_serializer=spdkrpc_dot_spdk__pb2.Replica.SerializeToString,
             ),
+            'ReplicaExpand': grpc.unary_unary_rpc_method_handler(
+                    servicer.ReplicaExpand,
+                    request_deserializer=spdkrpc_dot_spdk__pb2.ReplicaExpandRequest.FromString,
+                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
+            ),
             'ReplicaSnapshotCreate': grpc.unary_unary_rpc_method_handler(
                     servicer.ReplicaSnapshotCreate,
                     request_deserializer=spdkrpc_dot_spdk__pb2.SnapshotRequest.FromString,
@@ -1054,6 +1081,11 @@ def add_SPDKServiceServicer_to_server(servicer, server):
                     request_deserializer=spdkrpc_dot_spdk__pb2.EngineResumeRequest.FromString,
                     response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
             ),
+            'EngineExpand': grpc.unary_unary_rpc_method_handler(
+                    servicer.EngineExpand,
+                    request_deserializer=spdkrpc_dot_spdk__pb2.EngineExpandRequest.FromString,
+                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
+            ),
             'EngineSwitchOverTarget': grpc.unary_unary_rpc_method_handler(
                     servicer.EngineSwitchOverTarget,
                     request_deserializer=spdkrpc_dot_spdk__pb2.EngineSwitchOverTargetRequest.FromString,
@@ -1300,6 +1332,23 @@ def ReplicaGet(request,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
+    @staticmethod
+    def ReplicaExpand(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/spdkrpc.SPDKService/ReplicaExpand',
+            spdkrpc_dot_spdk__pb2.ReplicaExpandRequest.SerializeToString,
+            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
     @staticmethod
     def ReplicaSnapshotCreate(request,
             target,
@@ -1912,6 +1961,23 @@ def EngineResume(request,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
+    @staticmethod
+    def EngineExpand(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/spdkrpc.SPDKService/EngineExpand',
+            spdkrpc_dot_spdk__pb2.EngineExpandRequest.SerializeToString,
+            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
     @staticmethod
     def EngineSwitchOverTarget(request,
             target,