Versions in this module Expand all Collapse all v1 v1.0.0 Sep 10, 2021 Changes in this version + const HelloID + const JoinID + const LeaveID + const PingID + const PingOkID + const ShoutID + const Signature + const WhisperID + type Hello struct + Endpoint string + Groups []string + Headers map[string]string + Name string + Status byte + func NewHello() *Hello + func (h *Hello) Marshal() ([]byte, error) + func (h *Hello) RoutingID() []byte + func (h *Hello) Send(socket *zmq.Socket) (err error) + func (h *Hello) Sequence() uint16 + func (h *Hello) SetRoutingID(routingID []byte) + func (h *Hello) SetSequence(sequence uint16) + func (h *Hello) SetVersion(version byte) + func (h *Hello) String() string + func (h *Hello) Unmarshal(frames ...[]byte) error + func (h *Hello) Version() byte + type Join struct + Group string + Status byte + func NewJoin() *Join + func (j *Join) Marshal() ([]byte, error) + func (j *Join) RoutingID() []byte + func (j *Join) Send(socket *zmq.Socket) (err error) + func (j *Join) Sequence() uint16 + func (j *Join) SetRoutingID(routingID []byte) + func (j *Join) SetSequence(sequence uint16) + func (j *Join) SetVersion(version byte) + func (j *Join) String() string + func (j *Join) Unmarshal(frames ...[]byte) error + func (j *Join) Version() byte + type Leave struct + Group string + Status byte + func NewLeave() *Leave + func (l *Leave) Marshal() ([]byte, error) + func (l *Leave) RoutingID() []byte + func (l *Leave) Send(socket *zmq.Socket) (err error) + func (l *Leave) Sequence() uint16 + func (l *Leave) SetRoutingID(routingID []byte) + func (l *Leave) SetSequence(sequence uint16) + func (l *Leave) SetVersion(version byte) + func (l *Leave) String() string + func (l *Leave) Unmarshal(frames ...[]byte) error + func (l *Leave) Version() byte + type Ping struct + func NewPing() *Ping + func (p *Ping) Marshal() ([]byte, error) + func (p *Ping) RoutingID() []byte + func (p *Ping) Send(socket *zmq.Socket) (err error) + func (p *Ping) Sequence() uint16 + func (p *Ping) SetRoutingID(routingID []byte) + func (p *Ping) SetSequence(sequence uint16) + func (p *Ping) SetVersion(version byte) + func (p *Ping) String() string + func (p *Ping) Unmarshal(frames ...[]byte) error + func (p *Ping) Version() byte + type PingOk struct + func NewPingOk() *PingOk + func (p *PingOk) Marshal() ([]byte, error) + func (p *PingOk) RoutingID() []byte + func (p *PingOk) Send(socket *zmq.Socket) (err error) + func (p *PingOk) Sequence() uint16 + func (p *PingOk) SetRoutingID(routingID []byte) + func (p *PingOk) SetSequence(sequence uint16) + func (p *PingOk) SetVersion(version byte) + func (p *PingOk) String() string + func (p *PingOk) Unmarshal(frames ...[]byte) error + func (p *PingOk) Version() byte + type Shout struct + Content []byte + Group string + func NewShout() *Shout + func (s *Shout) Marshal() ([]byte, error) + func (s *Shout) RoutingID() []byte + func (s *Shout) Send(socket *zmq.Socket) (err error) + func (s *Shout) Sequence() uint16 + func (s *Shout) SetRoutingID(routingID []byte) + func (s *Shout) SetSequence(sequence uint16) + func (s *Shout) SetVersion(version byte) + func (s *Shout) String() string + func (s *Shout) Unmarshal(frames ...[]byte) error + func (s *Shout) Version() byte + type Transit interface + Marshal func() ([]byte, error) + RoutingID func() []byte + Send func(*zmq.Socket) error + Sequence func() uint16 + SetRoutingID func([]byte) + SetSequence func(uint16) + SetVersion func(byte) + String func() string + Unmarshal func(...[]byte) error + Version func() byte + func Clone(t Transit) Transit + func Recv(socket *zmq.Socket) (t Transit, err error) + func RecvNoWait(socket *zmq.Socket) (t Transit, err error) + func Unmarshal(frames ...[]byte) (t Transit, err error) + type Whisper struct + Content []byte + func NewWhisper() *Whisper + func (w *Whisper) Marshal() ([]byte, error) + func (w *Whisper) RoutingID() []byte + func (w *Whisper) Send(socket *zmq.Socket) (err error) + func (w *Whisper) Sequence() uint16 + func (w *Whisper) SetRoutingID(routingID []byte) + func (w *Whisper) SetSequence(sequence uint16) + func (w *Whisper) SetVersion(version byte) + func (w *Whisper) String() string + func (w *Whisper) Unmarshal(frames ...[]byte) error + func (w *Whisper) Version() byte