o
    $i_H                     @   s   d Z ddlZddlmZ G dd deZG dd deZd	d
 ZG dd deZ	G dd deZ
G dd deZdd ZG dd deZG dd deZG dd deZdd ZG dd deZG dd deZG dd  d eZd!d" ZG d#d$ d$eZdS )%zEClient and server classes corresponding to protobuf-defined services.    N   )	serve_pb2c                   @      e Zd ZdZdd ZdS )RayServeAPIServiceStub8Missing associated documentation comment in .proto file.c                 C   s8   |j dtjjtjjd| _|j dtjjtjjd| _	dS )IConstructor.

        Args:
            channel: A grpc.Channel.
        ./ray.serve.RayServeAPIService/ListApplicationsrequest_serializerresponse_deserializer%/ray.serve.RayServeAPIService/HealthzN)
unary_unary'src_dot_ray_dot_protobuf_dot_serve__pb2ListApplicationsRequestSerializeToStringListApplicationsResponse
FromStringListApplicationsHealthzRequestHealthzResponseHealthzselfchannel r   _/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/ray/serve/generated/serve_pb2_grpc.py__init__      zRayServeAPIServiceStub.__init__N__name__
__module____qualname____doc__r   r   r   r   r   r          r   c                   @       e Zd ZdZdd Zdd ZdS )RayServeAPIServiceServicerr   c                 C       | tjj |d tdr   zMethod not implemented!set_codegrpc
StatusCodeUNIMPLEMENTEDset_detailsNotImplementedErrorr   requestcontextr   r   r   r          
z+RayServeAPIServiceServicer.ListApplicationsc                 C   r&   r'   r(   r/   r   r   r   r   &   r2   z"RayServeAPIServiceServicer.HealthzN)r   r    r!   r"   r   r   r   r   r   r   r%          r%   c                 C   sR   t j| jtjjtjjdt j| jtj	jtj
jdd}t d|}||f d S )Nrequest_deserializerresponse_serializer)r   r   zray.serve.RayServeAPIService)r*   unary_unary_rpc_method_handlerr   r   r   r   r   r   r   r   r   method_handlers_generic_handleradd_generic_rpc_handlersservicerserverrpc_method_handlersgeneric_handlerr   r   r   (add_RayServeAPIServiceServicer_to_server-      r?   c                   @   L   e Zd ZdZe								d	ddZe								d	ddZdS )
RayServeAPIServicer   r   NFc
           
      C   ,   t j| |dtjjtjj||||||||	S )Nr   )r*   experimentalr   r   r   r   r   r   
r0   targetoptionschannel_credentialscall_credentialsinsecurecompressionwait_for_readytimeoutmetadatar   r   r   r   C      z#RayServeAPIService.ListApplicationsc
           
      C   rC   )Nr   )r*   rD   r   r   r   r   r   r   rE   r   r   r   r   T   rO   zRayServeAPIService.Healthzr   NNFNNNN)r   r    r!   r"   staticmethodr   r   r   r   r   r   rB   @   ,    rB   c                   @   r   )UserDefinedServiceStubr   c                 C   sl   |j dtjjtjjd| _|j dtjjtjjd| _|j dtjjtj	jd| _
