zmq

README

zmq

ZeroMQ out of the box

Pull Repository, Install Dependencies and Test

git clone https://github.com/MonteCarloClub/zmq.git && cd zmq
apt install pkg-config libzmq3-dev
go test -run TestPubAndSub github.com/MonteCarloClub/zmq
go test -run TestPullAndPush github.com/MonteCarloClub/zmq

Import This Go Module

import "github.com/MonteCarloClub/zmq"

Documentation

Index

• type SocketSet
  • func CreateSocketSet() *SocketSet
  • func (socketSet *SocketSet) Close()
  • func (socketSet *SocketSet) Pub(message string) error
  • func (socketSet *SocketSet) Pull() (string, error)
  • func (socketSet *SocketSet) PullToChan(messages chan string, errs chan error) error
  • func (socketSet *SocketSet) Push(message string) error
  • func (socketSet *SocketSet) SetPubSocket(endpoint string) error
  • func (socketSet *SocketSet) SetPullSocket(endpoint string) error
  • func (socketSet *SocketSet) SetPushSocket(endpoint string) error
  • func (socketSet *SocketSet) SetSubSocket(endpoint string, filter string) error
  • func (socketSet *SocketSet) Sub() (string, error)
  • func (socketSet *SocketSet) SubToChan(messages chan string, errs chan error) error

Types

type SocketSet

type SocketSet struct {
	Zmq4PubSocket, Zmq4SubSocket   *zmq4.Socket
	Zmq4PullSocket, Zmq4PushSocket *zmq4.Socket
}

func CreateSocketSet

func CreateSocketSet() *SocketSet

func (*SocketSet) Close

func (socketSet *SocketSet) Close()

func (*SocketSet) Pub

func (socketSet *SocketSet) Pub(message string) error

func (*SocketSet) Pull

func (socketSet *SocketSet) Pull() (string, error)

func (*SocketSet) PullToChan

func (socketSet *SocketSet) PullToChan(messages chan string, errs chan error) error

func (*SocketSet) Push

func (socketSet *SocketSet) Push(message string) error

func (*SocketSet) SetPubSocket

func (socketSet *SocketSet) SetPubSocket(endpoint string) error

func (*SocketSet) SetPullSocket

func (socketSet *SocketSet) SetPullSocket(endpoint string) error

func (*SocketSet) SetPushSocket

func (socketSet *SocketSet) SetPushSocket(endpoint string) error

func (*SocketSet) SetSubSocket

func (socketSet *SocketSet) SetSubSocket(endpoint string, filter string) error

func (*SocketSet) Sub

func (socketSet *SocketSet) Sub() (string, error)

func (*SocketSet) SubToChan

func (socketSet *SocketSet) SubToChan(messages chan string, errs chan error) error