franz-0.5: Append-only database
Safe HaskellNone
LanguageHaskell2010

Database.Franz.Internal.Reader

Synopsis

Documentation

data StreamStatus Source #

Constructors

CaughtUp 
Outdated 
Gone 

Instances

Instances details
Eq StreamStatus Source # 
Instance details

Defined in Database.Franz.Internal.Reader

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

range Source #

Arguments

:: Int

from

-> Int

to

-> RequestType 
-> IntMap Int

offsets

-> (Bool, QueryResult) 

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

data ReaperState Source #

Constructors

ReaperState 

Fields

newtype FranzPrefix Source #

Globally-configured path which contains franz directories.

Constructors

FranzPrefix 

Instances

Instances details
Eq FranzPrefix Source # 
Instance details

Defined in Database.Franz.Internal.Reader

Hashable FranzPrefix Source # 
Instance details

Defined in Database.Franz.Internal.Reader

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