|jdtjjtjjd| _dS )r   &/ray.serve.UserDefinedService/__call__r	   %/ray.serve.UserDefinedService/Method1%/ray.serve.UserDefinedService/Method2'/ray.serve.UserDefinedService/StreamingN)r   r   UserDefinedMessager   UserDefinedResponser   __call__Method1UserDefinedMessage2UserDefinedResponse2Method2unary_stream	Streamingr   r   r   r   r   i   s(   zUserDefinedServiceStub.__init__Nr   r   r   r   r   rS   f   r#   rS   c                   @   s0   e Zd ZdZdd Zdd Zdd Zdd	 Zd
S )UserDefinedServiceServicerr   c                 C   r&   r'   r(   r/   r   r   r   rZ      r2   z#UserDefinedServiceServicer.__call__c                 C   r&   r'   r(   r/   r   r   r   r[      r2   z"UserDefinedServiceServicer.Method1c                 C   r&   r'   r(   r/   r   r   r   r^      r2   z"UserDefinedServiceServicer.Method2c                 C   r&   r'   r(   r/   r   r   r   r`      r2   z$UserDefinedServiceServicer.StreamingN)r   r    r!   r"   rZ   r[   r^   r`   r   r   r   r   ra      s    ra   c                 C   s   t j| jtjjtjjdt j| jtjjtjjdt j| j	tj
jtjjdt j| jtjjtjjdd}t d|}||f d S )Nr4   )rZ   r[   r^   r`   zray.serve.UserDefinedService)r*   r7   rZ   r   rX   r   rY   r   r[   r^   r\   r]   unary_stream_rpc_method_handlerr`   r8   r9   r:   r   r   r   (add_UserDefinedServiceServicer_to_server   s2   rc   c                   @   s   e Zd ZdZe								dddZe								dddZe								dd	d
Ze								dddZdS )UserDefinedServicer   r   NFc
           
      C   rC   )NrT   r*   rD   r   r   rX   r   rY   r   rE   r   r   r   rZ      rO   zUserDefinedService.__call__c
           
      C   rC   )NrU   re   rE   r   r   r   r[      rO   zUserDefinedService.Method1c
           
      C   rC   )NrV   )r*   rD   r   r   r\   r   r]   r   rE   r   r   r   r^      rO   zUserDefinedService.Method2c
           
      C   rC   )NrW   )r*   rD   r_   r   rX   r   rY   r   rE   r   r   r   r`      rO   zUserDefinedService.StreamingrP   )	r   r    r!   r"   rQ   rZ   r[   r^   r`   r   r   r   r   rd      sT    rd   c                   @   r   )FruitServiceStubr   c                 C   s   |j dtjjtjjd| _dS )r   "/ray.serve.FruitService/FruitStandr	   N)r   r   FruitAmountsr   
FruitCostsr   
FruitStandr   r   r   r   r   	  s
   zFruitServiceStub.__init__Nr   r   r   r   r   rf     r#   rf   c                   @   r   )FruitServiceServicerr   c                 C   r&   r'   r(   r/   r   r   r   rj     r2   zFruitServiceServicer.FruitStandN)r   r    r!   r"   rj   r   r   r   r   rk     r#   rk   c                 C   s:   dt j| jtjjtjjdi}t d|}|	|f d S )Nrj   r4   zray.serve.FruitService)
r*   r7   rj   r   rh   r   ri   r   r8   r9   r:   r   r   r   "add_FruitServiceServicer_to_server   s   rl   c                   @   s.   e Zd ZdZe								dddZdS )FruitServicer   r   NFc
           
      C   rC   )Nrg   )r*   rD   r   r   rh   r   ri   r   rE   r   r   r   rj   1  rO   zFruitService.FruitStandrP   )r   r    r!   r"   rQ   rj   r   r   r   r   rm   .  s    rm   c                   @   r   )RayServeBenchmarkServiceStubr   c                 C   s8   |j dtjjtjjd| _|j dtjjtjjd| _dS )r   -/ray.serve.RayServeBenchmarkService/grpc_callr	   4/ray.serve.RayServeBenchmarkService/call_with_stringN)	r   r   	ArrayDatar   ModelOutputr   	grpc_call
StringDatacall_with_stringr   r   r   r   r   F  r   z%RayServeBenchmarkServiceStub.__init__Nr   r   r   r   r   rn   C  r#   rn   c                   @   r$   ) RayServeBenchmarkServiceServicerr   c                 C   r&   r'   r(   r/   r   r   r   rs   [  r2   z*RayServeBenchmarkServiceServicer.grpc_callc                 C   r&   r'   r(   r/   r   r   r   ru   a  r2   z1RayServeBenchmarkServiceServicer.call_with_stringN)r   r    r!   r"   rs   ru   r   r   r   r   rv   X  r3   rv   c                 C   sR   t j| jtjjtjjdt j| jtj	jtjjdd}t 
d|}||f d S )Nr4   )rs   ru   z"ray.serve.RayServeBenchmarkService)r*   r7   rs   r   rq   r   rr   r   ru   rt   r8   r9   r:   r   r   r   .add_RayServeBenchmarkServiceServicer_to_serverh  r@   rw   c                   @   rA   )
RayServeBenchmarkServicer   r   NFc
           
      C   rC   )Nro   )r*   rD   r   r   rq   r   rr   r   rE   r   r   r   rs   ~  rO   z"RayServeBenchmarkService.grpc_callc
           
      C   rC   )Nrp   )r*   rD   r   r   rt   r   rr   r   rE   r   r   r   ru     rO   z)RayServeBenchmarkService.call_with_stringrP   )r   r    r!   r"   rQ   rs   ru   r   r   r   r   rx   {  rR   rx   )r"   r*    r   r   objectr   r%   r?   rB   rS   ra   rc   rd   rf   rk   rl   rm   rn   rv   rw   rx   r   r   r   r   <module>   s&   &H
