golzmq

Documentation

Index

• func ZmqProxySocket(proxy ZmqProxyConfig)
• func ZmqReply(_socket *zmq.Socket, _compute_reply RecieveArrayReturnString) error
• func ZmqReplyByte(_socket *zmq.Socket, _compute_reply RecieveByteArrayReturnByte) error
• func ZmqReplySocket(ip string, reply_ports []int) *zmq.Socket
• func ZmqRequest(_socket *zmq.Socket, dat ...string) (string, error)
• func ZmqRequestByte(_socket *zmq.Socket, _msg []byte) ([]byte, error)
• func ZmqRequestSocket(ip string, requestPorts []int) *zmq.Socket
• type ReceiveStringReturnNil
• type RecieveArrayReturnString
• type RecieveByteArrayReturnByte
• type ZmqProxyConfig

Functions

func ZmqProxySocket

func ZmqProxySocket(proxy ZmqProxyConfig)

ZmqProxySocket creates a Proxy connection for given ZmqProxyConfig.

func ZmqReply

func ZmqReply(_socket *zmq.Socket, _compute_reply RecieveArrayReturnString) error

performs ZMQ Reply of received message at given Socket processed by given FUNC where FUNC take String-Array as argument and return result as String

func ZmqReplyByte

func ZmqReplyByte(_socket *zmq.Socket, _compute_reply RecieveByteArrayReturnByte) error

performs ZMQ Reply of received message at given Socket processed by given FUNC where FUNC take []byte as argument and return result as []byte

func ZmqReplySocket

func ZmqReplySocket(ip string, reply_ports []int) *zmq.Socket

returns ZMQ Reply Socket created at given IP-string and Ports-int-array

func ZmqRequest

func ZmqRequest(_socket *zmq.Socket, dat ...string) (string, error)

performs ZMQ Request at given Socket for given string data

func ZmqRequestByte

func ZmqRequestByte(_socket *zmq.Socket, _msg []byte) ([]byte, error)

performs ZMQ Request at given Socket for given message as []byte

func ZmqRequestSocket

func ZmqRequestSocket(ip string, requestPorts []int) *zmq.Socket

returns ZMQ Request Socket created at given IP-string and Ports-int-array

Types

type ReceiveStringReturnNil

type ReceiveStringReturnNil func(msg string)

type RecieveArrayReturnString

type RecieveArrayReturnString func(msg_array []string) string

type RecieveByteArrayReturnByte

type RecieveByteArrayReturnByte func(msg []byte) []byte

type ZmqProxyConfig

type ZmqProxyConfig struct {
	DestinationIP    string
	DestinationPorts []int
	SourceIP         string
	SourcePorts      []int
}

ZmqProxyConfig is structure to sustain ZMQ Proxy configuration.