Safe Haskell	Safe-Inferred
Language	Haskell2010

Network.ZRE.Types

Contents

Orphan instances

Documentation

isec :: Num a => a -> a Source #

sec :: RealFrac a => a -> Int Source #

msec :: RealFrac a => a -> Int Source #

data ZRECfg Source #

Constructors

ZRECfg
Fields zreNamed :: ByteString zreQuietPeriod :: Float zreQuietPingRate :: Float zreDeadPeriod :: Float zreBeaconPeriod :: Float zreInterfaces :: [ByteString] zreMCast :: Endpoint zreZGossip :: Maybe Endpoint zreDbg :: Bool

Instances

Instances details

Show ZRECfg Source #
Instance details Defined in Network.ZRE.Types Methods showsPrec :: Int -> ZRECfg -> ShowS # show :: ZRECfg -> String # showList :: [ZRECfg] -> ShowS #
Default ZRECfg Source #
Instance details Defined in Network.ZRE.Types Methods def :: ZRECfg #

defMCastEndpoint :: Endpoint Source #

defaultConf :: ZRECfg Source #

data Event Source #

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

Instances details

Show Event Source #
Instance details Defined in Network.ZRE.Types Methods showsPrec :: Int -> Event -> ShowS # show :: Event -> String # showList :: [Event] -> ShowS #
MonadReader (EventQueue, APIQueue) ZRE Source #
Instance details Defined in Network.ZRE.Types Methods ask :: ZRE (EventQueue, APIQueue) # local :: ((EventQueue, APIQueue) -> (EventQueue, APIQueue)) -> ZRE a -> ZRE a # reader :: ((EventQueue, APIQueue) -> a) -> ZRE a #

data API Source #

Constructors

DoJoin Group
DoLeave Group
DoShout Group ByteString
DoShoutMulti Group [ByteString]
DoWhisper UUID ByteString
DoDiscover UUID Endpoint
DoDebug Bool
DoQuit

Instances

Instances details

Show API Source #
Instance details Defined in Network.ZRE.Types Methods showsPrec :: Int -> API -> ShowS # show :: API -> String # showList :: [API] -> ShowS #
MonadReader (EventQueue, APIQueue) ZRE Source #
Instance details Defined in Network.ZRE.Types 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) Source #

type PeerGroups = Map Group Peers Source #

type EventQueue = TBQueue Event Source #

type APIQueue = TBQueue API Source #

data ZREState Source #

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 ()] zreCfg :: ZRECfg

data Peer Source #

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

Instances details

Show Peer Source #
Instance details Defined in Network.ZRE.Types Methods showsPrec :: Int -> Peer -> ShowS # show :: Peer -> String # showList :: [Peer] -> ShowS #

newtype ZRE a Source #

Constructors

Z
Fields runZ' :: ReaderT (EventQueue, APIQueue) IO a

Instances

Instances details

MonadIO ZRE Source #
Instance details Defined in Network.ZRE.Types Methods liftIO :: IO a -> ZRE a #
Applicative ZRE Source #
Instance details Defined in Network.ZRE.Types 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 #
Functor ZRE Source #
Instance details Defined in Network.ZRE.Types Methods fmap :: (a -> b) -> ZRE a -> ZRE b # (<$) :: a -> ZRE b -> ZRE a #
Monad ZRE Source #
Instance details Defined in Network.ZRE.Types Methods (>>=) :: ZRE a -> (a -> ZRE b) -> ZRE b # (>>) :: ZRE a -> ZRE b -> ZRE b # return :: a -> ZRE a #
MonadBaseControl IO ZRE Source #
Instance details Defined in Network.ZRE.Types Associated Types type StM ZRE a # Methods liftBaseWith :: (RunInBase ZRE IO -> IO a) -> ZRE a # restoreM :: StM ZRE a -> ZRE a #
MonadBase IO ZRE Source #
Instance details Defined in Network.ZRE.Types Methods liftBase :: IO α -> ZRE α #
MonadReader (EventQueue, APIQueue) ZRE Source #
Instance details Defined in Network.ZRE.Types Methods ask :: ZRE (EventQueue, APIQueue) # local :: ((EventQueue, APIQueue) -> (EventQueue, APIQueue)) -> ZRE a -> ZRE a # reader :: ((EventQueue, APIQueue) -> a) -> ZRE a #
type StM ZRE a Source #
Instance details Defined in Network.ZRE.Types type StM ZRE a = a

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

readZ :: ZRE Event Source #

unReadZ :: Event -> ZRE () Source #

writeZ :: API -> ZRE () Source #

getEventQueue :: ZRE EventQueue Source #

getApiQueue :: ZRE APIQueue Source #

zjoin :: Group -> ZRE () Source #

zleave :: Group -> ZRE () Source #

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

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

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

zdebug :: ZRE () Source #

znodebug :: ZRE () Source #

zquit :: ZRE () Source #

zfail :: String -> ZRE a Source #

zrecv :: ZRE Event Source #

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

newZREState :: Name -> Endpoint -> UUID -> EventQueue -> APIQueue -> Bool -> ZRECfg -> IO (TVar ZREState) Source #

Orphan instances

Show a => Show (Async a) Source #
Instance details Methods showsPrec :: Int -> Async a -> ShowS # show :: Async a -> String # showList :: [Async a] -> ShowS #
Show a => Show (TBQueue a) Source #
Instance details Methods showsPrec :: Int -> TBQueue a -> ShowS # show :: TBQueue a -> String # showList :: [TBQueue a] -> ShowS #