Network.ZRE.Types

Documentation

isec :: Num a => a -> a

sec :: RealFrac a => a -> Int

msec :: RealFrac a => a -> Int

zreBeaconMs :: Int

quietPeriod :: NominalDiffTime

deadPeriod :: NominalDiffTime

quietPingRate :: Int

data ZRECfg

Constructors

ZRECfg

Fields

• zreNamed :: ByteString
• zreQuietPeriod :: Int
• zreDeadPeriod :: Int
• zreBeaconPeriod :: Int
• zreInterfaces :: [ByteString]
• zreMCast :: Endpoint
• zreZGossip :: Maybe Endpoint

Instances

Show ZRECfg

Methods

showsPrec :: Int -> ZRECfg -> ShowS

show :: ZRECfg -> String

showList :: [ZRECfg] -> ShowS

Default ZRECfg

Methods

def :: ZRECfg

defMCastEndpoint :: Endpoint

defaultConf :: ZRECfg

data Event

Constructors

New UUID (Maybe Name) Groups Headers Endpoint

Ready UUID Name Groups Headers Endpoint

GroupJoin UUID Group

GroupLeave UUID Group

Quit UUID (Maybe Name)

Message ZREMsg

Shout UUID Group Content UTCTime

Whisper UUID Content UTCTime

Debug ByteString

Instances

Show Event

Methods

showsPrec :: Int -> Event -> ShowS

show :: Event -> String

showList :: [Event] -> ShowS

MonadReader (EventQueue, APIQueue) ZRE

Methods

ask :: ZRE (EventQueue, APIQueue)

local :: ((EventQueue, APIQueue) -> (EventQueue, APIQueue)) -> ZRE a -> ZRE a

reader :: ((EventQueue, APIQueue) -> a) -> ZRE a

data API

Constructors

DoJoin Group

DoLeave Group

DoShout Group ByteString

DoShoutMulti Group [ByteString]

DoWhisper UUID ByteString

DoDiscover UUID Endpoint

DoDebug Bool

DoQuit

Instances

Show API

Methods

showsPrec :: Int -> API -> ShowS

show :: API -> String

showList :: [API] -> ShowS

MonadReader (EventQueue, APIQueue) ZRE

Methods

ask :: ZRE (EventQueue, APIQueue)

local :: ((EventQueue, APIQueue) -> (EventQueue, APIQueue)) -> ZRE a -> ZRE a

reader :: ((EventQueue, APIQueue) -> a) -> ZRE a

type Peers = Map UUID (TVar Peer)

type PeerGroups = Map Group Peers

type EventQueue = TBQueue Event

type APIQueue = TBQueue API

data ZREState

Constructors

ZREState

Fields

• zreUUID :: UUID
• zrePeers :: Peers
• zrePeerGroups :: PeerGroups
• zreEndpoint :: Endpoint
• zreGroups :: Groups
• zreGroupSeq :: GroupSeq
• zreName :: Name
• zreHeaders :: Headers
• zreDebug :: Bool
• zreIn :: EventQueue
• zreOut :: APIQueue
• zreIfaces :: Map ByteString [Async ()]

data Peer

Constructors

Peer

Fields

• peerEndpoint :: Endpoint
• peerUUID :: UUID
• peerSeq :: Seq
• peerGroups :: Groups
• peerGroupSeq :: GroupSeq
• peerName :: Maybe Name
• peerHeaders :: Headers
• peerAsync :: Maybe (Async ())
• peerAsyncPing :: Maybe (Async ())
• peerQueue :: TBQueue ZRECmd
• peerLastHeard :: UTCTime

Instances

Show Peer

Methods

showsPrec :: Int -> Peer -> ShowS

show :: Peer -> String

showList :: [Peer] -> ShowS

newtype ZRE a

Constructors

Z

Fields

• runZ' :: ReaderT (EventQueue, APIQueue) IO a

Instances

Monad ZRE

Methods

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

(>>) :: ZRE a -> ZRE b -> ZRE b

return :: a -> ZRE a

fail :: String -> ZRE a

Functor ZRE

Methods

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

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

Applicative ZRE

Methods

pure :: a -> ZRE a

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

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

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

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

MonadIO ZRE

Methods

liftIO :: IO a -> ZRE a

MonadBase IO ZRE

Methods

liftBase :: IO α -> ZRE α

MonadBaseControl IO ZRE

Associated Types

type StM (ZRE :: * -> *) a :: *

Methods

liftBaseWith :: (RunInBase ZRE IO -> IO a) -> ZRE a

restoreM :: StM ZRE a -> ZRE a

MonadReader (EventQueue, APIQueue) ZRE

Methods

ask :: ZRE (EventQueue, APIQueue)

local :: ((EventQueue, APIQueue) -> (EventQueue, APIQueue)) -> ZRE a -> ZRE a

reader :: ((EventQueue, APIQueue) -> a) -> ZRE a

type StM ZRE a

type StM ZRE a = a

runZ :: ZRE a -> EventQueue -> APIQueue -> IO a

readZ :: ZRE Event

unReadZ :: Event -> ZRE ()

writeZ :: API -> ZRE ()

getEventQueue :: ZRE EventQueue

getApiQueue :: ZRE APIQueue

zjoin :: Group -> ZRE ()

zleave :: Group -> ZRE ()

zshout :: Group -> ByteString -> ZRE ()

zshout' :: Group -> [ByteString] -> ZRE ()

zwhisper :: UUID -> ByteString -> ZRE ()

zdebug :: ZRE ()

znodebug :: ZRE ()

zquit :: ZRE ()

maybeM :: Monad m => m b -> (a -> m b) -> m (Maybe a) -> m b

newZREState :: Name -> Endpoint -> UUID -> EventQueue -> APIQueue -> IO (TVar ZREState)

Orphan instances

Show a => Show (Async a)

Methods

showsPrec :: Int -> Async a -> ShowS

show :: Async a -> String

showList :: [Async a] -> ShowS

Show a => Show (TBQueue a)

Methods

showsPrec :: Int -> TBQueue a -> ShowS

show :: TBQueue a -> String

showList :: [TBQueue a] -> ShowS