
    &`i_H                        d Z ddlZddlmZ  G d de          Z G d de          Zd	 Z G d
 de          Z	 G d de          Z
 G d de          Zd Z G d de          Z G d de          Z G d de          Zd Z G d de          Z G d de          Z G d de          Zd Z G 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 ZdS )RayServeAPIServiceStub8Missing associated documentation comment in .proto file.c                     |                     dt          j        j        t          j        j                  | _        |                     dt          j        j        t          j        j                  | _	        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channels     v/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/serve/generated/serve_pb2_grpc.py__init__zRayServeAPIServiceStub.__init__   sm     !( 3 3@#J#b#t&M&f&q !4 ! !
 **7#J#Y#k&M&]&h +      N__name__
__module____qualname____doc__r    r   r   r   r      )        BB    r   r   c                       e Zd ZdZd Zd ZdS )RayServeAPIServiceServicerr   c                     |                     t          j        j                   |                    d           t          d          r   zMethod not implemented!set_codegrpc
StatusCodeUNIMPLEMENTEDset_detailsNotImplementedErrorr   requestcontexts      r   r   z+RayServeAPIServiceServicer.ListApplications    ?    67775666!";<<<r   c                     |                     t          j        j                   |                    d           t          d          r)   r*   r1   s      r   r   z"RayServeAPIServiceServicer.Healthz&   r4   r   N)r    r!   r"   r#   r   r   r$   r   r   r'   r'      8        BB= = == = = = =r   r'   c                 F   t          j        | j        t          j        j        t          j        j                  t          j        | j        t          j	        j        t          j
        j                  d}t          j        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_handlers       r   (add_RayServeAPIServiceServicer_to_serverrC   -   s     $ C-)P)h)s(O(h(z! ! !
 :$)P)_)j(O(_(q    :*,?A AO
##_$677777r   c                   b    e Zd ZdZe	 	 	 	 	 	 	 	 dd            Ze	 	 	 	 	 	 	 	 dd            ZdS )RayServeAPIServicer   r$   NFc
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )Nr
   )r,   experimentalr   r   r   r   r   r   
r2   targetoptionschannel_credentialscall_credentialsinsecurecompressionwait_for_readytimeoutmetadatas
             r   r   z#RayServeAPIService.ListApplicationsC   sO      ,,Wf>n3K]3LW(&^Wh	X X 	Xr   c
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )Nr   )r,   rG   r   r   r   r   r   r   rH   s
             r   r   zRayServeAPIService.HealthzT   sO      ,,Wf>e3BT3CN(&^Wh	X X 	Xr   r$   NNFNNNN)r    r!   r"   r#   staticmethodr   r   r$   r   r   rE   rE   @           BB  $!X X X \X    $!X X X \X X Xr   rE   c                       e Zd ZdZd ZdS )UserDefinedServiceStubr   c                    |                     dt          j        j        t          j        j                  | _        |                     dt          j        j        t          j        j                  | _        |                     dt          j        j        t          j	        j                  | _
        |                    dt          j        j        t          j        j                  | _        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   s     r   r   zUserDefinedServiceStub.__init__i   s      ++8#J#]#o&M&a&l ,  
 **7#J#]#o&M&a&l +  
 **7#J#^#p&M&b&m +  
 !--9#J#]#o&M&a&l .  r   Nr   r$   r   r   rW   rW   f   s)        BB    r   rW   c                   *    e Zd ZdZd Zd Zd Zd ZdS )UserDefinedServiceServicerr   c                     |                     t          j        j                   |                    d           t          d          r)   r*   r1   s      r   r_   z#UserDefinedServiceServicer.__call__   r4   r   c                     |                     t          j        j                   |                    d           t          d          r)   r*   r1   s      r   r`   z"UserDefinedServiceServicer.Method1   r4   r   c                     |                     t          j        j                   |                    d           t          d          r)   r*   r1   s      r   rc   z"UserDefinedServiceServicer.Method2   r4   r   c                     |                     t          j        j                   |                    d           t          d          r)   r*   r1   s      r   re   z$UserDefinedServiceServicer.Streaming   r4   r   N)r    r!   r"   r#   r_   r`   rc   re   r$   r   r   rg   rg      sV        BB= = == = == = == = = = =r   rg   c                 *   t          j        | j        t          j        j        t          j        j                  t          j        | j        t          j        j        t          j        j                  t          j        | j	        t          j
        j        t          j        j                  t          j        | j        t          j        j        t          j        j                  d}t          j        d|          }|                    |f           d S )Nr8   )r_   r`   rc   re   zray.serve.UserDefinedService)r,   r;   r_   r   r]   r   r^   r   r`   rc   ra   rb   unary_stream_rpc_method_handlerre   r<   r=   r>   s       r   (add_UserDefinedServiceServicer_to_serverrn      s   ;%)P)c)n(O(c(u  
 :$)P)c)n(O(c(u  
 :$)P)d)o(O(d(v  
 =&)P)c)n(O(c(u  ! , :*,?A AO
##_$677777r   c                       e Zd ZdZe	 	 	 	 	 	 	 	 d	d            Ze	 	 	 	 	 	 	 	 d	d            Ze	 	 	 	 	 	 	 	 d	d            Ze	 	 	 	 	 	 	 	 d	d            ZdS )
UserDefinedServicer   r$   NFc
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )NrY   r,   rG   r   r   r]   r   r^   r   rH   s
             r   r_   zUserDefinedService.__call__   sO      ,,Wf>f3FX3GR(&^Wh	X X 	Xr   c
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )NrZ   rr   rH   s
             r   r`   zUserDefinedService.Method1   sO      ,,Wf>e3FX3GR(&^Wh	X X 	Xr   c
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )Nr[   )r,   rG   r   r   ra   r   rb   r   rH   s
             r   rc   zUserDefinedService.Method2   sO      ,,Wf>e3GY3HS(&^Wh	X X 	Xr   c
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )Nr\   )r,   rG   rd   r   r]   r   r^   r   rH   s
             r   re   zUserDefinedService.Streaming   sO      --gv?h3FX3GR(&^Wh	X X 	Xr   rS   )	r    r!   r"   r#   rT   r_   r`   rc   re   r$   r   r   rp   rp      s       BB  $!X X X \X    $!X X X \X    $!X X X \X    $!X X X \X X Xr   rp   c                       e Zd ZdZd ZdS )FruitServiceStubr   c                 |    |                     dt          j        j        t          j        j                  | _        dS )r	   "/ray.serve.FruitService/FruitStandr   N)r   r   FruitAmountsr   
