Revert "pybind/mgr: Protobuffer file generation for grpc deps."

This reverts commit 0ff89b041d.

Signed-off-by: Nizamudeen A <nia@redhat.com>

.gitignore

@@ -97,7 +97,3 @@ src/pybind/rbd/rbd.egg-info/
 src/pybind/rgw/build/
 src/pybind/rgw/rgw.c
 src/pybind/rgw/rgw.egg-info/
-
-# GRPC protobuff file generation #PR 61089
-src/pybind/mgr/dashboard/services/proto/gateway_pb2.py
-src/pybind/mgr/dashboard/services/proto/gateway_pb2_grpc.py

src/pybind/mgr/dashboard/CMakeLists.txt

@@ -14,34 +14,6 @@ if(WITH_MGR_DASHBOARD_FRONTEND)
     add_tox_test(mgr-dashboard-check TOX_ENVS check)
     add_tox_test(mgr-dashboard-openapi TOX_ENVS openapi-check)
   endif()
-
-  # Required for building the dashboard grpc protos at build time
-  set(CEPH_GRPC_VIRTUALENV ${CEPH_BUILD_VIRTUALENV}/ceph-grpc-virtualenv)
-
-  add_custom_command(
-    OUTPUT ${CEPH_GRPC_VIRTUALENV}/lib/python*/site-packages/grpc_tools
-    COMMAND ${CMAKE_SOURCE_DIR}/src/tools/setup-virtualenv.sh --python=${Python3_EXECUTABLE} ${CEPH_GRPC_VIRTUALENV}
-    COMMAND ${CEPH_GRPC_VIRTUALENV}/bin/pip install grpcio-tools
-    WORKING_DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}
-    COMMENT "grpcio-tools is being installed")
-
-  # protobuffer files generation
-  add_custom_command(
-    OUTPUT "${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway_pb2.py" "${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway_pb2_grpc.py"
-    COMMAND . ${CEPH_GRPC_VIRTUALENV}/bin/activate && ${CEPH_GRPC_VIRTUALENV}/bin/python -m grpc_tools.protoc --proto_path=. --python_out=. --grpc_python_out=. dashboard/services/proto/gateway.proto && deactivate
-    WORKING_DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}/..
-    DEPENDS ${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway.proto ${CEPH_GRPC_VIRTUALENV}/lib/python*/site-packages/grpc_tools
-    COMMENT "proto generation for grpc deps")
-  add_custom_target(mgr-dashboard-services-deps
-    DEPENDS ${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway_pb2.py ${CMAKE_CURRENT_SOURCE_DIR}/services/proto/gateway_pb2_grpc.py
-    WORKING_DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR})
-
-  add_custom_target(mgr-dashboard-services-build
-    ALL
-    DEPENDS mgr-dashboard-services-deps)
-
-  add_dependencies(tests mgr-dashboard-services-build)
-
 else()
   if(EXISTS ${CMAKE_CURRENT_SOURCE_DIR}/frontend/dist)
     # prebuilt

src/pybind/mgr/dashboard/requirements.txt

@@ -11,5 +11,5 @@ pyyaml
 natsort
 setuptools
 jsonpatch
-grpcio
+grpcio==1.46.5
-grpcio-tools
+grpcio-tools==1.46.5

src/pybind/mgr/dashboard/services/proto/gateway_pb2_grpc.py

