o ˷e3@sdZddlZddlmZmZddlZddlmZddlm Z ddlm Z ddlm Z dd lm Z Gd d d ej ZGd d d ej ZGdddej ZGdddej ZGdddej ZdS)zDAbstract base classes for Channel objects and Multicallable objects.N)AnyOptional) _base_call)DeserializingFunction) MetadataType)RequestIterableType)SerializingFunctionc@deZdZdZejdddddddedeedee dee j dee d ee j d ejfd d ZdS) UnaryUnaryMultiCallablez4Enables asynchronous invocation of a unary-call RPC.Ntimeoutmetadata credentialswait_for_ready compressionrequestr rrrrreturncCdS)aAsynchronously 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: This is an EXPERIMENTAL argument. An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This is an EXPERIMENTAL option. 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. Nselfrr rrrrrrM/var/www/ideatree/venv/lib/python3.10/site-packages/grpc/aio/_base_channel.py__call__z UnaryUnaryMultiCallable.__call__)__name__ __module__ __qualname____doc__abcabstractmethodrrfloatrgrpcCallCredentialsbool CompressionrUnaryUnaryCallrrrrrr . r c@r ) UnaryStreamMultiCallablez:Enables asynchronous invocation of a server-streaming RPC.Nr rr rrrrrcCr)aAsynchronously 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: This is an EXPERIMENTAL argument. An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This is an EXPERIMENTAL option. 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. NrrrrrrFrz!UnaryStreamMultiCallable.__call__)rrrrrr rrr!rr"r#r$r%rUnaryStreamCallrrrrrr(Cr'r(c@heZdZdZej      d deedeedee dee j dee dee j d ejfd d ZdS) StreamUnaryMultiCallablez:Enables asynchronous invocation of a client-streaming RPC.Nrequest_iteratorr rrrrrcCr)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: This is an EXPERIMENTAL argument. An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This is an EXPERIMENTAL option. 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,r rrrrrrrrmrz!StreamUnaryMultiCallable.__call__NNNNNN)rrrrrr rrr!rr"r#r$r%rStreamUnaryCallrrrrrr+j0r+c@r*) StreamStreamMultiCallablezAEnables asynchronous invocation of a bidirectional-streaming RPC.Nr,r rrrrrcCr)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: This is an EXPERIMENTAL argument. An optional flag to enable :term:`wait_for_ready` mechanism. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This is an EXPERIMENTAL option. 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__r.)rrrrrr rrr!rr"r#r$r%rStreamStreamCallrrrrrr1r0r1c @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__cr4)zxFinishes the asynchronous context manager by closing the channel. Still active RPCs will be cancelled. Nr)rexc_typeexc_valexc_tbrrr __aexit__r7zChannel.__aexit__Ngracecr4)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<rrrcloser7z 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_statecr4)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)rr@rrrwait_for_state_changer7zChannel.wait_for_state_changecr4)z;Creates a coroutine that blocks until the Channel is READY.Nrr5rrr channel_ready r7zChannel.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. NrrrCrDrErrr unary_unaryrzChannel.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. NrrFrrr 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. NrrFrrr stream_unary8rzChannel.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. NrrFrrr stream_streamMrzChannel.stream_stream)N)F)rN)NN)rrrrrr r6r;rr!r=r$r"ChannelConnectivityr?rArBstrr rr rGr(rHr+rIr1rJrrrrr3s        r3)rrtypingrrr"r_typingrrrr ABCr r(r+r1r3rrrrs      ''''