Network.ZRE.Types

Documentation

isec :: Num a => a -> a

sec :: RealFrac a => a -> Int

msec :: RealFrac a => a -> Int

data ZRECfg

Constructors

ZRECfg

Fields

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

Instances

Show ZRECfg

Defined in Network.ZRE.Types

Methods

showsPrec :: Int -> ZRECfg -> ShowS

show :: ZRECfg -> String

showList :: [ZRECfg] -> ShowS

Default ZRECfg

Defined in Network.ZRE.Types

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

Defined in Network.ZRE.Types

Methods

showsPrec :: Int -> Event -> ShowS

show :: Event -> String

showList :: [Event] -> ShowS

MonadReader (EventQueue, APIQueue) ZRE

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

Constructors

DoJoin Group

DoLeave Group

DoShout Group ByteString

DoShoutMulti Group [ByteString]

DoWhisper UUID ByteString

DoDiscover UUID Endpoint

DoDebug Bool

DoQuit

Instances

Show API

Defined in Network.ZRE.Types

Methods

showsPrec :: Int -> API -> ShowS

show :: API -> String

showList :: [API] -> ShowS

MonadReader (EventQueue, APIQueue) ZRE

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)

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

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

Defined in Network.ZRE.Types

Methods

showsPrec :: Int -> Peer -> ShowS

show :: Peer -> String

showList :: [Peer] -> ShowS

newtype ZRE a

Constructors

Z

Fields

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

Instances

MonadIO ZRE

Defined in Network.ZRE.Types

Methods

liftIO :: IO a -> ZRE a

Applicative ZRE

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

Defined in Network.ZRE.Types

Methods

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

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

Monad ZRE

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

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

Defined in Network.ZRE.Types

Methods

liftBase :: IO α -> ZRE α

MonadReader (EventQueue, APIQueue) ZRE

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

Defined in Network.ZRE.Types

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 ()

zfail :: String -> ZRE a

zrecv :: ZRE Event

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

newZREState :: Name -> Endpoint -> UUID -> EventQueue -> APIQueue -> Bool -> ZRECfg -> 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