File manager - Edit - /usr/local/CyberPanel/lib/python3.10/site-packages/docker/api/__pycache__/service.cpython-310.pyc
Back
o �hK � @ sB d dl mZmZmZ d dlmZ dd� Zdd� ZG dd� d�Zd S ) � )�auth�errors�utils)� ServiceModec C sD dd� }|d urAt �| d�r d|v r|dd� d|v r |dd� t �| d�r2|�d �d kr2|d d� t �| d �rAd |v rA|dd � |d ur_t �| d�rP|dd� t �| d �r_d |v r_|dd � |d ur}t �| d�r}d|v r}tdd� |d D ��r}|dd� |d u�r�d|v r�t �| d�r�|dd� |�d�r�t �| d�r�|d �d�r�|dd� t �| d �r�|d �d �r�|d d � |�d ��r~|�d �}t �| d��r|�d �r�|d!d� |�d"�d ur�|d#d� |�d$�d ur�|d%d� |�d&�d ur�|d'd� |�d(�d u�r|d)d� |�d*�d u�r|d+d� t �| d��r5|�d,�d u�r(|d)d� |�d-�d u�r5|d.d� t �| d��rV|�d/�d u�rI|d0d� |�d1�d u�rV|d2d� t �| d3��rj|�d4�d u�rj|d5d3� t �| d6��r~|�d7�d u�r~|d8d6� |�d9��r�t �| d��r�|d9 �d:��r�|d;d� d S d S d S d S d S )<Nc S s t �| � d|� ���)Nz# is not supported in API version < )r �InvalidVersion)�param� min_version� r �H/usr/local/CyberPanel/lib/python3.10/site-packages/docker/api/service.py�raise_version_error s �z0_check_api_features.<locals>.raise_version_error�1.25�MaxFailureRatioz UpdateConfig.max_failure_ratio�MonitorzUpdateConfig.monitorz1.28� FailureAction�rollbackz$UpdateConfig.failure_action rollback�1.29�OrderzUpdateConfig.order�rollback_configzRollbackConfig.orderz1.32�Portsc s s � | ]}|� d �V qdS )� PublishModeN)�get)�.0�pr r r � <genexpr>( s � z&_check_api_features.<locals>.<genexpr>zEndpointSpec.Ports[].mode� ForceUpdate� force_update� Placementz1.30� PlatformszPlacement.platformsz1.27� PreferenceszPlacement.preferences� ContainerSpec�TTYzContainerSpec.tty�HostnamezContainerSpec.hostname�HostszContainerSpec.hosts�GroupszContainerSpec.groups� DNSConfigzContainerSpec.dns_config� HealthcheckzContainerSpec.healthcheck�ReadOnly� StopSignalzContainerSpec.stop_signal�ConfigszContainerSpec.configs� PrivilegeszContainerSpec.privilegesz1.35� IsolationzContainerSpec.isolationz1.38�InitzContainerSpec.init� Resources�GenericResourceszResources.generic_resources)r � version_ltr �any)�version� task_template� update_config� endpoint_specr r �container_specr r r �_check_api_features s� � � �2r5 c C sz | � � }|d ur;|�� D ].\}}|dkr2d|vr i |d< |d �� D ]\}}|d ur0||d |< q"q |d ur:|||< q |S )Nr )�copy�items)�current�override�merged�ts_key�ts_value�cs_key�cs_valuer r r �_merge_task_templatec s ���r? c @ s� e Zd Ze�d� ddd��Ze�d�e�d�ddd���Ze�d�e�d�d d � ��Ze�d�e�d�d d � ��Z e�d�dd d��Z e�d�e�d� d dd���Z e�d�ddd��Z e�d�e�d� d dd���Z dS ) �ServiceApiMixinz1.24Nc C s� t | j|||| � | �d�} i } |�di ��dd�} | du r#t�d��|r.t|t�s.t|�}t � | �\} }t � | | �}|rA|| d< t � | jd�rP|pO|�dd�}||||t �|�|d �}|durd||d < | durl| |d < | �| j| || d �d �S )a Create a service. Args: task_template (TaskTemplate): Specification of the task to start as part of the new service. name (string): User-defined name for the service. Optional. labels (dict): A map of labels to associate with the service. Optional. mode (ServiceMode): Scheduling mode for the service (replicated or global). Defaults to replicated. update_config (UpdateConfig): Specification for the update strategy of the service. Default: ``None`` rollback_config (RollbackConfig): Specification for the rollback strategy of the service. Default: ``None`` networks (:py:class:`list`): List of network names or IDs or :py:class:`~docker.types.NetworkAttachmentConfig` to attach the service to. Default: ``None``. endpoint_spec (EndpointSpec): Properties that can be configured to access and load balance a service. Default: ``None``. Returns: A dictionary containing an ``ID`` key for the newly created service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. z/services/creater �ImageNz,Missing mandatory Image key in ContainerSpec�X-Registry-Authr �Networks)�Name�Labels� TaskTemplate�ModerC � EndpointSpec� UpdateConfig�RollbackConfig)�data�headersT)r5 �_version�_urlr r �DockerException� isinstance�dictr r �resolve_repository_name�get_config_headerr r. �pop�convert_service_networks�_result� _post_json)�selfr1 �name�labels�moder2 �networks�endpoint_configr3 r �urlrL �image�registry� repo_name� auth_headerrK r r r �create_services sB $ � � � �z ServiceApiMixin.create_service�servicec C sN | � d|�}i }|dur t�| jd�rt�d��||d< | �| j||d�d�S )a� Return information about a service. Args: service (str): Service name or ID. insert_defaults (boolean): If true, default values will be merged into the service inspect output. Returns: (dict): A dictionary of the server-side representation of the service, including all relevant properties. Raises: :py:class:`docker.errors.APIError` If the server returns an error. � /services/{0}Nr z6insert_defaults is not supported in API version < 1.29�insertDefaults��paramsT)rN r r. rM r r rV �_get)rX rd �insert_defaultsr^ rh r r r �inspect_service� s �z ServiceApiMixin.inspect_service�taskc C s | � d|�}| �| �|�d�S )a Retrieve information about a task. Args: task (str): Task ID Returns: (dict): Information about the task. Raises: :py:class:`docker.errors.APIError` If the server returns an error. z /tasks/{0}T)rN rV ri )rX rl r^ r r r � inspect_task� s z ServiceApiMixin.inspect_taskc C s$ | � d|�}| �|�}| �|� dS )a Stop and remove a service. Args: service (str): Service name or ID Returns: ``True`` if successful. Raises: :py:class:`docker.errors.APIError` If the server returns an error. re T)rN �_delete�_raise_for_status)rX rd r^ �respr r r �remove_service� s z ServiceApiMixin.remove_servicec C s^ d|rt �|�ndi}|dur t �| jd�rt�d��||d< | �d�}| �| j||d�d�S ) a" List services. Args: filters (dict): Filters to process on the nodes list. Valid filters: ``id``, ``name`` , ``label`` and ``mode``. Default: ``None``. status (bool): Include the service task count of running and desired tasks. Default: ``None``. Returns: A list of dictionaries containing data about each service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. �filtersNz1.41z-status is not supported in API version < 1.41�statusz /servicesrg T) r �convert_filtersr. rM r r rN rV ri )rX rr rs rh r^ r r r �services s �� zServiceApiMixin.servicesr F� �allc C sd |||||||d�} | � d|�} | j| | dd�} | du r+| �|�d d d �d d �} | �d| | �S ) ar Get log stream for a service. Note: This endpoint works only for services with the ``json-file`` or ``journald`` logging drivers. Args: service (str): ID or name of the service details (bool): Show extra details provided to logs. Default: ``False`` follow (bool): Keep connection open to read logs as they are sent by the Engine. Default: ``False`` stdout (bool): Return logs from ``stdout``. Default: ``False`` stderr (bool): Return logs from ``stderr``. Default: ``False`` since (int): UNIX timestamp for the logs staring point. Default: 0 timestamps (bool): Add timestamps to every log line. tail (string or int): Number of log lines to be returned, counting from the current end of the logs. Specify an integer or ``'all'`` to output all log lines. Default: ``all`` is_tty (bool): Whether the service's :py:class:`ContainerSpec` enables the TTY option. If omitted, the method will query the Engine for the information, causing an additional roundtrip. Returns (generator): Logs for the service. )�details�follow�stdout�stderr�since� timestamps�tailz/services/{0}/logsT)rh �streamN�SpecrF r r F)rN ri rk r �_get_result_tty) rX rd rx ry rz r{ r| r} r~ �is_ttyrh r^ �resr r r � service_logs% s. !� �����z ServiceApiMixin.service_logsc C s6 d|rt �|�ndi}| �d�}| �| j||d�d�S )a� Retrieve a list of tasks. Args: filters (dict): A map of filters to process on the tasks list. Valid filters: ``id``, ``name``, ``service``, ``node``, ``label`` and ``desired-state``. Returns: (:py:class:`list`): List of task dictionaries. Raises: :py:class:`docker.errors.APIError` If the server returns an error. rr Nz/tasksrg T)r rt rN rV ri )rX rr rh r^ r r r �tasksW s � zServiceApiMixin.tasksc C sL t | j||| | � | r d} t�| jd�rd} | j|| d�d }ni }| �d|�}i }i }|du r5|�d�n||d< |du rB|�d�n||d< |durXt|t�sSt |�}||d < n|�d �|d < t |�d i �|�|d < |d �d i �}|�d d�}|dur�t � |�\}}t � | |�}|r�||d < |dur�||d< n|�d�|d< | dur�| |d< n|�d�|d< |dur�t�|�}t�| jd�r�||d< n?||d d< n8t�| jd�r�|�d�|d< n)|d �d�du �r|�d i �}|�d�}|du r�|�d�}|du�r||d d< | du�r | |d< n|�d�|d< | j||d|i|d�}| j|dd�S )a� Update a service. Args: service (string): A service identifier (either its name or service ID). version (int): The version number of the service object being updated. This is required to avoid conflicting writes. task_template (TaskTemplate): Specification of the updated task to start as part of the service. name (string): New name for the service. Optional. labels (dict): A map of labels to associate with the service. Optional. mode (ServiceMode): Scheduling mode for the service (replicated or global). Defaults to replicated. update_config (UpdateConfig): Specification for the update strategy of the service. Default: ``None``. rollback_config (RollbackConfig): Specification for the rollback strategy of the service. Default: ``None`` networks (:py:class:`list`): List of network names or IDs or :py:class:`~docker.types.NetworkAttachmentConfig` to attach the service to. Default: ``None``. endpoint_spec (EndpointSpec): Properties that can be configured to access and load balance a service. Default: ``None``. fetch_current_spec (boolean): Use the undefined settings from the current specification of the service. Default: ``False`` Returns: A dictionary containing a ``Warnings`` key. Raises: :py:class:`docker.errors.APIError` If the server returns an error. Tr N)rj r� z/services/{0}/updaterD rE rG rF r rA rB rI rJ r rC rH r0 )rK rh rL )�json)r5 rM r r. rk rN r rP rQ r r? r rR rS rU rW rV )rX rd r0 r1 rY rZ r[ r2 r\ r] r3 �fetch_current_specr �inspect_defaultsr8 r^ rK rL r4 r_ r` ra rb �converted_networks�current_task_template�current_networksrp r r r �update_serviceo sz * ��� � �z ServiceApiMixin.update_service)NNNNNNNN)N)NN)FFFFrv Frw N) NNNNNNNNFN)�__name__� __module__� __qualname__r �minimum_versionrc �check_resourcerk rm rq ru r� r� r� r r r r r@ r sB �K �0 �r@ N) � r r r �typesr r5 r? r@ r r r r �<module> s ^
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings