erebos-0.1.9: Decentralized messaging and synchronization
Safe HaskellNone
LanguageHaskell2010

Erebos.Network

Documentation

data Server Source #

startServer :: ServerOptions -> Head LocalState -> (String -> IO ()) -> [SomeService] -> IO Server Source #

stopServer :: Server -> IO () Source #

getCurrentPeerList :: Server -> IO [Peer] Source #

getNextPeerChange :: Server -> IO Peer Source #

getServerAddresses :: Server -> IO [SockAddr] Source #

data ServerOptions Source #

Constructors

ServerOptions 

Fields

serverIdentity :: Server -> IO UnifiedIdentity Source #

defaultServerOptions :: ServerOptions Source #

data Peer Source #

Instances

Instances details
Eq Peer Source # 
Instance details

Defined in Erebos.Network

Methods

(==) :: Peer -> Peer -> Bool #

(/=) :: Peer -> Peer -> Bool #

peerServer :: Peer -> Server Source #

peerStorage :: Peer -> Storage Source #

data PeerAddress Source #

Constructors

DatagramAddress SockAddr 

Instances

Instances details
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 (ServiceAttributes s), Typeable (ServiceState s), Typeable (ServiceGlobalState s)) => Service s where Source #

Minimal complete definition

serviceID, serviceHandler

Associated Types

type ServiceAttributes s = (attr :: Type) | attr -> s Source #

type ServiceAttributes s = Proxy s

type ServiceState s Source #

type ServiceState s = ()

type ServiceGlobalState s 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 #

serviceStopServer :: proxy s -> Server -> ServiceGlobalState s -> [(Peer, ServiceState s)] -> IO () Source #

Instances

Instances details
Service ChatroomService Source # 
Instance details

Defined in Erebos.Chatroom

Associated Types

type ServiceAttributes ChatroomService 
Instance details

Defined in Erebos.Chatroom

type ServiceAttributes ChatroomService = Proxy ChatroomService
type ServiceState ChatroomService 
Instance details

Defined in Erebos.Chatroom

type ServiceState ChatroomService
type ServiceGlobalState ChatroomService 
Instance details

Defined in Erebos.Chatroom

type ServiceGlobalState ChatroomService = ()

Methods

serviceID :: proxy ChatroomService -> ServiceID Source #

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

serviceNewPeer :: ServiceHandler ChatroomService () Source #

defaultServiceAttributes :: proxy ChatroomService -> ServiceAttributes ChatroomService Source #

emptyServiceState :: proxy ChatroomService -> ServiceState ChatroomService Source #

emptyServiceGlobalState :: proxy ChatroomService -> ServiceGlobalState ChatroomService Source #

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

serviceStopServer :: proxy ChatroomService -> Server -> ServiceGlobalState ChatroomService -> [(Peer, ServiceState ChatroomService)] -> IO () Source #

Service DiscoveryService Source # 
Instance details

Defined in Erebos.Discovery

Associated Types

type ServiceAttributes DiscoveryService 
Instance details

Defined in Erebos.Discovery

type ServiceAttributes DiscoveryService = DiscoveryAttributes
type ServiceState DiscoveryService 
Instance details

Defined in Erebos.Discovery

type ServiceState DiscoveryService
type ServiceGlobalState DiscoveryService 
Instance details

Defined in Erebos.Discovery

type ServiceGlobalState DiscoveryService

Methods

serviceID :: proxy DiscoveryService -> ServiceID Source #

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

serviceNewPeer :: ServiceHandler DiscoveryService () Source #

defaultServiceAttributes :: proxy DiscoveryService -> ServiceAttributes DiscoveryService Source #

emptyServiceState :: proxy DiscoveryService -> ServiceState DiscoveryService Source #

emptyServiceGlobalState :: proxy DiscoveryService -> ServiceGlobalState DiscoveryService Source #

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

serviceStopServer :: proxy DiscoveryService -> Server -> ServiceGlobalState DiscoveryService -> [(Peer, ServiceState DiscoveryService)] -> IO () Source #

Service DirectMessage Source # 
Instance details

Defined in Erebos.Message

Associated Types

type ServiceAttributes DirectMessage 
Instance details

Defined in Erebos.Message

type ServiceAttributes DirectMessage = DirectMessageAttributes
type ServiceState DirectMessage 
Instance details

Defined in Erebos.Message

type ServiceState DirectMessage = ()
type ServiceGlobalState DirectMessage 
Instance details

Defined in Erebos.Message

type ServiceGlobalState DirectMessage = ()

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 #

serviceStopServer :: proxy DirectMessage -> Server -> ServiceGlobalState DirectMessage -> [(Peer, ServiceState DirectMessage)] -> IO () Source #

Service SyncService Source # 
Instance details

Defined in Erebos.Sync

Associated Types

type ServiceAttributes SyncService 
Instance details

Defined in Erebos.Sync

type ServiceAttributes SyncService = Proxy SyncService
type ServiceState SyncService 
Instance details

Defined in Erebos.Sync

type ServiceState SyncService = ()
type ServiceGlobalState SyncService 
Instance details

Defined in Erebos.Sync

type ServiceGlobalState SyncService = ()

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 #

serviceStopServer :: proxy SyncService -> Server -> ServiceGlobalState SyncService -> [(Peer, ServiceState SyncService)] -> IO () Source #

PairingResult a => Service (PairingService a) Source # 
Instance details

Defined in Erebos.Pairing

Associated Types

type ServiceAttributes (PairingService a) 
Instance details

Defined in Erebos.Pairing

type ServiceAttributes (PairingService a) = PairingAttributes a
type ServiceState (PairingService a) 
Instance details

Defined in Erebos.Pairing

type ServiceState (PairingService a) = PairingState a
type ServiceGlobalState (PairingService a) 
Instance details

Defined in Erebos.Pairing

type ServiceGlobalState (PairingService a) = ()

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 #

serviceStopServer :: proxy (PairingService a) -> Server -> ServiceGlobalState (PairingService a) -> [(Peer, ServiceState (PairingService a))] -> IO () Source #

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

dropPeer :: MonadIO m => Peer -> m () Source #

isPeerDropped :: MonadIO m => Peer -> m Bool Source #

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

sendManyToPeer :: (Service s, MonadIO m) => Peer -> [s] -> m () Source #

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

sendManyToPeerStored :: (Service s, MonadIO m) => Peer -> [Stored s] -> m () Source #

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

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

modifyServiceGlobalState :: forall s a m proxy. (Service s, MonadIO m, MonadError String m) => Server -> proxy s -> (ServiceGlobalState s -> (ServiceGlobalState s, a)) -> m a Source #

discoveryPort :: PortNumber Source #