python3-maas-provisioningserver 2.4.0~beta2-6865-gec43e47e6-0ubuntu1 / usr / lib / python3 / dist-packages / provisioningserver / rpc / __init__.py

# Copyright 2013-2015 Canonical Ltd.  This software is licensed under the
# GNU Affero General Public License version 3 (see the file LICENSE).

"""Cluster Controller RPC."""

__all__ = [
    "getRegionClient",
]

import provisioningserver
from provisioningserver.rpc import exceptions


def getRegionClient():
    """getRegionClient()

    Get a client with which to make RPCs to the region.

    :raises: :py:class:`~.exceptions.NoConnectionsAvailable` when there
        are no open connections to the region controller.
    """
    # TODO: retry a couple of times before giving up if the service is
    # not running or if exceptions.NoConnectionsAvailable gets raised.
    try:
        rpc_service = provisioningserver.services.getServiceNamed('rpc')
    except KeyError:
        raise exceptions.NoConnectionsAvailable(
            "Cluster services are unavailable.")
    else:
        return rpc_service.getClient()