Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/openstack/message/v2/__pycache__/_proxy.cpython-39.pyc
Ðазад
a u�h=2 � @ s^ d dl mZ d dl mZ d dl mZ d dl mZ d dl m Z d dl m Z G dd� de j �Z d S ) � )�claim)�message)�queue)� subscription)�proxy)�resourcec @ s� e Zd Zdd� Zdd� Zdd� Zd#dd �Zd d � Zd d � Zdd� Z d$dd�Z dd� Z dd� Z dd� Z d%dd�Zdd � Zd d � Zd d � Zd&d!d"�ZdS )'�Proxyc K s | j tjfi |��S )av Create a new queue from attributes :param dict attrs: Keyword arguments which will be used to create a :class:`~openstack.message.v2.queue.Queue`, comprised of the properties on the Queue class. :returns: The results of queue creation :rtype: :class:`~openstack.message.v2.queue.Queue` )�_create�_queue�Queue)�self�attrs� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/openstack/message/v2/_proxy.py� create_queue s zProxy.create_queuec C s | � tj|�S )aU Get a queue :param queue: The value can be the name of a queue or a :class:`~openstack.message.v2.queue.Queue` instance. :returns: One :class:`~openstack.message.v2.queue.Queue` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no queue matching the name could be found. )�_getr r )r r r r r � get_queue# s zProxy.get_queuec K s | j tjfi |��S )a� Retrieve a generator of queues :param kwargs query: Optional query parameters to be sent to restrict the queues to be returned. Available parameters include: * limit: Requests at most the specified number of items be returned from the query. * marker: Specifies the ID of the last-seen queue. Use the limit parameter to make an initial limited request and use the ID of the last-seen queue from the response as the marker parameter value in a subsequent limited request. :returns: A generator of queue instances. )�_listr r )r �queryr r r �queues/ s z Proxy.queuesTc C s | j tj||d�S )a Delete a queue :param value: The value can be either the name of a queue or a :class:`~openstack.message.v2.queue.Queue` instance. :param bool ignore_missing: When set to ``False`` :class:`~openstack.exceptions.ResourceNotFound` will be raised when the queue does not exist. When set to ``True``, no exception will be set when attempting to delete a nonexistent queue. :returns: ``None`` ��ignore_missing)�_deleter r )r �valuer r r r � delete_queue@ s zProxy.delete_queuec C s | j tjd|d�}|�| |�S )a& Post messages to given queue :param queue_name: The name of target queue to post message to. :param messages: List of messages body and TTL to post. :type messages: :py:class:`list` :returns: A string includes location of messages successfully posted. N�� queue_name)� _get_resource�_message�Message�post)r r �messagesr r r r � post_messageO s �zProxy.post_messagec K s ||d< | j tjfi |��S )a� Retrieve a generator of messages :param queue_name: The name of target queue to query messages from. :param kwargs query: Optional query parameters to be sent to restrict the messages to be returned. Available parameters include: * limit: Requests at most the specified number of items be returned from the query. * marker: Specifies the ID of the last-seen subscription. Use the limit parameter to make an initial limited request and use the ID of the last-seen subscription from the response as the marker parameter value in a subsequent limited request. * echo: Indicate if the messages can be echoed back to the client that posted them. * include_claimed: Indicate if the messages list should include the claimed messages. :returns: A generator of message instances. r )r r r �r r r r r r r! \ s zProxy.messagesc C s | j tj||d�}| �tj|�S )a� Get a message :param queue_name: The name of target queue to get message from. :param message: The value can be the name of a message or a :class:`~openstack.message.v2.message.Message` instance. :returns: One :class:`~openstack.message.v2.message.Message` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no message matching the criteria could be found. r )r r r r )r r r r r r � get_messages s �zProxy.get_messageNc C s2 | j tj||d�}tj�|�|_| jtj||d�S )aZ Delete a message :param queue_name: The name of target queue to delete message from. :param value: The value can be either the name of a message or a :class:`~openstack.message.v2.message.Message` instance. :param claim: The value can be the ID or a :class:`~openstack.message.v2.claim.Claim` instance of the claim seizing the message. If None, the message has not been claimed. :param bool ignore_missing: When set to ``False`` :class:`~openstack.exceptions.ResourceNotFound` will be raised when the message does not exist. When set to ``True``, no exception will be set when attempting to delete a nonexistent message. :returns: ``None`` r r )r r r r �ResourceZ_get_idZclaim_idr )r r r r r r r r r �delete_message� s � �zProxy.delete_messagec K s | j tjfd|i|��S )a� Create a new subscription from attributes :param queue_name: The name of target queue to subscribe on. :param dict attrs: Keyword arguments which will be used to create a :class:`~openstack.message.v2.subscription.Subscription`, comprised of the properties on the Subscription class. :returns: The results of subscription creation :rtype: :class:`~openstack.message.v2.subscription.Subscription` r )r � _subscription� Subscription�r r r r r r �create_subscription� s �zProxy.create_subscriptionc K s ||d< | j tjfi |��S )a� Retrieve a generator of subscriptions :param queue_name: The name of target queue to subscribe on. :param kwargs query: Optional query parameters to be sent to restrict the subscriptions to be returned. Available parameters include: * limit: Requests at most the specified number of items be returned from the query. * marker: Specifies the ID of the last-seen subscription. Use the limit parameter to make an initial limited request and use the ID of the last-seen subscription from the response as the marker parameter value in a subsequent limited request. :returns: A generator of subscription instances. r )r r' r( r# r r r � subscriptions� s zProxy.subscriptionsc C s | j tj||d�}| �tj|�S )a� Get a subscription :param queue_name: The name of target queue of subscription. :param message: The value can be the ID of a subscription or a :class:`~openstack.message.v2.subscription.Subscription` instance. :returns: One :class:`~openstack.message.v2.subscription.Subscription` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no subscription matching the criteria could be found. r )r r' r( r )r r r r r r �get_subscription� s �zProxy.get_subscriptionc C s$ | j tj||d�}| jtj||d�S )a� Delete a subscription :param queue_name: The name of target queue to delete subscription from. :param value: The value can be either the name of a subscription or a :class:`~openstack.message.v2.subscription.Subscription` instance. :param bool ignore_missing: When set to ``False`` :class:`~openstack.exceptions.ResourceNotFound` will be raised when the subscription does not exist. When set to ``True``, no exception will be thrown when attempting to delete a nonexistent subscription. :returns: ``None`` r r )r r' r( r )r r r r r r r r �delete_subscription� s � �zProxy.delete_subscriptionc K s | j tjfd|i|��S )a� Create a new claim from attributes :param queue_name: The name of target queue to claim message from. :param dict attrs: Keyword arguments which will be used to create a :class:`~openstack.message.v2.claim.Claim`, comprised of the properties on the Claim class. :returns: The results of claim creation :rtype: :class:`~openstack.message.v2.claim.Claim` r )r �_claim�Claimr) r r r � create_claim� s zProxy.create_claimc C s | j tj||d�S )a� Get a claim :param queue_name: The name of target queue to claim message from. :param claim: The value can be either the ID of a claim or a :class:`~openstack.message.v2.claim.Claim` instance. :returns: One :class:`~openstack.message.v2.claim.Claim` :raises: :class:`~openstack.exceptions.ResourceNotFound` when no claim matching the criteria could be found. r )r r. r/ )r r r r r r � get_claim� s zProxy.get_claimc K s | j tj|fd|i|��S )a- Update an existing claim from attributes :param queue_name: The name of target queue to claim message from. :param claim: The value can be either the ID of a claim or a :class:`~openstack.message.v2.claim.Claim` instance. :param dict attrs: Keyword arguments which will be used to update a :class:`~openstack.message.v2.claim.Claim`, comprised of the properties on the Claim class. :returns: The results of claim update :rtype: :class:`~openstack.message.v2.claim.Claim` r )�_updater. r/ )r r r r r r r � update_claim� s �zProxy.update_claimc C s | j tj|||d�S )aY Delete a claim :param queue_name: The name of target queue to claim messages from. :param claim: The value can be either the ID of a claim or a :class:`~openstack.message.v2.claim.Claim` instance. :param bool ignore_missing: When set to ``False`` :class:`~openstack.exceptions.ResourceNotFound` will be raised when the claim does not exist. When set to ``True``, no exception will be thrown when attempting to delete a nonexistent claim. :returns: ``None`` )r r )r r. r/ )r r r r r r r � delete_claim s �zProxy.delete_claim)T)NT)T)T)�__name__� __module__� __qualname__r r r r r" r! r$ r& r* r+ r, r- r0 r1 r3 r4 r r r r r s$ � r N) Zopenstack.message.v2r r. r r r r r r' Z openstackr r r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка