h$E      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~                                        NoneNone#$franzBetter implementation of  None8< franz4Initial seqno, final seqno, base offset, index namesfranzresponse 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#$EfranzDirectory which contains franz streams. Values of this type serve two purposes:Arbitrary prefix so that clients don't have to specify the full path Gfranz:Globally-configured path which contains franz directories.LfranzHow many streams we pruned.Mfranz!How many streams we saw in total.ifranzfromfranztofranzoffsets-EFGHIJKMLNOQPRSTU_^]\[ZWVXY`cbadefghijklmnopq-`cbaTU_^]\[ZWVXYSdefgRhijNOQPJKMLklmnGHIEFopqNone#$%" wx|yz{}~ wx|yz{}~None#$%] wy| wy|None NfranzPrefix 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.franzWait 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 microsecondsfranztimeout in microseconds* !"#$'w*'"#$w ! None #$ franz A wrapper of  which calls  internallyfranzRun an action which takes a /, reconnecting whenever it throws an exception.franzRun an  action, throwing # when it exceeds the given timeout.franzdiagnostic outputfranztimeout in microseconds   None  #$8 'GHI GHI' None#$franz8Get the sequential number of the last item item written.franz#Flush any pending data and close a .franzFlush the changes.franzindex 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:;<=>?@ABCDEFGHIJKLMNOOPPQRRSTUUVWXYZZ[\]^_`abcdefghijklmnopqrstuvwxyz{||]}~^                                        "franz-0.5.2-DT0DpRlq3Nv7ChWZTFVJ1GDatabase.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 $fEqQuery$fGenericQuery $fShowItemRef $fEqItemRef$fGenericItemRef$fShowRequestType$fEqRequestType$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 createStream isEmptyResultrangesplitRreaperwithFranzReadernewFranzReadercloseFranzReadergetFranzDirectorygetFranzStreamPath 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 ReconnectReconnectByTimeoutReconnectByErrorReconnectInQueryPoolpoolRetryPolicy 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