FM / v2

/opt/imh-python/lib/python3.9/site-packages/cinderclient/v2/

/opt/imh-python/lib/python3.9/site-packages/cinderclient/v2

Name	Size	Mode	Actions
contrib/	-	0755	rm
__pycache__/	-	0755	rm
availability_zones.py	1426	0644	edit dl rm
capabilities.py	1265	0644	edit dl rm
cgsnapshots.py	3876	0644	edit dl rm
client.py	5621	0644	edit dl rm
consistencygroups.py	6048	0644	edit dl rm
limits.py	3014	0644	edit dl rm
pools.py	2185	0644	edit dl rm
qos_specs.py	5076	0644	edit dl rm
quotas.py	1978	0644	edit dl rm
quota_classes.py	1651	0644	edit dl rm
services.py	2862	0644	edit dl rm
shell.py	90696	0644	edit dl rm
volumes.py	24302	0644	edit dl rm
volume_backups.py	5528	0644	edit dl rm
volume_backups_restore.py	1669	0644	edit dl rm
volume_encryption_types.py	3952	0644	edit dl rm
volume_snapshots.py	1682	0644	edit dl rm
volume_transfers.py	2945	0644	edit dl rm
volume_types.py	5113	0644	edit dl rm
volume_type_access.py	2024	0644	edit dl rm
__init__.py	692	0644	edit dl rm

Edit: /opt/imh-python/lib/python3.9/site-packages/cinderclient/v2/services.py (2862B)

"""
service interface
"""

from cinderclient import base

class Service(base.Resource):

def __repr__(self):
        return "<Service: binary=%s host=%s>" % (self.binary, self.host)

class ServiceManager(base.ManagerWithFind):
    resource_class = Service

def list(self, host=None, binary=None):
        """
        Describes service list for host.

:param host: destination host name.
        :param binary: service binary.
        """
        url = "/os-services"
        filters = []
        if host:
            filters.append("host=%s" % host)
        if binary:
            filters.append("binary=%s" % binary)
        if filters:
            url = "%s?%s" % (url, "&".join(filters))
        return self._list(url, "services")

def enable(self, host, binary):
        """Enable the service specified by hostname and binary."""
        body = {"host": host, "binary": binary}
        result = self._update("/os-services/enable", body)
        return self.resource_class(self, result, resp=result.request_ids)

def disable(self, host, binary):
        """Disable the service specified by hostname and binary."""
        body = {"host": host, "binary": binary}
        result = self._update("/os-services/disable", body)
        return self.resource_class(self, result, resp=result.request_ids)

def disable_log_reason(self, host, binary, reason):
        """Disable the service with reason."""
        body = {"host": host, "binary": binary, "disabled_reason": reason}
        result = self._update("/os-services/disable-log-reason", body)
        return self.resource_class(self, result, resp=result.request_ids)

def freeze_host(self, host):
        """Freeze the service specified by hostname."""
        body = {"host": host}
        return self._update("/os-services/freeze", body)

def thaw_host(self, host):
        """Thaw the service specified by hostname."""
        body = {"host": host}
        return self._update("/os-services/thaw", body)

def failover_host(self, host, backend_id):
        """Failover a replicated backend by hostname."""
        body = {"host": host, "backend_id": backend_id}
        return self._update("/os-services/failover_host", body)

# Copyright (c) 2013 OpenStack Foundation # All Rights Reserved. # # Licensed under the Apache License, Version 2.0 (the "License"); you may # not use this file except in compliance with the License. You may obtain # a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the # License for the specific language governing permissions and limitations # under the License. """ service interface """ from cinderclient import base class Service(base.Resource): def __repr__(self): return "" % (self.binary, self.host) class ServiceManager(base.ManagerWithFind): resource_class = Service def list(self, host=None, binary=None): """ Describes service list for host. :param host: destination host name. :param binary: service binary. """ url = "/os-services" filters = [] if host: filters.append("host=%s" % host) if binary: filters.append("binary=%s" % binary) if filters: url = "%s?%s" % (url, "&".join(filters)) return self._list(url, "services") def enable(self, host, binary): """Enable the service specified by hostname and binary.""" body = {"host": host, "binary": binary} result = self._update("/os-services/enable", body) return self.resource_class(self, result, resp=result.request_ids) def disable(self, host, binary): """Disable the service specified by hostname and binary.""" body = {"host": host, "binary": binary} result = self._update("/os-services/disable", body) return self.resource_class(self, result, resp=result.request_ids) def disable_log_reason(self, host, binary, reason): """Disable the service with reason.""" body = {"host": host, "binary": binary, "disabled_reason": reason} result = self._update("/os-services/disable-log-reason", body) return self.resource_class(self, result, resp=result.request_ids) def freeze_host(self, host): """Freeze the service specified by hostname.""" body = {"host": host} return self._update("/os-services/freeze", body) def thaw_host(self, host): """Thaw the service specified by hostname.""" body = {"host": host} return self._update("/os-services/thaw", body) def failover_host(self, host, backend_id): """Failover a replicated backend by hostname.""" body = {"host": host, "backend_id": backend_id} return self._update("/os-services/failover_host", body)