úÎ!*“%X      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWNone"#HXÁ XfranzHandle for offsets and indicesYfranz3(next sequential number, current payload file size)Zfranzpending indices[franzthe number of pending indices\franz'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.]franz!Flush the change without locking Y^franzUSame 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 valuesfranzpayloadNone"#7_Ò"franzname of the index to search#franzname of the index to search&franzsequential number'franzindex name and value/franzfromfranztofranzoffsets-   $#"!%'&(*)+,-./0123-(*)%'& $#"!+,-./0   123None"#%47_#ù Afranz When it is _+, it might block until the content arrives.Bfranz(seqno, indices, payloads)`franz4Initial seqno, final seqno, base offset, index namesafranzDresponse ID, number of streams; there are items satisfying the querybfranz;response ID; requested elements are not available right nowcfranz3response ID, number of streams; items are availabledfranzsomething went wrongLfranz‡Fetch requested data from the server. Termination of the continuation cancels the request, allowing flexible control of its lifetime.MfranzQueries in traversable ta form an atomic request. The response will become available once all the elements are available._Generalisation to Traversable guarantees that the response preserves the shape of the request.NfranzVSend a single query and wait for the result. If it timeouts, it returns an empty list.Lfranz8running the STM action blocks until the response arrivesNfranztimeout in microsecondsOfranztimeout in microseconds!   !"#$%&'()*ABCDEFGHIJKLMNO!FEDGHI !"#$%&'()*JAKCBLMNO  e       !!"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefgh"franz-0.2.1-DMs1sFxJDSYKCecIbcBQYIDatabase.FranzDatabase.Franz.ReaderDatabase.Franz.Network WriterHandle getLastSeqNo openWriter closeWriter withWriterwriteflush FranzReader watchManagervStreamsprefixFranzExceptionMalformedRequestStreamNotFound IndexNotFound InternalError ClientError QueryResultActivityStreamvOffsets indexNamesindicesvCount vCaughtUp followThread indexHandle payloadHandle vActivityQuery reqStreamreqFromreqToreqTypeItemRefBySeqNumByIndex RequestTypeAllItemsLastItem addActivityremoveActivity closeStream createStreamrangesplitRreaperwithFranzReader handleQuery$fSerializeRequestType$fSerializeItemRef$fSerializeQuery$fExceptionFranzException$fSerializeFranzException$fShowRequestType$fGenericRequestType $fShowItemRef$fGenericItemRef $fShowQuery$fGenericQuery$fShowFranzException$fGenericFranzExceptionResponseContents SomeIndexMap Connection defaultPort startServerwithConnectionconnect disconnectdefQuery awaitResponsefetch fetchTraverse fetchSimpleatomicallyWithin$fSerializeRawRequest$fSerializeResponseHeader$fSerializePayloadHeader$fGenericRawRequest$fShowResponseHeader$fGenericResponseHeader$fShowResponseStatus$fFunctorResponseStatushOffsetvOffset offsetBuf offsetPtr indexCount unsafeFlush hPutElemsbase Data.EitherRight PayloadHeaderResponseInstant ResponseWaitResponseDelayed ResponseError