o NDiN@sddlZGdddejZededZdeeeZ Gddde Z e j d e j d e jd e jd e jd e jde jde jde jde jde jdi e _e j e j e je je je je je je je je jd e _ddZGddde ZGddde Zejejejejej ej!ej"ej#de_ddej$De_Gddde Z%Gd d!d!e Z&Gd"d#d#e Z'Gd$d%d%e'Z(Gd&d'd'e'Z)Gd(d)d)e*Z+Gd*d+d+e+Z,Gd,d-d-e,Z-Gd.d/d/e,Z.Gd0d1d1e.Z/Gd2d3d3e.Z0Gd4d5d5e,Z1Gd6d7d7e,Z2Gd8d9d9e2Z3Gd:d;d;e2Z4Gdd?d?e+Z6Gd@dAdAe6Z7GdBdCdCe7Z8GdDdEdEe6Z9GdFdGdGe6Z:GdHdIdIe+Z;GdJdKdKe+ZGdPdQdQe*Z?dS)RNc@seZdZddZdS) NullHandlercCsdSN)selfrecordrrK/var/www/Datamplify/venv/lib/python3.10/site-packages/cassandra/__init__.pyemitszNullHandler.emitN)__name__ __module__ __qualname__rrrrrrs r cassandra).c@s^eZdZdZdZ dZ dZ dZ dZ dZ dZ d Z d Z d Z d Z ed dZdS)ConsistencyLevelz Spcifies how many replicas must respond for an operation to be considered a success. By default, ``ONE`` is used for all operations. rrr  cCs|tjkp |tjkSr)rSERIAL LOCAL_SERIAL)clrrr is_serial_zConsistencyLevel.is_serialN)r r r __doc__ANYONETWOTHREEQUORUMALL LOCAL_QUORUM EACH_QUORUMrr LOCAL_ONE staticmethodrrrrrrs4rr r!r"r#r$r%r&r'rrr() r r!r"r#r$r%r&r'rrr(cCs|dur tj|SdS)NzNot Set)r value_to_name)valuerrrconsistency_value_to_namer,c@seZdZdZdZ dZ dZ dZ dZ dZ dZ d Z e e e eeeeefZ e fZ ee Z ee Z ed d Zed d ZeddZeddZeddZeddZeddZeddZeddZdS)ProtocolVersionzD Defines native protocol versions supported by this driver. rrr rrrABcs@ztfddttjddD}W|Styd}Y|Sw)zY Return the lower supported protocol version. Beta versions are omitted. c3s&|]}|tjvr|kr|VqdSr)r. BETA_VERSIONS).0vprevious_versionrr s z6ProtocolVersion.get_lower_supported..T)reverser)nextsortedr.SUPPORTED_VERSIONS StopIteration)clsr5versionrr4rget_lower_supporteds" z#ProtocolVersion.get_lower_supportedcC ||jkSrV5r<r=rrruses_int_query_flags z$ProtocolVersion.uses_int_query_flagscC||jko ||jkSrrADSE_V1rBrrruses_prepare_flagsrz"ProtocolVersion.uses_prepare_flagscCrErrFrBrrruses_prepared_metadatarz&ProtocolVersion.uses_prepared_metadatacCr?rr@rBrrruses_error_code_maprDz#ProtocolVersion.uses_error_code_mapcCrErrFrBrrruses_keyspace_flagrz"ProtocolVersion.uses_keyspace_flagcCr?r)rGrBrrrhas_continuous_paging_supportrDz-ProtocolVersion.has_continuous_paging_supportcCr?r)DSE_V2rBrrr has_continuous_paging_next_pagesrDz0ProtocolVersion.has_continuous_paging_next_pagescCs|j|ko |jkSSrrFrBrrrhas_checksumming_supportz(ProtocolVersion.has_checksumming_supportN)r r r rV1V2V3V4rAV6rGrMr:r1min MIN_SUPPORTEDmax MAX_SUPPORTED classmethodr>rCrHrIrJrKrLrNrOrrrrr.sX        r.c@s>eZdZdZdZ dZ dZ dZ dZ dZ dZ d Z d S) WriteTypez\ For usage with :class:`.RetryPolicy`, this describe a type of write operation. rrrr rrrrN) r r r rSIMPLEBATCHUNLOGGED_BATCHCOUNTER BATCH_LOGCASVIEWCDCrrrrr[s$r[)r\r]r^r_r`rarbrccCsi|]\}}||qSrr)r2kr3rrr :srec@seZdZdZdZdZdS)SchemaChangeTypeDROPPEDCREATEDUPDATEDN)r r r rgrhrirrrrrf=srfc@s eZdZdZdZdZdZdZdS)SchemaTargetTypeKEYSPACETABLETYPEFUNCTION AGGREGATEN)r r r rkrlrmrnrorrrrrjCs rjc@s4eZdZddZeddZeddZddZd S) SignatureDescriptorcCs||_||_dSrnameargument_types)rrrrsrrr__init__Ms zSignatureDescriptor.__init__cCs||j|jS)z function signature string in the form 'name([type0[,type1[...]]])' can be used to uniquely identify overloaded function names within a keyspace )format_signaturerrrsrrrr signatureQszSignatureDescriptor.signaturecCsd|ddd|DfS)Nz%s(%s),css|]}|VqdSrr)r2trrrr6\sz7SignatureDescriptor.format_signature..)joinrqrrrruZrPz$SignatureDescriptor.format_signaturecCsd|jj|j|jfS)Nz %s(%s, %s)) __class__r rrrsrvrrr__repr__^r-zSignatureDescriptor.__repr__N) r r r rtpropertyrwr)rur|rrrrrpKs   rpc@eZdZdZdZ dZdS)UserFunctionDescriptorzB Describes a User function by name and argument signature Nr r r rrrrsrrrrrb rc@r~)UserAggregateDescriptorzL Describes a User aggregate function by name and argument signature Nrrrrrrrrrc@eZdZdZdS)DriverExceptionzB Base for all exceptions explicitly raised by the driver. Nr r r rrrrrrrc@r)RequestExecutionExceptionzI Base for request execution exceptions returned from the server. Nrrrrrrrrc@s,eZdZdZdZ dZ dZ dddZdS) Unavailablez There were not enough live replicas to satisfy the requested consistency level, so the coordinator node immediately failed the request without forwarding it to any replicas. Nc Cs:||_||_||_t||dtt|||ddS)N info=) consistencyrequired_replicasalive_replicas)rrr Exceptionrtreprr,)rsummary_messagerrrrrrrts  zUnavailable.__init__NNN)r r r rrrrrtrrrrrsrc@s0eZdZdZdZ dZ dZ  dddZdS)TimeoutzO Replicas failed to respond to the coordinator node before timing out. NcKsb||_||_||_d|vrtj|d|d<t|||d}||t||dt |dS)N write_type)rrequired_responsesreceived_responsesr) rrrr[r*r,updaterrtr)rrrrrkwargsinforrrrts zTimeout.__init__r)r r r rrrrrtrrrrrsrc@ eZdZdZdZ dddZdS) ReadTimeouta< A subclass of :exc:`Timeout` for read operations. This indicates that the replicas failed to respond to the coordinator node before the configured timeout. This timeout is configured in ``cassandra.yaml`` with the ``read_request_timeout_in_ms`` and ``range_request_timeout_in_ms`` options. NcKtj||fi|||_dSr)rrtdata_retrievedrmessagerrrrrrt zReadTimeout.__init__rr r r rrrtrrrrrs  rc@r) WriteTimeouta A subclass of :exc:`Timeout` for write operations. This indicates that the replicas failed to respond to the coordinator node before the configured timeout. This timeout is configured in ``cassandra.yaml`` with the ``write_request_timeout_in_ms`` option. NcKs&||d<tj||fi|||_dS)Nr)rrtrrrrrrrrrts zWriteTimeout.__init__rr r r rrrtrrrrrs  rc@seZdZdZddZdS)CDCWriteFailurez> Hit limit on data in CDC folder, writes are rejected cCst||dSr)rrt)rrrrrrtszCDCWriteFailure.__init__N)r r r rrtrrrrrs rc@s<eZdZdZdZ dZ dZ dZ dZ  dddZ dS)CoordinationFailurez5 Replicas sent a failure to the coordinator. Nc Csr||_||_||_||_||_t||||d}|dur+tdd|D}||d<t ||dt |dS)N)rrrfailurescss |] \}}|d|fVqdS)z0x%04xNr)r2addrerr_coderrrr6,sz/CoordinationFailure.__init__..error_code_mapr) rrrrrr,dictitemsrrtr) rrrrrrr info_dict formatted_maprrrrts zCoordinationFailure.__init__)NNNNN) r r r rrrrrrrtrrrrrsrc@r) ReadFailurez A subclass of :exc:`CoordinationFailure` for read operations. This indicates that the replicas sent a failure message to the coordinator. NcKrr)rrtrrrrrrtArzReadFailure.__init__rrrrrrr3s rc@r) WriteFailurez A subclass of :exc:`CoordinationFailure` for write operations. This indicates that the replicas sent a failure message to the coordinator. NcKrr)rrtrrrrrrtRrzWriteFailure.__init__rrrrrrrFs rc@s*eZdZdZdZ dZ dZ ddZdS)FunctionFailurez7 User Defined Function failed during execution NcCs"||_||_||_t||dSr)keyspacefunction arg_typesrrt)rrrrrrrrrtkszFunctionFailure.__init__)r r r rrrrrtrrrrrWs rc@r)RequestValidationExceptionz* Server request validation failed Nrrrrrrrrrc@r)ConfigurationExceptionzE Server indicated request errro due to current configuration Nrrrrrryrrc@&eZdZdZdZ dZ dddZdS) AlreadyExistszP An attempt was made to create a keyspace or table that already exists. NcCs8|r d||f}nd|f}t||||_||_dS)NzTable '%s.%s' already existszKeyspace '%s' already exists)rrtrtable)rrrrrrrrts    zAlreadyExists.__init__NN)r r r rrrrtrrrrrsrc@r)InvalidRequestz A query was made that was invalid for some reason, such as trying to set the keyspace for a connection to a nonexistent keyspace. Nrrrrrrsrc@r) UnauthorizedzP The current user is not authorized to perform the requested operation. Nrrrrrrrrc@r)AuthenticationFailedz! Failed to authenticate. Nrrrrrrrrc@r)OperationTimedOutz The operation took longer than the specified (client-side) timeout to complete. This is not an error generated by Cassandra, only the driver. NcCs,||_||_d|j|jf}t||dS)Nzerrors=%s, last_host=%s)errors last_hostrrt)rrrrrrrrtszOperationTimedOut.__init__r)r r r rrrrtrrrrrsrc@r)UnsupportedOperationz An attempt was made to use a feature that is not supported by the selected protocol version. See :attr:`Cluster.protocol_version` for more details. Nrrrrrrsrc@r)UnresolvableContactPointsz The driver was unable to resolve any provided hostnames. Note that this is *not* raised when a :class:`.Cluster` is created with no contact points, only when lookup fails for all hosts Nrrrrrrsrc@s"eZdZdZgZ gfddZdS)DependencyExceptionzO Specific exception class for handling issues with driver dependencies cCs4|}|r|dddd|D7}t||dS)Nz- The following exceptions were observed: - z - css|]}t|VqdSr)str)r2errrr6sz/DependencyException.__init__..)rzrrt)rmsgexcs complete_msgrrrrtszDependencyException.__init__N)r r r rrrtrrrrrs r)@loggingHandlerr getLogger addHandler__version_info__rzmapr __version__objectrr r!r"r#r$r%r&r'rrr(r* name_to_valuer,r.r[r\r]r^r_r`rarbrcrrfrjrprrrrrrrrrrrrrrrrrrrrrrrrrrrrsHs7 "4