Versions in this module Expand all Collapse all v5 v5.0.0 May 26, 2021 Changes in this version + const CZMQVersionMajor + const CZMQVersionMinor + const CurveAllowAny + const Dealer + const FlagDontWait + const FlagMore + const FlagNone + const FlagReuse + const Pair + const Pollin + const Pollout + const Pub + const Pull + const Push + const Rep + const Req + const Router + const Stream + const Sub + const XPub + const XSub + const ZMQVersionMajor + const ZMQVersionMinor + var ErrActorCmd = errors.New("error sending actor command") + var ErrBind = errors.New("bind error") + var ErrCertNotFound = errors.New("file not found") + var ErrConnect = errors.New("connect error") + var ErrDisconnect = errors.New("disconnect error") + var ErrInvalidSockType = errors.New("invalid socket type") + var ErrMultiPartUnsupported = errors.New("function does not support multi part messages") + var ErrRecvFrame = errors.New("recv frame error") + var ErrRecvFrameAfterDestroy = errors.New("RecvFrame() is invalid on socket after Detroy() has been called.") + var ErrRecvMessage = errors.New("recv message error") + var ErrSendFrame = errors.New("send frame error") + var ErrSliceFull = errors.New("slice full") + var ErrSockAttach = errors.New("error attaching zsock") + var ErrSockAttachEmptyEndpoints = errors.New("Endpoints cannot be empty") + var ErrTimeout = errors.New("function timed out") + var ErrUnbind = errors.New("unbind error") + var ErrWaitAfterDestroy = errors.New("Wait() is invalid on Poller after Destroy() is called.") + func Affinity(s *Sock) int + func Backlog(s *Sock) int + func ConnectTimeout(s *Sock) int + func CurvePublickey(s *Sock) string + func CurveSecretkey(s *Sock) string + func CurveServer(s *Sock) int + func CurveServerkey(s *Sock) string + func Events(s *Sock) int + func Fd(s *Sock) int + func GssapiPlaintext(s *Sock) int + func GssapiPrincipal(s *Sock) string + func GssapiServer(s *Sock) int + func GssapiServicePrincipal(s *Sock) string + func HandshakeIvl(s *Sock) int + func HeartbeatIvl(s *Sock) int + func HeartbeatTimeout(s *Sock) int + func HeartbeatTtl(s *Sock) int + func Identity(s *Sock) string + func Immediate(s *Sock) int + func InvertMatching(s *Sock) int + func Ipv4only(s *Sock) int + func Ipv6(s *Sock) int + func LastEndpoint(s *Sock) string + func Linger(s *Sock) int + func Maxmsgsize(s *Sock) int + func Mechanism(s *Sock) int + func MulticastHops(s *Sock) int + func MulticastMaxtpdu(s *Sock) int + func PlainPassword(s *Sock) string + func PlainServer(s *Sock) int + func PlainUsername(s *Sock) string + func Rate(s *Sock) int + func Rcvbuf(s *Sock) int + func Rcvhwm(s *Sock) int + func Rcvmore(s *Sock) int + func Rcvtimeo(s *Sock) int + func ReconnectIvl(s *Sock) int + func ReconnectIvlMax(s *Sock) int + func RecoveryIvl(s *Sock) int + func Shutdown() + func Sndbuf(s *Sock) int + func Sndhwm(s *Sock) int + func Sndtimeo(s *Sock) int + func SocksProxy(s *Sock) string + func TcpAcceptFilter(s *Sock) string + func TcpKeepalive(s *Sock) int + func TcpKeepaliveCnt(s *Sock) int + func TcpKeepaliveIdle(s *Sock) int + func TcpKeepaliveIntvl(s *Sock) int + func TcpMaxrt(s *Sock) int + func ThreadSafe(s *Sock) int + func Tos(s *Sock) int + func Type(s *Sock) int + func UseFd(s *Sock) int + func VmciBufferMaxSize(s *Sock) int + func VmciBufferMinSize(s *Sock) int + func VmciBufferSize(s *Sock) int + func VmciConnectTimeout(s *Sock) int + func ZapDomain(s *Sock) string + type Auth struct + func NewAuth() *Auth + func (a *Auth) Allow(address string) error + func (a *Auth) Curve(allowed string) error + func (a *Auth) Deny(address string) error + func (a *Auth) Destroy() + func (a *Auth) Plain(directory string) error + func (a *Auth) Verbose() error + type Beacon struct + func NewBeacon() *Beacon + func (b *Beacon) Configure(port int) (string, error) + func (b *Beacon) Destroy() + func (b *Beacon) Publish(announcement string, interval int) error + func (b *Beacon) PublishBytes(announcement []byte, interval int) error + func (b *Beacon) Recv(timeout int) [][]byte + func (b *Beacon) Subscribe(filter string) error + func (b *Beacon) Verbose() error + type Cert struct + func NewCert() *Cert + func NewCertFromFile(filename string) (*Cert, error) + func NewCertFromKeys(public []byte, secret []byte) (*Cert, error) + func (c *Cert) Apply(s *Sock) + func (c *Cert) Destroy() + func (c *Cert) Dup() *Cert + func (c *Cert) Equal(compare *Cert) bool + func (c *Cert) Meta(key string) string + func (c *Cert) Print() + func (c *Cert) PublicText() string + func (c *Cert) Save(filename string) error + func (c *Cert) SavePublic(filename string) error + func (c *Cert) SaveSecret(filename string) error + func (c *Cert) SetMeta(key string, value string) + type CertStore struct + func NewCertStore(location string) *CertStore + func NewCertStoreInMemory() *CertStore + func (c *CertStore) Destroy() + func (c *CertStore) Insert(cert *Cert) + func (c *CertStore) Lookup(key string) *Cert + func (c *CertStore) Print() + type Channeler struct + ErrChan <-chan error + RecvChan <-chan [][]byte + SendChan chan<- [][]byte + func NewDealerChanneler(endpoints string, options ...SockOption) *Channeler + func NewPairChanneler(endpoints string, options ...SockOption) *Channeler + func NewPubChanneler(endpoints string, options ...SockOption) *Channeler + func NewPullChanneler(endpoints string, options ...SockOption) *Channeler + func NewPushChanneler(endpoints string, options ...SockOption) *Channeler + func NewRepChanneler(endpoints string, options ...SockOption) *Channeler + func NewReqChanneler(endpoints string, options ...SockOption) *Channeler + func NewRouterChanneler(endpoints string, options ...SockOption) *Channeler + func NewStreamChanneler(endpoints string, options ...SockOption) *Channeler + func NewSubChanneler(endpoints string, varargs ...interface{}) *Channeler + func NewXPubChanneler(endpoints string, options ...SockOption) *Channeler + func NewXSubChanneler(endpoints string, options ...SockOption) *Channeler + func (c *Channeler) Destroy() + func (c *Channeler) Subscribe(topic string) + func (c *Channeler) Unsubscribe(topic string) + type Monitor struct + func NewMonitor(socket *Sock) *Monitor + func (m *Monitor) Destroy() + func (m *Monitor) Listen(event string) error + func (m *Monitor) Socket() *Sock + func (m *Monitor) Start() error + func (m *Monitor) Verbose() error + type Poller struct + func NewPoller(readers ...*Sock) (*Poller, error) + func (p *Poller) Add(reader *Sock) error + func (p *Poller) Destroy() + func (p *Poller) Remove(reader *Sock) + func (p *Poller) Wait(millis int) (*Sock, error) + type Proxy struct + func NewProxy() *Proxy + func (p *Proxy) Destroy() + func (p *Proxy) Pause() error + func (p *Proxy) Resume() error + func (p *Proxy) SetBackend(sockType int, endpoint string) error + func (p *Proxy) SetBackendCurve(publicKey string, secretKey string) error + func (p *Proxy) SetBackendDomain(domain string) error + func (p *Proxy) SetCapture(endpoint string) error + func (p *Proxy) SetFrontend(sockType int, endpoint string) error + func (p *Proxy) SetFrontendCurve(publicKey string, secretKey string) error + func (p *Proxy) SetFrontendDomain(domain string) error + func (p *Proxy) Verbose() error + type ReadWriter struct + func NewReadWriter(sock *Sock) (*ReadWriter, error) + func (r *ReadWriter) Destroy() + func (r *ReadWriter) GetLastClientID() []byte + func (r *ReadWriter) Read(p []byte) (int, error) + func (r *ReadWriter) SetLastClientID(id []byte) + func (r *ReadWriter) SetTimeout(ms int) + func (r *ReadWriter) Write(p []byte) (int, error) + type Sock struct + func NewDealer(endpoints string, options ...SockOption) (*Sock, error) + func NewPair(endpoints string, options ...SockOption) (*Sock, error) + func NewPub(endpoints string, options ...SockOption) (*Sock, error) + func NewPull(endpoints string, options ...SockOption) (*Sock, error) + func NewPush(endpoints string, options ...SockOption) (*Sock, error) + func NewRep(endpoints string, options ...SockOption) (*Sock, error) + func NewReq(endpoints string, options ...SockOption) (*Sock, error) + func NewRouter(endpoints string, options ...SockOption) (*Sock, error) + func NewSock(t int, options ...SockOption) *Sock + func NewStream(endpoints string, options ...SockOption) (*Sock, error) + func NewSub(endpoints string, subscribe string, options ...SockOption) (*Sock, error) + func NewXPub(endpoints string, options ...SockOption) (*Sock, error) + func NewXSub(endpoints string, options ...SockOption) (*Sock, error) + func (s *Sock) Attach(endpoints string, serverish bool) error + func (s *Sock) Bind(endpoint string) (int, error) + func (s *Sock) Connect(endpoint string) error + func (s *Sock) Destroy() + func (s *Sock) Disconnect(endpoint string) error + func (s *Sock) GetLastClientID() []byte + func (s *Sock) GetType() int + func (s *Sock) Pollin() bool + func (s *Sock) Pollout() bool + func (s *Sock) Read(p []byte) (int, error) + func (s *Sock) RecvFrame() ([]byte, int, error) + func (s *Sock) RecvFrameNoWait() ([]byte, int, error) + func (s *Sock) RecvMessage() ([][]byte, error) + func (s *Sock) RecvMessageNoWait() ([][]byte, error) + func (s *Sock) SendFrame(data []byte, flags int) error + func (s *Sock) SendMessage(parts [][]byte) error + func (s *Sock) SetLastClientID(id []byte) + func (s *Sock) SetOption(o SockOption) + func (s *Sock) Unbind(endpoint string) error + func (s *Sock) Write(p []byte) (int, error) + type SockOption func(*Sock) + func SockSetAffinity(v int) SockOption + func SockSetBacklog(v int) SockOption + func SockSetConflate(v int) SockOption + func SockSetConnectRid(v string) SockOption + func SockSetConnectTimeout(v int) SockOption + func SockSetCurvePublickey(v string) SockOption + func SockSetCurveSecretkey(v string) SockOption + func SockSetCurveServer(v int) SockOption + func SockSetCurveServerkey(v string) SockOption + func SockSetDelayAttachOnConnect(v int) SockOption + func SockSetGssapiPlaintext(v int) SockOption + func SockSetGssapiPrincipal(v string) SockOption + func SockSetGssapiServer(v int) SockOption + func SockSetGssapiServicePrincipal(v string) SockOption + func SockSetHandshakeIvl(v int) SockOption + func SockSetHeartbeatIvl(v int) SockOption + func SockSetHeartbeatTimeout(v int) SockOption + func SockSetHeartbeatTtl(v int) SockOption + func SockSetIdentity(v string) SockOption + func SockSetImmediate(v int) SockOption + func SockSetInvertMatching(v int) SockOption + func SockSetIpv4only(v int) SockOption + func SockSetIpv6(v int) SockOption + func SockSetLinger(v int) SockOption + func SockSetMaxmsgsize(v int) SockOption + func SockSetMulticastHops(v int) SockOption + func SockSetMulticastMaxtpdu(v int) SockOption + func SockSetPlainPassword(v string) SockOption + func SockSetPlainServer(v int) SockOption + func SockSetPlainUsername(v string) SockOption + func SockSetProbeRouter(v int) SockOption + func SockSetRate(v int) SockOption + func SockSetRcvbuf(v int) SockOption + func SockSetRcvhwm(v int) SockOption + func SockSetRcvtimeo(v int) SockOption + func SockSetReconnectIvl(v int) SockOption + func SockSetReconnectIvlMax(v int) SockOption + func SockSetRecoveryIvl(v int) SockOption + func SockSetReqCorrelate(v int) SockOption + func SockSetReqRelaxed(v int) SockOption + func SockSetRouterHandover(v int) SockOption + func SockSetRouterMandatory(v int) SockOption + func SockSetRouterNotify(v int) SockOption + func SockSetRouterRaw(v int) SockOption + func SockSetSndbuf(v int) SockOption + func SockSetSndhwm(v int) SockOption + func SockSetSndtimeo(v int) SockOption + func SockSetSocksProxy(v string) SockOption + func SockSetStreamNotify(v int) SockOption + func SockSetSubscribe(v string) SockOption + func SockSetTcpAcceptFilter(v string) SockOption + func SockSetTcpKeepalive(v int) SockOption + func SockSetTcpKeepaliveCnt(v int) SockOption + func SockSetTcpKeepaliveIdle(v int) SockOption + func SockSetTcpKeepaliveIntvl(v int) SockOption + func SockSetTcpMaxrt(v int) SockOption + func SockSetTos(v int) SockOption + func SockSetUnsubscribe(v string) SockOption + func SockSetUseFd(v int) SockOption + func SockSetVmciBufferMaxSize(v int) SockOption + func SockSetVmciBufferMinSize(v int) SockOption + func SockSetVmciBufferSize(v int) SockOption + func SockSetVmciConnectTimeout(v int) SockOption + func SockSetXPubManual(v int) SockOption + func SockSetXPubNodrop(v int) SockOption + func SockSetXPubVerbose(v int) SockOption + func SockSetXPubVerboser(v int) SockOption + func SockSetXPubWelcomeMsg(v string) SockOption + func SockSetZapDomain(v string) SockOption