úÎ!0;)]s      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrNone"#HX sfranzHandle for offsets and indicestfranz3(next sequential number, current payload file size)ufranzpending indicesvfranzthe number of pending indiceswfranz'the number of Word64s to write for itemfranz8Get the sequential number of the last item item written.franz#Flush any pending data and close a .franzFlush the changes.xfranz!Flush the change without locking tyfranzUSame as hPutBuf but with a number of elements to write instead of a number of bytes.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 valuesfranzpayloadNonefranzBetter implementation of   None7á franz4Initial seqno, final seqno, base offset, index names franzDresponse 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  !"#$%&'('(& !"#$%  None "#4HV_#<franz When it is z+, it might block until the content arrives.=franz(seqno, indices, payloads){franzThe user cancelled the request.Efranz%Fetch requested data from the server.Termination of EN continuation cancels the request, allowing flexible control of its lifetime.FfranzVSend a single query and wait for the result. If it timeouts, it returns an empty list.Efranz[Wait for the response in a blocking manner. You should only run the continuation inside a EH block: leaking the STM action and running it outside will result in a % exception.Ffranztimeout in microsecondsGfranztimeout in microseconds !"#$%(<=>?@ABCDEFG(?@ABC<D>=EFG !"#$%None"#7_&ÄMfranzHow many streams we pruned.Nfranz!How many streams we saw in total.dfranzfromfranztofranzoffsetshfranzprefixfranz directoryKLNMOPRQSTUV_^]\[ZXWY`abcdefghUV_^]\[ZXWYT`abcSdeOPRQKLNMfghNone "#47HV_) |franz thread poolfranzpathfranzbuffer (ijmklnopq ijmklnopq(}      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOOPQRRSTUVWWXYZ[\]^_`abcdefghijjklmnopqrstuvwxyz{|}~$franz-0.3.0.1-4eG3N4JtDSvJ7a7VTycdfnDatabase.FranzDatabase.Franz.InternalDatabase.Franz.ProtocolDatabase.Franz.NetworkDatabase.Franz.ReaderDatabase.Franz.ServerData.Serialize getInt64le WriterHandle getLastSeqNo openWriter closeWriter withWriterwriteflush$fNFDataWriterHandle runGetRecv PayloadHeaderResponseHeaderResponse ResponseWait ResponseError ResponseId RawRequestRawCleanQuery reqStreamreqFromreqToreqTypeItemRefBySeqNumByIndex RequestTypeAllItemsLastItemFranzExceptionMalformedRequestStreamNotFound IndexNotFound InternalError ClientError IndexName apiVersion defaultPort$fExceptionFranzException$fSerializeFranzException$fSerializeRequestType$fSerializeItemRef$fSerializeQuery$fSerializeRawRequest$fSerializeResponseHeader$fSerializePayloadHeader$fShowFranzException$fGenericFranzException$fShowRequestType$fGenericRequestType $fShowItemRef$fGenericItemRef $fShowQuery$fGenericQuery$fGenericRawRequest$fShowResponseHeader$fGenericResponseHeaderContents SomeIndexMap ConnectionwithConnectionconnect disconnectdefQuery awaitResponsefetch fetchSimpleatomicallyWithin$fResourceMapConnStateMap$fShowResponseStatus$fFunctorResponseStatus ReaperState prunedStreams totalStreams FranzReader watchManagervStreams QueryResultActivityStreamvOffsets indexNamesindicesvCount vCaughtUp followThread indexHandle payloadHandle vActivity addActivityremoveActivity closeStream createStreamrangesplitRreaperwithFranzReader handleQuerySettings reapIntervalstreamLifetimeport livePrefix archivePrefix mountPrefix startServer$fResourceMapMountMaphOffsetvOffset offsetBuf offsetPtr indexCount unsafeFlush hPutElemsbase Data.EitherRightRequestFinishedrespond