File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/riak.cpython-310.pyc
o
�N�g� � @ sp d Z ddlZdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� ZdS )z
Riak Salt Module
� Nc C s t jj�d�r dS dS )z8
Only available on systems with Riak installed.
�riakT)FzMThe riak execution module failed to load: the riak binary is not in the path.)�salt�utils�path�which� r r �E/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/riak.py� __virtual__ s r c C s t d tjj�| �� d|� ��S )z
Execute Riak commands
z cmd.run_all� )Z__salt__r r r r )�name�cmdr r r �
__execute_cmd s r
c C �H ddd�} t dd�}|d dkr|d | d < | S |d
| d < d | d < | S )
z]
Start Riak
CLI Example:
.. code-block:: bash
salt '*' riak.start
� F��comment�successr �start�retcoder �stderrr �stdoutTr �r
��retr r r r r s
�r c C r )
z}
Stop Riak
.. versionchanged:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.stop
r Fr r �stopr r r r r Tr r r r r r r 2 �
�r c C �T ddd�}t dd| � d|� ��}|d dkr |d |d
< |S |d |d
< d |d < |S )
a
Join a Riak cluster
.. versionchanged:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.cluster_join <user> <host>
username - The riak username to join the cluster
hostname - The riak hostname you are connecting to
r Fr �
riak-adminz
cluster join �@r r r r Tr r ��username�hostnamer r r r r � cluster_joinK �
�r" c C r )
a
Leave a Riak cluster
.. versionadded:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.cluster_leave <username> <host>
username - The riak username to join the cluster
hostname - The riak hostname you are connecting to
r Fr r zcluster leave r r r r r Tr r r r r r �
cluster_leaveg r# r$ c C s t dd�} | d dkr
dS dS )z�
Review Cluster Plan
.. versionchanged:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.cluster_plan
r z cluster planr r FTr �r r r r � cluster_plan� s
r& c C �H ddd�} t dd�}|d dkr|d | d < | S |d | d < d
| d < | S ) z�
Commit Cluster Changes
.. versionchanged:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.cluster_commit
r Fr r zcluster commitr r r r Tr r r r r r �cluster_commit� r r( c
C s� i dddddd�d�} t dd�d �� }|D ]?}|�d�r qd|v r;|�d�D ]}|�d �\}}|�� | d
|�� < q't|�� �d krU|�� \}}}} |||d �| d
| < q| S )z�
Get cluster member status
.. versionchanged:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.member_status
r )ZValidZLeavingZExitingZJoiningZDown)�
membership�summaryr z
member-statusr )�=�-�Status�/�:r* � )r- ZRingZPendingr) )r
�
splitlines�
startswith�split�strip�len)
r �out�line�item�key�val�statusZring�pending�noder r r �
member_status� s&
�
��r> c C sL i } t dd�}|d �� D ]}d|v r#|�dd�\}}|�� | |�� < q
| S )z�
Current node status
.. versionadded:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.status
r r; r r/ � )r
r1 r3 r4 )r r �ir r: r r r r; � s
�r; c C r' ) z�
Runs a test of a few standard Riak operations
.. versionadded:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.test
r Fr r �testr r r r Tr r r r r r rA � r rA c C s t dd�} | d dd� �d�S )z�
List available services on a node
.. versionadded:: 2015.8.0
CLI Example:
.. code-block:: bash
salt '*' riak.services
r �servicesr r? ����,)r
r3 r% r r r rB
s
rB )�__doc__Zsalt.utils.pathr r r
r r r" r$ r& r( r> r; rA rB r r r r �<module> s )