Îõ³h$À      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯° ± ² ³ ´ µ ¶ · ¸ ¹ º » ¼ ½ ¾ ¿ None#$–franzBetter implementation of  None8<ÎY franz4Initial seqno, final seqno, base offset, index namesfranzÄresponse ID, number of streams; there are items satisfying the queryfranz;response ID; requested elements are not available right nowfranzsomething went wrongfranzname of the index to searchfranzname of the index to searchfranzsequential numberfranzindex name and value&franz UTF-8 encoded#  !"#$%##$" !%  None#$Îà9?franzÐDirectory which contains franz streams. Values of this type serve two purposes:ÅArbitrary prefix so that clients don't have to specify the full path Afranz:Globally-configured path which contains franz directories.FfranzHow many streams we pruned.Gfranz!How many streams we saw in total.bfranzfromfranztofranzoffsets,?@ABCDEGFHIKJLMNOYXWVUTQPRSZ]\[^_`abcdefghij,Z]\[NOYXWVUTQPRSM^_`aLbcHIKJDEGFdefgABC?@hijNone#$%²pqrstvuwxyz{|}pqstvuwxzr{|y}None  #$8É×àø $€‚ƒ„…†‡ˆ‰Š €‚ƒ„…†‡ˆ$‰ŠNone é‘franzPrefix of franz directories’franzParse a franz URI (franz:/ host:portpath or franz-local:path).“franzRender Œ as a franz URI.ŒŽ‘’“ŒŽ‘’“None  #$5É×à m—franz When it is À+, it might block until the content arrives.žfranz%Fetch requested data from the server.Termination of žÎ continuation cancels the request, allowing flexible control of its lifetime.Ÿfranz,Send a single query and wait for the result.žfranzÛWait for the response in a blocking manner. You should only run the continuation inside a žÈ block: leaking the STM action and running it outside will result in a  exception.Ÿfranztimeout in microseconds franztimeout in microseconds)  !$pŒŽ‘’“—˜™š›œžŸ )ŒŽ‘“’$˜™š› ! œ—pžŸ None #$ÔÙà J©franz A wrapper of ž which calls ª internallyªfranzRun an action which takes a ˜/, reconnecting whenever it throws an exception.¬franzRun an Á action, throwing ¤# when it exceeds the given timeout.«franzdiagnostic output¬franztimeout in microseconds ¤¥¦¨§©ª«¬ ¦¨§«ª¤¥¬© None#$ÉÙ±franz8Get the sequential number of the last item item written.³franz#Flush any pending data and close a °.¶franzFlush the changes.²franz°index names: a fixed-length collection of the names of indices for this stream. Use Proxy if you don't want any indices. If you want only one type of index, use `Identity ""`.µfranz index valuesfranzpayload°±²³´µ¶°²³´µ¶± NoneW °±³¶¸¹º»¼ °º³»¼¶±¸¹Â   !"#$%&'(()*+,-./0123456789:;<=>?@ABCDEFGGHHIJJKLMMNOPQRRSTUVWXYZ[\]^_`abcdefghijklmnopqrsUtuuvVwxyz{|}~€€‚ƒ„…†‡ˆ‰Š‹‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¡¢£¤¥¦§¨©ª« ¬ ­ ® ¯ ° ± ² ³ ´ µ ® ° ± ¶ · ¸¹º»¹¼½¾ franz-0.4-LNZZ0SvHlh3Au9fLOQbiuaDatabase.Franz.InternalDatabase.Franz.ProtocolDatabase.Franz.ReaderDatabase.Franz.ContentsDatabase.Franz.ServerDatabase.Franz.URIDatabase.Franz.ClientDatabase.Franz.ReconnectDatabase.Franz.WriterDatabase.Franz.Writer.SimpleData.Serialize getInt64le runGetRecv hGetRange PayloadHeaderResponseHeaderResponse ResponseWait ResponseError ResponseId RawRequestRawCleanQuery reqStreamreqFromreqToreqTypeItemRefBySeqNumByIndex RequestTypeAllItemsLastItemFranzExceptionMalformedRequestStreamNotFound IndexNotFound InternalError ClientError StreamName unStreamName IndexName apiVersion defaultPortstreamNameToPath$fIsStringStreamName$fExceptionFranzException$fSerializeFranzException$fSerializeRequestType$fSerializeItemRef$fSerializeQuery$fSerializeRawRequest$fSerializeResponseHeader$fSerializePayloadHeader$fShowResponseHeader$fGenericResponseHeader$fGenericRawRequest $fShowQuery$fGenericQuery $fShowItemRef$fGenericItemRef$fShowRequestType$fGenericRequestType$fShowFranzException$fGenericFranzException$fShowStreamName$fEqStreamName$fOrdStreamName$fHashableStreamName$fSerializeStreamNameFranzDirectory FranzPrefix unFranzPrefix ReaperState prunedStreams totalStreams FranzReader watchManagervStreams QueryResultActivityStream streamPathvOffsets indexNamesindicesvCountvStatus followThread indexHandle payloadHandle vActivity StreamStatusCaughtUpOutdatedGone addActivityremoveActivity closeStream createStreamrangesplitRreaperwithFranzReadernewFranzReadercloseFranzReadergetFranzDirectorygetFranzStreamPath handleQuery$fEqFranzDirectory$fHashableFranzDirectory$fEqFranzPrefix$fHashableFranzPrefix$fEqStreamStatusContentslengthItemseqNopayloadtoList getResponselastindex lookupIndex readContents $fShowItem$fEqItemSettings reapIntervalstreamLifetimeport livePrefix archivePrefix mountPrefix startServer mountFusekillFuse$fResourceMapMountMap FranzPathLocalFranzPath franzHost franzPortfranzDir toFranzPath fromFranzPath$fShowFranzPath $fEqFranzPath$fOrdFranzPath ConnectionwithConnectionconnect disconnectdefQuery awaitResponsefetch fetchSimpleatomicallyWithin$fResourceMapConnStateMap$fShowResponseStatus$fFunctorResponseStatus ReconnectPoolpoolRetryPolicy poolLogFunc fetchWithPoolwithReconnectionwithPoolatomicallyReconnecting$fExceptionReconnect$fShowReconnect $fEqReconnect WriterHandle getLastSeqNo openWriter closeWriter withWriterwriteflush$fNFDataWriterHandle ToFastBuilder toFastBuilder$fToFastBuilderBuilder$fToFastBuilderByteString$fToFastBuilderByteString0base Data.EitherRight GHC.Conc.SyncSTM