Safe Haskell	None
Language	Haskell2010

MessageDb.Subscription.PositionStrategy

Description

Strategies for saving subscription position.

Synopsis

type LastPositionSaved = GlobalPosition
type CurrentPosition = GlobalPosition
type PositionSaved = GlobalPosition
data PositionStrategy = PositionStrategy {
- restore :: IO GlobalPosition
- save :: LastPositionSaved -> CurrentPosition -> IO (Maybe PositionSaved)
}
dontSave :: PositionStrategy
newtype PositionUpdateInterval = PositioUpdateInterval {
- fromPositionUpdateInterval :: NumberOfMessages
}
writeToStream :: WithConnection -> PositionUpdateInterval -> StreamName -> PositionStrategy

Documentation

type LastPositionSaved = GlobalPosition Source #

type CurrentPosition = GlobalPosition Source #

type PositionSaved = GlobalPosition Source #

data PositionStrategy Source #

Strategy for saving and restoring a subscription's position.

Constructors

PositionStrategy
Fields restore :: IO GlobalPosition save :: LastPositionSaved -> CurrentPosition -> IO (Maybe PositionSaved)

dontSave :: PositionStrategy Source #

Start at zero and don't ever save the position.

newtype PositionUpdateInterval Source #

Minimum difference between the current position and last position saved to save the position.

Constructors

PositioUpdateInterval
Fields fromPositionUpdateInterval :: NumberOfMessages

Instances

Instances details

Enum PositionUpdateInterval Source #
Instance details Defined in MessageDb.Subscription.PositionStrategy Methods succ :: PositionUpdateInterval -> PositionUpdateInterval # pred :: PositionUpdateInterval -> PositionUpdateInterval # toEnum :: Int -> PositionUpdateInterval # fromEnum :: PositionUpdateInterval -> Int # enumFrom :: PositionUpdateInterval -> [PositionUpdateInterval] # enumFromThen :: PositionUpdateInterval -> PositionUpdateInterval -> [PositionUpdateInterval] # enumFromTo :: PositionUpdateInterval -> PositionUpdateInterval -> [PositionUpdateInterval] # enumFromThenTo :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval -> [PositionUpdateInterval] #
Eq PositionUpdateInterval Source #
Instance details Defined in MessageDb.Subscription.PositionStrategy Methods (==) :: PositionUpdateInterval -> PositionUpdateInterval -> Bool # (/=) :: PositionUpdateInterval -> PositionUpdateInterval -> Bool #
Integral PositionUpdateInterval Source #
Instance details Defined in MessageDb.Subscription.PositionStrategy Methods quot :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval # rem :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval # div :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval # mod :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval # quotRem :: PositionUpdateInterval -> PositionUpdateInterval -> (PositionUpdateInterval, PositionUpdateInterval) # divMod :: PositionUpdateInterval -> PositionUpdateInterval -> (PositionUpdateInterval, PositionUpdateInterval) # toInteger :: PositionUpdateInterval -> Integer #
Num PositionUpdateInterval Source #
Instance details Defined in MessageDb.Subscription.PositionStrategy Methods (+) :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval # (-) :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval # (*) :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval # negate :: PositionUpdateInterval -> PositionUpdateInterval # abs :: PositionUpdateInterval -> PositionUpdateInterval # signum :: PositionUpdateInterval -> PositionUpdateInterval # fromInteger :: Integer -> PositionUpdateInterval #
Ord PositionUpdateInterval Source #
Instance details Defined in MessageDb.Subscription.PositionStrategy Methods compare :: PositionUpdateInterval -> PositionUpdateInterval -> Ordering # (<) :: PositionUpdateInterval -> PositionUpdateInterval -> Bool # (<=) :: PositionUpdateInterval -> PositionUpdateInterval -> Bool # (>) :: PositionUpdateInterval -> PositionUpdateInterval -> Bool # (>=) :: PositionUpdateInterval -> PositionUpdateInterval -> Bool # max :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval # min :: PositionUpdateInterval -> PositionUpdateInterval -> PositionUpdateInterval #
Real PositionUpdateInterval Source #
Instance details Defined in MessageDb.Subscription.PositionStrategy Methods toRational :: PositionUpdateInterval -> Rational #
Show PositionUpdateInterval Source #
Instance details Defined in MessageDb.Subscription.PositionStrategy Methods showsPrec :: Int -> PositionUpdateInterval -> ShowS # show :: PositionUpdateInterval -> String # showList :: [PositionUpdateInterval] -> ShowS #

writeToStream :: WithConnection -> PositionUpdateInterval -> StreamName -> PositionStrategy Source #

Write the subscription's position to a stream.