o i eN3@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/myenv/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 @sFeZdZdZejddZejddZejddee fdd Z ej d d e d e j fd dZejde j d dfddZejd!ddZej  d"dedeedeed efddZej  d"dedeedeed efddZej  d"dedeedeed efddZej  d"dedeedeed efddZdS)#ChannelzEnables 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. 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)aCloses 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 wait until all active RPCs are finshed, once the grace period is reached the ones that haven't been terminated are cancelled. 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_deserializercCr)a0Creates 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. Returns: A UnaryUnaryMultiCallable value for the named unary-unary method. NrrrErFrGrrr unary_unary rzChannel.unary_unarycCr)a4Creates 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. Returns: A UnarySteramMultiCallable value for the named unary-stream method. NrrHrrr unary_stream"rzChannel.unary_streamcCr)a4Creates 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. Returns: A StreamUnaryMultiCallable value for the named stream-unary method. NrrHrrr stream_unary7rzChannel.stream_unarycCr)a8Creates 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. Returns: A StreamStreamMultiCallable value for the named stream-stream method. NrrHrrr stream_streamLrzChannel.stream_stream)N)F)rN)NN)rrrr r!r"r8r=rr#r?r&r$ChannelConnectivityrArCrDstrr rr rIr*rJr-rKr3rLrrrrr5s        r5)r r!typingrrr$r_typingrrrr r r ABCr r*r-r3r5rrrrs         &&&&