A Go interface to ZeroMQ version 4

Related tags

Messaging zmq4
Overview

A Go interface to ZeroMQ version 4.


Warning

Starting with Go 1.14, on Unix-like systems, you will get a lot of interrupted signal calls. See the top of a package documentation for a fix.


Go Report Card GoDoc

This requires ZeroMQ version 4.0.1 or above. To use CURVE security in versions prior to 4.2, ZeroMQ must be installed with libsodium enabled.

Partial support for ZeroMQ 4.2 DRAFT is available in the alternate version of zmq4 draft. The API pertaining to this is subject to change. To use this:

import (
    zmq "github.com/pebbe/zmq4/draft"
)

For ZeroMQ version 3, see: http://github.com/pebbe/zmq3

For ZeroMQ version 2, see: http://github.com/pebbe/zmq2

Including all examples of ØMQ - The Guide.

Keywords: zmq, zeromq, 0mq, networks, distributed computing, message passing, fanout, pubsub, pipeline, request-reply

See also

  • Mangos — An implementation in pure Go of the SP ("Scalable Protocols") protocols
  • go-nanomsg — Language bindings for nanomsg in Go
  • goczmq — A Go interface to CZMQ

Requirements

zmq4 is just a wrapper for the ZeroMQ library. It doesn't include the library itself. So you need to have ZeroMQ installed, including its development files. On Linux and Darwin you can check this with ($ is the command prompt):

$ pkg-config --modversion libzmq
4.3.1

The Go compiler must be able to compile C code. You can check this with:

$ go env CGO_ENABLED
1

You can't do cross-compilation. That would disable C.

Install

go get github.com/pebbe/zmq4

Docs

API change

There has been an API change in commit 0bc5ab465849847b0556295d9a2023295c4d169e of 2014-06-27, 10:17:55 UTC in the functions AuthAllow and AuthDeny.

Old:

func AuthAllow(addresses ...string)
func AuthDeny(addresses ...string)

New:

func AuthAllow(domain string, addresses ...string)
func AuthDeny(domain string, addresses ...string)

If domain can be parsed as an IP address, it will be interpreted as such, and it and all remaining addresses are added to all domains.

So this should still work as before:

zmq.AuthAllow("127.0.0.1", "123.123.123.123")

But this won't compile:

a := []string{"127.0.0.1", "123.123.123.123"}
zmq.AuthAllow(a...)

And needs to be rewritten as:

a := []string{"127.0.0.1", "123.123.123.123"}
zmq.AuthAllow("*", a...)

Furthermore, an address can now be a single IP address, as well as an IP address and mask in CIDR notation, e.g. "123.123.123.0/24".

