o پi@sdZddlZddlZddlmZdZejZdZ z ddl m Z e eeZ Wn e y/dZ Ynwe rMe ded d d ed d eded GdddeZGdddeZddZGdddeZdS)zEClient and server classes corresponding to protobuf-defined services.N) health_pb2z1.78.0F)first_version_is_lowerTz)The grpc package installed is at version ,zG but the generated code in grpc_health/v1/health_pb2_grpc.py depends onz grpcio>=.z, Please upgrade your grpc module to grpcio>=z6 or downgrade your generated code using grpcio-tools<=c@seZdZdZddZdS) HealthStub8Missing associated documentation comment in .proto file.cCs<|jdtjjtjjdd|_|jdtjjtjjdd|_dS)zIConstructor. Args: channel: A grpc.Channel. /grpc.health.v1.Health/CheckT)request_serializerresponse_deserializer_registered_method/grpc.health.v1.Health/WatchN) unary_unary#grpc__health_dot_v1_dot_health__pb2HealthCheckRequestSerializeToStringHealthCheckResponse FromStringCheck unary_streamWatch)selfchannelrR/home/ubuntu/.local/lib/python3.10/site-packages/grpc_health/v1/health_pb2_grpc.py__init__s zHealthStub.__init__N)__name__ __module__ __qualname____doc__rrrrrrs rc@s eZdZdZddZddZdS)HealthServicerrcC |tjj|dtd)z_If the requested service is unknown, the call will fail with status NOT_FOUND. Method not implemented!set_codegrpc StatusCode UNIMPLEMENTED set_detailsNotImplementedErrorrrequestcontextrrrr4s zHealthServicer.CheckcCr )aPerforms a watch for the serving status of the requested service. The server will immediately send back a message indicating the current serving status. It will then subsequently send a new message whenever the service's serving status changes. If the requested service is unknown when the call is received, the server will send a message setting the serving status to SERVICE_UNKNOWN but will *not* terminate the call. If at some future point, the serving status of the service becomes known, the server will send a new message with the service's serving status. If the call terminates with status UNIMPLEMENTED, then clients should assume this method is not supported and should not retry the call. If the call terminates with any other status (including OK), clients should retry the call with appropriate exponential backoff. r!r"r)rrrr<s zHealthServicer.WatchN)rrrrrrrrrrr1s rcCs^tj|jtjjtjjdtj|j tjjtjjdd}t d|}| |f| d|dS)N)request_deserializerresponse_serializer)rrzgrpc.health.v1.Health) r$unary_unary_rpc_method_handlerrrrrrrunary_stream_rpc_method_handlerrmethod_handlers_generic_handleradd_generic_rpc_handlersadd_registered_method_handlers)servicerserverrpc_method_handlersgeneric_handlerrrradd_HealthServicer_to_serverRs   r7c@sLeZdZdZe        d ddZe        d ddZdS) HealthrrNFc C0tjj||dtjjtjj|||||||| ddS)NrTr )r$ experimentalr rrrrr r*targetoptionschannel_credentialscall_credentialsinsecure compressionwait_for_readytimeoutmetadatarrrri  z Health.Checkc Cr9)Nr Tr:)r$r;rrrrrrr<rrrrrFz Health.Watch)rNNFNNNN)rrrr staticmethodrrrrrrr8fs, r8)rr$warningsgrpc_health.v1rrGRPC_GENERATED_VERSION __version__ GRPC_VERSION_version_not_supportedgrpc._utilitiesr ImportError RuntimeErrorobjectrrr7r8rrrrs:       !