Control.Distributed.Raketka.Type.Server

Documentation

type Content tag ps s c = (PeerInfo ps, Specific tag ps s c, Serializable c, Show c)

constraint type

c is Message content type, implementation-specific

class Specific tag ps s c | tag -> ps, tag -> s, tag -> c where

methods in this instance are called in library, defined in the program (this or another program that consumes this library)

see example implementation in Control.Distributed.Raketka.Impl.Inst

Control.Distributed.Raketka.Impl.Inst is part of the package, is not displayed in docs because it is part of a program, not the library.

see also Main.hs there is important code there

c is Message content type, implementation-specific

Minimal complete definition

startServer, handleMessage, onPeerConnected, onPeerDisConnected

Methods

startServer :: Tagged tag ServerId -> s -> Process ()

handleMessage :: Tagged tag (Server ps s) -> c -> Process ()

onPeerConnected :: Tagged tag (Server ps s) -> ProcessId -> Process ()

onPeerDisConnected :: Tagged tag (Server ps s) -> ProcessId -> Process ()

class PeerInfo ps where

Minimal complete definition

onPeerConnected', onPeerDisConnected', peer_pids

Methods

onPeerConnected' :: ps -> ProcessId -> ps

onPeerDisConnected' :: ps -> ProcessId -> ps

peer_pids :: ps -> [ProcessId]

Instances

PeerInfo (Set ProcessId)

Methods

onPeerConnected' :: Set ProcessId -> ProcessId -> Set ProcessId

onPeerDisConnected' :: Set ProcessId -> ProcessId -> Set ProcessId

peer_pids :: Set ProcessId -> [ProcessId]

passTag :: Tagged a b -> c -> Tagged a c

pass tag between different types

data Server ps s

Constructors

Server

Fields

• proxychan :: TChan (Process ())

  pipeline for sending messages

• servers :: TVar ps

  peer specific store

• spid :: ProcessId

  this node's pid

• state :: s

  this node's common store

la :: STM a -> Process a