Database.Franz.Reader

Documentation

data Stream

Constructors

Stream

Fields

• vOffsets :: !(TVar (IntMap Int))
• indexNames :: ![ByteString]
• indices :: !(HashMap ByteString (TVar (IntMap Int)))
• vCount :: !(TVar Int)
• vCaughtUp :: !(TVar Bool)
• followThread :: !ThreadId
• indexHandle :: !Handle
• payloadHandle :: !Handle
• vActivity :: !(TVar Activity)

type Activity = Either Double Int

addActivity :: Stream -> STM ()

removeActivity :: Stream -> IO ()

closeStream :: Stream -> IO ()

createStream :: WatchManager -> FilePath -> IO Stream

type QueryResult = ((Int, Int), (Int, Int))

range

Arguments

:: Int

from

-> Int

to

-> RequestType

-> IntMap Int

offsets

-> (Bool, QueryResult)

splitR :: Int -> IntMap a -> (IntMap a, IntMap a)

data FranzReader

Constructors

FranzReader

Fields

• watchManager :: WatchManager
• vStreams :: TVar (HashMap FilePath (HashMap ByteString Stream))

data ReaperState

Constructors

ReaperState

Fields

• prunedStreams :: !Int

  How many streams we pruned.

• totalStreams :: !Int

  How many streams we saw in total.

reaper :: Double -> Double -> FranzReader -> IO ()

withFranzReader :: (FranzReader -> IO ()) -> IO ()

handleQuery

Arguments

:: FilePath

prefix

-> FranzReader

-> FilePath

directory

-> Query

-> (Stream -> STM (Bool, QueryResult) -> IO r)

-> IO r