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

getTimes, advance

Methods

getTimes

Arguments

:: Natural

number of needed timestamps

-> m LamportTime

Starting value of the range. So return value t means range [t .. t + n - 1].

Get sequential timestamps.

Laws: 1. t1 <- getTimes n t2 <- getTime t2 >= t1 + n

1. getTimes 0 == getTimes 1

advance :: LocalTime -> m ()

Instances

Clock LamportClock

Methods

getTimes :: Natural -> LamportClock LamportTime

advance :: LocalTime -> LamportClock ()

Monad m => Clock (ProcessSimT m)

Methods

getTimes :: Natural -> ProcessSimT m LamportTime

advance :: LocalTime -> ProcessSimT m ()

Clock m => Clock (StateT s m)

Methods

getTimes :: Natural -> StateT s m LamportTime

advance :: LocalTime -> StateT s m ()

Clock m => Clock (ReaderT * r m)

Methods

getTimes :: Natural -> ReaderT * r m LamportTime

advance :: LocalTime -> ReaderT * r m ()

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 :: Clock m => m LamportTime

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

Monad m => Process (ProcessSimT m)

Methods

getPid :: ProcessSimT m Pid

Process m => Process (StateT s m)

Methods

getPid :: StateT s m Pid

Process m => Process (ReaderT * r m)

Methods

getPid :: ReaderT * r m Pid

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

getTimes :: Natural -> LamportClock LamportTime

advance :: LocalTime -> LamportClock ()

Process LamportClock

Methods

getPid :: LamportClock Pid

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

Helpers

getRealLocalTime :: IO LocalTime

getMacAddress :: IO Word64