o |j6hE6@sdZddlZddlmZmZddlZddlmZddlm Z ddlm Z ddlm Z dd lm Z dd lm Z dd lmZGd d d ee e fejZGdddee e fejZGdddejZGdddejZGdddejZdS)zDAbstract base classes for Channel objects and Multicallable objects.N)GenericOptional) _base_call)DeserializingFunction) MetadataType)RequestIterableType) RequestType) ResponseType)SerializingFunctionc@leZdZdZejdddddddedeedee dee j dee d ee j d ejeeffd d ZdS) UnaryUnaryMultiCallablez4Enables asynchronous invocation of a unary-call RPC.Ntimeoutmetadata credentialswait_for_ready compressionrequestrrrrrreturncCdS)arAsynchronously 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. Nselfrrrrrrrre/var/www/html/chefvision.cloud.itp360.com/venv/lib/python3.10/site-packages/grpc/aio/_base_channel.py__call__!z UnaryUnaryMultiCallable.__call__)__name__ __module__ __qualname____doc__abcabstractmethodr rfloatrgrpcCallCredentialsbool CompressionrUnaryUnaryCallr rrrrrr . r c@r ) UnaryStreamMultiCallablez:Enables asynchronous invocation of a server-streaming RPC.NrrrrrrrrcCr)asAsynchronously 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. NrrrrrrGrz!UnaryStreamMultiCallable.__call__)rrrr r!r"r rr#rr$r%r&r'rUnaryStreamCallr rrrrrr*Dr)r*c@heZdZdZej      d deedeedee dee j dee dee j d ejfd d ZdS) StreamUnaryMultiCallablez:Enables asynchronous invocation of a client-streaming RPC.Nrequest_iteratorrrrrrrcCr)aAsynchronously 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. Nrrr.rrrrrrrrrmrz!StreamUnaryMultiCallable.__call__NNNNNN)rrrr r!r"rrr#rr$r%r&r'rStreamUnaryCallrrrrrr-j0r-c@r,) StreamStreamMultiCallablezAEnables asynchronous invocation of a bidirectional-streaming RPC.Nr.rrrrrrcCr)aAsynchronously 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. Nrr/rrrrrz"StreamStreamMultiCallable.__call__r0)rrrr r!r"rrr#rr$r%r&r'rStreamStreamCallrrrrrr3r2r3c @sneZdZdZejddZejddZejd dee fdd Z ej d!d e d e j fd dZejde j d dfddZejd"ddZej   d#dedeedeedee d ef ddZej   d#dedeedeedee d ef ddZej   d#dedeedeedee d ef ddZej   d#dedeedeedee d ef ddZdS)$ChannelzEnables asynchronous RPC invocation as a client. Channel objects implement the Asynchronous Context Manager (aka. async with) type, although they are not supported to be entered and exited multiple times. cdS)zwStarts an asynchronous context manager. Returns: Channel the channel that was instantiated. Nrrrrr __aenter__zChannel.__aenter__cr6)zxFinishes the asynchronous context manager by closing the channel. Still active RPCs will be cancelled. Nr)rexc_typeexc_valexc_tbrrr __aexit__r9zChannel.__aexit__Ngracecr6)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)rr>rrrcloser9z Channel.closeFtry_to_connectrcCr)aChecks 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)rr@rrr get_staterzChannel.get_statelast_observed_statecr6)aWaits 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)rrBrrrwait_for_state_changer9zChannel.wait_for_state_changecr6)z;Creates a coroutine that blocks until the Channel is READY.Nrr7rrr channel_ready r9zChannel.channel_readymethodrequest_serializerresponse_deserializer_registered_methodcCr)aCreates 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. NrrrErFrGrHrrr unary_unaryrzChannel.unary_unarycCr)aCreates 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 UnaryStreamMultiCallable value for the named unary-stream method. NrrIrrr unary_stream&rzChannel.unary_streamcCr)aCreates 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. NrrIrrr stream_unary>rzChannel.stream_unarycCr)aCreates 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. NrrIrrr stream_streamVrzChannel.stream_stream)N)F)rN)NNF)rrrr r!r"r8r=rr#r?r&r$ChannelConnectivityrArCrDstrr rr rJr*rKr-rLr3rMrrrrr5s        r5)r r!typingrrr$r_typingrrrr r r ABCr r*r-r3r5rrrrs         &&&&