@@ -0,0 +1,883 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+
+from dashboard.services.proto import gateway_pb2 as dashboard_dot_services_dot_proto_dot_gateway__pb2
+
+
+class GatewayStub(object):
+    """Missing associated documentation comment in .proto file."""
+
+    def __init__(self, channel):
+        """Constructor.
+
+        Args:
+            channel: A grpc.Channel.
+        """
+        self.namespace_add = channel.unary_unary(
+                '/Gateway/namespace_add',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_add_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.nsid_status.FromString,
+                )
+        self.create_subsystem = channel.unary_unary(
+                '/Gateway/create_subsystem',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.create_subsystem_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.delete_subsystem = channel.unary_unary(
+                '/Gateway/delete_subsystem',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_subsystem_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.list_namespaces = channel.unary_unary(
+                '/Gateway/list_namespaces',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_namespaces_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespaces_info.FromString,
+                )
+        self.namespace_resize = channel.unary_unary(
+                '/Gateway/namespace_resize',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_resize_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.namespace_get_io_stats = channel.unary_unary(
+                '/Gateway/namespace_get_io_stats',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_get_io_stats_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_io_stats_info.FromString,
+                )
+        self.namespace_set_qos_limits = channel.unary_unary(
+                '/Gateway/namespace_set_qos_limits',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_set_qos_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.namespace_change_load_balancing_group = channel.unary_unary(
+                '/Gateway/namespace_change_load_balancing_group',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_change_load_balancing_group_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.namespace_delete = channel.unary_unary(
+                '/Gateway/namespace_delete',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_delete_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.add_host = channel.unary_unary(
+                '/Gateway/add_host',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.add_host_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.remove_host = channel.unary_unary(
+                '/Gateway/remove_host',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.remove_host_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.list_hosts = channel.unary_unary(
+                '/Gateway/list_hosts',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_hosts_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.hosts_info.FromString,
+                )
+        self.list_connections = channel.unary_unary(
+                '/Gateway/list_connections',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_connections_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.connections_info.FromString,
+                )
+        self.create_listener = channel.unary_unary(
+                '/Gateway/create_listener',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.create_listener_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.delete_listener = channel.unary_unary(
+                '/Gateway/delete_listener',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_listener_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.list_listeners = channel.unary_unary(
+                '/Gateway/list_listeners',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_listeners_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.listeners_info.FromString,
+                )
+        self.list_subsystems = channel.unary_unary(
+                '/Gateway/list_subsystems',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_subsystems_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info_cli.FromString,
+                )
+        self.get_subsystems = channel.unary_unary(
+                '/Gateway/get_subsystems',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_subsystems_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info.FromString,
+                )
+        self.set_ana_state = channel.unary_unary(
+                '/Gateway/set_ana_state',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.ana_info.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.get_spdk_nvmf_log_flags_and_level = channel.unary_unary(
+                '/Gateway/get_spdk_nvmf_log_flags_and_level',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_spdk_nvmf_log_flags_and_level_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.spdk_nvmf_log_flags_and_level_info.FromString,
+                )
+        self.disable_spdk_nvmf_logs = channel.unary_unary(
+                '/Gateway/disable_spdk_nvmf_logs',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.disable_spdk_nvmf_logs_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.set_spdk_nvmf_logs = channel.unary_unary(
+                '/Gateway/set_spdk_nvmf_logs',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.set_spdk_nvmf_logs_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+        self.get_gateway_info = channel.unary_unary(
+                '/Gateway/get_gateway_info',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_info_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_info.FromString,
+                )
+        self.get_gateway_log_level = channel.unary_unary(
+                '/Gateway/get_gateway_log_level',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_log_level_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_log_level_info.FromString,
+                )
+        self.set_gateway_log_level = channel.unary_unary(
+                '/Gateway/set_gateway_log_level',
+                request_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.set_gateway_log_level_req.SerializeToString,
+                response_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+                )
+
+
+class GatewayServicer(object):
+    """Missing associated documentation comment in .proto file."""
+
+    def namespace_add(self, request, context):
+        """Creates a namespace from an RBD image
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def create_subsystem(self, request, context):
+        """Creates a subsystem
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def delete_subsystem(self, request, context):
+        """Deletes a subsystem
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def list_namespaces(self, request, context):
+        """List namespaces
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def namespace_resize(self, request, context):
+        """Resizes a namespace
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def namespace_get_io_stats(self, request, context):
+        """Gets namespace's IO stats
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def namespace_set_qos_limits(self, request, context):
+        """Sets namespace's qos limits
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def namespace_change_load_balancing_group(self, request, context):
+        """Changes namespace's load balancing group
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def namespace_delete(self, request, context):
+        """Deletes a namespace
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def add_host(self, request, context):
+        """Adds a host to a subsystem
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def remove_host(self, request, context):
+        """Removes a host from a subsystem
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def list_hosts(self, request, context):
+        """List hosts
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def list_connections(self, request, context):
+        """List connections
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def create_listener(self, request, context):
+        """Creates a listener for a subsystem at a given IP/Port
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def delete_listener(self, request, context):
+        """Deletes a listener from a subsystem at a given IP/Port
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def list_listeners(self, request, context):
+        """List listeners
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def list_subsystems(self, request, context):
+        """List subsystems
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def get_subsystems(self, request, context):
+        """Gets subsystems
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def set_ana_state(self, request, context):
+        """Set gateway ANA states
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def get_spdk_nvmf_log_flags_and_level(self, request, context):
+        """Gets spdk nvmf log flags and level
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def disable_spdk_nvmf_logs(self, request, context):
+        """Disables spdk nvmf logs
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def set_spdk_nvmf_logs(self, request, context):
+        """Set spdk nvmf logs
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def get_gateway_info(self, request, context):
+        """Get gateway info
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def get_gateway_log_level(self, request, context):
+        """Get gateway log level
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def set_gateway_log_level(self, request, context):
+        """Set gateway log level
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+
+def add_GatewayServicer_to_server(servicer, server):
+    rpc_method_handlers = {
+            'namespace_add': grpc.unary_unary_rpc_method_handler(
+                    servicer.namespace_add,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_add_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.nsid_status.SerializeToString,
+            ),
+            'create_subsystem': grpc.unary_unary_rpc_method_handler(
+                    servicer.create_subsystem,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.create_subsystem_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'delete_subsystem': grpc.unary_unary_rpc_method_handler(
+                    servicer.delete_subsystem,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_subsystem_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'list_namespaces': grpc.unary_unary_rpc_method_handler(
+                    servicer.list_namespaces,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_namespaces_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespaces_info.SerializeToString,
+            ),
+            'namespace_resize': grpc.unary_unary_rpc_method_handler(
+                    servicer.namespace_resize,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_resize_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'namespace_get_io_stats': grpc.unary_unary_rpc_method_handler(
+                    servicer.namespace_get_io_stats,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_get_io_stats_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_io_stats_info.SerializeToString,
+            ),
+            'namespace_set_qos_limits': grpc.unary_unary_rpc_method_handler(
+                    servicer.namespace_set_qos_limits,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_set_qos_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'namespace_change_load_balancing_group': grpc.unary_unary_rpc_method_handler(
+                    servicer.namespace_change_load_balancing_group,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_change_load_balancing_group_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'namespace_delete': grpc.unary_unary_rpc_method_handler(
+                    servicer.namespace_delete,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_delete_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'add_host': grpc.unary_unary_rpc_method_handler(
+                    servicer.add_host,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.add_host_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'remove_host': grpc.unary_unary_rpc_method_handler(
+                    servicer.remove_host,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.remove_host_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'list_hosts': grpc.unary_unary_rpc_method_handler(
+                    servicer.list_hosts,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_hosts_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.hosts_info.SerializeToString,
+            ),
+            'list_connections': grpc.unary_unary_rpc_method_handler(
+                    servicer.list_connections,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_connections_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.connections_info.SerializeToString,
+            ),
+            'create_listener': grpc.unary_unary_rpc_method_handler(
+                    servicer.create_listener,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.create_listener_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'delete_listener': grpc.unary_unary_rpc_method_handler(
+                    servicer.delete_listener,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_listener_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'list_listeners': grpc.unary_unary_rpc_method_handler(
+                    servicer.list_listeners,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_listeners_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.listeners_info.SerializeToString,
+            ),
+            'list_subsystems': grpc.unary_unary_rpc_method_handler(
+                    servicer.list_subsystems,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.list_subsystems_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info_cli.SerializeToString,
+            ),
+            'get_subsystems': grpc.unary_unary_rpc_method_handler(
+                    servicer.get_subsystems,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_subsystems_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info.SerializeToString,
+            ),
+            'set_ana_state': grpc.unary_unary_rpc_method_handler(
+                    servicer.set_ana_state,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.ana_info.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'get_spdk_nvmf_log_flags_and_level': grpc.unary_unary_rpc_method_handler(
+                    servicer.get_spdk_nvmf_log_flags_and_level,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_spdk_nvmf_log_flags_and_level_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.spdk_nvmf_log_flags_and_level_info.SerializeToString,
+            ),
+            'disable_spdk_nvmf_logs': grpc.unary_unary_rpc_method_handler(
+                    servicer.disable_spdk_nvmf_logs,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.disable_spdk_nvmf_logs_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'set_spdk_nvmf_logs': grpc.unary_unary_rpc_method_handler(
+                    servicer.set_spdk_nvmf_logs,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.set_spdk_nvmf_logs_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+            'get_gateway_info': grpc.unary_unary_rpc_method_handler(
+                    servicer.get_gateway_info,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_info_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_info.SerializeToString,
+            ),
+            'get_gateway_log_level': grpc.unary_unary_rpc_method_handler(
+                    servicer.get_gateway_log_level,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_log_level_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_log_level_info.SerializeToString,
+            ),
+            'set_gateway_log_level': grpc.unary_unary_rpc_method_handler(
+                    servicer.set_gateway_log_level,
+                    request_deserializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.set_gateway_log_level_req.FromString,
+                    response_serializer=dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.SerializeToString,
+            ),
+    }
+    generic_handler = grpc.method_handlers_generic_handler(
+            'Gateway', rpc_method_handlers)
+    server.add_generic_rpc_handlers((generic_handler,))
+
+
+ # This class is part of an EXPERIMENTAL API.
+class Gateway(object):
+    """Missing associated documentation comment in .proto file."""
+
+    @staticmethod
+    def namespace_add(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, '/Gateway/namespace_add',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_add_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.nsid_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def create_subsystem(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, '/Gateway/create_subsystem',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.create_subsystem_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def delete_subsystem(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, '/Gateway/delete_subsystem',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_subsystem_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def list_namespaces(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, '/Gateway/list_namespaces',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.list_namespaces_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.namespaces_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def namespace_resize(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, '/Gateway/namespace_resize',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_resize_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def namespace_get_io_stats(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, '/Gateway/namespace_get_io_stats',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_get_io_stats_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_io_stats_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def namespace_set_qos_limits(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, '/Gateway/namespace_set_qos_limits',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_set_qos_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def namespace_change_load_balancing_group(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, '/Gateway/namespace_change_load_balancing_group',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_change_load_balancing_group_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def namespace_delete(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, '/Gateway/namespace_delete',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.namespace_delete_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def add_host(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, '/Gateway/add_host',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.add_host_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def remove_host(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, '/Gateway/remove_host',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.remove_host_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def list_hosts(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, '/Gateway/list_hosts',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.list_hosts_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.hosts_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def list_connections(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, '/Gateway/list_connections',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.list_connections_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.connections_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def create_listener(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, '/Gateway/create_listener',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.create_listener_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def delete_listener(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, '/Gateway/delete_listener',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.delete_listener_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def list_listeners(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, '/Gateway/list_listeners',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.list_listeners_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.listeners_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def list_subsystems(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, '/Gateway/list_subsystems',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.list_subsystems_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info_cli.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def get_subsystems(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, '/Gateway/get_subsystems',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.get_subsystems_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.subsystems_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def set_ana_state(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, '/Gateway/set_ana_state',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.ana_info.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def get_spdk_nvmf_log_flags_and_level(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, '/Gateway/get_spdk_nvmf_log_flags_and_level',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.get_spdk_nvmf_log_flags_and_level_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.spdk_nvmf_log_flags_and_level_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def disable_spdk_nvmf_logs(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, '/Gateway/disable_spdk_nvmf_logs',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.disable_spdk_nvmf_logs_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def set_spdk_nvmf_logs(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, '/Gateway/set_spdk_nvmf_logs',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.set_spdk_nvmf_logs_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def get_gateway_info(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, '/Gateway/get_gateway_info',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_info_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def get_gateway_log_level(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, '/Gateway/get_gateway_log_level',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.get_gateway_log_level_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.gateway_log_level_info.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def set_gateway_log_level(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, '/Gateway/set_gateway_log_level',
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.set_gateway_log_level_req.SerializeToString,
+            dashboard_dot_services_dot_proto_dot_gateway__pb2.req_status.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)