!"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~ None #Tag some value with a phantom type.hA CQL value. The various constructors correspond to CQL data-types for individual columns in Cassandra.binary protocol version >= 3binary protocol version >= 3/ The type of a single CQL column.G8An opcode is a tag to distinguish protocol frame bodies.XConsistency level.m2The CQL version (not the binary protocol version).pCQL binary protocol version.q version 2r version 3v!ID representing a prepared query.y<Opaque token passed to the server to continue result paging.  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXY^Z[\]_`abcdehfgijklmonpqrstuvwxyz{|}~  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWX YZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~NoneDR&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  NoneL3(3None KType representing header flags. Flags form a monoid and can be used as in compress <> tracing <> mempty.QStreams allow multiplexing of requests over a single communication channel. The  correlates Requests with Responses.*The type denoting a protocol frame length.A request frame header.A response frame header.Protocol frame header.FDeserialise a frame header using the version specific decoding format.QCreate a StreamId from the given integral value. In version 2, a StreamId is an  and in version 3 an .$Convert the stream ID to an integer.7Compression flag. If set, the frame body is compressed.Tracing 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.&Check if a particular flag is present.$None9;T2A 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" the column-type of amap a to some CQL data-typemap a CQL value back to aPlease 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.NoneTA row is a vector of s.Convert a row element."NoneT  None%&/T>Consistency level for the serial phase of conditional updates.Query parameters.consistency leven to useskip metadata in responsequery argumentsdesired result set sizeZA GADT to unify queries and prepared queries both of which can be used in batch requests.0default, uses a batch log for atomic applicationskip the batch log used for batched counter updates@Allows executing a list of queries (prepared or not) as a batch.Event types to register.0events related to change in the cluster topology'events related to change of node statusevents related to schema changeRRegister's the connection this request is made through, to receive server events.)Prepare a query for later execution (cf. ).Executes a prepared query.#A CQL query (select, insert, etc.)."An options request, send prior to * to request the server's startup options.BA request send in response to a previous authentication challenge.A startup request which is used when initialising a connection to the server. It specifies the CQL version to use and optionally the compression algorithm.5The 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.Serialise 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.Get the protocol G corresponding to the given .C     /protocol version, which determines the encodingcompression to useenable/disable tracingthe stream Id to usethe actual request to serialiseB           None0T %Error response.IIMessages send by the server without request, if the connection has been Registered to receive such events.U"The column specification. Part of [ unless  skipMetaData in  QueryParams was True.[ Part of a  RowsResult. Describes the result set.`Query response.f<The startup options supported by the server. Response of an Options request.h6The server is ready to process queries. Response of a Startup request.j1Indicates the success of an authentication phase.l'A server-send authentication challenge.n#The server requires authentication.p6The 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.yDeserialise a p from the given .j !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~i !"#$%&,'()*+-./0123456789:;<=>?@ABCEDFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~None  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXY^Z[\]_`abcdehfgijklmonpqrstuvwxyz{|}~      !"#$%&,'()*+-./0123456789:;<=>?@ABCEDFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~|}~yz{vwxstupqrmnoijkldefghXYZ[\]^_`abcGHIJKLMNOPQRSTUVW/0123456789:;<=>?@ABCDEF,-.)*+&'(#$% !"      pqrstuvwxyhi}nolmjkz{|`abcde[\]^_UVWXYZfg~IJKLFGHQRSTCDEMNOP%&'()*+,-./0123456789:;<=>?@AB !"#$ None=  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXY^Z[\]_`abcdehfgijklmonpqrstuvwxyz{|}~      !"#$%&,'()*+-./0123456789:;<=>?@ABCEDFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxy=|}~yz{vwxstupqrmnoijkldefghXYZ[\]^_`abcGHIJKLMNOPQRSTUVW/0123456789:;<=>?@ABCDEF,-.)*+&'(#$% !"      pqrstuvwxyhinolmjk`abcde[\]^_UVWXYZfgIJKLFGHQRSTCDEMNOP%&'()*+,-./0123456789:;<=>?@AB !"#$   !"#$%&'(()**+,,-../001223456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghiijklmnopqrqstuvvwxxyzz{||}~~                                                                          ! " # $ % & ' ( ) * + , - . / 0 1 2 3 4 5 6 7 8 9 : ; < = > ? @ A B C D E F F G H I J K K L M N O P Q R S T U U V V W W X X Y Y Z [ \ ] ^ _ ` a b c d e f g h i j k l m n o p qrstuvwxyz{|}~{|   cql-3.1.1-8Dyia0LBWrS1RFeb3HoonEDatabase.CQL.Protocol.InternalDatabase.CQL.Protocol.TypesDatabase.CQL.Protocol.RecordDatabase.CQL.Protocol.CodecDatabase.CQL.Protocol.HeaderDatabase.CQL.Protocol.ClassDatabase.CQL.Protocol.Tuple.THDatabase.CQL.Protocol.TupleDatabase.CQL.Protocol.RequestDatabase.CQL.Protocol.ResponseDatabase.CQL.ProtocolSWRTaggeduntagValue CqlCustom CqlBooleanCqlInt CqlBigInt CqlVarIntCqlFloat CqlDecimal CqlDoubleCqlTextCqlInetCqlUuid CqlTimestampCqlAsciiCqlBlob CqlCounter CqlTimeUuidCqlMaybeCqlListCqlSetCqlMapCqlTupleCqlUdtMapfromMapSetfromSetTimeUuid fromTimeUuidCounter fromCounterBlobfromBlobAscii fromAscii ColumnType CustomColumn AsciiColumn BigIntColumn BlobColumn BooleanColumn CounterColumn DecimalColumn DoubleColumn FloatColumn IntColumn TextColumnTimestampColumn UuidColumn VarCharColumn VarIntColumnTimeUuidColumn InetColumn MaybeColumn ListColumn SetColumn MapColumn TupleColumn UdtColumnOpCodeOcError OcStartupOcReadyOcAuthenticate OcOptions OcSupportedOcQueryOcResult OcPrepare OcExecute OcRegisterOcEventOcBatchOcAuthChallengeOcAuthResponse OcAuthSuccess ConsistencyAnyOneTwoThreeQuorumAll LocalQuorum EachQuorumSerialLocalOne LocalSerial Compression algorithmshrinkexpandCompressionAlgorithmSnappyLZ4None CqlVersionCqlv300VersionV2V3 QueryString unQueryStringQueryId unQueryId PagingState unPagingStateTableunTableKeyspace unKeyspace noCompressionretagRecordasTupleasRecord TupleTyperecordInstance 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 decodeFlagscompresstracingisSetCqlctypetoCqlfromCqlTuplecountchecktuplestoreRowfromRowmkRow rowLength columnTypesSerialConsistencyLocalSerialConsistency QueryParams consistency skipMetaDatavaluespageSizequeryPagingStateserialConsistency BatchQuery BatchPrepared BatchType BatchLogged BatchUnLogged BatchCounterBatch batchType batchQuerybatchConsistencybatchSerialConsistency EventTypeTopologyChangeEventStatusChangeEventSchemaChangeEventRegisterPrepareExecuteQueryOptions AuthResponseStartupRequest RqStartup RqOptions RqRegisterRqBatch RqAuthResp RqPrepareRqQuery RqExecute encodeRequestpack getOpCode encodeStartupencodeAuthResponse encodeOptions encodeQuery encodeExecute encodePrepareencodeRegisterencodeEventType encodeBatchencodeBatchTypeencodeBatchQueryencodeQueryParams WriteType WriteSimple WriteBatch WriteBatchLogWriteUnloggedBatch WriteCounterError AlreadyExistsBadCredentials ConfigErrorInvalidIsBootstrapping Overloaded ProtocolError ServerError SyntaxError TruncateError Unauthorized Unprepared Unavailable ReadTimeout WriteTimeoutunavailMessageunavailConsistencyunavailNumRequiredunavailNumAliverTimeoutMessagerTimeoutConsistencyrTimeoutNumAckrTimeoutNumRequiredrTimeoutDataPresentwTimeoutMessagewTimeoutConsistencywTimeoutNumAckwTimeoutNumRequiredwTimeoutWriteType StatusChangeUpDownTopologyChangeNewNode RemovedNodeEvent TopologyEvent StatusEvent SchemaEventChangeKeyspaceChange TableChange TypeChange SchemaChange SchemaCreated SchemaUpdated SchemaDropped ColumnSpeckeyspacetable columnName columnTypeMetaData columnCount pagingState columnSpecsResult VoidResult RowsResultSetKeyspaceResultPreparedResultSchemaChangeResult SupportedReady AuthSuccess AuthChallenge AuthenticateResponseRsErrorRsReadyRsAuthenticateRsAuthChallenge RsAuthSuccess RsSupportedRsResultRsEventunpackdecodeAuthenticatedecodeAuthChallengedecodeAuthSuccess decodeReadydecodeSupported decodeResultdecodeMetaDatadecodeSchemaChange decodeChange decodeEventdecodeTopologyChangedecodeStatusChange decodeErrordecodeWriteType$fIsStringAscii$fShowColumnType$fShowCompression$fIsStringQueryString typeSynDeclstart tupleType asTupleDecl asRecrdDecl$$$: putNative getNativegetList withBytesremainingBytesremainingBytesLazytoBytes integer2bytesexplode bytes2integerimplodebaseGHC.IntInt8Int16 mapHeaderType mapVersion toVersion $fMonoidFlags $fCqlMaybe$fCqlSet$fCqlMap$fCql[] $fCqlTimeUuid $fCqlCounter $fCqlBlob $fCqlUTCTime $fCqlUUID$fCqlIP $fCqlAscii $fCqlText$fCqlDecimalRaw $fCqlDouble $fCqlFloat $fCqlInteger $fCqlInt64 $fCqlInt32 $fCqlBool PrivateTupletypes genInstances tupleInstance countDecl checkDecl tupleDecl storeDecllitIntvarcontconelement typecheck $fTupleRow$fPrivateTupleRow$fTupleIdentity$fPrivateTupleIdentity $fTuple()$fPrivateTuple()8$fTuple(,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,)mapConsbytestring-0.10.8.1Data.ByteString.Internal ByteString$fExceptionError