Safe Haskell	None
Language	Haskell2010

Database.Franz.Reader

Documentation

data RequestType Source #

Constructors

AllItems
LastItem

Instances

Show RequestType Source #
Instance details Defined in Database.Franz.Reader Methods showsPrec :: Int -> RequestType -> ShowS # show :: RequestType -> String # showList :: [RequestType] -> ShowS #
Generic RequestType Source #
Instance details Defined in Database.Franz.Reader Associated Types type Rep RequestType :: Type -> Type # Methods from :: RequestType -> Rep RequestType x # to :: Rep RequestType x -> RequestType #
Serialize RequestType Source #
Instance details Defined in Database.Franz.Reader Methods put :: Putter RequestType # get :: Get RequestType #
type Rep RequestType Source #
Instance details Defined in Database.Franz.Reader type Rep RequestType = D1 (MetaData "RequestType" "Database.Franz.Reader" "franz-0.2.1-DMs1sFxJDSYKCecIbcBQYI" False) (C1 (MetaCons "AllItems" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "LastItem" PrefixI False) (U1 :: Type -> Type))

data ItemRef Source #

Constructors

BySeqNum !Int	sequential number
ByIndex !ByteString !Int	index name and value

Instances

Show ItemRef Source #
Instance details Defined in Database.Franz.Reader Methods showsPrec :: Int -> ItemRef -> ShowS # show :: ItemRef -> String # showList :: [ItemRef] -> ShowS #
Generic ItemRef Source #
Instance details Defined in Database.Franz.Reader Associated Types type Rep ItemRef :: Type -> Type # Methods from :: ItemRef -> Rep ItemRef x # to :: Rep ItemRef x -> ItemRef #
Serialize ItemRef Source #
Instance details Defined in Database.Franz.Reader Methods put :: Putter ItemRef # get :: Get ItemRef #
type Rep ItemRef Source #
Instance details Defined in Database.Franz.Reader type Rep ItemRef = D1 (MetaData "ItemRef" "Database.Franz.Reader" "franz-0.2.1-DMs1sFxJDSYKCecIbcBQYI" False) (C1 (MetaCons "BySeqNum" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Int)) :+: C1 (MetaCons "ByIndex" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ByteString) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Int)))

data Query Source #

Constructors

Query
Fields reqStream :: !ByteString reqFrom :: !ItemRef name of the index to search reqTo :: !ItemRef name of the index to search reqType :: !RequestType

Instances

Show Query Source #
Instance details Defined in Database.Franz.Reader Methods showsPrec :: Int -> Query -> ShowS # show :: Query -> String # showList :: [Query] -> ShowS #
Generic Query Source #
Instance details Defined in Database.Franz.Reader Associated Types type Rep Query :: Type -> Type # Methods from :: Query -> Rep Query x # to :: Rep Query x -> Query #
Serialize Query Source #
Instance details Defined in Database.Franz.Reader Methods put :: Putter Query # get :: Get Query #
type Rep Query Source #
Instance details Defined in Database.Franz.Reader type Rep Query = D1 (MetaData "Query" "Database.Franz.Reader" "franz-0.2.1-DMs1sFxJDSYKCecIbcBQYI" False) (C1 (MetaCons "Query" PrefixI True) ((S1 (MetaSel (Just "reqStream") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ByteString) :: S1 (MetaSel (Just "reqFrom") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ItemRef)) :: (S1 (MetaSel (Just "reqTo") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ItemRef) :*: S1 (MetaSel (Just "reqType") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 RequestType))))

data Stream Source #

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 Source #

addActivity :: Activity -> Activity Source #

removeActivity :: Stream -> IO () Source #

closeStream :: Stream -> IO () Source #

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

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 FranzException Source #

Constructors

MalformedRequest !String
StreamNotFound !FilePath
IndexNotFound !ByteString ![ByteString]
InternalError !String
ClientError !String

Instances

Show FranzException Source #
Instance details Defined in Database.Franz.Reader Methods showsPrec :: Int -> FranzException -> ShowS # show :: FranzException -> String # showList :: [FranzException] -> ShowS #
Generic FranzException Source #
Instance details Defined in Database.Franz.Reader Associated Types type Rep FranzException :: Type -> Type # Methods from :: FranzException -> Rep FranzException x # to :: Rep FranzException x -> FranzException #
Exception FranzException Source #
Instance details Defined in Database.Franz.Reader Methods toException :: FranzException -> SomeException # fromException :: SomeException -> Maybe FranzException # displayException :: FranzException -> String #
Serialize FranzException Source #
Instance details Defined in Database.Franz.Reader Methods put :: Putter FranzException # get :: Get FranzException #
type Rep FranzException Source #
Instance details Defined in Database.Franz.Reader type Rep FranzException = D1 (MetaData "FranzException" "Database.Franz.Reader" "franz-0.2.1-DMs1sFxJDSYKCecIbcBQYI" False) ((C1 (MetaCons "MalformedRequest" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 String)) :+: C1 (MetaCons "StreamNotFound" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 FilePath))) :+: (C1 (MetaCons "IndexNotFound" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ByteString) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 [ByteString])) :+: (C1 (MetaCons "InternalError" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 String)) :+: C1 (MetaCons "ClientError" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 String)))))

data FranzReader Source #

Constructors

FranzReader
Fields watchManager :: WatchManager vStreams :: TVar (HashMap ByteString Stream) prefix :: FilePath

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

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

handleQuery :: FranzReader -> FilePath -> Query -> IO (Stream, STM (Bool, QueryResult)) Source #