| 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��fF6 � @ s� d Z ddlZddlmZmZ ddlZddlmZ ddlm Z ddlm
Z
ddlm Z dd lm Z dd
lm
Z
dd lmZ G d d
� d
ee e
f ej�ZG dd� dee e
f ej�ZG dd� dej�ZG dd� dej�ZG dd� dej�ZdS )zDAbstract base classes for Channel objects and Multicallable objects.� N)�Generic�Optional� )�
_base_call)�DeserializingFunction)� MetadataType)�RequestIterableType)� RequestType)� ResponseType)�SerializingFunctionc @ s` e Zd ZdZejdddddd�eee ee ee
j ee ee
j
ejeef d�dd��ZdS )�UnaryUnaryMultiCallablez4Enables asynchronous invocation of a unary-call RPC.N��timeout�metadata� credentials�wait_for_ready� compression��requestr r r r r �returnc C s dS )ar Asynchronously invokes the underlying RPC.
Args:
request: The request value for the RPC.
timeout: An optional duration of time in seconds to allow
for the RPC.
metadata: Optional :term:`metadata` to be transmitted to the
service-side of the RPC.
credentials: An optional CallCredentials for the RPC. Only valid for
secure Channel.
wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism.
compression: An element of grpc.compression, e.g.
grpc.compression.Gzip.
Returns:
A UnaryUnaryCall object.
Raises:
RpcError: Indicates that the RPC terminated with non-OK status. The
raised RpcError will also be a Call for the RPC affording the RPC's
metadata, status code, and details.
N� ��selfr r r r r r r r �z/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/grpc/aio/_base_channel.py�__call__! s z UnaryUnaryMultiCallable.__call__)�__name__�
__module__� __qualname__�__doc__�abc�abstractmethodr r �floatr �grpc�CallCredentials�bool� Compressionr �UnaryUnaryCallr
r r r r r r s � �r c @ s` e Zd ZdZejdddddd�eee ee ee
j ee ee
j
ejeef d�dd��ZdS )�UnaryStreamMultiCallablez:Enables asynchronous invocation of a server-streaming RPC.Nr
r c C s dS )as Asynchronously invokes the underlying RPC.
Args:
request: The request value for the RPC.
timeout: An optional duration of time in seconds to allow
for the RPC.
metadata: Optional :term:`metadata` to be transmitted to the
service-side of the RPC.
credentials: An optional CallCredentials for the RPC. Only valid for
secure Channel.
wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism.
compression: An element of grpc.compression, e.g.
grpc.compression.Gzip.
Returns:
A UnaryStreamCall object.
Raises:
RpcError: Indicates that the RPC terminated with non-OK status. The
raised RpcError will also be a Call for the RPC affording the RPC's
metadata, status code, and details.
Nr r r r r r G s z!UnaryStreamMultiCallable.__call__)r r r r r r r r r! r r" r# r$ r% r �UnaryStreamCallr
r r r r r r' D s � �r' c
@ sP e Zd ZdZejdee ee ee ee
j ee ee
j
ejd�dd��ZdS )�StreamUnaryMultiCallablez:Enables asynchronous invocation of a client-streaming RPC.N��request_iteratorr r r r r r c C s dS )a� Asynchronously invokes the underlying RPC.
Args:
request_iterator: An optional async iterable or iterable of request
messages for the RPC.
timeout: An optional duration of time in seconds to allow
for the RPC.
metadata: Optional :term:`metadata` to be transmitted to the
service-side of the RPC.
credentials: An optional CallCredentials for the RPC. Only valid for
secure Channel.
wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism.
compression: An element of grpc.compression, e.g.
grpc.compression.Gzip.
Returns:
A StreamUnaryCall object.
Raises:
RpcError: Indicates that the RPC terminated with non-OK status. The
raised RpcError will also be a Call for the RPC affording the RPC's
metadata, status code, and details.
Nr �r r+ r r r r r r r r r m s
z!StreamUnaryMultiCallable.__call__)NNNNNN)r r r r r r r r r! r r" r# r$ r% r �StreamUnaryCallr r r r r r) j s" ��r) c
@ sP e Zd ZdZejdee ee ee ee
j ee ee
j
ejd�dd��ZdS )�StreamStreamMultiCallablezAEnables asynchronous invocation of a bidirectional-streaming RPC.Nr* c C s dS )a� Asynchronously invokes the underlying RPC.
Args:
request_iterator: An optional async iterable or iterable of request
messages for the RPC.
timeout: An optional duration of time in seconds to allow
for the RPC.
metadata: Optional :term:`metadata` to be transmitted to the
service-side of the RPC.
credentials: An optional CallCredentials for the RPC. Only valid for
secure Channel.
wait_for_ready: An optional flag to enable :term:`wait_for_ready` mechanism.
compression: An element of grpc.compression, e.g.
grpc.compression.Gzip.
Returns:
A StreamStreamCall object.
Raises:
RpcError: Indicates that the RPC terminated with non-OK status. The
raised RpcError will also be a Call for the RPC affording the RPC's
metadata, status code, and details.
Nr r, r r r r � s
z"StreamStreamMultiCallable.__call__)NNNNNN)r r r r r r r r r! r r" r# r$ r% r �StreamStreamCallr r r r r r. � s" ��r. c @ s4 e Zd ZdZejdd� �Zejdd� �Zejd ee d�dd ��Z
ejd e e j
d �d d
��Zeje j
dd�dd��Zejdd�dd��Zejd eee ee ee ed�dd��Zejd eee ee ee ed�dd��Zejd!eee ee ee ed�dd��Zejd"eee ee ee ed�dd ��ZdS )#�Channelz�Enables asynchronous RPC invocation as a client.
Channel objects implement the Asynchronous Context Manager (aka. async
with) type, although they are not supportted to be entered and exited
multiple times.
c � s dS )zwStarts an asynchronous context manager.
Returns:
Channel the channel that was instantiated.
Nr �r r r r �
__aenter__� s zChannel.__aenter__c � s dS )zxFinishes the asynchronous context manager by closing the channel.
Still active RPCs will be cancelled.
Nr )r �exc_type�exc_val�exc_tbr r r � __aexit__� s zChannel.__aexit__N)�gracec � s dS )a Closes this Channel and releases all resources held by it.
This method immediately stops the channel from executing new RPCs in
all cases.
If a grace period is specified, this method waits until all active
RPCs are finished or until the grace period is reached. RPCs that haven't
been terminated within the grace period are aborted.
If a grace period is not specified (by passing None for grace),
all existing RPCs are cancelled immediately.
This method is idempotent.
Nr )r r7 r r r �close� s z
Channel.closeF)�try_to_connectr c C s dS )a� Checks the connectivity state of a channel.
This is an EXPERIMENTAL API.
If the channel reaches a stable connectivity state, it is guaranteed
that the return value of this function will eventually converge to that
state.
Args:
try_to_connect: a bool indicate whether the Channel should try to
connect to peer or not.
Returns: A ChannelConnectivity object.
Nr )r r9 r r r � get_state� s zChannel.get_state)�last_observed_stater c � s dS )a Waits for a change in connectivity state.
This is an EXPERIMENTAL API.
The function blocks until there is a change in the channel connectivity
state from the "last_observed_state". If the state is already
different, this function will return immediately.
There is an inherent race between the invocation of
"Channel.wait_for_state_change" and "Channel.get_state". The state can
change arbitrary many times during the race, so there is no way to
observe every state transition.
If there is a need to put a timeout for this function, please refer to
"asyncio.wait_for".
Args:
last_observed_state: A grpc.ChannelConnectivity object representing
the last known state.
Nr )r r; r r r �wait_for_state_change� s z Channel.wait_for_state_change)r c � s dS )z;Creates a coroutine that blocks until the Channel is READY.Nr r1 r r r �
channel_ready
s zChannel.channel_ready)�method�request_serializer�response_deserializer�_registered_methodr c C s dS )a� Creates a UnaryUnaryMultiCallable for a unary-unary method.
Args:
method: The name of the RPC method.
request_serializer: Optional :term:`serializer` for serializing the request
message. Request goes unserialized in case None is passed.
response_deserializer: Optional :term:`deserializer` for deserializing the
response message. Response goes undeserialized in case None
is passed.
_registered_method: Implementation Private. Optional: A bool representing
whether the method is registered.
Returns:
A UnaryUnaryMultiCallable value for the named unary-unary method.
Nr �r r> r? r@ rA r r r � unary_unary s zChannel.unary_unaryc C s dS )a� Creates a UnaryStreamMultiCallable for a unary-stream method.
Args:
method: The name of the RPC method.
request_serializer: Optional :term:`serializer` for serializing the request
message. Request goes unserialized in case None is passed.
response_deserializer: Optional :term:`deserializer` for deserializing the
response message. Response goes undeserialized in case None
is passed.
_registered_method: Implementation Private. Optional: A bool representing
whether the method is registered.
Returns:
A UnarySteramMultiCallable value for the named unary-stream method.
Nr rB r r r � unary_stream& s zChannel.unary_streamc C s dS )a� Creates a StreamUnaryMultiCallable for a stream-unary method.
Args:
method: The name of the RPC method.
request_serializer: Optional :term:`serializer` for serializing the request
message. Request goes unserialized in case None is passed.
response_deserializer: Optional :term:`deserializer` for deserializing the
response message. Response goes undeserialized in case None
is passed.
_registered_method: Implementation Private. Optional: A bool representing
whether the method is registered.
Returns:
A StreamUnaryMultiCallable value for the named stream-unary method.
Nr rB r r r � stream_unary> s zChannel.stream_unaryc C s dS )a� Creates a StreamStreamMultiCallable for a stream-stream method.
Args:
method: The name of the RPC method.
request_serializer: Optional :term:`serializer` for serializing the request
message. Request goes unserialized in case None is passed.
response_deserializer: Optional :term:`deserializer` for deserializing the
response message. Response goes undeserialized in case None
is passed.
_registered_method: Implementation Private. Optional: A bool representing
whether the method is registered.
Returns:
A StreamStreamMultiCallable value for the named stream-stream method.
Nr rB r r r �
stream_streamV s zChannel.stream_stream)N)F)NNF)NNF)NNF)NNF) r r r r r r r2 r6 r r! r8 r$ r" �ChannelConnectivityr: r< r= �strr r r rC r' rD r) rE r. rF r r r r r0 � s~
��� �� �� �� ��r0 )r r �typingr r r" � r �_typingr r r r r
r �ABCr r' r) r. r0 r r r r �<module> s & &&&