a !f@sdZddlZddlZddlZddlmZddlmZddlmZddlm Z Gddde Z Gd d d e d d Z Gd d d e ejdZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddejZGdd d eejdZGd!d"d"eejdZGd#d$d$ejZGd%d&d&ejZGd'd(d(ejZGd)d*d*ejZGd+d,d,ejZGd-d.d.ejZ Gd/d0d0ejZ!Gd1d2d2ejZ"Gd3d4d4ejZ#dS)5z4Interfaces defining the Face layer of RPC Framework.N) cardinality)style)future)streamcs(eZdZdZfddZddZZS)NoSuchMethodErrorzRaised by customer code to indicate an unrecognized method. Attributes: group: The group of the unrecognized method. name: The name of the unrecognized method. cstt|||_||_dS)zConstructor. Args: group: The group identifier of the unrecognized RPC name. method: The method identifier of the unrecognized RPC name. N)superr__init__groupmethodselfr r  __class__d/var/www/html/python-backend/venv/lib/python3.9/site-packages/grpc/framework/interfaces/face/face.pyr&szNoSuchMethodError.__init__cCsd|j|jfS)Nzface.NoSuchMethodError(%s, %s))r r r rrr__repr__1szNoSuchMethodError.__repr__)__name__ __module__ __qualname____doc__rr __classcell__rrr rrs rc@s(eZdZdZejGdddejZdS)AbortionaEA value describing RPC abortion. Attributes: kind: A Kind value identifying how the RPC failed. initial_metadata: The initial metadata from the other side of the RPC or None if no initial metadata value was received. terminal_metadata: The terminal metadata from the other side of the RPC or None if no terminal metadata value was received. code: The code value from the other side of the RPC or None if no code value was received. details: The details value from the other side of the RPC or None if no details value was received. c@s,eZdZdZdZdZdZdZdZdZ dZ d S) z Abortion.KindzTypes of RPC abortion. cancelledZexpiredzlocal shutdownzremote shutdownznetwork failurez local failurezremote failureN) rrrr CANCELLEDZEXPIREDZLOCAL_SHUTDOWNZREMOTE_SHUTDOWNZNETWORK_FAILUREZ LOCAL_FAILUREZREMOTE_FAILURErrrrKindNsrN)rrrrenumuniqueEnumrrrrrr8sr)kindinitial_metadataterminal_metadatacodedetailscs(eZdZdZfddZddZZS) AbortionErroraCommon super type for exceptions indicating RPC abortion. initial_metadata: The initial metadata from the other side of the RPC or None if no initial metadata value was received. terminal_metadata: The terminal metadata from the other side of the RPC or None if no terminal metadata value was received. code: The code value from the other side of the RPC or None if no code value was received. details: The details value from the other side of the RPC or None if no details value was received. cs*tt|||_||_||_||_dS)N)rr$rr r!r"r#)r r r!r"r#r rrrhs zAbortionError.__init__cCsd|jj|j|jfS)Nz%s(code=%s, details="%s"))rrr"r#rrrr__str__oszAbortionError.__str__)rrrrrr%rrrr rr$[s r$) metaclassc@seZdZdZdS)CancellationErrorz)Indicates that an RPC has been cancelled.Nrrrrrrrrr'tsr'c@seZdZdZdS)ExpirationErrorz0Indicates that an RPC has expired ("timed out").Nr(rrrrr)xsr)c@seZdZdZdS)LocalShutdownErrorzCIndicates that an RPC has terminated due to local shutdown of RPCs.Nr(rrrrr*|sr*c@seZdZdZdS)RemoteShutdownErrorzDIndicates that an RPC has terminated due to remote shutdown of RPCs.Nr(rrrrr+sr+c@seZdZdZdS) NetworkErrorz2Indicates that some error occurred on the network.Nr(rrrrr,sr,c@seZdZdZdS) LocalErrorz;Indicates that an RPC has terminated due to a local defect.Nr(rrrrr-sr-c@seZdZdZdS) RemoteErrorz=s  r>c@s@eZdZdZejd ddZejd ddZejd dd ZdS) UnaryUnaryMultiCallablez5Affords invoking a unary-unary RPC in any call style.NFcCs tdS)aSynchronously invokes the underlying RPC. Args: request: The request value for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. with_call: Whether or not to include return a Call for the RPC in addition to the response. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: The response value for the RPC, and a Call for the RPC if with_call was set to True at invocation. Raises: AbortionError: Indicating that the RPC was aborted. Nr0)r requesttimeoutmetadata with_callprotocol_optionsrrr__call__csz UnaryUnaryMultiCallable.__call__cCs tdS)aAsynchronously invokes the underlying RPC. Args: request: The request value for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: An object that is both a Call for the RPC and a future.Future. In the event of RPC completion, the return Future's result value will be the response value of the RPC. In the event of RPC abortion, the returned Future's exception value will be an AbortionError. Nr0r rBrCrDrFrrrrszUnaryUnaryMultiCallable.futurecCs tdS)auAsynchronously invokes the underlying RPC. Args: request: The request value for the RPC. receiver: A ResponseReceiver to be passed the response data of the RPC. abortion_callback: A callback to be called and passed an Abortion value in the event of RPC abortion. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: A Call for the RPC. Nr0r rBreceiverr4rCrDrFrrreventszUnaryUnaryMultiCallable.event)NFN)NN)NN rrrrr8r9rGrrKrrrrrA`s  rAc@s0eZdZdZejdddZejdddZdS) UnaryStreamMultiCallablez6Affords invoking a unary-stream RPC in any call style.NcCs tdS)aYInvokes the underlying RPC. Args: request: The request value for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: An object that is both a Call for the RPC and an iterator of response values. Drawing response values from the returned iterator may raise AbortionError indicating abortion of the RPC. Nr0rHrrrrGsz!UnaryStreamMultiCallable.__call__cCs tdS)a|Asynchronously invokes the underlying RPC. Args: request: The request value for the RPC. receiver: A ResponseReceiver to be passed the response data of the RPC. abortion_callback: A callback to be called and passed an Abortion value in the event of RPC abortion. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: A Call object for the RPC. Nr0rIrrrrKszUnaryStreamMultiCallable.event)NN)NNrrrrr8r9rGrKrrrrrMs rMc@s@eZdZdZejd ddZejd ddZejd dd ZdS) StreamUnaryMultiCallablez6Affords invoking a stream-unary RPC in any call style.NFcCs tdS)aSynchronously invokes the underlying RPC. Args: request_iterator: An iterator that yields request values for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. with_call: Whether or not to include return a Call for the RPC in addition to the response. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: The response value for the RPC, and a Call for the RPC if with_call was set to True at invocation. Raises: AbortionError: Indicating that the RPC was aborted. Nr0)r request_iteratorrCrDrErFrrrrGsz!StreamUnaryMultiCallable.__call__cCs tdS)aAsynchronously invokes the underlying RPC. Args: request_iterator: An iterator that yields request values for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: An object that is both a Call for the RPC and a future.Future. In the event of RPC completion, the return Future's result value will be the response value of the RPC. In the event of RPC abortion, the returned Future's exception value will be an AbortionError. Nr0r rPrCrDrFrrrrszStreamUnaryMultiCallable.futurecCs tdSaAsynchronously invokes the underlying RPC. Args: receiver: A ResponseReceiver to be passed the response data of the RPC. abortion_callback: A callback to be called and passed an Abortion value in the event of RPC abortion. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: A single object that is both a Call object for the RPC and a stream.Consumer to which the request values of the RPC should be passed. Nr0r rJr4rCrDrFrrrrKszStreamUnaryMultiCallable.event)NFN)NN)NNrLrrrrrOs  rOc@s0eZdZdZejdddZejdddZdS) StreamStreamMultiCallablez7Affords invoking a stream-stream RPC in any call style.NcCs tdS)awInvokes the underlying RPC. Args: request_iterator: An iterator that yields request values for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: An object that is both a Call for the RPC and an iterator of response values. Drawing response values from the returned iterator may raise AbortionError indicating abortion of the RPC. Nr0rQrrrrG3sz"StreamStreamMultiCallable.__call__cCs tdSrRr0rSrrrrKJszStreamStreamMultiCallable.event)NN)NNrNrrrrrT0s rTc@seZdZdZdS)MethodImplementationa A sum type that describes a method implementation. Attributes: cardinality: A cardinality.Cardinality value. style: A style.Service value. unary_unary_inline: The implementation of the method as a callable value that takes a request value and a ServicerContext object and returns a response value. Only non-None if cardinality is cardinality.Cardinality.UNARY_UNARY and style is style.Service.INLINE. unary_stream_inline: The implementation of the method as a callable value that takes a request value and a ServicerContext object and returns an iterator of response values. Only non-None if cardinality is cardinality.Cardinality.UNARY_STREAM and style is style.Service.INLINE. stream_unary_inline: The implementation of the method as a callable value that takes an iterator of request values and a ServicerContext object and returns a response value. Only non-None if cardinality is cardinality.Cardinality.STREAM_UNARY and style is style.Service.INLINE. stream_stream_inline: The implementation of the method as a callable value that takes an iterator of request values and a ServicerContext object and returns an iterator of response values. Only non-None if cardinality is cardinality.Cardinality.STREAM_STREAM and style is style.Service.INLINE. unary_unary_event: The implementation of the method as a callable value that takes a request value, a response callback to which to pass the response value of the RPC, and a ServicerContext. Only non-None if cardinality is cardinality.Cardinality.UNARY_UNARY and style is style.Service.EVENT. unary_stream_event: The implementation of the method as a callable value that takes a request value, a stream.Consumer to which to pass the response values of the RPC, and a ServicerContext. Only non-None if cardinality is cardinality.Cardinality.UNARY_STREAM and style is style.Service.EVENT. stream_unary_event: The implementation of the method as a callable value that takes a response callback to which to pass the response value of the RPC and a ServicerContext and returns a stream.Consumer to which the request values of the RPC should be passed. Only non-None if cardinality is cardinality.Cardinality.STREAM_UNARY and style is style.Service.EVENT. stream_stream_event: The implementation of the method as a callable value that takes a stream.Consumer to which to pass the response values of the RPC and a ServicerContext and returns a stream.Consumer to which the request values of the RPC should be passed. Only non-None if cardinality is cardinality.Cardinality.STREAM_STREAM and style is style.Service.EVENT. Nr(rrrrrUdsrUc@seZdZdZejddZdS)MultiMethodImplementationz,A general type able to service many methods.cCs tdS)aServices an RPC. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. response_consumer: A stream.Consumer to be called to accept the response values of the RPC. context: a ServicerContext object. Returns: A stream.Consumer with which to accept the request values of the RPC. The consumer returned from this method may or may not be invoked to completion: in the case of RPC abortion, RPC Framework will simply stop passing values to this object. Implementations must not assume that this object will be called to completion of the request stream or even called at all. Raises: abandonment.Abandoned: May or may not be raised when the RPC has been aborted. NoSuchMethodError: If this MultiMethod does not recognize the given group and name for the RPC and is not able to service the RPC. Nr0)r r r Zresponse_consumercontextrrrservicesz!MultiMethodImplementation.serviceN)rrrrr8r9rXrrrrrVsrVc@seZdZdZejd ddZejd!ddZejd"dd Zejd#d d Z ejd$d d Z ejd%ddZ ejd&ddZ ejd'ddZ ejd(ddZejd)ddZejddZejddZejddZejddZdS)* GenericStubz+Affords RPC invocation via generic methods.NFcCs tdS)aInvokes a unary-request-unary-response method. This method blocks until either returning the response value of the RPC (in the event of RPC completion) or raising an exception (in the event of RPC abortion). Args: group: The group identifier of the RPC. method: The method identifier of the RPC. request: The request value for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. with_call: Whether or not to include return a Call for the RPC in addition to the response. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: The response value for the RPC, and a Call for the RPC if with_call was set to True at invocation. Raises: AbortionError: Indicating that the RPC was aborted. Nr0)r r r rBrCrDrErFrrrblocking_unary_unarys!z GenericStub.blocking_unary_unarycCs tdS)aInvokes a unary-request-unary-response method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. request: The request value for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: An object that is both a Call for the RPC and a future.Future. In the event of RPC completion, the return Future's result value will be the response value of the RPC. In the event of RPC abortion, the returned Future's exception value will be an AbortionError. Nr0r r r rBrCrDrFrrrfuture_unary_unaryszGenericStub.future_unary_unarycCs tdS)aInvokes a unary-request-stream-response method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. request: The request value for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: An object that is both a Call for the RPC and an iterator of response values. Drawing response values from the returned iterator may raise AbortionError indicating abortion of the RPC. Nr0r[rrrinline_unary_streamszGenericStub.inline_unary_streamcCs tdS)aInvokes a stream-request-unary-response method. This method blocks until either returning the response value of the RPC (in the event of RPC completion) or raising an exception (in the event of RPC abortion). Args: group: The group identifier of the RPC. method: The method identifier of the RPC. request_iterator: An iterator that yields request values for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. with_call: Whether or not to include return a Call for the RPC in addition to the response. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: The response value for the RPC, and a Call for the RPC if with_call was set to True at invocation. Raises: AbortionError: Indicating that the RPC was aborted. Nr0)r r r rPrCrDrErFrrrblocking_stream_unary s!z!GenericStub.blocking_stream_unarycCs tdS)a5Invokes a stream-request-unary-response method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. request_iterator: An iterator that yields request values for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: An object that is both a Call for the RPC and a future.Future. In the event of RPC completion, the return Future's result value will be the response value of the RPC. In the event of RPC abortion, the returned Future's exception value will be an AbortionError. Nr0r r r rPrCrDrFrrrfuture_stream_unary.szGenericStub.future_stream_unarycCs tdS)aInvokes a stream-request-stream-response method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. request_iterator: An iterator that yields request values for the RPC. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: An object that is both a Call for the RPC and an iterator of response values. Drawing response values from the returned iterator may raise AbortionError indicating abortion of the RPC. Nr0r_rrrinline_stream_streamIsz GenericStub.inline_stream_streamc Cs tdS)aEvent-driven invocation of a unary-request-unary-response method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. request: The request value for the RPC. receiver: A ResponseReceiver to be passed the response data of the RPC. abortion_callback: A callback to be called and passed an Abortion value in the event of RPC abortion. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: A Call for the RPC. Nr0 r r r rBrJr4rCrDrFrrrevent_unary_unarycszGenericStub.event_unary_unaryc Cs tdS)aEvent-driven invocation of a unary-request-stream-response method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. request: The request value for the RPC. receiver: A ResponseReceiver to be passed the response data of the RPC. abortion_callback: A callback to be called and passed an Abortion value in the event of RPC abortion. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: A Call for the RPC. Nr0rbrrrevent_unary_streamszGenericStub.event_unary_streamcCs tdS)aEvent-driven invocation of a unary-request-unary-response method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. receiver: A ResponseReceiver to be passed the response data of the RPC. abortion_callback: A callback to be called and passed an Abortion value in the event of RPC abortion. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: A pair of a Call object for the RPC and a stream.Consumer to which the request values of the RPC should be passed. Nr0r r r rJr4rCrDrFrrrevent_stream_unaryszGenericStub.event_stream_unarycCs tdS)aEvent-driven invocation of a unary-request-stream-response method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. receiver: A ResponseReceiver to be passed the response data of the RPC. abortion_callback: A callback to be called and passed an Abortion value in the event of RPC abortion. timeout: A duration of time in seconds to allow for the RPC. metadata: A metadata value to be passed to the service-side of the RPC. protocol_options: A value specified by the provider of a Face interface implementation affording custom state and behavior. Returns: A pair of a Call object for the RPC and a stream.Consumer to which the request values of the RPC should be passed. Nr0rerrrevent_stream_streamszGenericStub.event_stream_streamcCs tdS)zCreates a UnaryUnaryMultiCallable for a unary-unary method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. Returns: A UnaryUnaryMultiCallable value for the named unary-unary method. Nr0r rrr unary_unarys zGenericStub.unary_unarycCs tdS)aCreates a UnaryStreamMultiCallable for a unary-stream method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. Returns: A UnaryStreamMultiCallable value for the name unary-stream method. Nr0r rrr unary_streams zGenericStub.unary_streamcCs tdS)aCreates a StreamUnaryMultiCallable for a stream-unary method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. Returns: A StreamUnaryMultiCallable value for the named stream-unary method. Nr0r rrr stream_unarys zGenericStub.stream_unarycCs tdS)aCreates a StreamStreamMultiCallable for a stream-stream method. Args: group: The group identifier of the RPC. method: The method identifier of the RPC. Returns: A StreamStreamMultiCallable value for the named stream-stream method. Nr0r rrr stream_streams zGenericStub.stream_stream)NFN)NN)NN)NFN)NN)NN)NN)NN)NN)NN)rrrrr8r9rZr\r]r^r`rarcrdrfrgrhrirjrkrrrrrYsf "   "         rYc@seZdZdZdS) DynamicStubavAffords RPC invocation via attributes corresponding to afforded methods. Instances of this type may be scoped to a single group so that attribute access is unambiguous. Instances of this type respond to attribute access as follows: if the requested attribute is the name of a unary-unary method, the value of the attribute will be a UnaryUnaryMultiCallable with which to invoke an RPC; if the requested attribute is the name of a unary-stream method, the value of the attribute will be a UnaryStreamMultiCallable with which to invoke an RPC; if the requested attribute is the name of a stream-unary method, the value of the attribute will be a StreamUnaryMultiCallable with which to invoke an RPC; and if the requested attribute is the name of a stream-stream method, the value of the attribute will be a StreamStreamMultiCallable with which to invoke an RPC. Nr(rrrrrl srl)$rr8 collectionsrZgrpc.framework.commonrrZgrpc.framework.foundationrr Exceptionr namedtuplerABCMetar$r'r)r*r+r,r-r.ABCr/r:r;r>rArMrOrTrUrVrYrlrrrrsB      #08E#N1Q4-\