Safe Haskell	None
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 #

zreBeaconMs :: Int Source #

quietPeriod :: NominalDiffTime Source #

deadPeriod :: NominalDiffTime Source #

quietPingRate :: Int Source #

data ZRECfg Source #

Constructors

ZRECfg
Fields zreNamed :: ByteString zreQuietPeriod :: Int zreDeadPeriod :: Int zreBeaconPeriod :: Int 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 ()]

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

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 #
Functor ZRE Source #
Instance details Defined in Network.ZRE.Types Methods fmap :: (a -> b) -> ZRE a -> ZRE b # (<$) :: a -> ZRE b -> 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 #
MonadIO ZRE Source #
Instance details Defined in Network.ZRE.Types Methods liftIO :: IO a -> ZRE a #
MonadBase IO ZRE Source #
Instance details Defined in Network.ZRE.Types Methods liftBase :: IO α -> ZRE α #
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 #
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 #

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 -> 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 #