o $ºiå•ã @s² dZddlmZddlmZddlmZddlmZ ddlm Z ddlm Z e  ¡Ze ¡ d¡Zejd Ze e¡Zejd Ze e¡Zejd Ze e¡Zejd Ze e¡Zejd Ze e¡ZejdZe e¡ZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZej=dZ?ej=dZ@ej=dZAej=dZBej=dZCeCjDdZEej=dZFej=d ZGej=d!ZHeHjDd"ZIej=d#ZJeJjDd$ZKej=d%ZLeLjDd&ZMej=d'ZNeNjDd(ZOej=d)ZPej=d*ZQej=d+ZRej=d,ZSej=d-ZTej=d.ZUej=d/ZVej=d0ZWej=d1ZXej=d2ZYej=d3ZZej=d4Z[ej=d5Z\ej=d6Z]ej=d7Z^ej=d8Z_ej=d9Z`ej=d:Zaej=d;Zbej=d<Zcej=d=Zdej=d>Zeej=d?Zfej=d@Zgej=dAZhej=dBZie  jde jkfe>dCdDœ¡Zle mel¡e  jde jkfe?dCdDœ¡Zne men¡e  jde jkfe@dCdDœ¡Zoe meo¡e  jde jkfeAdCdDœ¡Zpe mep¡e  jde jkfeBdCdDœ¡Zqe meq¡e  jde jkfe  jde jkfeEdCdDœ¡eCdCdEœ¡Zre mer¡e merjs¡e  jde jkfeFdCdDœ¡Zte met¡e  jd e jkfeGdCdDœ¡Zue meu¡e  jd!e jkfe  jd"e jkfeIdCdDœ¡eHdCdFœ¡Zve mev¡e mevjw¡e  jd#e jkfe  jd$e jkfeKdCdDœ¡eJdCdGœ¡Zxe mex¡e mexjy¡e  jd%e jkfe  jd&e jkfeMdCdDœ¡eLdCdHœ¡Zze mez¡e mezj{¡e  jd'e jkfe  jd(e jkfeOdCdDœ¡eNdCdIœ¡Z|e me|¡e me|j}¡e  jd)e jkfePdCdDœ¡Z~e me~¡e  jd*e jkfeQdCdDœ¡Ze me¡e  jd+e jkfeRdCdDœ¡Z€e me€¡e  jd,e jkfeSdCdDœ¡Ze me¡e  jd-e jkfeTdCdDœ¡Z‚e me‚¡e  jd.e jkfeUdCdDœ¡Zƒe meƒ¡e  jd/e jkfeVdCdDœ¡Z„e me„¡e  jd0e jkfeWdCdDœ¡Z…e me…¡e  jd1e jkfeXdCdDœ¡Z†e me†¡e  jd2e jkfeYdCdDœ¡Z‡e me‡¡e  jd3e jkfeZdCdDœ¡Zˆe meˆ¡e  jd4e jkfe[dCdDœ¡Z‰e me‰¡e  jd5e jkfe\dCdDœ¡ZŠe meŠ¡e  jd6e jkfe]dCdDœ¡Z‹e me‹¡e  jd7e jkfe^dCdDœ¡ZŒe meŒ¡e  jd8e jkfe_dCdDœ¡Ze me¡e  jd9e jkfe`dCdDœ¡ZŽe meŽ¡e  jd:e jkfeadCdDœ¡Ze me¡e  jd;e jkfebdCdDœ¡Ze me¡e  jde jkfeedCdDœ¡Z“e me“¡e  jd?e jkfefdCdDœ¡Z”e me”¡e  jd@e jkfegdCdDœ¡Z•e me•¡e  jdAe jkfehdCdDœ¡Z–e me–¡e  jdBe jkfeidCdDœ¡Z—e me—¡ej˜dJZ™ej˜dKZšej˜dLZ›ej˜dMZœejdNkr×dOe_ždPe_ŸdOeE_ždQeE_ŸdOeI_ždQeI_ŸdOeK_ždQeK_ŸdOeM_ždQeM_ŸdOeO_ždQeO_ŸdRe_ dSe_¡dTe_ dUe_¡dVe_ dWe_¡dXe_ dYe_¡dZe_ d[e_¡d\e_ d]e_¡d^e>_ d_e>_¡d`e?_ dae?_¡dbe@_ dce@_¡ddeA_ deeA_¡dfeB_ dgeB_¡dheC_ dieC_¡djeE_ dieE_¡dkeF_ dleF_¡dmeG_ dneG_¡doeH_ dpeH_¡dqeI_ dpeI_¡dreJ_ dseJ_¡dteK_ dseK_¡dueL_ dveL_¡dweM_ dveM_¡dxeN_ dyeN_¡dzeO_ dyeO_¡d{eP_ d|eP_¡d}eQ_ d~eQ_¡deR_ d€eR_¡deS_ d‚eS_¡dƒeT_ d„eT_¡d…eU_ d†eU_¡d‡eV_ dˆeV_¡d‰eW_ dŠeW_¡d‹eX_ dŒeX_¡deY_ dŽeY_¡deZ_ deZ_¡d‘e[_ d’e[_¡d“e\_ d”e\_¡d•e]_ d–e]_¡d—e^_ d˜e^_¡d™e__ dše__¡d›e`_ dœe`_¡dea_ džea_¡dŸeb_ d eb_¡d¡ec_ d¢ec_¡d£ed_ d¤ed_¡d¥ee_ d¦ee_¡d§ef_ d¨ef_¡d©eg_ dªeg_¡d«eh_ d¬eh_¡d­ei_ d®ei_¡d¯e™_ d°e™_¡d±eš_ d²eš_¡d³e›_ d´e›_¡dµeœ_ d¶eœ_¡dOSdOS)·zGenerated protocol buffer code.é)Úenum_type_wrapper)Ú descriptor)Údescriptor_pool)Úmessage)Ú reflection)Úsymbol_databases¼" src/ray/protobuf/serve.proto ray.serve"q AutoscalingPolicy' policy_function ( RpolicyFunction3 _serialized_policy_def ( RSerializedPolicyDef"Ä AutoscalingConfig! min_replicas ( R minReplicas! max_replicas ( R maxReplicas, metrics_interval_s (RmetricsIntervalS+ look_back_period_s (RlookBackPeriodS) smoothing_factor (RsmoothingFactor* downscale_delay_s (RdownscaleDelayS& upscale_delay_s (R upscaleDelayS. initial_replicas ( HRinitialReplicasˆ= upscale_smoothing_factor (HRupscaleSmoothingFactorˆA downscale_smoothing_factor (HRdownscaleSmoothingFactorˆ4 policy ( 2.ray.serve.AutoscalingPolicyRpolicy6 target_ongoing_requests (RtargetOngoingRequests. upscaling_factor (HRupscalingFactorˆ2 downscaling_factor (HRdownscalingFactorˆ= downscale_to_zero_delay_s (HRdownscaleToZeroDelaySˆ1 aggregation_function ( RaggregationFunctionB _initial_replicasB _upscale_smoothing_factorB _downscale_smoothing_factorB _upscaling_factorB _downscaling_factorB _downscale_to_zero_delay_s"ë LoggingConfig3 encoding (2.ray.serve.EncodingTypeRencoding log_level ( RlogLevel logs_dir ( RlogsDir* enable_access_log (RenableAccessLogA additional_log_standard_attrs ( RadditionalLogStandardAttrs"É RequestRouterConfigB _serialized_request_router_cls ( RSerializedRequestRouterCls0 request_router_class ( RrequestRouterClassB request_routing_stats_period_s (RrequestRoutingStatsPeriodSD request_routing_stats_timeout_s (RrequestRoutingStatsTimeoutS2 request_router_kwargs ( RrequestRouterKwargs"™ DeploymentConfig! num_replicas (R numReplicas0 max_ongoing_requests (RmaxOngoingRequests. max_queued_requests (RmaxQueuedRequests user_config ( R userConfig@ graceful_shutdown_wait_loop_s (RgracefulShutdownWaitLoopS= graceful_shutdown_timeout_s (RgracefulShutdownTimeoutS1 health_check_period_s (RhealthCheckPeriodS3 health_check_timeout_s (RhealthCheckTimeoutS* is_cross_language (RisCrossLanguageN deployment_language (2.ray.serve.DeploymentLanguageRdeploymentLanguageK autoscaling_config ( 2.ray.serve.AutoscalingConfigRautoscalingConfig version ( Rversion? user_configured_option_names ( RuserConfiguredOptionNames? logging_config ( 2.ray.serve.LoggingConfigR loggingConfigR request_router_config ( 2.ray.serve.RequestRouterConfigRrequestRouterConfig= max_constructor_retry_count (RmaxConstructorRetryCount"È RequestMetadata request_id ( R requestId. internal_request_id ( RinternalRequestId call_method ( R callMethodA context ( 2'.ray.serve.RequestMetadata.ContextEntryRcontext0 multiplexed_model_id ( RmultiplexedModelId route ( Rroute: ContextEntry key ( Rkey value ( Rvalue:8"$ RequestWrapper body ( Rbody"Y UpdatedObject' object_snapshot ( RobjectSnapshot snapshot_id (R snapshotId"» LongPollRequestb keys_to_snapshot_ids ( 21.ray.serve.LongPollRequest.KeysToSnapshotIdsEntryRkeysToSnapshotIdsD KeysToSnapshotIdsEntry key ( Rkey value (Rvalue:8"Å LongPollResultV updated_objects ( 2-.ray.serve.LongPollResult.UpdatedObjectsEntryRupdatedObjects[ UpdatedObjectsEntry key ( Rkey. value ( 2.ray.serve.UpdatedObjectRvalue:8"Á EndpointInfo# endpoint_name ( R endpointName route ( Rroute; config ( 2#.ray.serve.EndpointInfo.ConfigEntryRconfig9 ConfigEntry key ( Rkey value ( Rvalue:8"© EndpointSetC endpoints ( 2%.ray.serve.EndpointSet.EndpointsEntryR endpointsU EndpointsEntry key ( Rkey- value ( 2.ray.serve.EndpointInfoRvalue:8"% ActorNameList names ( Rnames"^ DeploymentTargetInfo# replica_names ( R replicaNames! is_available (R isAvailable"Ñ DeploymentVersion! code_version ( R codeVersionH deployment_config ( 2.ray.serve.DeploymentConfigRdeploymentConfig* ray_actor_options ( RrayActorOptions6 placement_group_bundles ( RplacementGroupBundles8 placement_group_strategy ( RplacementGroupStrategy1 max_replicas_per_node (RmaxReplicasPerNode"õ ReplicaConfig. deployment_def_name ( RdeploymentDefName% deployment_def ( R deploymentDef init_args ( RinitArgs init_kwargs ( R initKwargs* ray_actor_options ( RrayActorOptions6 placement_group_bundles ( RplacementGroupBundles8 placement_group_strategy ( RplacementGroupStrategy1 max_replicas_per_node (RmaxReplicasPerNode"µ DeploymentInfo name ( RnameH deployment_config ( 2.ray.serve.DeploymentConfigRdeploymentConfig? replica_config ( 2.ray.serve.ReplicaConfigR replicaConfig" start_time_ms (R startTimeMs actor_name ( R actorName version ( Rversion end_time_ms (R endTimeMs' target_capacity (RtargetCapacity^ target_capacity_direction (2".ray.serve.TargetCapacityDirectionRtargetCapacityDirection"k DeploymentRouteB deployment_info ( 2.ray.serve.DeploymentInfoRdeploymentInfo route ( Rroute"^ DeploymentRouteListG deployment_routes ( 2.ray.serve.DeploymentRouteRdeploymentRoutes"Ä DeploymentStatusInfo name ( Rname3 status (2.ray.serve.DeploymentStatusRstatus message ( RmessageI status_trigger (2".ray.serve.DeploymentStatusTriggerR statusTrigger"s DeploymentStatusInfoListW deployment_status_infos ( 2.ray.serve.DeploymentStatusInfoRdeploymentStatusInfos"š ApplicationStatusInfo4 status (2.ray.serve.ApplicationStatusRstatus message ( Rmessage1 deployment_timestamp (RdeploymentTimestamp"» StatusOverview? app_status ( 2 .ray.serve.ApplicationStatusInfoR appStatusT deployment_statuses ( 2#.ray.serve.DeploymentStatusInfoListRdeploymentStatuses name ( Rname" ListApplicationsRequest"G ListApplicationsResponse+ application_names ( RapplicationNames" HealthzRequest"+ HealthzResponse message ( Rmessage"L UserDefinedMessage name ( Rname foo ( Rfoo num (Rnum"H UserDefinedResponse greeting ( Rgreeting num_x2 (RnumX2" UserDefinedMessage2"2 UserDefinedResponse2 greeting ( Rgreeting"T FruitAmounts orange (Rorange apple (Rapple banana (Rbanana"" FruitCosts costs (Rcosts" ArrayData nums (Rnums" StringData data ( Rdata"% ModelOutput output (Routput"¸ DeploymentArgs' deployment_name ( RdeploymentName+ deployment_config ( RdeploymentConfig% replica_config ( R replicaConfig& deployer_job_id ( R deployerJobId& route_prefix ( HR routePrefixˆ ingress (Ringress docs_path ( HRdocsPathˆB _route_prefixB _docs_path"I ApplicationArgs6 external_scaler_enabled (RexternalScalerEnabled*" EncodingType TEXT JSON** DeploymentLanguage PYTHON JAVA*6 TargetCapacityDirection UNSET UP DOWN*Û DeploymentStatus DEPLOYMENT_STATUS_UPDATING DEPLOYMENT_STATUS_HEALTHY DEPLOYMENT_STATUS_UNHEALTHY# DEPLOYMENT_STATUS_DEPLOY_FAILED DEPLOYMENT_STATUS_UPSCALING! DEPLOYMENT_STATUS_DOWNSCALING*þ DeploymentStatusTrigger) %DEPLOYMENT_STATUS_TRIGGER_UNSPECIFIED3 /DEPLOYMENT_STATUS_TRIGGER_CONFIG_UPDATE_STARTED5 1DEPLOYMENT_STATUS_TRIGGER_CONFIG_UPDATE_COMPLETED/ +DEPLOYMENT_STATUS_TRIGGER_UPSCALE_COMPLETED1 -DEPLOYMENT_STATUS_TRIGGER_DOWNSCALE_COMPLETED) %DEPLOYMENT_STATUS_TRIGGER_AUTOSCALING4 0DEPLOYMENT_STATUS_TRIGGER_REPLICA_STARTUP_FAILED1 -DEPLOYMENT_STATUS_TRIGGER_HEALTH_CHECK_FAILED, (DEPLOYMENT_STATUS_TRIGGER_INTERNAL_ERROR& "DEPLOYMENT_STATUS_TRIGGER_DELETING *â ApplicationStatus APPLICATION_STATUS_DEPLOYING APPLICATION_STATUS_RUNNING$ APPLICATION_STATUS_DEPLOY_FAILED APPLICATION_STATUS_DELETING" APPLICATION_STATUS_NOT_STARTED APPLICATION_STATUS_UNHEALTHY2³ RayServeAPIService[ ListApplications".ray.serve.ListApplicationsRequest#.ray.serve.ListApplicationsResponse@ Healthz.ray.serve.HealthzRequest.ray.serve.HealthzResponse2à UserDefinedServiceI __call__.ray.serve.UserDefinedMessage.ray.serve.UserDefinedResponseH Method1.ray.serve.UserDefinedMessage.ray.serve.UserDefinedResponseJ Method2.ray.serve.UserDefinedMessage2.ray.serve.UserDefinedResponse2L Streaming.ray.serve.UserDefinedMessage.ray.serve.UserDefinedResponse02L FruitService< FruitStand.ray.serve.FruitAmounts.ray.serve.FruitCosts2˜ RayServeBenchmarkService9 grpc_call.ray.serve.ArrayData.ray.serve.ModelOutputA call_with_string.ray.serve.StringData.ray.serve.ModelOutputB' io.ray.serve.generatedB ServeProtosPbproto3Ú EncodingTypeÚDeploymentLanguageÚTargetCapacityDirectionÚDeploymentStatusÚDeploymentStatusTriggerÚApplicationStatusééééééééé ÚAutoscalingPolicyÚAutoscalingConfigÚ LoggingConfigÚRequestRouterConfigÚDeploymentConfigÚRequestMetadataÚ ContextEntryÚRequestWrapperÚ UpdatedObjectÚLongPollRequestÚKeysToSnapshotIdsEntryÚLongPollResultÚUpdatedObjectsEntryÚ EndpointInfoÚ ConfigEntryÚ EndpointSetÚEndpointsEntryÚ ActorNameListÚDeploymentTargetInfoÚDeploymentVersionÚ ReplicaConfigÚDeploymentInfoÚDeploymentRouteÚDeploymentRouteListÚDeploymentStatusInfoÚDeploymentStatusInfoListÚApplicationStatusInfoÚStatusOverviewÚListApplicationsRequestÚListApplicationsResponseÚHealthzRequestÚHealthzResponseÚUserDefinedMessageÚUserDefinedResponseÚUserDefinedMessage2ÚUserDefinedResponse2Ú FruitAmountsÚ FruitCostsÚ ArrayDataÚ StringDataÚ ModelOutputÚDeploymentArgsÚApplicationArgszray.serve.generated.serve_pb2)Ú DESCRIPTORÚ __module__)rrBrC)r!rBrC)r#rBrC)r%rBrC)r'rBrCÚRayServeAPIServiceÚUserDefinedServiceÚ FruitServiceÚRayServeBenchmarkServiceFNs' io.ray.serve.generatedB ServeProtosPs8i\i~i€iªi¬iâiåiÀiÃiÁiÄi¦é+éœéŸicifiQiTii i9 i< i„ iJ i† iª i¬ i i ià i iÆ i‹ i0 iŽ iOiiRiûi¦iýi"i$i‚i…iÖiÙiNiQiiisiuiÓiÖišiœiii¬i¯ijili…i‡iÎiÐiàiâi ii[i]i¥i§i¼i¾iðiòiFiHijili‹ii­i¯iÔi×iiiZi©i\ i_ i¢!i¤!ið!ió!i‹")¢Ú__doc__Úgoogle.protobuf.internalrÚgoogle.protobufrÚ _descriptorrÚ_descriptor_poolrÚ_messagerÚ _reflectionrÚ_symbol_databaseÚDefaultÚ_sym_dbÚAddSerializedFilerBÚenum_types_by_nameÚ _ENCODINGTYPEÚEnumTypeWrapperrÚ_DEPLOYMENTLANGUAGEr Ú_TARGETCAPACITYDIRECTIONr Ú_DEPLOYMENTSTATUSr Ú_DEPLOYMENTSTATUSTRIGGERr Ú_APPLICATIONSTATUSr ÚTEXTÚJSONÚPYTHONÚJAVAÚUNSETÚUPÚDOWNÚDEPLOYMENT_STATUS_UPDATINGÚDEPLOYMENT_STATUS_HEALTHYÚDEPLOYMENT_STATUS_UNHEALTHYÚDEPLOYMENT_STATUS_DEPLOY_FAILEDÚDEPLOYMENT_STATUS_UPSCALINGÚDEPLOYMENT_STATUS_DOWNSCALINGÚ%DEPLOYMENT_STATUS_TRIGGER_UNSPECIFIEDÚ/DEPLOYMENT_STATUS_TRIGGER_CONFIG_UPDATE_STARTEDÚ1DEPLOYMENT_STATUS_TRIGGER_CONFIG_UPDATE_COMPLETEDÚ+DEPLOYMENT_STATUS_TRIGGER_UPSCALE_COMPLETEDÚ-DEPLOYMENT_STATUS_TRIGGER_DOWNSCALE_COMPLETEDÚ%DEPLOYMENT_STATUS_TRIGGER_AUTOSCALINGÚ0DEPLOYMENT_STATUS_TRIGGER_REPLICA_STARTUP_FAILEDÚ-DEPLOYMENT_STATUS_TRIGGER_HEALTH_CHECK_FAILEDÚ(DEPLOYMENT_STATUS_TRIGGER_INTERNAL_ERRORÚ"DEPLOYMENT_STATUS_TRIGGER_DELETINGÚAPPLICATION_STATUS_DEPLOYINGÚAPPLICATION_STATUS_RUNNINGÚ APPLICATION_STATUS_DEPLOY_FAILEDÚAPPLICATION_STATUS_DELETINGÚAPPLICATION_STATUS_NOT_STARTEDÚAPPLICATION_STATUS_UNHEALTHYÚmessage_types_by_nameÚ_AUTOSCALINGPOLICYÚ_AUTOSCALINGCONFIGÚ_LOGGINGCONFIGÚ_REQUESTROUTERCONFIGÚ_DEPLOYMENTCONFIGÚ_REQUESTMETADATAÚnested_types_by_nameÚ_REQUESTMETADATA_CONTEXTENTRYÚ_REQUESTWRAPPERÚ_UPDATEDOBJECTÚ_LONGPOLLREQUESTÚ'_LONGPOLLREQUEST_KEYSTOSNAPSHOTIDSENTRYÚ_LONGPOLLRESULTÚ#_LONGPOLLRESULT_UPDATEDOBJECTSENTRYÚ _ENDPOINTINFOÚ_ENDPOINTINFO_CONFIGENTRYÚ _ENDPOINTSETÚ_ENDPOINTSET_ENDPOINTSENTRYÚ_ACTORNAMELISTÚ_DEPLOYMENTTARGETINFOÚ_DEPLOYMENTVERSIONÚ_REPLICACONFIGÚ_DEPLOYMENTINFOÚ_DEPLOYMENTROUTEÚ_DEPLOYMENTROUTELISTÚ_DEPLOYMENTSTATUSINFOÚ_DEPLOYMENTSTATUSINFOLISTÚ_APPLICATIONSTATUSINFOÚ_STATUSOVERVIEWÚ_LISTAPPLICATIONSREQUESTÚ_LISTAPPLICATIONSRESPONSEÚ_HEALTHZREQUESTÚ_HEALTHZRESPONSEÚ_USERDEFINEDMESSAGEÚ_USERDEFINEDRESPONSEÚ_USERDEFINEDMESSAGE2Ú_USERDEFINEDRESPONSE2Ú _FRUITAMOUNTSÚ _FRUITCOSTSÚ _ARRAYDATAÚ _STRINGDATAÚ _MODELOUTPUTÚ_DEPLOYMENTARGSÚ_APPLICATIONARGSÚGeneratedProtocolMessageTypeÚMessagerÚRegisterMessagerrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rAÚservices_by_nameÚ_RAYSERVEAPISERVICEÚ_USERDEFINEDSERVICEÚ _FRUITSERVICEÚ_RAYSERVEBENCHMARKSERVICEÚ_USE_C_DESCRIPTORSÚ_optionsÚ_serialized_optionsÚ_serialized_startÚ_serialized_end©rµrµúZ/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/ray/serve/generated/serve_pb2.pyÚs`                                                              þ  þ  þ  þ  þ   þ÷  þ  þ   þ÷   þ÷   þ÷   þ÷  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ  þ       ‰