zmtp

Documentation

Overview

Package zmtp implements the wire format used in ZMTP, the ZeroMQ Message Transport Protocol.

For more information, see: http://zmtp.org/

Index

• type Negotiator
  • func (h *Negotiator) Upgrade(r io.Reader, w io.Writer) (protocol.Reader, protocol.Writer, error)
• type Type

Types

type Negotiator

type Negotiator struct {
	// Identity is used as an addressing mechanism in ZMTP. If not specified, the
	// anonymous identity will be used. The maximum length is 254 bytes and should
	// not start with 0x00.
	Identity []byte
}

func (*Negotiator) Upgrade

func (h *Negotiator) Upgrade(r io.Reader, w io.Writer) (protocol.Reader, protocol.Writer, error)

Upgrade performs the handshake as defined by ZMTP and upgrades the given r and w to a reader and writer capable of communicating with the other node using ZMTP.

type Type

type Type int

const (
	REQ Type = 3
	REP      = 4
)