Îõ³h$7Æ      !"#$%&'()*+,-./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#$Îà~AfranzÐ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 Cfranz:Globally-configured path which contains franz directories.HfranzHow many streams we pruned.Ifranz!How many streams we saw in total.dfranzfromfranztofranzoffsets,ABCDEFGIHJKMLNOPQ[ZYXWVSRTU\_^]`abcdefghijkl,\_^]PQ[ZYXWVSRTUO`abcNdeJKMLFGIHfghiCDEABjklNone#$%ö rswtuvxyz{| zrswtuvxy{|None#$%- rtw}~€‚ƒ„… rt}~€‚ƒw„…None franzPrefix of franz directoriesŽfranzParse 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) !"#&rˆ‰Š‹ŒŽ“”•–—˜™š›œ)ˆ‰Š‹ŒŽ&”•–—!"#˜“™rš›œ None #$ÔÙà u¥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É×à à &CDE¬­°®¯±²³´ ¬­°®¯±²³´CDE& 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:;<=>?@ABCDEFGHIJKKLLMNNOPQQRSTUVVWXYZ[\]^_`abcdefghijklmnopqrstuvwwYxyz{|}~€€Z‚ƒ„…†‡ˆ‰‰Š‹ŒŽ‘’“”•–—˜™š›œž Ÿ Ÿ   ¡ ¢ £ ¤ ¥ ¦ § ¨ © ª ª « ¬ ­ ® ¯ ° ± ² ³ ´ µ ¶ · ¸ ¹ º » ¼ µ · ¸ ½ ¾ ¿ÀÁÂÀÃÄÅ franz-0.5-KxXJcuIWnOq5voPsLQF7IGDatabase.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 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$fEqStreamStatusContentspayloadsindicesslength payloadOffset seqnoOffsetIndexVec getResponse readContentsItemseqNopayloadtoListlastindex 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