CRDT.LamportClock

Documentation

newtype Pid

Unique process identifier

Constructors

Pid Int

Instances

Eq Pid

Methods

(==) :: Pid -> Pid -> Bool

(/=) :: Pid -> Pid -> Bool

Ord Pid

Methods

compare :: Pid -> Pid -> Ordering

(<) :: Pid -> Pid -> Bool

(<=) :: Pid -> Pid -> Bool

(>) :: Pid -> Pid -> Bool

(>=) :: Pid -> Pid -> Bool

max :: Pid -> Pid -> Pid

min :: Pid -> Pid -> Pid

Show Pid

Methods

showsPrec :: Int -> Pid -> ShowS

show :: Pid -> String

showList :: [Pid] -> ShowS

Lamport timestamp (for a single process)

data LamportTime

Constructors

LamportTime !LocalTime !Pid

Instances

Eq LamportTime

Methods

(==) :: LamportTime -> LamportTime -> Bool

(/=) :: LamportTime -> LamportTime -> Bool

Ord LamportTime

Methods

compare :: LamportTime -> LamportTime -> Ordering

(<) :: LamportTime -> LamportTime -> Bool

(<=) :: LamportTime -> LamportTime -> Bool

(>) :: LamportTime -> LamportTime -> Bool

(>=) :: LamportTime -> LamportTime -> Bool

max :: LamportTime -> LamportTime -> LamportTime

min :: LamportTime -> LamportTime -> LamportTime

Show LamportTime

Methods

showsPrec :: Int -> LamportTime -> ShowS

show :: LamportTime -> String

showList :: [LamportTime] -> ShowS

getTime :: Process LamportTime

advance :: LamportTime -> Process ()

Lamport clock (for a whole multi-process system)

newtype LamportClock a

Key is Pid. Non-present value is equivalent to 0.

Constructors

LamportClock (State (IntMap LocalTime) a)

Instances

Monad LamportClock

Methods

(>>=) :: LamportClock a -> (a -> LamportClock b) -> LamportClock b

(>>) :: LamportClock a -> LamportClock b -> LamportClock b

return :: a -> LamportClock a

fail :: String -> LamportClock a

Functor LamportClock

Methods

fmap :: (a -> b) -> LamportClock a -> LamportClock b

(<$) :: a -> LamportClock b -> LamportClock a

Applicative LamportClock

Methods

pure :: a -> LamportClock a

(<*>) :: LamportClock (a -> b) -> LamportClock a -> LamportClock b

(*>) :: LamportClock a -> LamportClock b -> LamportClock b

(<*) :: LamportClock a -> LamportClock b -> LamportClock a

runLamportClock :: LamportClock a -> a

Process

newtype Process a

Constructors

Process (ReaderT Pid LamportClock a)

Instances

Monad Process

Methods

(>>=) :: Process a -> (a -> Process b) -> Process b

(>>) :: Process a -> Process b -> Process b

return :: a -> Process a

fail :: String -> Process a

Functor Process

Methods

fmap :: (a -> b) -> Process a -> Process b

(<$) :: a -> Process b -> Process a

Applicative Process

Methods

pure :: a -> Process a

(<*>) :: Process (a -> b) -> Process a -> Process b

(*>) :: Process a -> Process b -> Process b

(<*) :: Process a -> Process b -> Process a

getPid :: Process Pid

runProcess :: Pid -> Process a -> LamportClock a