Documentation

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

printPeer :: Peer -> ByteString Source #

printAll :: TVar ZREState -> IO () Source #

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

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

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

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

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