
    ZThN                     d    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	y)zEClient and server classes corresponding to protobuf-defined services.    N)
ingest_pb2c                       e Zd ZdZd Zy)IngestServiceStub8Missing associated documentation comment in .proto file.c                 (   |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j                  j                  t        j                  j
                        | _	        y)zIConstructor.

        Args:
            channel: A grpc.Channel.
        8/sift.ingest.v1.IngestService/IngestWithConfigDataStream)request_serializerresponse_deserializer?/sift.ingest.v1.IngestService/IngestArbitraryProtobufDataStreamN)
stream_unary&sift_dot_ingest_dot_v1_dot_ingest__pb2!IngestWithConfigDataStreamRequestSerializeToString"IngestWithConfigDataStreamResponse
FromStringIngestWithConfigDataStream(IngestArbitraryProtobufDataStreamRequest)IngestArbitraryProtobufDataStreamResponse!IngestArbitraryProtobufDataStream)selfchannels     c/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift/ingest/v1/ingest_pb2_grpc.py__init__zIngestServiceStub.__init__   s     +2*>*>J#I#k#k#}#}&L&o&o&z&z +? +'
 291E1EQ#I#r#r  $E  $E&L&v&v  'B  'B 2F 2.    N)__name__
__module____qualname____doc__r    r   r   r   r      s
    Br   r   c                       e Zd ZdZd Zd Zy)IngestServiceServicerr   c                     |j                  t        j                  j                         |j	                  d       t        d      r   zMethod not implemented!set_codegrpc
StatusCodeUNIMPLEMENTEDset_detailsNotImplementedErrorr   request_iteratorcontexts      r   r   z0IngestServiceServicer.IngestWithConfigDataStream    5    66756!";<<r   c                     |j                  t        j                  j                         |j	                  d       t        d      r#   r$   r+   s      r   r   z7IngestServiceServicer.IngestArbitraryProtobufDataStream&   r.   r   N)r   r   r   r   r   r   r   r   r   r!   r!      s    B==r   r!   c                    t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        d}t        j                  d|      }|j                  |f       y )N)request_deserializerresponse_serializer)r   r   zsift.ingest.v1.IngestService)r&   stream_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_IngestServiceServicer_to_serverr:   -   s    *.*N*N77)O)q)q)|)|(N(q(q  )D  )D+
 261U1U>>)O)x)x  *D  *D(N(x(x  )K  )K2 ::*,?AO
##_$67r   c                   T    e Zd ZdZe	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Zy)IngestServicer   Nc
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r&   experimentalr   r   r   r   r   r   
r,   targetoptionschannel_credentialscall_credentialsinsecurecompressionwait_for_readytimeoutmetadatas
             r   r   z(IngestService.IngestWithConfigDataStreamC   s]       --.>  IC2TTff2UU``(&^Wh	X 	Xr   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r&   r>   r   r   r   r   r   r   r?   s
             r   r   z/IngestService.IngestArbitraryProtobufDataStreamT   s]       --.>  IJ2[[mm2\\gg(&^Wh	X 	Xr   )r   NNFNNNN)r   r   r   r   staticmethodr   r   r   r   r   r<   r<   @   sc    B  $!X X    $!X Xr   r<   )
r   r&   sift.ingest.v1r   r   objectr   r!   r:   r<   r   r   r   <module>rM      s9    K  O *=F = 8&#XF #Xr   