Module

ZeroMQ

Package: purescript-zeromq
Repository: athanclark/purescript-zeromq

#ZEROMQ Source

data ZEROMQ :: Effect

#Pair Source

newtype Pair

Instances

#pair Source

pair :: Pair

#Pub Source

newtype Pub

Instances

#pub Source

pub :: Pub

#Sub Source

newtype Sub

Instances

#sub Source

sub :: Sub

#XPub Source

newtype XPub

Instances

#xpub Source

xpub :: XPub

#XSub Source

newtype XSub

Instances

#xsub Source

xsub :: XSub

#Pull Source

newtype Pull

Instances

#pull Source

pull :: Pull

#Push Source

newtype Push

Instances

#push Source

push :: Push

#Req Source

newtype Req

Instances

#req Source

req :: Req

#Rep Source

newtype Rep

Instances

#rep Source

rep :: Rep

#Router Source

newtype Router

Instances

#router Source

router :: Router

#Dealer Source

newtype Dealer

Instances

#dealer Source

dealer :: Dealer

#Socket Source

data Socket :: Type -> Type -> Location -> Type

#IsLegal Source

class IsLegal from to

Instances

#socket Source

socket :: forall eff loc to from. IsLegal from to => from -> to -> Eff (zeromq :: ZEROMQ | eff) (Socket from to loc)

#ZMQ_Option Source

newtype ZMQ_Option

Instances

Generic ZMQ_Option
Eq ZMQ_Option

#zmqIdentity Source

zmqIdentity :: ZMQ_Option

#ZMQIdent Source

newtype ZMQIdent

Constructors

ZMQIdent Buffer

Instances

#setOption Source

setOption :: forall loc to from eff. Socket from to loc -> ZMQ_Option -> Buffer -> Eff (zeromq :: ZEROMQ | eff) Unit

#getOption Source

getOption :: forall loc to from eff. Socket from to loc -> ZMQ_Option -> Eff (zeromq :: ZEROMQ | eff) (Maybe Buffer)

#bind' Source

bind' :: forall to from eff. Bindable from => Socket from to Bound -> String -> Aff (zeromq :: ZEROMQ | eff) Unit

#unbind Source

unbind :: forall to from eff. Bindable from => Socket from to Bound -> String -> Aff (zeromq :: ZEROMQ | eff) Unit

#bindSync Source

bindSync :: forall to from eff. Bindable from => Socket from to Bound -> String -> Eff (zeromq :: ZEROMQ | eff) Unit

#unbindSync Source

unbindSync :: forall to from eff. Bindable from => Socket from to Bound -> String -> Eff (zeromq :: ZEROMQ | eff) Unit

#Bindable Source

class Bindable from

Instances

#connect Source

connect :: forall to from eff. Connectable from => Socket from to Connected -> String -> Eff (zeromq :: ZEROMQ | eff) Unit

#disconnect Source

disconnect :: forall to from eff. Connectable from => Socket from to Connected -> String -> Eff (zeromq :: ZEROMQ | eff) Unit

#Connectable Source

class Connectable from

Instances

#unsubscribe Source

unsubscribe :: forall loc to from eff. Subscriber from => Socket from to loc -> String -> Eff (zeromq :: ZEROMQ | eff) Unit

#Subscriber Source

class Subscriber from

Instances

Subscriber Sub

#monitor Source

monitor :: forall loc to from eff. Socket from to loc -> Milliseconds -> Int -> Eff (zeromq :: ZEROMQ | eff) Unit

#unmonitor Source

unmonitor :: forall loc to from eff. Socket from to loc -> Eff (zeromq :: ZEROMQ | eff) Unit

#addMonitorListener Source

addMonitorListener :: forall loc to from eff. Socket from to loc -> MonitorEvent -> (Foreign -> Eff (zeromq :: ZEROMQ | eff) Unit) -> Eff (zeromq :: ZEROMQ | eff) Unit

#removeAllMonitorListeners Source

removeAllMonitorListeners :: forall loc to from eff. Socket from to loc -> MonitorEvent -> Eff (zeromq :: ZEROMQ | eff) Unit

#MonitorEvent Source

newtype MonitorEvent

Instances

Generic MonitorEvent
Eq MonitorEvent

#connectE Source

connectE :: MonitorEvent

#connectDelayE Source

connectDelayE :: MonitorEvent

