File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/transport/__pycache__/client.cpython-310.pyc
o
�N�g�
� @ s� d Z ddlZddlmZ e�e�ZG dd� d�ZG dd� d�ZG dd � d �Z G d
d � d �Z
G d d
� d
�Z G dd� d�Z G dd� d�Z
dS )z�
Encapsulate the different transports available to Salt.
This includes client side transport, for the ReqServer and the Publisher
NOTE: This module has been deprecated and will be removed in Argon. Please use
salt.channel.server instead.
� N)�
warn_untilc @ � e Zd ZdZedd� �ZdS )�
ReqChannelzd
Factory class to create a sychronous communication channels to the master's
ReqServer.
c K �* dd l }tdd� |jjjj| fi |��S �Nr �Argon�BThis module is deprecated. Please use salt.channel.client instead.)�salt.channel.clientr �channel�clientr �factory��opts�kwargs�salt� r �I/opt/saltstack/salt/lib/python3.10/site-packages/salt/transport/client.pyr � �zReqChannel.factoryN��__name__�
__module__� __qualname__�__doc__� staticmethodr r r r r r s r c @ r )� PushChannelzM
Factory class to create Sync channel for push side of push/pull IPC
c K r r )r r r
r r r r
r r r r ( r zPushChannel.factoryNr r r r r r # � r c @ r )� PullChannelzM
Factory class to create Sync channel for pull side of push/pull IPC
c K r r )r r r
r r r r
r r r r 8 r zPullChannel.factoryNr r r r r r 3 r r c @ r )�AsyncReqChannelz�
Factory class to create a asynchronous communication channels to the
master's ReqServer. ReqChannels connect to the master's ReqServerChannel on
the minion's master_port (default: 4506) option.
c K �* dd l }tdd� |jjjj|fi |��S r )r r r
r r r ��clsr r r r r r r J r zAsyncReqChannel.factoryN�r r r r � classmethodr r r r r r C s r c @ r )�AsyncPubChannelzQ
Factory class to create subscription channels to the master's Publisher
c K r r )r r r
r r# r r r r r r Z r zAsyncPubChannel.factoryNr! r r r r r# U r r# c @ r )�AsyncPushChannelz3
Factory class to create IPC Push channels
c K �* ddl }tdd� |jjjj| fi |��S )z\
If we have additional IPC transports other than UxD and TCP, add them here
r Nr r )r r r
r r$ r r
r r r r j � �zAsyncPushChannel.factoryNr r r r r r$ e r r$ c @ r )�AsyncPullChannelz3
Factory class to create IPC pull channels
c K r% )z\
If we have additional IPC transports other than UXD and TCP, add them here
r Nr r )r r r
r r' r r
r r r r } r& zAsyncPullChannel.factoryNr r r r r r' x r r' )r �loggingZsalt.utils.versionsr � getLoggerr �logr r r r r# r$ r' r r r r �<module> s