Show PeerAddress Source #
Instance details Defined in Erebos.Network Methods showsPrec :: Int -> PeerAddress -> ShowS # show :: PeerAddress -> String # showList :: [PeerAddress] -> ShowS #
Eq PeerAddress Source #
Instance details Defined in Erebos.Network Methods (==) :: PeerAddress -> PeerAddress -> Bool # (/=) :: PeerAddress -> PeerAddress -> Bool #
Ord PeerAddress Source #
Instance details Defined in Erebos.Network Methods compare :: PeerAddress -> PeerAddress -> Ordering # (<) :: PeerAddress -> PeerAddress -> Bool # (<=) :: PeerAddress -> PeerAddress -> Bool # (>) :: PeerAddress -> PeerAddress -> Bool # (>=) :: PeerAddress -> PeerAddress -> Bool # max :: PeerAddress -> PeerAddress -> PeerAddress # min :: PeerAddress -> PeerAddress -> PeerAddress #

peerAddress :: Peer -> PeerAddress Source #

data PeerIdentity Source #

Constructors

PeerIdentityUnknown (TVar [UnifiedIdentity -> ExceptT String IO ()])
PeerIdentityRef WaitingRef (TVar [UnifiedIdentity -> ExceptT String IO ()])
PeerIdentityFull UnifiedIdentity

peerIdentity :: MonadIO m => Peer -> m PeerIdentity Source #

data WaitingRef Source #

wrDigest :: WaitingRef -> RefDigest Source #

class (Typeable s, Storable s, Typeable (ServiceState s), Typeable (ServiceGlobalState s)) => Service s where Source #

Minimal complete definition

serviceID, serviceHandler

Associated Types

type ServiceAttributes s = attr | attr -> s Source #

type ServiceAttributes s = Proxy s

type ServiceState s :: Type Source #

type ServiceState s = ()

type ServiceGlobalState s :: Type Source #

type ServiceGlobalState s = ()

Methods

serviceID :: proxy s -> ServiceID Source #

serviceHandler :: Stored s -> ServiceHandler s () Source #

serviceNewPeer :: ServiceHandler s () Source #

defaultServiceAttributes :: proxy s -> ServiceAttributes s Source #

default defaultServiceAttributes :: ServiceAttributes s ~ Proxy s => proxy s -> ServiceAttributes s Source #

emptyServiceState :: proxy s -> ServiceState s Source #

default emptyServiceState :: ServiceState s ~ () => proxy s -> ServiceState s Source #

emptyServiceGlobalState :: proxy s -> ServiceGlobalState s Source #

default emptyServiceGlobalState :: ServiceGlobalState s ~ () => proxy s -> ServiceGlobalState s Source #

serviceStorageWatchers :: proxy s -> [SomeStorageWatcher s] Source #

Instances

Instances details

Service DirectMessage Source #
Instance details Defined in Erebos.Message Associated Types type ServiceAttributes DirectMessage = (attr :: Type) Source # type ServiceState DirectMessage Source # type ServiceGlobalState DirectMessage Source # Methods serviceID :: proxy DirectMessage -> ServiceID Source # serviceHandler :: Stored DirectMessage -> ServiceHandler DirectMessage () Source # serviceNewPeer :: ServiceHandler DirectMessage () Source # defaultServiceAttributes :: proxy DirectMessage -> ServiceAttributes DirectMessage Source # emptyServiceState :: proxy DirectMessage -> ServiceState DirectMessage Source # emptyServiceGlobalState :: proxy DirectMessage -> ServiceGlobalState DirectMessage Source # serviceStorageWatchers :: proxy DirectMessage -> [SomeStorageWatcher DirectMessage] Source #
Service SyncService Source #
Instance details Defined in Erebos.Sync Associated Types type ServiceAttributes SyncService = (attr :: Type) Source # type ServiceState SyncService Source # type ServiceGlobalState SyncService Source # Methods serviceID :: proxy SyncService -> ServiceID Source # serviceHandler :: Stored SyncService -> ServiceHandler SyncService () Source # serviceNewPeer :: ServiceHandler SyncService () Source # defaultServiceAttributes :: proxy SyncService -> ServiceAttributes SyncService Source # emptyServiceState :: proxy SyncService -> ServiceState SyncService Source # emptyServiceGlobalState :: proxy SyncService -> ServiceGlobalState SyncService Source # serviceStorageWatchers :: proxy SyncService -> [SomeStorageWatcher SyncService] Source #
PairingResult a => Service (PairingService a) Source #
Instance details Defined in Erebos.Pairing Associated Types type ServiceAttributes (PairingService a) = (attr :: Type) Source # type ServiceState (PairingService a) Source # type ServiceGlobalState (PairingService a) Source # Methods serviceID :: proxy (PairingService a) -> ServiceID Source # serviceHandler :: Stored (PairingService a) -> ServiceHandler (PairingService a) () Source # serviceNewPeer :: ServiceHandler (PairingService a) () Source # defaultServiceAttributes :: proxy (PairingService a) -> ServiceAttributes (PairingService a) Source # emptyServiceState :: proxy (PairingService a) -> ServiceState (PairingService a) Source # emptyServiceGlobalState :: proxy (PairingService a) -> ServiceGlobalState (PairingService a) Source # serviceStorageWatchers :: proxy (PairingService a) -> [SomeStorageWatcher (PairingService a)] Source #

serverPeer :: Server -> SockAddr -> IO Peer Source #

sendToPeer :: (Service s, MonadIO m) => Peer -> s -> m () Source #

sendToPeerStored :: (Service s, MonadIO m) => Peer -> Stored s -> m () Source #

sendToPeerWith :: forall s m. (Service s, MonadIO m, MonadError String m) => Peer -> (ServiceState s -> ExceptT String IO (Maybe s, ServiceState s)) -> m () Source #

runPeerService :: forall s m. (Service s, MonadIO m) => Peer -> ServiceHandler s () -> m () Source #

discoveryPort :: PortNumber Source #