#connectRetryE Source

connectRetryE :: MonitorEvent

#listenE Source

listenE :: MonitorEvent

#bindErrorE Source

bindErrorE :: MonitorEvent

#acceptE Source

acceptE :: MonitorEvent

#acceptErrorE Source

acceptErrorE :: MonitorEvent

#closeE Source

closeE :: MonitorEvent

#closeErrorE Source

closeErrorE :: MonitorEvent

#disconnectE Source

disconnectE :: MonitorEvent

#Flag Source

newtype Flag

Instances

Generic Flag
Eq Flag

#sendMore Source

sendMore :: Flag

#dontWait Source

dontWait :: Flag

#close Source

close :: forall loc to from eff. Socket from to loc -> Eff (zeromq :: ZEROMQ | eff) Unit

#Sendable Source

class Sendable from to aux | from to -> aux where

Members

sendMany :: forall loc eff. aux -> Socket from to loc -> NonEmpty Array Buffer -> Eff (zeromq :: ZEROMQ | eff) Unit

Instances

#sendJson Source

sendJson :: forall loc eff a aux to from. Sendable from to aux => EncodeJson a => aux -> Socket from to loc -> a -> Eff (buffer :: BUFFER, zeromq :: ZEROMQ | eff) Unit

#Receivable Source

class Receivable from to aux | from to -> aux where

Members

readMany :: forall loc eff. Socket from to loc -> Aff (zeromq :: ZEROMQ | eff) (Maybe { aux :: aux, msg :: NonEmpty Array Buffer })

Instances

#readJson Source

readJson :: forall a loc eff aux to from. Receivable from to aux => DecodeJson a => Socket from to loc -> Aff (buffer :: BUFFER, zeromq :: ZEROMQ | eff) (Maybe { aux :: aux, msg :: a })

#readJson' Source

readJson' :: forall a loc eff aux to from. Receivable from to aux => DecodeJson a => Socket from to loc -> Aff (buffer :: BUFFER, zeromq :: ZEROMQ | eff) (Maybe (Either String { aux :: aux, msg :: a }))

#addReceiveListener Source

addReceiveListener :: forall loc to from eff. Socket from to loc -> (Array Buffer -> Eff (zeromq :: ZEROMQ | eff) Unit) -> Eff (zeromq :: ZEROMQ | eff) Unit

#removeAllReceiveListeners Source

removeAllReceiveListeners :: forall loc to from eff. Socket from to loc -> Eff (zeromq :: ZEROMQ | eff) Unit

#proxy Source

proxy :: forall loc3 to3 from3 to2 from2 to1 from1 eff. Socket from1 to1 Bound -> Socket from2 to2 Bound -> Maybe (Socket from3 to3 loc3) -> Eff (zeromq :: ZEROMQ | eff) Unit

#Location Source

data Location :: Type

#Bound Source

data Bound :: Location

#Connected Source

data Connected :: Location

Modules: ZeroMQ

ZeroMQ

#ZEROMQ Source

#Pair Source

Instances

#pair Source

#Pub Source

Instances

#pub Source

#Sub Source

Instances

#sub Source

#XPub Source

Instances

#xpub Source

#XSub Source

Instances

#xsub Source

#Pull Source

Instances

#pull Source

#Push Source

Instances

#push Source

#Req Source

Instances

#req Source

#Rep Source

Instances

#rep Source

#Router Source

Instances

#router Source

#Dealer Source

Instances

#dealer Source

#Socket Source

#IsLegal Source

Instances

#socket Source

#ZMQ_Option Source

Instances

#zmqIdentity Source

#ZMQIdent Source

Constructors

Instances

#setOption Source

#getOption Source

#bind' Source

#unbind Source

#bindSync Source

#unbindSync Source

#Bindable Source

Instances

#connect Source

#disconnect Source

#Connectable Source

Instances

#subscribe Source

#unsubscribe Source

#Subscriber Source

Instances

#monitor Source

#unmonitor Source

#addMonitorListener Source

#removeAllMonitorListeners Source

#MonitorEvent Source

Instances

#connectE Source

#connectDelayE Source

#connectRetryE Source

#listenE Source

#bindErrorE Source

#acceptE Source

#acceptErrorE Source

#closeE Source

#closeErrorE Source

#disconnectE Source

#Flag Source

Instances

#sendMore Source