| 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/grpc/aio/ |
Upload File : |
a
K��f� � @ s& d Z ddlmZ ddlmZ ddlmZmZmZmZm Z m
Z
ddl Z ddl m
Z
ddlmZ dd lmZ dd
lmZ dd lmZ d ZG d
d� ded�ZG dd� deed�ZG dd� deeef eed�ZG dd� deeef eed�ZG dd� deeef eed�ZG dd� deeef eed�ZdS )z�Abstract base classes for client-side Call objects.
Call objects represents the RPC itself, and offer methods to access / modify
its information. They also offer methods to manipulate the life-cycle of the
RPC, e.g. cancellation.
� )�ABCMeta)�abstractmethod)�Any�
AsyncIterator� Generator�Generic�Optional�UnionN� )�Metadata)�DoneCallbackType)�EOFType)� RequestType)� ResponseType)�
RpcContext�Call�UnaryUnaryCall�UnaryStreamCallc @ sp e Zd ZdZeed�dd��Zeed�dd��Zeee d�dd��Z
eed�d d
��Z ee d d �d
d��Z
d S )r z,Provides RPC-related information and action.��returnc C s dS )z�Return True if the RPC is cancelled.
The RPC is cancelled when the cancellation was requested with cancel().
Returns:
A bool indicates whether the RPC is cancelled or not.
N� ��selfr r �w/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/aio/_base_call.py� cancelled' s zRpcContext.cancelledc C s dS )z�Return True if the RPC is done.
An RPC is done if the RPC is completed, cancelled or aborted.
Returns:
A bool indicates if the RPC is done.
Nr r r r r �done1 s zRpcContext.donec C s dS )a8 Describes the length of allowed time remaining for the RPC.
Returns:
A nonnegative float indicating the length of allowed time in seconds
remaining for the RPC to complete before it is considered to have
timed out, or None if no deadline was specified for the RPC.
Nr r r r r �time_remaining; s zRpcContext.time_remainingc C s dS )z�Cancels the RPC.
Idempotent and has no effect if the RPC has already terminated.
Returns:
A bool indicates if the cancellation is performed or not.
Nr r r r r �cancelE s zRpcContext.cancelN)�callbackr c C s dS )z�Registers a callback to be called on RPC termination.
Args:
callback: A callable object will be called with the call object as
its only argument.
Nr )r r r r r �add_done_callbackO s z RpcContext.add_done_callback)�__name__�
__module__� __qualname__�__doc__r �boolr r r �floatr r r r r r r r r $ s r )� metaclassc @ sl e Zd ZdZeed�dd��Zeed�dd��Zeej d�dd��Z
ee d�d d
��Z ed d�d d
��Z
d S )r z5The abstract base class of an RPC on the client-side.r c � s dS )ztAccesses the initial metadata sent by the server.
Returns:
The initial :term:`metadata`.
Nr r r r r �initial_metadata\ s zCall.initial_metadatac � s dS )zvAccesses the trailing metadata sent by the server.
Returns:
The trailing :term:`metadata`.
Nr r r r r �trailing_metadatad s zCall.trailing_metadatac � s dS )zsAccesses the status code sent by the server.
Returns:
The StatusCode value for the RPC.
Nr r r r r �codel s z Call.codec � s dS )zlAccesses the details sent by the server.
Returns:
The details string of the RPC.
Nr r r r r �detailst s z Call.detailsNc � s dS )ah Waits until connected to peer and raises aio.AioRpcError if failed.
This is an EXPERIMENTAL method.
This method ensures the RPC has been successfully connected. Otherwise,
an AioRpcError will be raised to explain the reason of the connection
failure.
This method is recommended for building retry mechanisms.
Nr r r r r �wait_for_connection| s zCall.wait_for_connection)r r! r" r# r r r' r( �grpc�
StatusCoder) �strr* r+ r r r r r Y s r c @ s, e Zd ZdZeeedef d�dd��ZdS )r zAThe abstract base class of an unary-unary RPC on the client-side.Nr c C s dS )zmAwait the response message to be ready.
Returns:
The response message of the RPC.
Nr r r r r � __await__� s zUnaryUnaryCall.__await__) r r! r" r# r r r r r/ r r r r r � s r c @ s< e Zd Zeee d�dd��Zeeeef d�dd��Z dS )r r c C s dS �z�Returns the async iterator representation that yields messages.
Under the hood, it is calling the "read" method.
Returns:
An async iterator object that yields messages.
Nr r r r r � __aiter__� s zUnaryStreamCall.__aiter__c � s dS �aU Reads one message from the stream.
Read operations must be serialized when called from multiple
coroutines.
Note that the iterator and read/write APIs may not be mixed on
a single RPC.
Returns:
A response message, or an `grpc.aio.EOF` to indicate the end of the
stream.
Nr r r r r �read� s zUnaryStreamCall.readN)
r r! r" r r r r1 r r
r3 r r r r r � s r c @ sN e Zd Zeedd�dd��Zedd�dd��Zeeede f d�dd ��Z
dS )
�StreamUnaryCallN��requestr c � s dS �z�Writes one message to the stream.
Note that the iterator and read/write APIs may not be mixed on
a single RPC.
Raises:
An RpcError exception if the write failed.
Nr �r r6 r r r �write� s zStreamUnaryCall.writer c � s dS �z�Notifies server that the client is done sending messages.
After done_writing is called, any additional invocation to the write
function will fail. This function is idempotent.
Nr r r r r � done_writing� s z StreamUnaryCall.done_writingc C s dS )zpAwait the response message to be ready.
Returns:
The response message of the stream.
Nr r r r r r/ � s zStreamUnaryCall.__await__) r r! r" r r r9 r; r r r r/ r r r r r4 � s
r4 c @ sb e Zd Zeee d�dd��Zeeeef d�dd��Z ee
dd�dd ��Z edd�d
d ��Z dS ) �StreamStreamCallr c C s dS r0 r r r r r r1 � s zStreamStreamCall.__aiter__c � s dS r2 r r r r r r3 � s zStreamStreamCall.readNr5 c � s dS r7 r r8 r r r r9 � s zStreamStreamCall.writec � s dS r: r r r r r r; � s z StreamStreamCall.done_writing)
r r! r" r r r r1 r r
r3 r r9 r; r r r r r< � s
r< )r# �abcr r �typingr r r r r r r, � _metadatar �_typingr r
r r �__all__r r r r r4 r< r r r r �<module> s0 51
�
�
�
