Safe Haskell	None
Language	Haskell2010

Database.Franz.Internal.Reader

Synopsis

data StreamStatus
- = CaughtUp
- | Outdated
- | Gone
data Stream = Stream {
- streamPath :: FilePath
- vOffsets :: !(TVar (IntMap Int))
- indexNames :: !(Vector IndexName)
- indices :: !(HashMap IndexName (TVar (IntMap Int)))
- vCount :: !(TVar Int)
- vStatus :: !(TVar StreamStatus)
- 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))
isEmptyResult :: QueryResult -> Bool
range :: Int -> Int -> RequestType -> IntMap Int -> (Bool, QueryResult)
splitR :: Int -> IntMap a -> (IntMap a, IntMap a)
data FranzReader = FranzReader {
- watchManager :: WatchManager
- vStreams :: TVar (HashMap FranzDirectory (HashMap StreamName Stream))
}
data ReaperState = ReaperState {
- prunedStreams :: !Int
- totalStreams :: !Int
}
reaper :: Double -> Double -> FranzReader -> IO ()
withFranzReader :: (FranzReader -> IO ()) -> IO ()
newFranzReader :: IO FranzReader
closeFranzReader :: FranzReader -> IO ()
newtype FranzPrefix = FranzPrefix {
- unFranzPrefix :: FilePath
}
newtype FranzDirectory = FranzDirectory FilePath
getFranzDirectory :: FranzPrefix -> FranzDirectory -> FilePath
getFranzStreamPath :: FranzPrefix -> FranzDirectory -> StreamName -> FilePath
handleQuery :: FranzPrefix -> FranzReader -> FranzDirectory -> Query -> (FranzException -> IO r) -> (Stream -> STM (Maybe QueryResult) -> IO r) -> IO r

Documentation

data StreamStatus Source #

Constructors

CaughtUp
Outdated
Gone

Instances

Instances details

Eq StreamStatus Source #
Instance details Defined in Database.Franz.Internal.Reader Methods (==) :: StreamStatus -> StreamStatus -> Bool # (/=) :: StreamStatus -> StreamStatus -> Bool #

data Stream Source #

Constructors

Stream
Fields streamPath :: FilePath vOffsets :: !(TVar (IntMap Int)) indexNames :: !(Vector IndexName) indices :: !(HashMap IndexName (TVar (IntMap Int))) vCount :: !(TVar Int) vStatus :: !(TVar StreamStatus) followThread :: !ThreadId indexHandle :: !Handle payloadHandle :: !Handle vActivity :: !(TVar Activity)

type Activity = Either Double Int Source #

addActivity :: Stream -> STM () Source #

removeActivity :: Stream -> IO () Source #

closeStream :: Stream -> IO () Source #

createStream :: WatchManager -> FilePath -> IO Stream Source #

type QueryResult = ((Int, Int), (Int, Int)) Source #

isEmptyResult :: QueryResult -> Bool Source #

range Source #

Arguments

:: Int	from
-> Int	to
-> RequestType
-> IntMap Int	offsets
-> (Bool, QueryResult)

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

data FranzReader Source #

Constructors

FranzReader
Fields watchManager :: WatchManager vStreams :: TVar (HashMap FranzDirectory (HashMap StreamName Stream))

data ReaperState Source #

Constructors

ReaperState
Fields prunedStreams :: !Int How many streams we pruned. totalStreams :: !Int How many streams we saw in total.

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

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

newFranzReader :: IO FranzReader Source #

closeFranzReader :: FranzReader -> IO () Source #

newtype FranzPrefix Source #

Globally-configured path which contains franz directories.

Constructors

FranzPrefix
Fields unFranzPrefix :: FilePath

Instances

Instances details

Eq FranzPrefix Source #
Instance details Defined in Database.Franz.Internal.Reader Methods (==) :: FranzPrefix -> FranzPrefix -> Bool # (/=) :: FranzPrefix -> FranzPrefix -> Bool #
Hashable FranzPrefix Source #
Instance details Defined in Database.Franz.Internal.Reader Methods hashWithSalt :: Int -> FranzPrefix -> Int # hash :: FranzPrefix -> Int #

newtype FranzDirectory Source #

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

Constructors

FranzDirectory FilePath

Instances

Instances details

Eq FranzDirectory Source #
Instance details Defined in Database.Franz.Internal.Reader Methods (==) :: FranzDirectory -> FranzDirectory -> Bool # (/=) :: FranzDirectory -> FranzDirectory -> Bool #
Hashable FranzDirectory Source #
Instance details Defined in Database.Franz.Internal.Reader Methods hashWithSalt :: Int -> FranzDirectory -> Int # hash :: FranzDirectory -> Int #

getFranzDirectory :: FranzPrefix -> FranzDirectory -> FilePath Source #

getFranzStreamPath :: FranzPrefix -> FranzDirectory -> StreamName -> FilePath Source #

handleQuery :: FranzPrefix -> FranzReader -> FranzDirectory -> Query -> (FranzException -> IO r) -> (Stream -> STM (Maybe QueryResult) -> IO r) -> IO r Source #