zmq4

May 16, 2024

Changes in this version

type Option

+ func WithTimeout(timeout time.Duration) Option

Sep 14, 2023

Changes in this version

+ type UnknownTransportError struct

+ Name string

+ func (ute UnknownTransportError) Error() string

Jun 21, 2022

Changes in this version

type Option

+ func WithAutomaticReconnect(automaticReconnect bool) Option

+ func WithDialerMaxRetries(maxRetries int) Option

Oct 21, 2020

Changes in this version

+ func RegisterTransport(name string, trans transport.Transport) error

+ func Transports() []string

Feb 26, 2020

Changes in this version

type Option

+ func WithLogger(msg *log.Logger) Option

+ type Proxy struct

+ func NewProxy(ctx context.Context, front, back, capture Socket) *Proxy

+ func (p *Proxy) Kill()

+ func (p *Proxy) Pause()

+ func (p *Proxy) Resume()

+ func (p *Proxy) Run() error

+ func (p *Proxy) Stats()

Dec 7, 2019

Changes in this version

+ const OptionHWM

+ var ErrClosedConn = xerrors.New("zmq4: read/write on closed connection")

type Conn

+ func (conn *Conn) Closed() bool

+ func (conn *Conn) SetClosed()

+ type Queue struct

+ func NewQueue() *Queue

+ func (q *Queue) Init()

+ func (q *Queue) Len() int

+ func (q *Queue) Peek() (Msg, bool)

+ func (q *Queue) Pop()

+ func (q *Queue) Push(val Msg)

type Socket

+ SendMulti func(msg Msg) error

+ type Topics interface

+ Topics func() []string

Oct 14, 2019

Changes in this version

+ const CmdCancel

+ const CmdError

+ const CmdHello

+ const CmdInitiate

+ const CmdPing

+ const CmdPong

+ const CmdReady

+ const CmdSubscribe

+ const CmdUnsubscribe

+ const CmdWelcome

+ const OptionSubscribe

+ const OptionUnsubscribe

+ var ErrBadCmd = xerrors.New("zmq4: invalid command name")

+ var ErrBadFrame = xerrors.New("zmq4: invalid frame")

+ var ErrBadProperty = xerrors.New("zmq4: bad property")

+ type Cmd struct

+ Body []byte

+ Name string

+ type Conn struct

+ Meta Metadata

+ Peer struct{ ... }

+ Server bool

+ func Open(rw io.ReadWriteCloser, sec Security, sockType SocketType, ...) (*Conn, error)

+ func (c *Conn) Close() error

+ func (c *Conn) Read(p []byte) (int, error)

+ func (c *Conn) RecvCmd() (Cmd, error)

+ func (c *Conn) RecvMsg() (Msg, error)

+ func (c *Conn) SendCmd(name string, body []byte) error

+ func (c *Conn) SendMsg(msg Msg) error

+ func (c *Conn) Write(p []byte) (int, error)

+ type Metadata map[string]string

+ func (md *Metadata) UnmarshalZMTP(p []byte) error

+ func (md Metadata) MarshalZMTP() ([]byte, error)

+ type Msg struct

+ Frames [][]byte

+ Type MsgType

+ func NewMsg(frame []byte) Msg

+ func NewMsgFrom(frames ...[]byte) Msg

+ func NewMsgFromString(frames []string) Msg

+ func NewMsgString(frame string) Msg

+ func (msg Msg) Bytes() []byte

+ func (msg Msg) Clone() Msg

+ func (msg Msg) Err() error

+ func (msg Msg) String() string

+ type MsgType byte

+ const CmdMsg

+ const UsrMsg

+ type Option func(s *socket)

+ func WithDialerRetry(retry time.Duration) Option

+ func WithDialerTimeout(timeout time.Duration) Option

+ func WithID(id SocketIdentity) Option

+ func WithSecurity(sec Security) Option

+ type Property struct

+ K string

+ V string

+ func (prop *Property) Write(data []byte) (n int, err error)

+ func (prop Property) Read(data []byte) (n int, err error)

+ type Security interface

+ Decrypt func(w io.Writer, data []byte) (int, error)

+ Encrypt func(w io.Writer, data []byte) (int, error)

+ Handshake func(conn *Conn, server bool) error

+ Type func() SecurityType

+ type SecurityType string

+ const CurveSecurity

+ const NullSecurity

+ const PlainSecurity

+ type Socket interface

+ Addr func() net.Addr

+ Close func() error

+ Dial func(ep string) error

+ GetOption func(name string) (interface{}, error)

+ Listen func(ep string) error

+ Recv func() (Msg, error)

+ Send func(msg Msg) error

+ SetOption func(name string, value interface{}) error

+ Type func() SocketType

+ func NewDealer(ctx context.Context, opts ...Option) Socket

+ func NewPair(ctx context.Context, opts ...Option) Socket

+ func NewPub(ctx context.Context, opts ...Option) Socket

+ func NewPull(ctx context.Context, opts ...Option) Socket

+ func NewPush(ctx context.Context, opts ...Option) Socket

+ func NewRep(ctx context.Context, opts ...Option) Socket

+ func NewReq(ctx context.Context, opts ...Option) Socket

+ func NewRouter(ctx context.Context, opts ...Option) Socket

+ func NewSub(ctx context.Context, opts ...Option) Socket

+ func NewXPub(ctx context.Context, opts ...Option) Socket

+ func NewXSub(ctx context.Context, opts ...Option) Socket

+ type SocketIdentity []byte

+ func (id SocketIdentity) String() string

+ type SocketType string

+ const Dealer

+ const Pair

+ const Pub

+ const Pull

+ const Push

+ const Rep

+ const Req

+ const Router

+ const Sub

+ const XPub

+ const XSub

+ func (sck SocketType) IsCompatible(peer SocketType) bool