CRDT.LamportClock

Documentation

newtype Pid

Unique process identifier

Constructors

Pid Word64

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)

class Process m => Clock m where

Minimal complete definition

getTime, advance

Methods

getTime :: m LamportTime

advance :: LocalTime -> m ()

Instances

Clock LamportClock

Methods

getTime :: LamportClock LamportTime

advance :: LocalTime -> LamportClock ()

Clock ProcessSim

Methods

getTime :: ProcessSim LamportTime

advance :: LocalTime -> ProcessSim ()

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

type LocalTime = Natural

Unix time in 10^{-7} seconds (100 ns), as in RFC 4122 and Swarm RON.

class Monad m => Process m where

Minimal complete definition

getPid

Methods

getPid :: m Pid

Instances

Process LamportClock

Methods

getPid :: LamportClock Pid

Process ProcessSim

Methods

getPid :: ProcessSim Pid

Lamport clock simulation

newtype LamportClockSim a

Lamport clock simpulation. Key is Pid. Non-present value is equivalent to 0.

Constructors

LamportClockSim (State (Map Pid LocalTime) a)

Instances

Monad LamportClockSim

Methods

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

(>>) :: LamportClockSim a -> LamportClockSim b -> LamportClockSim b

return :: a -> LamportClockSim a

fail :: String -> LamportClockSim a

Functor LamportClockSim

Methods

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

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

Applicative LamportClockSim

Methods

pure :: a -> LamportClockSim a

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

liftA2 :: (a -> b -> c) -> LamportClockSim a -> LamportClockSim b -> LamportClockSim c

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

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

newtype ProcessSim a

ProcessSim inside Lamport clock simpulation.

Constructors

ProcessSim (ReaderT Pid LamportClockSim a)

Instances

Monad ProcessSim

Methods

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

(>>) :: ProcessSim a -> ProcessSim b -> ProcessSim b

return :: a -> ProcessSim a

fail :: String -> ProcessSim a

Functor ProcessSim

Methods

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

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

Applicative ProcessSim

Methods

pure :: a -> ProcessSim a

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

liftA2 :: (a -> b -> c) -> ProcessSim a -> ProcessSim b -> ProcessSim c

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

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

Clock ProcessSim

Methods

getTime :: ProcessSim LamportTime

advance :: LocalTime -> ProcessSim ()

Process ProcessSim

Methods

getPid :: ProcessSim Pid

runLamportClockSim :: LamportClockSim a -> a

runProcessSim :: Pid -> ProcessSim a -> LamportClockSim a

Real Lamport clock

data LamportClock 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

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

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

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

MonadIO LamportClock

Methods

liftIO :: IO a -> LamportClock a

Clock LamportClock

Methods

getTime :: LamportClock LamportTime

advance :: LocalTime -> LamportClock ()

Process LamportClock

Methods

getPid :: LamportClock Pid

runLamportClock :: TVar LocalTime -> LamportClock a -> IO a

Helpers

getRealLocalTime :: IO LocalTime