403Webshell
Server IP : 162.144.4.212  /  Your IP : 216.73.216.108
Web Server : Apache
System : Linux gator2125.hostgator.com 5.14.0-162.23.1.9991722448259.nf.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 31 18:11:45 UTC 2024 x86_64
User : cozeellc ( 2980)
PHP Version : 8.3.31
Disable Function : NONE
MySQL : OFF |  cURL : ON |  WGET : ON |  Perl : ON |  Python : OFF |  Sudo : ON |  Pkexec : ON
Directory :  /usr/libexec/oracle-cloud-agent/plugins/osms/oci/queue/

Upload File :
current_dir [ Writeable] document_root [ Writeable]

 

Command :

[ Back ]     

Current File : /usr/libexec/oracle-cloud-agent/plugins/osms/oci/queue/queue_admin_client_composite_operations.pyc
a

O��fo-�@s(ddlZddlmZGdd�de�ZdS)�N)�WAIT_RESOURCE_NOT_FOUNDc@sheZdZdZdd�Zgiifdd�Zgiifdd�Zgiifdd	�Zgiifd
d�Zgiifdd
�Z	dS)�#QueueAdminClientCompositeOperationsa�
    This class provides a wrapper around :py:class:`~oci.queue.QueueAdminClient` and offers convenience methods
    for operations that would otherwise need to be chained together. For example, instead of performing an action
    on a resource (e.g. launching an instance, creating a load balancer) and then using a waiter to wait for the resource
    to enter a given state, you can call a single method in this class to accomplish the same functionality
    cKs
||_dS)z�
        Creates a new QueueAdminClientCompositeOperations object

        :param QueueAdminClient client:
            The service client which will be wrapped by this object
        N)�client)�selfr�kwargs�r��/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/oci/queue/queue_admin_client_composite_operations.py�__init__sz,QueueAdminClientCompositeOperations.__init__c
s�|jj||fi|��}|s|Sdd�|D��|jd}z4tj|j|j�|�fd�fdd�i|��}|}	|	WSty�}
ztjj|g|
d��WYd}
~
n
d}
~
00dS)	aE
        Calls :py:func:`~oci.queue.QueueAdminClient.change_queue_compartment` and waits for the :py:class:`~oci.queue.models.WorkRequest`
        to enter the given state(s).

        :param str queue_id: (required)
            unique Queue identifier

        :param oci.queue.models.ChangeQueueCompartmentDetails change_queue_compartment_details: (required)
            The information to be updated.

        :param list[str] wait_for_states:
            An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status`

        :param dict operation_kwargs:
            A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.change_queue_compartment`

        :param dict waiter_kwargs:
            A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds``
            as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait
        cSsg|]}|���qSr��lower��.0�wrrr�
<listcomp>3�zcQueueAdminClientCompositeOperations.change_queue_compartment_and_wait_for_state.<locals>.<listcomp>�opc-work-request-id�evaluate_responsecs t|jd�ot|jd����vS�N�status��getattr�datar��r��lowered_wait_for_statesrr�<lambda>:rzaQueueAdminClientCompositeOperations.change_queue_compartment_and_wait_for_state.<locals>.<lambda>��partial_results�causeN)	r�change_queue_compartment�headers�oci�
wait_until�get_work_request�	Exception�
exceptions�CompositeOperationError)r�queue_id� change_queue_compartment_details�wait_for_states�operation_kwargs�
waiter_kwargs�operation_result�wait_for_resource_id�
waiter_result�result_to_return�errr�+change_queue_compartment_and_wait_for_states$

�
��zOQueueAdminClientCompositeOperations.change_queue_compartment_and_wait_for_statec

s�|jj|fi|��}|s|Sdd�|D��|jd}z4tj|j|j�|�fd�fdd�i|��}|}|WSty�}	ztjj|g|	d��WYd}	~	n
d}	~	00dS)	a�
        Calls :py:func:`~oci.queue.QueueAdminClient.create_queue` and waits for the :py:class:`~oci.queue.models.WorkRequest`
        to enter the given state(s).

        :param oci.queue.models.CreateQueueDetails create_queue_details: (required)
            Details for the new Queue.

        :param list[str] wait_for_states:
            An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status`

        :param dict operation_kwargs:
            A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.create_queue`

        :param dict waiter_kwargs:
            A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds``
            as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait
        cSsg|]}|���qSrr
