!^      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~ SafeHVZcql&Record/Tuple conversion. For example: data Peer = Peer { peerAddr :: IP , peerRPC :: IP , peerDC :: Text , peerRack :: Text } deriving Show recordInstance ''Peer map asRecord <$> performQuery "SELECT peer, rpc_address, data_center, rack FROM system.peers" MThe generated type-class instance maps between record and tuple constructors: type instance TupleType Peer = (IP, IP, Text, Text) instance Record Peer where asTuple (Peer a b c d) = (a, b, c, d) asRecord (a, b, c, d) = Peer a b c d SafeXNone,cql6Type tag for schema queries, i.e. 'QueryString S a b'.cql5Type tag for write queries, i.e. 'QueryString W a b'.cql4Type tag for read queries, i.e. 'QueryString R a b'.cql#Tag some value with a phantom type. cqlhA CQL value. The various constructors correspond to CQL data-types for individual columns in Cassandra.8cql The type of a single CQL column.Tcql8An opcode is a tag to distinguish protocol frame bodies.ecqlConsistency level.See: Uhttps://docs.datastax.com/en/cassandra/latest/cassandra/dml/dmlConfigConsistency.html ConsistencyncqlOnly for write queries.ocqlOnly for read queries.pcqlOnly for read queries.zcql2The CQL version (not the binary protocol version).}cqlCQL binary protocol version.~cql version 3cql version 4cql!ID representing a prepared query.cql<Opaque token passed to the server to continue result paging. %$#"! &'()*+,-./012345678SRQPOMLKJIHGFEDCBA@?>=<;:9NTdcba`_^]\[ZYXWVUeponlkhjigmfqrutsvyxwz{|}~None/(None= cqlKType representing header flags. Flags form a monoid and can be used as in compress <> tracing <> mempty.cqlQStreams allow multiplexing of requests over a single communication channel. The  correlates Requests with Responses.cql*The type denoting a protocol frame length.cqlA request frame header.cqlA response frame header.cqlProtocol frame header.cqlFDeserialise a frame header using the version specific decoding format.cqlQCreate a StreamId from the given integral value. In version 2, a StreamId is an  and in version 3 an .cql$Convert the stream ID to an integer.cql7Compression flag. If set, the frame body is compressed.cqlTracing flag. If a request support tracing and the tracing flag was set, the response to this request will have the tracing flag set and contain tracing information.cql&Check if a particular flag is present. None=?XIcql2A type that can be converted from and to some CQL  .RThis type-class is used to map custom types to Cassandra data-types. For example: newtype MyType = MyType Int32 instance Cql MyType where ctype = Tagged IntColumn toCql (MyType i) = CqlInt i fromCql (CqlInt i) = Right (MyType i) fromCql _ = Left "Expected CqlInt" cqlthe column-type of acqlmap a to some CQL data-typecqlmap a CQL value back to acqlPlease note that due to the fact that Cassandra internally represents empty collection type values (i.e. lists, maps and sets) as null, we can not distinguish Just [] from Nothing on response decoding.NoneXJ[cqlA row is a vector of  s.cqlConvert a row element.  None2X\cqlSince .cqlSince .cqlError response.#cqlIMessages send by the server without request, if the connection has been Registered to receive such events.1cql"The column specification. Part of 7 unless  skipMetaData in  QueryParams was True.7cql Part of a  RowsResult. Describes the result set.=cqlQuery response.Ccql<The startup options supported by the server. Response of an Options request.Ecql6The server is ready to process queries. Response of a Startup request.Gcql1Indicates the success of an authentication phase.Icql'A server-send authentication challenge.Kcql#The server requires authentication.Mcql6The type corresponding to the protocol response frame.The type parameter kq denotes the kind of response. It is present to allow distinguishing read operations from write operations. Use  for read,  for write and  for schema related operations.a" represents the argument type and b# the return type of this response.Vcql)Get server warnings from response if any.Wcql)Get server trace ID from response if any.XcqlDeserialise a M from the given .      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdef None&'1XIgcql`Consistency level for the serial phase of conditional updates (aka "lightweight transactions").See: [https://docs.datastax.com/en/cassandra/latest/cassandra/dml/dmlConfigSerialConsistency.htmlSerialConsistencyhcql/Default. Quorum-based linearizable consistency.icqlLike g4 except confined to a single (logical) data center.jcqlQuery parameters.lcql#(Regular) consistency level to use.mcql$Whether to omit the metadata in the Response of the query. This is an optimisation only relevant for use with prepared queries, for which the metadata obtained from the PreparedResult may be reused.ncql"The bound parameters of the query.ocql$The desired maximum result set size.pcqlaThe current paging state that determines the "offset" of the results to return for a read query.qcql|Serial consistency level to use for conditional updates (aka "lightweight transactions"). Irrelevant for any other queries.rcqlDWhether tracing should be enabled for the query, in which case the Response will carry a traceId.scqlZA GADT to unify queries and prepared queries both of which can be used in batch requests.wcql0default, uses a batch log for atomic applicationxcqlskip the batch logycql used for batched counter updateszcql@Allows executing a list of queries (prepared or not) as a batch.cqlEvent types to register.cql0events related to change in the cluster topologycql'events related to change of node statuscqlevents related to schema changecqlRRegister's the connection this request is made through, to receive server events.cql)Prepare a query for later execution (cf. ).cqlExecutes a prepared query.cql#A CQL query (select, insert, etc.).cql"An options request, send prior to * to request the server's startup options.cqlBA request send in response to a previous authentication challenge.cqlA startup request which is used when initialising a connection to the server. It specifies the CQL version to use and optionally the compression algorithm.cql5The type corresponding to the protocol request frame.The type parameter kp denotes the kind of request. It is present to allow distinguishing read operations from write operations. Use  for read,  for write and  for schema related operations.a" represents the argument type and b! the return type of this request.cqlSerialise the given request, optionally using compression. The result is either an error description in case of failure or a binary protocol frame, including ,  and body.cqlGet the protocol T corresponding to the given .cql/protocol version, which determines the encodingcqlcompression to usecqlenable/disable tracingcqlthe stream Id to usecqlthe actual request to serialiseCghijknmlopqrstuvwxyz{|}~None !"#$%&'()*+,-./012345678N9:;<=>?@ABCDEFGHIJKLMOPQRSTUVWXYZ[\]^_`abcdefmgijhklnopqrstuvwxyz|{}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijknmlopqrstuvwxyz{|}~}~z{|vyxwqrutseponlkhjigmfTdcba`_^]\[ZYXWVU8SRQPOMLKJIHGFEDCBA@?>=<;:9N567234/01,-.)*+&'( %$#"!  jknmlopqrghiz{|}~stuvwxyMNOPQRSTUVWXEF\KLIJGHYZ[=>?@AB789:;<123456^_CD]#$%& !"-./0'()*+,`abcd     ef None] !"#$%&'()*+,-./012345678N9:;<=>?@ABCDEFGHIJKLMOPQRSTUVWXYZ[\]^_`abcdefmgijhklnopqrstuvwxyz|{}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXghijknmlopqrstuvwxyz{|}~]}~z{|vyxwqrutseponlkhjigmfTdcba`_^]\[ZYXWVU8SRQPOMLKJIHGFEDCBA@?>=<;:9N567234/01,-.)*+&'( %$#"!  jknmlopqrghiz{|}~stuvwxyMNOPQRSTUVWXEFKLIJGH=>?@AB789:;<123456CD#$%& !"-./0'()*+,        !"#$%&'()*+,-./011233455677899:;;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvvwxyz{|}~~                                                              ! " # $ % & ' ( ) * + , - - . / 0 1 2 2 3 4 5 6 7 8 9 : ; < = = > > ? ? @ @ A A B C D E F G H I J K L M N O P Q R S T U V W X Y Z [ \ \ ] ^ ^ _ ` a b c d e f f g h i j k l l m n o p q r s t u u v v w w x x y y z z { { | } ~                      cql-4.0.2-8ZC9e5JcNOI26cJJdkKytxDatabase.CQL.Protocol.InternalDatabase.CQL.Protocol.RecordDatabase.CQL.Protocol.Tuple.THDatabase.CQL.Protocol.TypesDatabase.CQL.Protocol.CodecDatabase.CQL.Protocol.HeaderDatabase.CQL.Protocol.ClassDatabase.CQL.Protocol.TupleDatabase.CQL.Protocol.ResponseDatabase.CQL.Protocol.RequestDatabase.CQL.ProtocolRecordasTupleasRecord TupleTyperecordInstanceSWRTaggeduntagValue CqlCustom CqlBooleanCqlInt CqlBigInt CqlVarIntCqlFloat CqlDecimal CqlDoubleCqlTextCqlInetCqlUuid CqlTimestampCqlAsciiCqlBlob CqlCounter CqlTimeUuidCqlMaybeCqlListCqlSetCqlMapCqlTupleCqlUdtCqlDateCqlTime CqlSmallInt CqlTinyIntMapfromMapSetfromSetTimeUuid fromTimeUuidCounter fromCounterBlobfromBlobAscii fromAscii ColumnType CustomColumn AsciiColumn BigIntColumn BlobColumn BooleanColumn CounterColumn DecimalColumn DoubleColumn FloatColumn IntColumn TextColumnTimestampColumn UuidColumn VarCharColumn VarIntColumnTimeUuidColumn InetColumn MaybeColumn ListColumn SetColumn MapColumn TupleColumn UdtColumn DateColumn TimeColumnSmallIntColumn TinyIntColumnOpCodeOcError OcStartupOcReadyOcAuthenticate OcOptions OcSupportedOcQueryOcResult OcPrepare OcExecute OcRegisterOcEventOcBatchOcAuthChallengeOcAuthResponse OcAuthSuccess ConsistencyAnyOneLocalOneTwoThreeQuorum LocalQuorumAll EachQuorumSerial LocalSerial Compression algorithmshrinkexpandCompressionAlgorithmSnappyLZ4None CqlVersionCqlv300VersionV3V4 QueryString unQueryStringQueryId unQueryId PagingState unPagingStateTableunTableKeyspace unKeyspace noCompressionretag encodeByte decodeByteencodeSignedBytedecodeSignedByte encodeShort decodeShortencodeSignedShortdecodeSignedShort encodeInt decodeInt encodeString decodeStringencodeLongStringdecodeLongString encodeBytes decodeBytesencodeShortBytesdecodeShortBytes encodeUUID decodeUUID encodeList decodeList encodeMap decodeMapencodeMultiMapdecodeMultiMapencodeSockAddrdecodeSockAddrencodeConsistencydecodeConsistency encodeOpCode decodeOpCodedecodeColumnTypeencodePagingStatedecodePagingStateputValuegetValuedecodeKeyspace decodeTable decodeQueryIdFlagsStreamIdLength lengthRepr HeaderTypeRqHeaderRsHeaderHeader headerTypeversionflagsstreamIdopCode bodyLength encodeHeader decodeHeaderheader encodeLength decodeLength mkStreamId fromStreamIdencodeStreamIddecodeStreamId encodeFlags decodeFlagscompresstracing customPayloadwarningisSetCqlctypetoCqlfromCqlTuplecountchecktuplestoreRowfromRowmkRow rowLength columnTypes WriteType WriteSimple WriteBatch WriteBatchLogWriteUnloggedBatch WriteCounterWriteCas WriteViewWriteCdcError AlreadyExistsBadCredentials ConfigErrorFunctionFailureInvalidIsBootstrapping Overloaded ProtocolError ServerError SyntaxError TruncateError Unauthorized Unprepared Unavailable ReadFailure ReadTimeout WriteFailure WriteTimeoutunavailMessageunavailConsistencyunavailNumRequiredunavailNumAliverFailureMessagerFailureConsistencyrFailureNumAckrFailureNumRequiredrFailureNumFailuresrFailureDataPresentrTimeoutMessagerTimeoutConsistencyrTimeoutNumAckrTimeoutNumRequiredrTimeoutDataPresentwFailureMessagewFailureConsistencywFailureNumAckwFailureNumRequiredwFailureNumFailureswFailureWriteTypewTimeoutMessagewTimeoutConsistencywTimeoutNumAckwTimeoutNumRequiredwTimeoutWriteType StatusChangeUpDownTopologyChangeNewNode RemovedNodeEvent TopologyEvent StatusEvent SchemaEventChangeKeyspaceChange TableChange TypeChangeFunctionChangeAggregateChange SchemaChange SchemaCreated SchemaUpdated SchemaDropped ColumnSpeckeyspacetable columnName columnTypeMetaData columnCount pagingState columnSpecsprimaryKeyIndicesResult VoidResult RowsResultSetKeyspaceResultPreparedResultSchemaChangeResult SupportedReady AuthSuccess AuthChallenge AuthenticateResponseRsErrorRsReadyRsAuthenticateRsAuthChallenge RsAuthSuccess RsSupportedRsResultRsEventwarningstraceIdunpackdecodeAuthenticatedecodeAuthChallengedecodeAuthSuccess decodeReadydecodeSupported decodeResultdecodeMetaDatadecodeSchemaChange decodeChange decodeEventdecodeTopologyChangedecodeStatusChange decodeErrordecodeWriteTypeSerialConsistencyLocalSerialConsistency QueryParams consistency skipMetaDatavaluespageSizequeryPagingStateserialConsistency enableTracing BatchQuery BatchPrepared BatchType BatchLogged BatchUnLogged BatchCounterBatch batchType batchQuerybatchConsistencybatchSerialConsistency EventTypeTopologyChangeEventStatusChangeEventSchemaChangeEventRegisterPrepareExecuteQueryOptions AuthResponseStartupRequest RqStartup RqOptions RqRegisterRqBatch RqAuthResp RqPrepareRqQuery RqExecute encodeRequestpack getOpCode encodeStartupencodeAuthResponse encodeOptions encodeQuery encodeExecute encodePrepareencodeRegisterencodeEventType encodeBatchencodeBatchTypeencodeBatchQueryencodeQueryParams genInstances tupleInstance countDecl taggedDecl tupleDecl storeDeclgenCqlInstances cqlInstanceslitIntvarcontcon$$$:baseGHC.IntInt8Int16 $fCqlMaybebytestring-0.10.8.2Data.ByteString.Internal ByteString