Îõ³h$WÈ      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢ £ ¤ ¥ ¦ § ¨ © ª « ¬ ­ ® ¯ ° ± ² ³ ´ µ ¶ · ¸ ¹ º » ¼ ½ ¾ ¿ À Á Â Ã Ä Å Æ Ç NoneÔÙà—None#$åfranzBetter implementation of  None8<Ψ franz4Initial seqno, final seqno, base offset, index namesfranzÄresponse ID, number of streams; there are items satisfying the query franz;response ID; requested elements are not available right now franzsomething went wrongfranzname of the index to searchfranzname of the index to searchfranzsequential numberfranzindex name and value)franz UTF-8 encoded$  !"#$%&'($&'%"#$( !   None#$ÎàŠBfranzÐ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 Dfranz:Globally-configured path which contains franz directories.IfranzHow many streams we pruned.Jfranz!How many streams we saw in total.efranzfromfranztofranzoffsets,BCDEFGHJIKLNMOPQR\[ZYXWTSUV]`_^abcdefghijklm,]`_^QR\[ZYXWTSUVPabcdOefKLNMGHJIghijDEFBCklmNone#$% stxuvwyz{|} {stxuvwyz|}None#$%9 sux~€‚ƒ„…†‡ su~€‚ƒ„…x†‡None &franzPrefix of franz directoriesfranzParse a franz URI (franz:/ host:portpath or franz-local:path).‘franzRender Š as a franz URI.Š‹ŒŽ‘Š‹ŒŽ‘None  #$5É×à ª•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* !"#$'sŠ‹ŒŽ‘•–—˜™š›œž*Š‹ŒŽ‘'–—˜™"#$š•›sœž ! None #$ÔÙà ‰§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  #$8É×à × 'DEF®¯²°±³´µ¶ ®¯²°±³´µ¶DEF' 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¸¹º»¼½¾¸º»¼½¾¹ Noneì ¸¹»¾ÀÁÂÃÄ ¸Â»Ãľ¹ÀÁÊ !"#$%&'()*+,--./0123456789:;<=>?@ABCDEFGHIJKLLMMNOOPQRRSTUVWWXYZ[\]^_`abcdefghijklmnopqrstuvwxxZyz{|}~€‚[ƒ„…†‡ˆ‰Š‹‹ŒŽ‘’“”•–—˜™š›œžŸ  ¡ ¡ ¢ £ ¤ ¥ ¦ § ¨ © ª « ¬ ¬ ­ ® ¯ ° ± ² ³ ´ µ ¶ · ¸ ¹ º » ¼ ½ ¾ · ¹ º ¿ À ÁÂÃÄÂÅÆÇ"franz-0.5.1-BSnbaghgjFvGowne7q4U0sDatabase.Franz.Internal.FuseDatabase.Franz.Internal.IO Database.Franz.Internal.ProtocolDatabase.Franz.Internal.Reader Database.Franz.Internal.ContentsDatabase.Franz.ContentsDatabase.Franz.Internal.URIDatabase.Franz.ClientDatabase.Franz.Client.ReconnectDatabase.Franz.ServerDatabase.Franz.WriterDatabase.Franz.Writer.SimpleData.Serialize getInt64le mountFusekillFuse runGetRecv hGetRange PayloadHeaderResponseHeaderResponse ResponseWait ResponseError ResponseId RawRequestRawCleanQuery reqStreamreqFromreqToreqTypeItemRefBySeqNumByIndex RequestTypeAllItemsLastItem FirstItemFranzExceptionMalformedRequestStreamNotFound 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$fEqStreamStatusContentspayloadsindicesslength payloadOffset seqnoOffsetIndexVec getResponse readContentsItemseqNopayloadtoListtoVectorlastindex lookupIndex $fShowItem$fEqItem FranzPathLocalFranzPath franzHost franzPortfranzDir toFranzPath fromFranzPath$fShowFranzPath $fEqFranzPath$fOrdFranzPath ConnectionwithConnectionconnect disconnectdefQuery awaitResponsefetch fetchSimpleatomicallyWithin$fResourceMapConnStateMap$fShowResponseStatus$fFunctorResponseStatus ReconnectPoolpoolRetryPolicy poolLogFunc fetchWithPoolwithReconnectionwithPoolatomicallyReconnecting$fExceptionReconnect$fShowReconnect $fEqReconnectSettings reapIntervalstreamLifetimeport livePrefix archivePrefix mountPrefix startServer$fResourceMapMountMap WriterHandle getLastSeqNo openWriter closeWriter withWriterwriteflush$fNFDataWriterHandle ToFastBuilder toFastBuilder$fToFastBuilderBuilder$fToFastBuilderByteString$fToFastBuilderByteString0base Data.EitherRight GHC.Conc.SyncSTM