rrrrrYrzWQueueAdminClientCompositeOperations.create_queue_and_wait_for_state.<locals>.<listcomp>rrcs t|jd�ot|jd����vSrrrrrrr`rzUQueueAdminClientCompositeOperations.create_queue_and_wait_for_state.<locals>.<lambda>rN)	r�create_queuer!r"r#r$r%r&r')
r�create_queue_detailsr*r+r,r-r.r/r0r1rrr�create_queue_and_wait_for_stateCs$

�
��zCQueueAdminClientCompositeOperations.create_queue_and_wait_for_statec

s�d}z|jj|fi|��}WnFtjjyb}z*|jdkrJtWYd}~S|�WYd}~n
d}~00|sl|Sdd�|D��|jd}z4tj|j|j�	|�fd�fdd�i|��}|}	|	WSt
y�}ztjj|g|d	��WYd}~n
d}~00dS)
a�
        Calls :py:func:`~oci.queue.QueueAdminClient.delete_queue` and waits for the :py:class:`~oci.queue.models.WorkRequest`
        to enter the given state(s).

        :param str queue_id: (required)
            unique Queue identifier

        :param list[str] wait_for_states:
            An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status`

        :param dict operation_kwargs:
            A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.delete_queue`

        :param dict waiter_kwargs:
            A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds``
            as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait
        Ni�cSsg|]}|���qSrr
rrrrr�rzWQueueAdminClientCompositeOperations.delete_queue_and_wait_for_state.<locals>.<listcomp>rrcs t|jd�ot|jd����vSrrrrrrr�rzUQueueAdminClientCompositeOperations.delete_queue_and_wait_for_state.<locals>.<lambda>r)r�delete_queuer"r&�ServiceErrorrrr!r#r$r%r')
rr(r*r+r,r-r1r.r/r0rrr�delete_queue_and_wait_for_stateis0


�
��zCQueueAdminClientCompositeOperations.delete_queue_and_wait_for_statec
s�|jj||fi|��}|s|Sdd�|D��|jd}z4tj|j|j�|�fd�fdd�i|��}|}	|	WSty�}
ztjj|g|
d��WYd}
~
n
d}
~
00dS)	a
        Calls :py:func:`~oci.queue.QueueAdminClient.purge_queue` and waits for the :py:class:`~oci.queue.models.WorkRequest`
        to enter the given state(s).

        :param str queue_id: (required)
            unique Queue identifier

        :param oci.queue.models.PurgeQueueDetails purge_queue_details: (required)
            The information to be updated.

        :param list[str] wait_for_states:
            An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status`

        :param dict operation_kwargs:
            A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.purge_queue`

        :param dict waiter_kwargs:
            A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds``
            as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait
        cSsg|]}|���qSrr
rrrrr�rzVQueueAdminClientCompositeOperations.purge_queue_and_wait_for_state.<locals>.<listcomp>rrcs t|jd�ot|jd����vSrrrrrrr�rzTQueueAdminClientCompositeOperations.purge_queue_and_wait_for_state.<locals>.<lambda>rN)	r�purge_queuer!r"r#r$r%r&r')rr(�purge_queue_detailsr*r+r,r-r.r/r0r1rrr�purge_queue_and_wait_for_state�s$

�
��zBQueueAdminClientCompositeOperations.purge_queue_and_wait_for_statec
s�|jj||fi|��}|s|Sdd�|D��|jd}z4tj|j|j�|�fd�fdd�i|��}|}	|	WSty�}
ztjj|g|
d��WYd}
~
n
d}
~
00dS)	a
        Calls :py:func:`~oci.queue.QueueAdminClient.update_queue` and waits for the :py:class:`~oci.queue.models.WorkRequest`
        to enter the given state(s).

        :param str queue_id: (required)
            unique Queue identifier

        :param oci.queue.models.UpdateQueueDetails update_queue_details: (required)
            The information to be updated.

        :param list[str] wait_for_states:
            An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status`

        :param dict operation_kwargs:
            A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.update_queue`

        :param dict waiter_kwargs:
            A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds``
            as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait
        cSsg|]}|���qSrr
rrrrr�rzWQueueAdminClientCompositeOperations.update_queue_and_wait_for_state.<locals>.<listcomp>rrcs t|jd�ot|jd����vSrrrrrrr�rzUQueueAdminClientCompositeOperations.update_queue_and_wait_for_state.<locals>.<lambda>rN)	r�update_queuer!r"r#r$r%r&r')rr(�update_queue_detailsr*r+r,r-r.r/r0r1rrr�update_queue_and_wait_for_state�s$

�
��zCQueueAdminClientCompositeOperations.update_queue_and_wait_for_stateN)
�__name__�
__module__�__qualname__�__doc__r	r2r5r8r;r>rrrrr	s	)&.)r)r"�oci.utilr�objectrrrrr�<module>s

Youez - 2016 - github.com/yon3zu
LinuXploit