1#@!#!123s

: / proc / self / root / opt / saltstack / salt / lib / python3.10 / site-packages / salt / states /
Filename : rabbitmq_cluster.py
back
"""
Manage RabbitMQ Clusters
========================

Example:

.. code-block:: yaml

    rabbit@rabbit.example.com:
      rabbitmq_cluster.join:
        - user: rabbit
        - host: rabbit.example.com
"""

import logging

import salt.utils.functools
import salt.utils.path

log = logging.getLogger(__name__)


def __virtual__():
    """
    Only load if RabbitMQ is installed.
    """
    if salt.utils.path.which("rabbitmqctl"):
        return True
    return (False, "Command not found: rabbitmqctl")


def joined(name, host, user="rabbit", ram_node=None, runas="root"):
    """
    Ensure the current node joined to a cluster with node user@host

    name
        Irrelevant, not used (recommended: user@host)
    user
        The user of node to join to (default: rabbit)
    host
        The host of node to join to
    ram_node
        Join node as a RAM node
    runas
        The user to run the rabbitmq command as
    """

    ret = {"name": name, "result": True, "comment": "", "changes": {}}

    status = __salt__["rabbitmq.cluster_status"]()
    if "{}@{}".format(user, host) in status:
        ret["comment"] = "Already in cluster"
        return ret

    if not __opts__["test"]:
        result = __salt__["rabbitmq.join_cluster"](host, user, ram_node, runas=runas)
        if "Error" in result:
            ret["result"] = False
            ret["comment"] = result["Error"]
            return ret
        elif "Join" in result:
            ret["comment"] = result["Join"]

    # If we've reached this far before returning, we have changes.
    ret["changes"] = {"old": "", "new": "{}@{}".format(user, host)}

    if __opts__["test"]:
        ret["result"] = None
        ret["comment"] = "Node is set to join cluster {}@{}".format(user, host)

    return ret


# Alias join to preserve backward compat
join = salt.utils.functools.alias_function(joined, "join")