Network.ZRE.Peer

Documentation

newPeerFromBeacon :: MonadIO m => Address -> Port -> UTCTime -> UUID -> TVar ZREState -> STM (TVar Peer, Maybe (m a), Maybe (IO b))

newPeerFromHello :: MonadIO m => ZRECmd -> UTCTime -> UUID -> TVar ZREState -> STM (TVar Peer, Maybe (m a), Maybe (IO b))

newPeerFromEndpoint :: MonadIO m => Endpoint -> UTCTime -> UUID -> TVar ZREState -> STM (TVar Peer, Maybe (m a), Maybe (IO b))

makePeer :: TVar ZREState -> UUID -> (UTCTime -> UUID -> TVar ZREState -> STM (TVar Peer, Maybe (IO ()), Maybe (IO ()))) -> IO (TVar Peer)

destroyPeer :: TVar ZREState -> UUID -> IO ()

msgPeer :: TVar Peer -> ZRECmd -> STM ()

msgPeerUUID :: TVar ZREState -> UUID -> ZRECmd -> STM ()

msgAll :: TVar ZREState -> ZRECmd -> STM ()

msgGroup :: TVar ZREState -> Group -> ZRECmd -> STM ()

joinGroup :: TVar ZREState -> TVar Peer -> Group -> GroupSeq -> STM ()

joinGroups :: TVar ZREState -> TVar Peer -> Set Group -> GroupSeq -> STM ()

leaveGroup :: TVar ZREState -> TVar Peer -> Group -> GroupSeq -> STM ()

leaveGroups :: TVar ZREState -> TVar Peer -> Set Group -> GroupSeq -> STM ()

lookupPeer :: TVar ZREState -> UUID -> STM (Maybe (TVar Peer))

updatePeer :: TVar Peer -> (Peer -> Peer) -> STM ()

updateLastHeard :: TVar Peer -> UTCTime -> STM ()

printPeer :: Peer -> ByteString

printAll :: TVar ZREState -> IO ()

msgAllJoin :: TVar ZREState -> Group -> GroupSeq -> STM ()

msgAllLeave :: TVar ZREState -> Group -> GroupSeq -> STM ()

shoutGroup :: TVar ZREState -> Group -> ByteString -> STM ()

shoutGroupMulti :: TVar ZREState -> Group -> Content -> STM ()

whisperPeerUUID :: TVar ZREState -> UUID -> ByteString -> STM ()