Transient.Move.PubSub

Documentation

type Suscribed = Map String [Node]

suscribed :: DBRef Suscribed

atomicModifyDBRef :: DBRef Suscribed -> (Suscribed -> (Suscribed, a)) -> IO a

suscribe :: (Typeable a, Loggable a) => String -> Cloud a

notifySuscribe :: Loggable a => String -> Node -> Cloud a

unsuscribe :: Typeable a => String -> a -> Cloud ()

publish :: (Typeable a, Loggable a) => String -> a -> Cloud ()

foldPublish :: (Loggable a1, Loggable a2) => (Cloud a2 -> Cloud a3 -> Cloud a3) -> Cloud a3 -> [Node] -> String -> Cloud a2 -> Cloud a1

executes proc in all the nodes suscribed to key

Orphan instances

Indexable Suscribed

Methods

key :: Suscribed -> String

defPath :: Suscribed -> String

Serializable Suscribed

Methods

serialize :: Suscribed -> ByteString

deserialize :: ByteString -> Suscribed

deserialKey :: String -> ByteString -> Suscribed

setPersist :: Suscribed -> Maybe Persist