File: //proc/1233/root/usr/lib/python3/dist-packages/docker/models/__pycache__/swarm.cpython-310.pyc
o
�2.a2 � @ s8 d dl mZ d dlmZ ddlmZ G dd� de�ZdS )� )� APIClient)�APIError� )�Modelc s� e Zd ZdZdZ� fdd�Zedd� �Zdd� Ze jje_
dd d
�Z
dd� Z e j je _dd� Z
e jje
_dd� Zdd� Ze jje_ ddd�Z� ZS )�Swarmzu
The server's Swarm state. This a singleton that must be reloaded to get
the current state of the Swarm.
�IDc
s` t � j|i |�� | jr.z| �� W d S ty- } z|jjdvr"� W Y d }~d S d }~ww d S )N)i� i� )�super�__init__�client�reloadr �response� status_code)�self�args�kwargs�e�� __class__� �5/usr/lib/python3/dist-packages/docker/models/swarm.pyr
s ����zSwarm.__init__c C s | j �d��d�S )z�
The version number of the swarm. If this is not the same as the
server, the :py:meth:`update` function will not work and you will
need to call :py:meth:`reload` before calling it again.
�Version�Index)�attrs�get�r r r r �version s z
Swarm.versionc C s | j j�� S �N)r
�api�get_unlock_keyr r r r r s zSwarm.get_unlock_keyN� 0.0.0.0:2377Fc
K sJ ||||||d�}| j jjdi |��|d< | j jjdi |��} | �� | S )a:
Initialize a new swarm on this Engine.
Args:
advertise_addr (str): Externally reachable address advertised to
other nodes. This can either be an address/port combination in
the form ``192.168.1.1:4567``, or an interface followed by a
port number, like ``eth0:4567``. If the port number is omitted,
the port number from the listen address is used.
If not specified, it will be automatically detected when
possible.
listen_addr (str): Listen address used for inter-manager
communication, as well as determining the networking interface
used for the VXLAN Tunnel Endpoint (VTEP). This can either be
an address/port combination in the form ``192.168.1.1:4567``,
or an interface followed by a port number, like ``eth0:4567``.
If the port number is omitted, the default swarm listening port
is used. Default: ``0.0.0.0:2377``
force_new_cluster (bool): Force creating a new Swarm, even if
already part of one. Default: False
default_addr_pool (list of str): Default Address Pool specifies
default subnet pools for global scope networks. Each pool
should be specified as a CIDR block, like '10.0.0.0/8'.
Default: None
subnet_size (int): SubnetSize specifies the subnet size of the
networks created from the default subnet pool. Default: None
data_path_addr (string): Address or interface to use for data path
traffic. For example, 192.168.1.1, or an interface, like eth0.
task_history_retention_limit (int): Maximum number of tasks
history stored.
snapshot_interval (int): Number of logs entries between snapshot.
keep_old_snapshots (int): Number of snapshots to keep beyond the
current snapshot.
log_entries_for_slow_followers (int): Number of log entries to
keep around to sync up slow followers after a snapshot is
created.
heartbeat_tick (int): Amount of ticks (in seconds) between each
heartbeat.
election_tick (int): Amount of ticks (in seconds) needed without a
leader to trigger a new election.
dispatcher_heartbeat_period (int): The delay for an agent to send
a heartbeat to the dispatcher.
node_cert_expiry (int): Automatic expiry for nodes certificates.
external_ca (dict): Configuration for forwarding signing requests
to an external certificate authority. Use
``docker.types.SwarmExternalCA``.
name (string): Swarm's name
labels (dict): User-defined key/value metadata.
signing_ca_cert (str): The desired signing CA certificate for all
swarm node TLS leaf certificates, in PEM format.
signing_ca_key (str): The desired signing CA key for all swarm
node TLS leaf certificates, in PEM format.
ca_force_rotate (int): An integer whose purpose is to force swarm
to generate a new signing CA certificate and key, if none have
been specified.
autolock_managers (boolean): If set, generate a key and use it to
lock data stored on the managers.
log_driver (DriverConfig): The default log driver to use for tasks
created in the orchestrator.
Returns:
(str): The ID of the created node.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
Example:
>>> client.swarm.init(
advertise_addr='eth0', listen_addr='0.0.0.0:5000',
force_new_cluster=False, default_addr_pool=['10.20.0.0/16],
subnet_size=24, snapshot_interval=5000,
log_entries_for_slow_followers=1200
)
)�advertise_addr� listen_addr�force_new_cluster�default_addr_pool� subnet_size�data_path_addr�
swarm_specNr )r
r �create_swarm_spec�
init_swarmr )
r r r! r" r# r$ r% r � init_kwargs�node_idr r r �init$ s R�z
Swarm.initc O � | j jj|i |��S r )r
r �
join_swarm�r r r r r r �join� � z
Swarm.joinc O r, r )r
r � leave_swarmr. r r r �leave� r0 z Swarm.leavec C s | j j�� | _dS )z�
Inspect the swarm on the server and store the response in
:py:attr:`attrs`.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
N)r
r �
inspect_swarmr r r r r r � s z Swarm.reloadc C s | j j�|�S r )r
r � unlock_swarm)r �keyr r r �unlock� s z Swarm.unlockc K s@ |� d�du r d|d< | jjj| j| jjjdi |��|||d�S )a�
Update the swarm's configuration.
It takes the same arguments as :py:meth:`init`, except
``advertise_addr``, ``listen_addr``, and ``force_new_cluster``. In
addition, it takes these arguments:
Args:
rotate_worker_token (bool): Rotate the worker join token. Default:
``False``.
rotate_manager_token (bool): Rotate the manager join token.
Default: ``False``.
rotate_manager_unlock_key (bool): Rotate the manager unlock key.
Default: ``False``.
Raises:
:py:class:`docker.errors.APIError`
If the server returns an error.
�node_cert_expiryNl �+� � )r r& �rotate_worker_token�rotate_manager_token�rotate_manager_unlock_keyr )r r
r � update_swarmr r' )r r8 r9 r: r r r r �update� s �z Swarm.update)Nr FNNN)FFF)�__name__�
__module__� __qualname__�__doc__� id_attributer �propertyr r r r+ r/ r- r2 r1 r r6 r4 r< �
__classcell__r r r r r s,
�^
�r N)�
docker.apir �
docker.errorsr �resourcer r r r r r �<module> s