Issues
  • AuthStop() and Term() causes a hang on shutdown

    AuthStop() and Term() causes a hang on shutdown

    zmq4 version: 4b5b0725b5d36cef61e2744bd7c93067180e3edf (latest) zeromq-4.1.3 (latest) libsodium: 1.0.3 (latest)

    There appears to be a race condition with the AuthStop() and Term() functions. Steps to reproduce the problem:

    1. Run the below code
    2. Wait 2 seconds and ctrl-c.
    3. It will hang within 3-5 tries.
    4. A second ctrl-c exists the program.

    Comment-out the AuthStop() and Term() code below and the program exits cleanly upon ctrl-c.

    Workaround: Do not use AuthStop() and Term(). The program will end just fine.

    package main
    
    import (
            "log"
            "os"
            "os/signal"
            "syscall"
            "time"
    
            z "github.com/pebbe/zmq4"
    )
    
    func main() {
            us_public_key := "VVPVGyASr0?}lkRR28ULJj}N4Ut-NC>Q?qZ6!F3N"
            us_secret_key := "lU9<Y]^0CG*gI6N7Gyx.Sb/Q5:SX=[3moZv>B<c9"
            them_public_key := "K!y%@qX/ukA=Tw0E+#Lt.]k{Xu9yzZFf66TK&[email protected]"
            defer log.Println("After Term(), stopped")
            defer z.Term() // Comment-out to avoid hang
            defer log.Println("before Term()")
            z.AuthStart()
            defer z.AuthStop() // Comment-out to avoid hang
            defer log.Println("before AuthStop()")
            z.AuthCurveAdd("*", them_public_key)
            defer z.AuthCurveRemoveAll("*")
            sock, _ := z.NewSocket(z.ROUTER)
            defer sock.Close()
            sock.SetIdentity("a")
            sock.ClientAuthCurve(them_public_key, us_public_key, us_secret_key)
            connect := "tcp://127.0.0.1:5000"
            sock.SetReconnectIvl(time.Second * 1)
            sock.SetReconnectIvlMax(time.Second * 1)
            sock.Connect(connect)
            defer sock.Disconnect(connect)
            defer sock.SetLinger(0)
            sigc := make(chan os.Signal, 10)
            signal.Notify(sigc, os.Interrupt, syscall.SIGTERM)
            log.Println("Waiting ..")
            <-time.After(3 * time.Second)
            log.Println("ok to ctrl-c")
            <-sigc
            log.Println("received sigc")
    }
    

    Also hangs with zeromq-3.2.5.

    Thank you for creating the golang library. Works great.

    opened by aletheia7 23
  • Stuck with idiomatic way for low-latency Send/Recv

    Stuck with idiomatic way for low-latency Send/Recv

    Hi Peter,

    I'm lost trying to figure this out for days, I'm probably missing the point, can you point me in the right direction?

    I want to send/recv messages concurrently with a ROUTER. The code below describes how it's done logically. The code either polls or sends a message. If TIMEOUT is big, say 10s, outgoing messages are blocked. If TIMEOUT is small, say 10us, processor usage goes 100%. Now what?

    func Listen() {
        poller := zmq.NewPoller()
        poller.Add(socket, zmq.POLLIN)
    
        for {
            polled, _ := poller.Poll(TIMEOUT)
            handleIncoming(polled)
    
            sendAnyMessages()
        }
    }
    

    Any hint is appreciated.

    opened by zupa-hu 17
  • Can't compile on Alpine Linux

    Can't compile on Alpine Linux

    I have a Golang application that utilizes pebbe/zmq4 and I'd love to be able to run it in Alpine Linux due to the much smaller container size. However, I get the following error:

    apk update
    apk install gcc pkgconfig zeromq-dev
    go run main.go
    # github.com/pebbe/zmq4
    In file included from /go/src/github.com/pebbe/zmq4/ctxoptions_unix.go:6:0:
    /usr/include/zmq.h:46:19: fatal error: errno.h: No such file or directory
    compilation terminated.
    

    I'm using the golang:1.5-alpine container available on Docker Hub.

    opened by activeshadow 16
  • Proxy error:

    Proxy error: "socket operation on non-socket"

    I am trying to setup a Pub-Sub network with a proxy (like in the doc). However after a short period of time (about 1 minute) the proxy dies:

    socket operation on non-socket

           ctx, err := zmq.NewContext()
            // frontend
    	s, err := ctx.NewSocket(zmq.XSUB)
    	if err != nil {
    		return fmt.Errorf("NewSocket: %s", err)
    	}
    	if err = s.Bind("inproc://input"); err != nil {
    		return fmt.Errorf("Bind: %s", err)
    	}
    	// backend
    	p, err := zmq.NewSocket(zmq.XPUB)
    	if err != nil {
    		return fmt.Errorf("NewSocket: %s", err)
    	}
    	if err = p.Bind("tcp://*:5555"); err != nil {
    		return fmt.Errorf("Bind: %s", err)
    	}
    	// listen
    	l, err := ctx.NewSocket(zmq.PAIR)
    	if err != nil {
    		return fmt.Errorf("NewSocket: %s", err)
    	}
    	if err = l.Connect("inproc://pipe"); err != nil {
    		return fmt.Errorf("Connect: %s", err)
    	}
    	if err := zmq.Proxy(s, p, l); err != nil {
    		log.Fatal("Proxy is dead: ", err)
    	}
    

    And then all my publishers (each in their own thread) share the same context (ctx) and publish on inproc.

    opened by kprimice 15
  • ZMQ version mismatch

    ZMQ version mismatch

    Hi pebbe, I am inclined to say that something is broken with the way pebbe/zqm4 is checking for zmq lib versions or I am really overlooking something here. any help is appreciated.

    please have a look at this. I will give you the whole workflow I do here.

    let's start with a clean go environment:

    ~  $ rm -rf gocode/src/github.com/pebbe/
    ~  $ rm -rf gocode/pkg/
    ~  $ go get -u github.com/pebbe/zmq4
    # pkg-config --cflags libzmq
    Package libzmq was not found in the pkg-config search path.
    Perhaps you should add the directory containing `libzmq.pc'
    to the PKG_CONFIG_PATH environment variable
    No package 'libzmq' found
    pkg-config: exit status 1
    ~  $ 
    

    so far so good. zmq4 is missing libzmq package. which is right. because I have none installed yet. so let's do that:

    ~  $ sudo apt-cache policy libczmq-dev
    libczmq-dev:
      Installed: (none)
      Candidate: 4.1.0
      Version table:
         4.1.0 500
            500 http://download.opensuse.org/repositories/network:/messaging:/zeromq:/release-stable/Debian_9.0 ./ Packages
         3.0.2-5 500
            500 http://de.archive.ubuntu.com/ubuntu xenial/universe amd64 Packages
    ~  $ 
    

    notice that I am downloading from official zmq repository for debian9.0/ubuntu like said on http://czmq.zeromq.org/page:get-the-software

    now let's check if we really have no libzmq libs installed:

    ~  $ ll /usr/lib/x86_64-linux-gnu/libzmq*
    ls: cannot access '/usr/lib/x86_64-linux-gnu/libzmq*': No such file or directory
    

    now let's install libczmq-dev finally:

    ~  $ sudo apt-get install libczmq-dev
    Reading package lists... Done
    Building dependency tree       
    Reading state information... Done
    The following additional packages will be installed:
      libczmq4 libnorm1 libsodium18 libsystemd-dev libzmq3-dev libzmq5
    The following NEW packages will be installed:
      libczmq-dev libczmq4 libnorm1 libsodium18 libsystemd-dev libzmq3-dev libzmq5
    0 upgraded, 7 newly installed, 0 to remove and 178 not upgraded.
    Need to get 0 B/1,331 kB of archives.
    After this operation, 5,340 kB of additional disk space will be used.
    Do you want to continue? [Y/n] 
    Selecting previously unselected package libnorm1:amd64.
    (Reading database ... 237362 files and directories currently installed.)
    Preparing to unpack .../libnorm1_1.5r6+dfsg1-1_amd64.deb ...
    Unpacking libnorm1:amd64 (1.5r6+dfsg1-1) ...
    Selecting previously unselected package libsodium18:amd64.
    Preparing to unpack .../libsodium18_1.0.8-5_amd64.deb ...
    Unpacking libsodium18:amd64 (1.0.8-5) ...
    Selecting previously unselected package libzmq5:amd64.
    Preparing to unpack .../libzmq5_4.2.3_amd64.deb ...
    Unpacking libzmq5:amd64 (4.2.3) ...
    Selecting previously unselected package libzmq3-dev:amd64.
    Preparing to unpack .../libzmq3-dev_4.2.3_amd64.deb ...
    Unpacking libzmq3-dev:amd64 (4.2.3) ...
    Selecting previously unselected package libsystemd-dev:amd64.
    Preparing to unpack .../libsystemd-dev_229-4ubuntu21.1_amd64.deb ...
    Unpacking libsystemd-dev:amd64 (229-4ubuntu21.1) ...
    Selecting previously unselected package libczmq4.
    Preparing to unpack .../libczmq4_4.1.0_amd64.deb ...
    Unpacking libczmq4 (4.1.0) ...
    Selecting previously unselected package libczmq-dev.
    Preparing to unpack .../libczmq-dev_4.1.0_amd64.deb ...
    Unpacking libczmq-dev (4.1.0) ...
    Processing triggers for libc-bin (2.23-0ubuntu10) ...
    Processing triggers for man-db (2.7.5-1) ...
    Setting up libnorm1:amd64 (1.5r6+dfsg1-1) ...
    Setting up libsodium18:amd64 (1.0.8-5) ...
    Setting up libzmq5:amd64 (4.2.3) ...
    Setting up libzmq3-dev:amd64 (4.2.3) ...
    Setting up libsystemd-dev:amd64 (229-4ubuntu21.1) ...
    Setting up libczmq4 (4.1.0) ...
    Setting up libczmq-dev (4.1.0) ...
    Processing triggers for libc-bin (2.23-0ubuntu10) ...
    ~  $
    

    check again:

    ~  $ ll /usr/lib/x86_64-linux-gnu/libzmq*
    -rw-r--r-- 1 root root 1.8M Dec 31  2014 /usr/lib/x86_64-linux-gnu/libzmq.a
    lrwxrwxrwx 1 root root   15 Dec 31  2014 /usr/lib/x86_64-linux-gnu/libzmq.so -> libzmq.so.5.1.3
    lrwxrwxrwx 1 root root   15 Dec 31  2014 /usr/lib/x86_64-linux-gnu/libzmq.so.5 -> libzmq.so.5.1.3
    -rw-r--r-- 1 root root 596K Dec 31  2014 /usr/lib/x86_64-linux-gnu/libzmq.so.5.1.3
    ~  $ 
    

    5.1.3 stands for version 4.2.3 here.

    now let's see what pkgconfig would say to pebbe/zmq4 if pebbe/zmq4 were to ask for it when we go get this repository:

    ~  $ cat /usr/lib/x86_64-linux-gnu/pkgconfig/libzmq.pc 
    prefix=/usr
    exec_prefix=${prefix}
    libdir=${prefix}/lib/x86_64-linux-gnu
    includedir=${prefix}/include
    
    Name: libzmq
    Description: 0MQ c++ library
    Version: 4.2.3
    Libs: -L${libdir} -lzmq
    Libs.private: -lstdc++  -lsodium -lpgm -lpthread -lm -lnorm
    Cflags: -I${includedir} 
    ~  $ 
    

    notice: it says you will find the libzmq packages/libs in /usr/lib/x86_64-linux-gnu/ with version 4.2.3.

    so far so good. let's continue to go get this repository finally:

    ~  $ go get -u github.com/pebbe/zmq4
    ~  $ 
    

    worked. now let's continue to build our go application:

    ~/gocode/src/github.com/omani/lol/cmd (master [uncommited!]) $ go build -o lol main.go
    ~/gocode/src/github.com/omani/lol/cmd (master [uncommited!]) $ 
    

    worked. now let's run the just created binary:

    ~/gocode/src/github.com/omani/lol/cmd (master [uncommited!]) $ ./lol
    
    USAGE:
       lol -c=<string> --identity=<string>
                        [--debug]
       lol --help
       lol --version
    
    Use 'lol --help' to get detailed information about options and examples of usage.
    ~/gocode/src/github.com/omani/lol/cmd (master [uncommited!]) $ 
    

    so at first sight, it seems to work. but that's just an illusion. this is only flags doing it's job and returning due to missing arguments. we never really ran the app. so now let's give the application some working cli arguments to see what really happens:

    ~/gocode/src/github.com/omani/lol/cmd (master [uncommited!]) $ ./lol -c ~/lol.toml -identity lol01 -debug
    2018/03/10 15:27:57 zmq4 was installed with ZeroMQ version 4.2.4, but the application links with version 4.2.3
    ~/gocode/src/github.com/omani/lol/cmd (master [uncommited!]) $ 
    

    there you go. the app does not start because it's complaining about zmq.

    now here is my question: How can this even be? As you can see we installed libczmq version 4.2.3. and all it's dependencies for version 4.2.3. Why should this ever happen that zmq4 is thinking we had version 4.2.4 during the time we ran go get github.com/pebbe/zmq4? You see what pkgconfig said which version we have installed and I assume that is the same information zmq4 is getting.

    so where does version 4.2.4 come from?

    thanks.

    opened by omani 14
  • Lot's of

    Lot's of "interrupted system call" on RecvBytes() and SendBytes() with go 1.14 linux

    Hi,

    I am seeing lot's of errors "interrupted system call" on a typical broker implementation when compiling with the current go version 1.14 and running on linux/amd64. According to the release notes this is sort of expected. My question is, if we can expect this to be handled in the library in the future or if we need to implement a loop around each and every zmq call retrying it in case of EINTR?

    The code looks something like this: (results and pub are *zmq.Socket):

    for {
        // receive a result
        msg, err := results.RecvMessageBytes(0)
        total++
        if err != nil {
          log.Printf("Error receiving a result: %s", err)
          errorcount++
          continue
        }
        m := msg[0]
        // publish it (it should have already the topic prepended)
        _, err = pub.SendBytes(m, 0)
        if err != nil {
          log.Printf("Error publishing message: %s", err)
          errorcount++
          // fall through, so we can still push it to another socket
        }
    ...
    

    I am running in a docker container in case that matters. Compiling with go 1.13 does not show the issue.

    Thank you!

    --Matthias

    opened by mfl-q 13
  • go install

    go install "could not determine kind of name for C.ZMQ_CURVE_PUBLICKEY "

    ➜  http-test  go get github.com/pebbe/zmq4
    # github.com/pebbe/zmq4
    could not determine kind of name for C.ZMQ_CURVE_PUBLICKEY
    could not determine kind of name for C.ZMQ_CURVE_SECRETKEY
    could not determine kind of name for C.ZMQ_CURVE_SERVERKEY
    could not determine kind of name for C.ZMQ_GSSAPI_PLAINTEXT
    could not determine kind of name for C.ZMQ_GSSAPI_PRINCIPAL
    could not determine kind of name for C.ZMQ_GSSAPI_SERVER
    could not determine kind of name for C.ZMQ_GSSAPI_SERVICE_PRINCIPAL
    could not determine kind of name for C.ZMQ_HANDSHAKE_IVL
    could not determine kind of name for C.ZMQ_IMMEDIATE
    could not determine kind of name for C.ZMQ_IPV6
    could not determine kind of name for C.ZMQ_LAST_ENDPOINT
    could not determine kind of name for C.ZMQ_MAXMSGSIZE
    could not determine kind of name for C.ZMQ_MECHANISM
    could not determine kind of name for C.ZMQ_MULTICAST_HOPS
    could not determine kind of name for C.ZMQ_PLAIN_PASSWORD
    could not determine kind of name for C.ZMQ_PLAIN_SERVER
    could not determine kind of name for C.ZMQ_PLAIN_USERNAME
    could not determine kind of name for C.ZMQ_RCVHWM
    could not determine kind of name for C.ZMQ_SNDHWM
    could not determine kind of name for C.ZMQ_SOCKS_PROXY
    could not determine kind of name for C.ZMQ_TCP_KEEPALIVE
    could not determine kind of name for C.ZMQ_TCP_KEEPALIVE_CNT
    could not determine kind of name for C.ZMQ_TCP_KEEPALIVE_IDLE
    could not determine kind of name for C.ZMQ_TCP_KEEPALIVE_INTVL
    could not determine kind of name for C.ZMQ_TOS
    could not determine kind of name for C.ZMQ_ZAP_DOMAIN
    
    
    ➜  http-test  go version
    go version go1.4 linux/amd64
    
    
    ➜  http-test  gcc -v
    Using built-in specs.
    COLLECT_GCC=gcc
    COLLECT_LTO_WRAPPER=/usr/lib/gcc/x86_64-linux-gnu/4.8/lto-wrapper
    Target: x86_64-linux-gnu
    Configured with: ../src/configure -v --with-pkgversion='Ubuntu 4.8.2-19ubuntu1' --with-bugurl=file:///usr/share/doc/gcc-4.8/README.Bugs --enable-languages=c,c++,java,go,d,fortran,objc,obj-c++ --prefix=/usr --program-suffix=-4.8 --enable-shared --enable-linker-build-id --libexecdir=/usr/lib --without-included-gettext --enable-threads=posix --with-gxx-include-dir=/usr/include/c++/4.8 --libdir=/usr/lib --enable-nls --with-sysroot=/ --enable-clocale=gnu --enable-libstdcxx-debug --enable-libstdcxx-time=yes --enable-gnu-unique-object --disable-libmudflap --enable-plugin --with-system-zlib --disable-browser-plugin --enable-java-awt=gtk --enable-gtk-cairo --with-java-home=/usr/lib/jvm/java-1.5.0-gcj-4.8-amd64/jre --enable-java-home --with-jvm-root-dir=/usr/lib/jvm/java-1.5.0-gcj-4.8-amd64 --with-jvm-jar-dir=/usr/lib/jvm-exports/java-1.5.0-gcj-4.8-amd64 --with-arch-directory=amd64 --with-ecj-jar=/usr/share/java/eclipse-ecj.jar --enable-objc-gc --enable-multiarch --disable-werror --with-arch-32=i686 --with-abi=m64 --with-multilib-list=m32,m64,mx32 --with-tune=generic --enable-checking=release --build=x86_64-linux-gnu --host=x86_64-linux-gnu --target=x86_64-linux-gnu
    Thread model: posix
    gcc version 4.8.2 (Ubuntu 4.8.2-19ubuntu1) 
    
    ➜  http-test  uname -a
    Linux wkc-pc 3.13.0-43-generic #72-Ubuntu SMP Mon Dec 8 19:35:06 UTC 2014 x86_64 x86_64 x86_64 GNU/Linux
    
    opened by wangkechun 12
  • Getting

    Getting "interrupted system call" (EINTR) on socket.RecvMessage()

    This bug report is posted as recommended by the good people who have replied to my question here: https://groups.google.com/forum/#!topic/Golang-nuts/TeZwtP6z98w

    socket.RecvMessage() is getting interrupted with EINTR for some reason and according to the golang-nuts replies, this should be hidden from the user and automatically retried.

    opened by veegee 12
  • Cannot do static build using zmq4

    Cannot do static build using zmq4

    I am trying to build a static binary and I get the following error

    CGO_ENABLED=0 go get -a -ldflags '-s' github.com/pebbe/zmq4
    # github.com/pebbe/zmq4
    /go/src/github.com/pebbe/zmq4/auth.go:564: undefined: Socket
    /go/src/github.com/pebbe/zmq4/auth.go:573: undefined: Socket
    /go/src/github.com/pebbe/zmq4/auth.go:582: undefined: Socket
    /go/src/github.com/pebbe/zmq4/auth.go:594: undefined: Socket
    /go/src/github.com/pebbe/zmq4/auth.go:603: undefined: Socket
    /go/src/github.com/pebbe/zmq4/reactor.go:10: undefined: State
    /go/src/github.com/pebbe/zmq4/reactor.go:11: undefined: State
    
    opened by paulbdavis 11
  • Assertion failed: pfd.revents & POLLIN (signaler.cpp:193)

    Assertion failed: pfd.revents & POLLIN (signaler.cpp:193)

    when i cycle call NewContext()->NewSocket()->socket.close()->context.term(), some times later, this problem appears and the program crash。Or maybe, the progress block in term(). Or maybe,it crash in term() with "Assertion failed: ok (mailbox.cpp:82)".

    opened by pingzilao 11
  • Context issues

    Context issues

    We've been using your library to build a thin inter-service communication layer on top of zmq. Recently when testing more extensively we ran into a major issue with this lib which forced us to migrate to alecthomas's lib. Now when he officially put it in maintenance mode I thought we should work this out together:

    The issue is when connecting a "client" to multiple "servers", there is only one zmq.Context created (in init()). We have clients that connects to multiple backing services via different sockets but since the init() is only run once it only creates one context which makes client connections to multiple backends impossible. At least that's what our investigations found, and switching to alecthomas's which lets you manually create contexts made it work.

    To clarify: It works just fine to bind one socket to multiple endpoints, the issue is when creating multiple sockets. Maybe there already is a solution already but otherwise I suggest something like this not to break the API:

    • Introduce the concept of Context (exported) and basically support creating Contexts and a few methods for creating socket(s) in that context (we could probably borrow some code from alecthomas here).
    • Keep the current implementation of a "global" context for use cases not dealing with contexts and also (mainly) not to break current API.
    opened by gust1n 11
  • Unable to build on M1 ARM Mac

    Unable to build on M1 ARM Mac

    Installed zeromq using brew and using go1.18.4

    brew install pkg-config zeromq

    ➜ pkg-config --modversion libzmq
    4.3.4
    ➜ go env CGO_ENABLED
    1
    

    Tried to build a package that imports "github.com/pebbe/zmq4"

    ld: warning: ignoring file /opt/homebrew/Cellar/zeromq/4.3.4/lib/libzmq.dylib, building for macOS-x86_64 but attempting to link with file built for macOS-arm64
    Undefined symbols for architecture x86_64:
      "_zmq_bind", referenced from:
          _zmq4_bind in _x009.o
      "_zmq_close", referenced from:
          _zmq4_close in _x009.o
      "_zmq_connect", referenced from:
          _zmq4_connect in _x009.o
      "_zmq_ctx_get", referenced from:
          _zmq4_ctx_get in _x009.o
      "_zmq_ctx_new", referenced from:
          _zmq4_ctx_new in _x009.o
      "_zmq_ctx_set", referenced from:
          _zmq4_ctx_set in _x009.o
      "_zmq_ctx_term", referenced from:
          _zmq4_ctx_term in _x009.o
      "_zmq_curve_keypair", referenced from:
          _zmq4_curve_keypair in _x009.o
      "_zmq_curve_public", referenced from:
          _zmq4_curve_public in _x009.o
      "_zmq_disconnect", referenced from:
          _zmq4_disconnect in _x009.o
      "_zmq_getsockopt", referenced from:
          _zmq4_getsockopt in _x009.o
      "_zmq_has", referenced from:
          __cgo_623c834d1dc5_Cfunc_zmq_has in _x010.o
         (maybe you meant: __cgo_623c834d1dc5_Cfunc_zmq_has)
      "_zmq_msg_close", referenced from:
          __cgo_623c834d1dc5_Cfunc_zmq_msg_close in _x010.o
         (maybe you meant: __cgo_623c834d1dc5_Cfunc_zmq_msg_close)
      "_zmq_msg_data", referenced from:
          _zmq4_get_event40 in _x010.o
          _zmq4_get_event41 in _x010.o
          __cgo_623c834d1dc5_Cfunc_zmq4_get_event40 in _x010.o
          __cgo_623c834d1dc5_Cfunc_zmq4_get_event41 in _x010.o
          __cgo_623c834d1dc5_Cfunc_zmq_msg_data in _x010.o
         (maybe you meant: __cgo_623c834d1dc5_Cfunc_zmq_msg_data)
      "_zmq_msg_gets", referenced from:
          _zmq4_msg_gets in _x009.o
      "_zmq_msg_init", referenced from:
          __cgo_623c834d1dc5_Cfunc_zmq_msg_init in _x010.o
         (maybe you meant: __cgo_623c834d1dc5_Cfunc_zmq_msg_init)
      "_zmq_msg_recv", referenced from:
          _zmq4_msg_recv in _x009.o
      "_zmq_poll", referenced from:
          _zmq4_poll in _x009.o
      "_zmq_proxy", referenced from:
          _zmq4_proxy in _x009.o
      "_zmq_proxy_steerable", referenced from:
          _zmq4_proxy_steerable in _x009.o
      "_zmq_send", referenced from:
          _zmq4_send in _x009.o
      "_zmq_setsockopt", referenced from:
          _zmq4_setsockopt in _x009.o
      "_zmq_socket", referenced from:
          _zmq4_socket in _x009.o
      "_zmq_socket_monitor", referenced from:
          _zmq4_socket_monitor in _x009.o
      "_zmq_strerror", referenced from:
          __cgo_623c834d1dc5_Cfunc_zmq_strerror in _x004.o
         (maybe you meant: __cgo_623c834d1dc5_Cfunc_zmq_strerror)
      "_zmq_unbind", referenced from:
          _zmq4_unbind in _x009.o
      "_zmq_version", referenced from:
          __cgo_623c834d1dc5_Cfunc_zmq_version in _x010.o
         (maybe you meant: __cgo_623c834d1dc5_Cfunc_zmq_version)
      "_zmq_z85_decode", referenced from:
          __cgo_623c834d1dc5_Cfunc_zmq_z85_decode in _x010.o
         (maybe you meant: __cgo_623c834d1dc5_Cfunc_zmq_z85_decode)
      "_zmq_z85_encode", referenced from:
          __cgo_623c834d1dc5_Cfunc_zmq_z85_encode in _x010.o
         (maybe you meant: __cgo_623c834d1dc5_Cfunc_zmq_z85_encode)
    ld: symbol(s) not found for architecture x86_64
    clang: error: linker command failed with exit code 1 (use -v to see invocation)
    

    Am I missing a dependency or have I gone wrong somewhere in configuring things? Would appreciate any push in the right direction.

    opened by jacobkring 0
  • Reduce CPU usage at high message rates.

    Reduce CPU usage at high message rates.

    @pebbe , Hey,this is not an issue, hoping to understand and start a discussion if it merits so. Did not find a forum for this.

    My questions and concerns: https://stackoverflow.com/questions/72847547/high-cpu-usage-when-using-pebbe-zmq-proxy-at-high-message-rates

    opened by dev-agk 0
  • monitor docs warn about

    monitor docs warn about "random crashes" but do not explain, how to avoid

    Quote from https://pkg.go.dev/github.com/pebbe/zmq4 :

    func (*Socket) Monitor ¶
    func (soc *Socket) Monitor(addr string, events Event) error
    Register a monitoring callback.
    
    See: http://api.zeromq.org/4-1:zmq-socket-monitor#toc2
    
    WARNING: Closing a context with a monitoring callback will lead to random crashes. This is a bug in the ZeroMQ library. The monitoring callback has the same context as the socket it was created for.
    

    It would be helpful if the comment could be expanded to explain and give instructions on how to avoid random crashes.

    Is the context an explicit Go context type, or does "context" mean the socket being monitored?

    Does the developer need to call Close() on the PAIR monitor socket before calling Close() on the socket that is being monitored? (i.e. the problem occurs when the monitor socket is active but the socket being monitored is closed?)

    Will the bug be triggered by runs of the example code, in which the monitor goroutine only exits the RecvEvent loop when RecvEvent returns err!=nil, or is the example code ok to use as a base for actual monitoring?

    Is there an upstream reference for this bug? Or is it a "working as designed" issue, where developers are expected to write code in a certain way to not trigger a crash?

    opened by chrbsg 0
  • Install zmq4 Go Windows

    Install zmq4 Go Windows

    I would like to use zmq4 (https://github.com/pebbe/zmq4) in Go Programming Language on a Windows system. This need to have ZeroMQ (libzmq) installed (https://zeromq.org/download/ or https://github.com/zeromq/libzmq). Unfortunately, I can not find a way to install libzmq on Windows. Can anyone help me?

    opened by const97 0
  • Failed to cross compile a project from macos to linux

    Failed to cross compile a project from macos to linux

    Environment

    • go version: 1.17.5
    • zmq4 version: v1.2.7
    • libsodium version: 1.0.18_1
    • macos version: 12.0.1

    Way to Reproduce

    1. make a go project in macos;
    2. run
      env GOOS=linux GOARCH=amd64 CGO_ENABLED=1 go build -o "bin/main-linux-amd64" "main.go"
      
    3. go fails to produce a binary file.

    Unexpected Output

    # runtime/cgo
    linux_syscall.c:67:13: error: implicit declaration of function 'setresgid' is invalid in C99 [-Werror,-Wimplicit-function-declaration]
    linux_syscall.c:67:13: note: did you mean 'setregid'?
    /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX.sdk/usr/include/unistd.h:593:6: note: 'setregid' declared here
    linux_syscall.c:73:13: error: implicit declaration of function 'setresuid' is invalid in C99 [-Werror,-Wimplicit-function-declaration]
    linux_syscall.c:73:13: note: did you mean 'setreuid'?
    /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX.sdk/usr/include/unistd.h:595:6: note: 'setreuid' declared here
    
    opened by Banyc 0
Releases(v1.2.9)
Owner
Peter Kleiweg
Peter Kleiweg
A Go interface to ZeroMQ version 3

A Go interface to ZeroMQ version 3. For ZeroMQ version 4, see: http://github.com/pebbe/zmq4 For ZeroMQ version 2, see: http://github.com/pebbe/zmq2 In

Peter Kleiweg 131 Nov 25, 2021
Go (golang) bindings for the 0mq (zmq, zeromq) C API

NOTE: These gozmq bindings are in maintenance mode. Only critical bugs will be fixed. Henceforth I would suggest using @pebbe's actively maintained bi

Alec Thomas 469 Jul 24, 2022
Transpiled version of the CCXT exchange library to Go (Golang)

CCXT Go Transpiled CCXT exchange library from their original JavaScript source to Go (Golang). Features support 100+ cryptocurrency exchanges with a u

null 45 Jul 23, 2022
go broker interface,you can use kafka,redis,pulsar etc.

broker go broker interface,you can use kafka,redis,pulsar etc. pulsar in docker run pulsar in docker docker run -dit \ --name pulsar-sever \ -p 6650:

go-god 11 Jul 29, 2022
A Go interface to ZeroMQ version 2

A Go interface to ZeroMQ version 2. Requires ZeroMQ version 2.1 or 2.2 For ZeroMQ version 4, see: http://github.com/pebbe/zmq4 For ZeroMQ version 3, s

Peter Kleiweg 18 May 26, 2021
A Go interface to ZeroMQ version 3

A Go interface to ZeroMQ version 3. For ZeroMQ version 4, see: http://github.com/pebbe/zmq4 For ZeroMQ version 2, see: http://github.com/pebbe/zmq2 In

Peter Kleiweg 131 Nov 25, 2021
Bump-version - Bump a given semantic version, following a given version fragment

bump-version Bump a given semantic version, following a given version fragment.

Weslei Juan Novaes Pereira 3 Feb 7, 2022
Go (golang) bindings for the 0mq (zmq, zeromq) C API

NOTE: These gozmq bindings are in maintenance mode. Only critical bugs will be fixed. Henceforth I would suggest using @pebbe's actively maintained bi

Alec Thomas 469 Jul 24, 2022
Let's implement some basic ZeroMQ publisher and subscriber in Golang. Utilize Envoy as a proxy.

Envy proxy with ZeroMQ Solution tested on DigitalOcean Droplet. In case of re-creation VM follow this article. Introduction Let's implement some basic

Jakub Wołynko 0 Jan 25, 2022
A tool to determine the highest version number that's smaller than a target version number

semver-highest A tool to determine the highest version number that's smaller than a target version number. Installation go install github.com/marten-s

Marten Seemann 1 Oct 13, 2021
dont-interface calculates how many interface{} are declared or used in your project?

dont-interface calculates how many interface{} are declared or used in your project?

Ray Eldath 17 Jun 9, 2022
Go library to interface with NEAR nodes' JSON-RPC interface

StreamingFast Solana library for Go Go library to interface with NEAR nodes' JSON-RPC interface Contributing Issues and PR in this repo related strict

StreamingFast 1 Nov 9, 2021
Recursively searches a map[string]interface{} structure for another map[string]interface{} structure

msirecurse Recursively searches a map[string]interface{} structure for existence of a map[string]interface{} structure Motivation I wrote this package

Fred Moyer 1 Mar 3, 2022
Go Version Manager

gvm By Josh Bussdieker (jbuss, jaja, jbussdieker) while working at Moovweb Currently lovingly maintained by Benjamin Knigge Pull requests and other an

Moovweb 7.6k Aug 8, 2022
A node.js version management utility for Windows. Ironically written in Go.

The npm/Microsoft/Google recommended Node.js version manager for Windows. This is not the same thing as nvm. The original nvm is a completely separate

Corey Butler 22.5k Aug 9, 2022
The pure golang implementation of nanomsg (version 1, frozen)

mangos NOTE: This is the legacy version of mangos (v1). Users are encouraged to use mangos v2 instead if possible. No further development is taking pl

nanomsg 1.5k Jun 22, 2022
libsvm go version

libsvm golang version libsvm golang version derived work based on LIBSVM 3.14. Info this lib based on LIBSVM java version, just translate java to go.

Xianjie 71 Jan 23, 2022
This is a Golang wrapper for working with TMDb API. It aims to support version 3.

This is a Golang wrapper for working with TMDb API. It aims to support version 3. An API Key is required. To register for one, head over to themoviedb

Cyro Dubeux 54 Aug 1, 2022
"go build" wrapper to add version info to Golang applications

govvv The simple Go binary versioning tool that wraps the go build command. Stop worrying about -ldflags and go get github.com/ahmetb/govvv now. Build

Ahmet Alp Balkan 527 Jul 25, 2022
Go Version Manager

gvm By Josh Bussdieker (jbuss, jaja, jbussdieker) while working at Moovweb Currently lovingly maintained by Benjamin Knigge Pull requests and other an

Moovweb 7.6k Aug 4, 2022
A live-updating version of the UNIX wc command.

lwc A live-updating version of the UNIX wc command. Installation You can get a prebuilt binary for every major platform from the Releases page. Just e

Tim De Pauw 27 Jul 26, 2022
Speak HTTP like a local. (the simple, intuitive HTTP console, golang version)

http-gonsole This is the Go port of the http-console. Speak HTTP like a local Talking to an HTTP server with curl can be fun, but most of the time it'

mattn 65 Jul 14, 2021
Markdown version of Reverse Engineering the source code of the BioNTech/Pfizer SARS-CoV-2 Vaccine

The big BNT162b2 archive All vaccine data here is sourced from this World Health Organization document. This describes the RNA contents of the BNT162b

null 158 Aug 2, 2022
Go version of Plan9 Acme Editor

Overview Go port of Rob Pike's Acme editor. Derived from ProjectSerenity but now increasingly divergent. ProjectSerenity was itself a transliteration

Robert Kroeger 325 Aug 6, 2022
Golang Version Manager

g 注意:master分支可能处于开发之中并非稳定版本,请通过tag下载稳定版本的源代码,或通过release下载已编译的二进制可执行文件。 g是一个Linux、macOS、Windows下的命令行工具,可以提供一个便捷的多版本go环境的管理和切换。 特性 支持列出可供安装的go版本号 支持列出已安

voidint 752 Aug 11, 2022
High-precision indoor positioning framework, version 3.

The Framework for Internal Navigation and Discovery (FIND) is like indoor GPS for your house or business, using only a simple smartphone or laptop. Th

Zack 4.3k Aug 10, 2022
Go tool for major version upgrades

GOMAJOR $ gomajor help GoMajor is a tool for major version upgrades Usage: gomajor <command> [arguments] The commands are: get upgrad

Ilia Choly 67 Jul 29, 2022
Metrics dashboards on terminal (a grafana inspired terminal version)

Grafterm Visualize metrics dashboards on the terminal, like a simplified and minimalist version of Grafana for terminal. Features Multiple widgets (gr

Xabier Larrakoetxea Gallego 769 Aug 7, 2022
Sentinel Go version (Reliability & Resilience)

Sentinel: The Sentinel of Your Microservices Introduction As distributed systems become increasingly popular, the reliability between services is beco

Alibaba 2.1k Aug 7, 2022