transport

Documentation

Overview

Package transport defines the Transport interface and provides a net-based implementation that can be used by zmq4 sockets to exchange messages.

Index

• type Dialer
• type Transport
  • func New(network string) Transport

Types

type Dialer

type Dialer interface {
	DialContext(ctx context.Context, network, address string) (net.Conn, error)
}

Dialer is the interface that wraps the DialContext method.

type Transport

type Transport interface {
	// Dial connects to the address on the named network using the provided
	// context.
	Dial(ctx context.Context, dialer Dialer, addr string) (net.Conn, error)

	// Listen announces on the provided network address.
	Listen(ctx context.Context, addr string) (net.Listener, error)

	// Addr returns the end-point address.
	Addr(ep string) (addr string, err error)
}

Transport is the zmq4 transport interface that wraps the Dial and Listen methods.

func New

func New(network string) Transport

New returns a new net-based transport with the given network (e.g "tcp").