Documentation
¶
Index ¶
- Constants
- func AssertError(err error)
- func CreateInputPort(name string, endpoint string, monitCh chan<- bool) (socket *zmq.Socket, err error)
- func CreateOutputPort(name string, endpoint string, monitCh chan<- bool) (socket *zmq.Socket, err error)
- func MonitorSocket(socket *zmq.Socket, name string) (<-chan zmq.Event, error)
Constants ¶
View Source
const MonitorEvents zmq.Event = zmq.EVENT_CONNECTED | zmq.EVENT_LISTENING | zmq.EVENT_ACCEPTED | zmq.EVENT_BIND_FAILED | zmq.EVENT_ACCEPT_FAILED | zmq.EVENT_CLOSED | zmq.EVENT_DISCONNECTED
MonitorEvents is a bit mask of ZMQ events to listen to
Variables ¶
This section is empty.
Functions ¶
func AssertError ¶
func AssertError(err error)
AssertError prints given error message if err is not nil & exist with status code 1
func CreateInputPort ¶
func CreateInputPort(name string, endpoint string, monitCh chan<- bool) (socket *zmq.Socket, err error)
CreateInputPort creates a ZMQ PULL socket & bind to a given endpoint
func CreateOutputPort ¶
func CreateOutputPort(name string, endpoint string, monitCh chan<- bool) (socket *zmq.Socket, err error)
CreateOutputPort creates a ZMQ PUSH socket & connect to a given endpoint
func MonitorSocket ¶
MonitorSocket creates a monitoring socket using given context and connects to a given socket to be monitored. Returns a channel to receive monitoring events. See event definitions here: http://api.zeromq.org/3-2:zmq-socket-monitor
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.