FruitCostsr   
FruitStandr   s     r   r   zFruitServiceStub.__init__	  s9     "--4#J#W#i&M&X&c .  r   Nr   r$   r   r   rw   rw     s)        BB
 
 
 
 
r   rw   c                       e Zd ZdZd ZdS )FruitServiceServicerr   c                     |                     t          j        j                   |                    d           t          d          r)   r*   r1   s      r   r|   zFruitServiceServicer.FruitStand  r4   r   N)r    r!   r"   r#   r|   r$   r   r   r~   r~     s)        BB= = = = =r   r~   c                     dt          j        | j        t          j        j        t          j        j                  i}t          j        d|          }|	                    |f           d S )Nr|   r8   zray.serve.FruitService)
r,   r;   r|   r   rz   r   r{   r   r<   r=   r>   s       r   "add_FruitServiceServicer_to_serverr      sp    $=')P)])h(O(Z(l   :$&9; ;O
##_$677777r   c                   :    e Zd ZdZe	 	 	 	 	 	 	 	 dd            ZdS )FruitServicer   r$   NFc
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )Nry   )r,   rG   r   r   rz   r   r{   r   rH   s
             r   r|   zFruitService.FruitStand1  sO      ,,Wf>b3@R3>I(&^Wh	X X 	Xr   rS   )r    r!   r"   r#   rT   r|   r$   r   r   r   r   .  sX        BB  $!X X X \X X Xr   r   c                       e Zd ZdZd ZdS )RayServeBenchmarkServiceStubr   c                     |                     dt          j        j        t          j        j                  | _        |                     dt          j        j        t          j        j                  | _        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   s     r   r   z%RayServeBenchmarkServiceStub.__init__F  so     !,,?#J#T#f&M&Y&d -  
 !( 3 3F#J#U#g&M&Y&d !4 ! !r   Nr   r$   r   r   r   r   C  r%   r   r   c                       e Zd ZdZd Zd ZdS ) RayServeBenchmarkServiceServicerr   c                     |                     t          j        j                   |                    d           t          d          r)   r*   r1   s      r   r   z*RayServeBenchmarkServiceServicer.grpc_call[  r4   r   c                     |                     t          j        j                   |                    d           t          d          r)   r*   r1   s      r   r   z1RayServeBenchmarkServiceServicer.call_with_stringa  r4   r   N)r    r!   r"   r#   r   r   r$   r   r   r   r   X  r6   r   r   c                 F   t          j        | j        t          j        j        t          j        j                  t          j        | j        t          j	        j        t          j        j                  d}t          j
        d|          }|                    |f           d S )Nr8   )r   r   z"ray.serve.RayServeBenchmarkService)r,   r;   r   r   r   r   r   r   r   r   r<   r=   r>   s       r   .add_RayServeBenchmarkServiceServicer_to_serverr   h  s    <&)P)Z)e(O([(m  
 !% C-)P)[)f(O([(m! ! !  :02EG GO
##_$677777r   c                   b    e Zd ZdZe	 	 	 	 	 	 	 	 dd            Ze	 	 	 	 	 	 	 	 dd            ZdS )RayServeBenchmarkServicer   r$   NFc
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )Nr   )r,   rG   r   r   r   r   r   r   rH   s
             r   r   z"RayServeBenchmarkService.grpc_call~  sO      ,,Wf>m3=O3?J(&^Wh	X X 	Xr   c
                     t           j                            | |dt          j        j        t          j        j        ||||||||	          S )Nr   )r,   rG   r   r   r   r   r   r   rH   s
             r   r   z)RayServeBenchmarkService.call_with_string  sO      ,,Wf>t3>P3?J(&^Wh	X X 	Xr   rS   )r    r!   r"   r#   rT   r   r   r$   r   r   r   r   {  rU   r   r   )r#   r,    r   r   objectr   r'   rC   rE   rW   rg   rn   rp   rw   r~   r   r   r   r   r   r   r$   r   r   <module>r      s   K K  B B B B B B    V   *= = = = = = = = 8 8 8&#X #X #X #X #X #X #X #XL    V   >= = = = = = = =88 8 8:EX EX EX EX EX EX EX EXP    v    = = = = =6 = = =
8 
8 
8X X X X X6 X X X*    6   *= = = = =v = = = 8 8 8&#X #X #X #X #Xv #X #X #X #X #Xr   