a
    !fF                     @   s  d dl Z e jd  dk rdd p$dd Zd dlmZ d dlmZ d dlmZ	 d d	lm
Z d d
lmZ e Zd dlmZ d dlmZ d dlmZ d dlmZ ejdddedejejejejgdZee ejdddedejddd dddddedddddddddejdddd d!d"ddddddddddejd#d$d dd!d"ddddddddddejd%d&dd'dd ddd dddddddgg g g dddg g d(d)d*Z ejd+d,dedejd-d.d dd/dddeddddddddejd0d1dd d!d"ddddddddddejd2d3d dd!d"ddddddddddejd4d5dd'dd ddd dddddddejd6d7d'd8ddddg dddddddejd9d:d8d;d/dddeddddddddejd<d=d;d>d8dddd dddddddejd?d@d>dAdAd>ddddddddddejdBdCdAddAd>ddddddddddg	g g g dddg ej!dDdEd dg dFgdGdHd*Z"ejdIdJdedejdKdLd dd!d"ddg dddddddejdMdNdd d/dddeddddddddgg e"gg dddg g dOdHd*Z#ejdPdQdedejddRd dddddedddddddddgg g g dddg g dSdTd*Z$ejdUdVdedejd-dWd dd/dddeddddddddejdXdYdd dd ddd dddddddgg g g dddg g dZd[d*Z%ejd\d]dedejdd^d dddddedddddddddejd-d_dd d/dddeddddddddejd`dad dd!d"ddg dddddddgg g g dddg g dbdcd*Z&ejdddededg g g g dddg g dfdgd*Z'ejdhdidedejd-djd dd/dddeddddddddejd`dkdd d!d"ddg dddddddgg g g dddg g dldmd*Z(ejdndodedejddpd dddddedddddddddejdqdrdd d!d"ddg dddddddgg e(gg dddg g dsdmd*Z)ejdhdtdedejdudvd ddd ddd dddddddejdwdxdd d!d"ddddddddddgg g g dddg g dydzd*Z*ejd{d|dedejdqd}d dd!d"ddg dddddddgg e*gg dddg g d~dzd*Z+ejdddedejddd dddddedddddddddejd-ddd d/dddeddddddddejddd d;d!d"ddddddddddejdddd'd!d"ddg dddddddejddd'd8d!d"ddg dddddddgg g g dddg g ddd*Z,ejdddedejddd ddAd>ddddddddddgg g g dddg g ddd*Z-ejdddedejddd dddddedddddddddejd-ddd d/dddeddddddddejddd dd!d"ddg dddddddgg g g dddg g ddd*Z.ejdddedejddd dd!d"ddddddddddgg g g dddg g ddd*Z/ej0e j1d _2ej3e j1d# _2ej4e"j1d0 _2ej5e"j1d2 _2e#e"_6e"j7dD j89e"j1d?  e"j7dD e"j1d? _:e"j7dD j89e"j1dB  e"j7dD e"j1dB _:e"e#j1dK _2ej;e&j1d` _2ej;e(j1d` _2e)e(_6e(e)j1dq _2ej<e*j1dw _2e+e*_6e*e+j1dq _2ej3e,j1d _2ej;e,j1d _2ej;e,j1d _2ej=e.j1d _2ej>e/j1d _2e ej?d< e#ej?dI< e$ej?dP< e%ej?dU< e&ej?d\< e'ej?dd< e)ej?dn< e+ej?d{< e,ej?d< e-ej?d< e.ej?d< e/ej?d< e	@dejAfeBe ddZCeDeC e	@dIejAfeBe	@d+ejAfeBe"dde#ddZEeDeE eDeEjF e	@dPejAfeBe$ddZGeDeG e	@dUejAfeBe%ddZHeDeH e	@d\ejAfeBe&ddZIeDeI e	@ddejAfeBe'ddZJeDeJ e	@dnejAfeBe	@dhejAfeBe(dde)ddZKeDeK eDeKjL e	@d{ejAfeBe	@dhejAfeBe*dde+ddZMeDeM eDeMjL e	@dejAfeBe,ddZNeDeN e	@dejAfeBe-ddZOeDeO e	@dejAfeBe.ddZPeDeP e	@dejAfeBe/ddZQeDeQ de_ReSeT ede_Ud dlVmWZX d dlVmYZZ d dl[m\Z\ d dl]m^Z_ G dd de`ZaG dd de`Zbdd ZcG dd de`ZdG dd de`ZedddZfdddZgdS )    N   c                 C   s   | S )N xr   r   h/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/bigtable/_generated/bigtable_pb2.py<lambda>       r   c                 C   s
   |  dS )Nlatin1)encoder   r   r   r   r      r   )
descriptor)message)
reflection)symbol_database)descriptor_pb2)annotations_pb2)data_pb2)wrappers_pb2)
status_pb2z!google/bigtable/v2/bigtable.protozgoogle.bigtable.v2Zproto3uS  
!google/bigtable/v2/bigtable.protogoogle.bigtable.v2google/api/annotations.protogoogle/bigtable/v2/data.protogoogle/protobuf/wrappers.protogoogle/rpc/status.proto"
ReadRowsRequest

table_name (	(
rows (2.google.bigtable.v2.RowSet-
filter (2.google.bigtable.v2.RowFilter

rows_limit ("ø
ReadRowsResponse>
chunks (2..google.bigtable.v2.ReadRowsResponse.CellChunk
last_scanned_row_key (
	CellChunk
row_key (1
family_name (2.google.protobuf.StringValue.
	qualifier (2.google.protobuf.BytesValue
timestamp_micros (
labels (	
value (

value_size (
	reset_row (H 

commit_row	 (H B

row_status"*
SampleRowKeysRequest

table_name (	">
SampleRowKeysResponse
row_key (
offset_bytes ("h
MutateRowRequest

table_name (	
row_key (/
	mutations (2.google.bigtable.v2.Mutation"
MutateRowResponse"°
MutateRowsRequest

table_name (	<
entries (2+.google.bigtable.v2.MutateRowsRequest.EntryI
Entry
row_key (/
	mutations (2.google.bigtable.v2.Mutation"
MutateRowsResponse=
entries (2,.google.bigtable.v2.MutateRowsResponse.Entry:
Entry
index ("
status (2.google.rpc.Status"å
CheckAndMutateRowRequest

table_name (	
row_key (7
predicate_filter (2.google.bigtable.v2.RowFilter4
true_mutations (2.google.bigtable.v2.Mutation5
false_mutations (2.google.bigtable.v2.Mutation"6
CheckAndMutateRowResponse
predicate_matched ("x
ReadModifyWriteRowRequest

table_name (	
row_key (6
rules (2'.google.bigtable.v2.ReadModifyWriteRule"B
ReadModifyWriteRowResponse$
row (2.google.bigtable.v2.Row2­
Bigtable
ReadRows#.google.bigtable.v2.ReadRowsRequest$.google.bigtable.v2.ReadRowsResponse"DÓä>"9/v2/{table_name=projects/*/instances/*/tables/*}:readRows:*0®
SampleRowKeys(.google.bigtable.v2.SampleRowKeysRequest).google.bigtable.v2.SampleRowKeysResponse"FÓä@>/v2/{table_name=projects/*/instances/*/tables/*}:sampleRowKeys0
	MutateRow$.google.bigtable.v2.MutateRowRequest%.google.bigtable.v2.MutateRowResponse"EÓä?":/v2/{table_name=projects/*/instances/*/tables/*}:mutateRow:*¥

MutateRows%.google.bigtable.v2.MutateRowsRequest&.google.bigtable.v2.MutateRowsResponse"FÓä@";/v2/{table_name=projects/*/instances/*/tables/*}:mutateRows:*0¿
CheckAndMutateRow,.google.bigtable.v2.CheckAndMutateRowRequest-.google.bigtable.v2.CheckAndMutateRowResponse"MÓäG"B/v2/{table_name=projects/*/instances/*/tables/*}:checkAndMutateRow:*Ã
ReadModifyWriteRow-.google.bigtable.v2.ReadModifyWriteRowRequest..google.bigtable.v2.ReadModifyWriteRowResponse"NÓäH"C/v2/{table_name=projects/*/instances/*/tables/*}:readModifyWriteRow:*B)
com.google.bigtable.v2BBigtableProtoPbproto3)namepackagesyntaxZserialized_pbdependenciesReadRowsRequestz"google.bigtable.v2.ReadRowsRequestZ
table_namez-google.bigtable.v2.ReadRowsRequest.table_name   	   F zutf-8)r   	full_nameindexnumbertypeZcpp_typelabelZhas_default_valuedefault_valuemessage_typeZ	enum_typecontaining_typeZis_extensionZextension_scopeoptionsrowsz'google.bigtable.v2.ReadRowsRequest.rows      
   filterz)google.bigtable.v2.ReadRowsRequest.filterZ
rows_limitz-google.bigtable.v2.ReadRowsRequest.rows_limit      iB  )r   r   filenamefiler#   fields
extensionsZnested_types
enum_typesr$   Zis_extendabler   Zextension_rangesZoneofsZserialized_startZserialized_end	CellChunkz-google.bigtable.v2.ReadRowsResponse.CellChunkZrow_keyz5google.bigtable.v2.ReadRowsResponse.CellChunk.row_key   Zfamily_namez9google.bigtable.v2.ReadRowsResponse.CellChunk.family_nameZ	qualifierz7google.bigtable.v2.ReadRowsResponse.CellChunk.qualifierZtimestamp_microsz>google.bigtable.v2.ReadRowsResponse.CellChunk.timestamp_microslabelsz4google.bigtable.v2.ReadRowsResponse.CellChunk.labels   valuez3google.bigtable.v2.ReadRowsResponse.CellChunk.value   Z
value_sizez8google.bigtable.v2.ReadRowsResponse.CellChunk.value_size   Z	reset_rowz7google.bigtable.v2.ReadRowsResponse.CellChunk.reset_row   Z
commit_rowz8google.bigtable.v2.ReadRowsResponse.CellChunk.commit_rowZ
row_statusz8google.bigtable.v2.ReadRowsResponse.CellChunk.row_status)r   r   r   r#   r.   i  i  ReadRowsResponsez#google.bigtable.v2.ReadRowsResponsechunksz*google.bigtable.v2.ReadRowsResponse.chunksZlast_scanned_row_keyz8google.bigtable.v2.ReadRowsResponse.last_scanned_row_keyiE  SampleRowKeysRequestz'google.bigtable.v2.SampleRowKeysRequestz2google.bigtable.v2.SampleRowKeysRequest.table_namei  i  SampleRowKeysResponsez(google.bigtable.v2.SampleRowKeysResponsez0google.bigtable.v2.SampleRowKeysResponse.row_keyZoffset_bytesz5google.bigtable.v2.SampleRowKeysResponse.offset_bytesi  i)  MutateRowRequestz#google.bigtable.v2.MutateRowRequestz.google.bigtable.v2.MutateRowRequest.table_namez+google.bigtable.v2.MutateRowRequest.row_keyZ	mutationsz-google.bigtable.v2.MutateRowRequest.mutationsi+  i  MutateRowResponsez$google.bigtable.v2.MutateRowResponsei  i  Entryz*google.bigtable.v2.MutateRowsRequest.Entryz2google.bigtable.v2.MutateRowsRequest.Entry.row_keyz4google.bigtable.v2.MutateRowsRequest.Entry.mutationsi  i[  MutateRowsRequestz$google.bigtable.v2.MutateRowsRequestz/google.bigtable.v2.MutateRowsRequest.table_nameentriesz,google.bigtable.v2.MutateRowsRequest.entriesi  z+google.bigtable.v2.MutateRowsResponse.Entryr   z1google.bigtable.v2.MutateRowsResponse.Entry.indexstatusz2google.bigtable.v2.MutateRowsResponse.Entry.statusi  i  MutateRowsResponsez%google.bigtable.v2.MutateRowsResponsez-google.bigtable.v2.MutateRowsResponse.entriesi^  CheckAndMutateRowRequestz+google.bigtable.v2.CheckAndMutateRowRequestz6google.bigtable.v2.CheckAndMutateRowRequest.table_namez3google.bigtable.v2.CheckAndMutateRowRequest.row_keyZpredicate_filterz<google.bigtable.v2.CheckAndMutateRowRequest.predicate_filterZtrue_mutationsz:google.bigtable.v2.CheckAndMutateRowRequest.true_mutationsZfalse_mutationsz;google.bigtable.v2.CheckAndMutateRowRequest.false_mutationsi  i  CheckAndMutateRowResponsez,google.bigtable.v2.CheckAndMutateRowResponseZpredicate_matchedz>google.bigtable.v2.CheckAndMutateRowResponse.predicate_matchedi  i  ReadModifyWriteRowRequestz,google.bigtable.v2.ReadModifyWriteRowRequestz7google.bigtable.v2.ReadModifyWriteRowRequest.table_namez4google.bigtable.v2.ReadModifyWriteRowRequest.row_keyrulesz2google.bigtable.v2.ReadModifyWriteRowRequest.rulesi  i  ReadModifyWriteRowResponsez-google.bigtable.v2.ReadModifyWriteRowResponserowz1google.bigtable.v2.ReadModifyWriteRowResponse.rowi  i  zgoogle.bigtable.v2.bigtable_pb2)
DESCRIPTOR
__module__)r1   rJ   rK   )r?   rJ   rK   Tz)
com.google.bigtable.v2BBigtableProtoP)implementations)
interfaces)cardinality)	utilitiesc                   @   s   e Zd ZdZdd ZdS )BigtableStubDService for reading from and writing to existing Bigtable tables.
  c                 C   s   |j dtjtjd| _|j dtjtjd| _|j	dt
jtjd| _|j dtjtjd| _|j	dtjtjd| _|j	dtjtjd| _dS )	z;Constructor.

    Args:
      channel: A grpc.Channel.
    z%/google.bigtable.v2.Bigtable/ReadRows)Zrequest_serializerZresponse_deserializerz*/google.bigtable.v2.Bigtable/SampleRowKeysz&/google.bigtable.v2.Bigtable/MutateRowz'/google.bigtable.v2.Bigtable/MutateRowsz./google.bigtable.v2.Bigtable/CheckAndMutateRowz//google.bigtable.v2.Bigtable/ReadModifyWriteRowN)Zunary_streamr   SerializeToStringr9   
FromStringReadRowsr;   r<   SampleRowKeysZunary_unaryr=   r>   	MutateRowr@   rC   
MutateRowsrD   rE   CheckAndMutateRowrF   rH   ReadModifyWriteRow)selfchannelr   r   r   __init__2  s<    zBigtableStub.__init__N)__name__rK   __qualname____doc__r\   r   r   r   r   rP   .  s   rP   c                   @   s@   e Zd ZdZdd Zdd Zdd Zdd	 Zd
d Zdd Z	dS )BigtableServicerrQ   c                 C   s$   | tjj |d tddS )4  Streams back the contents of all requested rows, optionally
    applying the same Reader filter to each. Depending on their size,
    rows and cells may be broken up across multiple responses, but
    atomicity of each row will still be preserved. See the
    ReadRowsResponse documentation for details.
    Method not implemented!NZset_codegrpc
StatusCodeUNIMPLEMENTEDZset_detailsNotImplementedErrorrZ   requestcontextr   r   r   rT   \  s    
zBigtableServicer.ReadRowsc                 C   s$   | tjj |d tddS )Returns a sample of row keys in the table. The returned row keys will
    delimit contiguous sections of the table of approximately equal size,
    which can be used to break up the data for distributed tasks like
    mapreduces.
    rb   Nrc   rh   r   r   r   rU   g  s    
zBigtableServicer.SampleRowKeysc                 C   s$   | tjj |d tddS )Mutates a row atomically. Cells already present in the row are left
    unchanged unless explicitly changed by `mutation`.
    rb   Nrc   rh   r   r   r   rV   q  s    
zBigtableServicer.MutateRowc                 C   s$   | tjj |d tddS )Mutates multiple rows in a batch. Each individual row is mutated
    atomically as in MutateRow, but the entire batch is not executed
    atomically.
    rb   Nrc   rh   r   r   r   rW   y  s    
zBigtableServicer.MutateRowsc                 C   s$   | tjj |d tddS )OMutates a row atomically based on the output of a predicate Reader filter.
    rb   Nrc   rh   r   r   r   rX     s    
z"BigtableServicer.CheckAndMutateRowc                 C   s$   | tjj |d tddS )h  Modifies a row atomically. The method reads the latest existing timestamp
    and value from the specified columns and writes a new entry based on
    pre-defined read/modify/write rules. The new value for the timestamp is the
    greater of the existing timestamp or the current server time. The method
    returns the new contents of all modified cells.
    rb   Nrc   rh   r   r   r   rY     s    
z#BigtableServicer.ReadModifyWriteRowN
r]   rK   r^   r_   rT   rU   rV   rW   rX   rY   r   r   r   r   r`   X  s   
	r`   c              
   C   s   t j| jtjtjdt j| jtjt	jdt j
| jtjtjdt j| jtjtjdt j
| jtjtjdt j
| jtjtjdd}t d|}||f d S )N)Zrequest_deserializerZresponse_serializer)rT   rU   rV   rW   rX   rY   google.bigtable.v2.Bigtable)rd   Zunary_stream_rpc_method_handlerrT   r   rS   r9   rR   rU   r;   r<   Zunary_unary_rpc_method_handlerrV   r=   r>   rW   r@   rC   rX   rD   rE   rY   rF   rH   Zmethod_handlers_generic_handlerZadd_generic_rpc_handlers)servicerserverZrpc_method_handlersZgeneric_handlerr   r   r   add_BigtableServicer_to_server  sF     rt   c                   @   s@   e Zd ZdZdd Zdd Zdd Zdd	 Zd
d Zdd Z	dS )BetaBigtableServicerrQ   c                 C   s   | tjj dS ra   Ncodebeta_interfacesre   rf   rh   r   r   r   rT     s    zBetaBigtableServicer.ReadRowsc                 C   s   | tjj dS rk   Nrw   rh   r   r   r   rU     s    z"BetaBigtableServicer.SampleRowKeysc                 C   s   | tjj dS rl   Nrw   rh   r   r   r   rV     s    zBetaBigtableServicer.MutateRowc                 C   s   | tjj dS rm   Nrw   rh   r   r   r   rW     s    zBetaBigtableServicer.MutateRowsc                 C   s   | tjj dS rn   Nrw   rh   r   r   r   rX     s    z&BetaBigtableServicer.CheckAndMutateRowc                 C   s   | tjj dS ro   Nrw   rh   r   r   r   rY     s    z'BetaBigtableServicer.ReadModifyWriteRowNrp   r   r   r   r   ru     s   ru   c                   @   s^   e Zd ZdZdddZdddZddd	Zde_dd
dZdddZ	de	_dddZ
de
_dS )BetaBigtableStubrQ   NFc                 C   s
   t  dS rv   rg   rZ   ri   timeoutmetadataZ	with_callZprotocol_optionsr   r   r   rT     s    zBetaBigtableStub.ReadRowsc                 C   s
   t  dS rz   r   r   r   r   r   rU     s    zBetaBigtableStub.SampleRowKeysc                 C   s
   t  dS r{   r   r   r   r   r   rV     s    zBetaBigtableStub.MutateRowc                 C   s
   t  dS r|   r   r   r   r   r   rW     s    zBetaBigtableStub.MutateRowsc                 C   s
   t  dS r}   r   r   r   r   r   rX     s    z"BetaBigtableStub.CheckAndMutateRowc                 C   s
   t  dS r~   r   r   r   r   r   rY   	  s    z#BetaBigtableStub.ReadModifyWriteRow)NFN)NFN)NFN)NFN)NFN)NFN)r]   rK   r^   r_   rT   rU   rV   futurerW   rX   rY   r   r   r   r   r     s   





r   c           	      C   s   t jtjtjtjtjtjd}tjt	jt
jtjtjtjd}t| jt| jt| jt| jt| jt| jd}tj||||||d}tj||dS )N)rq   rX   )rq   rV   )rq   rW   )rq   rY   )rq   rT   )rq   rU   )request_deserializersresponse_serializersthread_poolthread_pool_sizedefault_timeoutmaximum_timeoutr$   )rD   rS   r=   r@   rF   r   r;   rE   rR   r>   rC   rH   r9   r<   face_utilitiesZunary_unary_inlinerX   rV   Zunary_stream_inlinerW   rY   rT   rU   beta_implementationsserver_optionsrs   )	rr   pool	pool_sizer   r   r   r   Zmethod_implementationsr   r   r   r   beta_create_Bigtable_server  s.    		





r   c           	      C   s   t jtjtjtjtjtjd}tjt	jt
jtjtjtjd}tjjtjjtjjtjjtjjtjjd}tj||||||d}tj| d||dS )Nr   )rX   rV   rW   rY   rT   rU   )hostmetadata_transformerrequest_serializersresponse_deserializersr   r   rq   r   )rD   rR   r=   r@   rF   r   r;   rE   rS   r>   rC   rH   r9   r<   rN   ZCardinalityZUNARY_UNARYZUNARY_STREAMr   stub_optionsZdynamic_stub)	r[   r   r   r   r   r   r   Zcardinalitiesr   r   r   r   beta_create_Bigtable_stub1  s.    		r   )NNNN)NNNN)hsysversion_info_bZgoogle.protobufr   Z_descriptorr   _messager   Z_reflectionr   Z_symbol_databaser   ZDefaultZ_sym_dbZ
google.apir   Z#google_dot_api_dot_annotations__pb2Zgcloud.bigtable._generatedr   Z(google_dot_bigtable_dot_v2_dot_data__pb2r   Z%google_dot_protobuf_dot_wrappers__pb2Z
google.rpcr   Zgoogle_dot_rpc_dot_status__pb2ZFileDescriptorrJ   ZRegisterFileDescriptorZ
DescriptorZFieldDescriptordecodeZ_READROWSREQUESTZOneofDescriptorZ_READROWSRESPONSE_CELLCHUNKZ_READROWSRESPONSEZ_SAMPLEROWKEYSREQUESTZ_SAMPLEROWKEYSRESPONSEZ_MUTATEROWREQUESTZ_MUTATEROWRESPONSEZ_MUTATEROWSREQUEST_ENTRYZ_MUTATEROWSREQUESTZ_MUTATEROWSRESPONSE_ENTRYZ_MUTATEROWSRESPONSEZ_CHECKANDMUTATEROWREQUESTZ_CHECKANDMUTATEROWRESPONSEZ_READMODIFYWRITEROWREQUESTZ_READMODIFYWRITEROWRESPONSEZ_ROWSETZfields_by_namer"   Z
_ROWFILTERZ_STRINGVALUEZ_BYTESVALUEr#   Zoneofs_by_namer.   appendZcontaining_oneofZ	_MUTATIONZ_STATUSZ_READMODIFYWRITERULEZ_ROWZmessage_types_by_nameZGeneratedProtocolMessageTypeMessagedictr   ZRegisterMessager9   r1   r;   r<   r=   r>   r@   r?   rC   rD   rE   rF   rH   Zhas_optionsZ_ParseOptionsZFileOptions_optionsZ	grpc.betarL   r   rM   ry   Zgrpc.framework.commonrN   Zgrpc.framework.interfaces.facerO   r   objectrP   r`   rt   ru   r   r   r   r   r   r   r   <module>   s  
4AY&	&-%&%	%;	-	























*=&+.
