transport

Documentation

Index

• func RegisterTransport(t Transport)
• func ResolveTCPAddr(addr string) (*net.TCPAddr, error)
• func StripScheme(t Transport, addr string) (string, error)
• type Dialer
• type Listener
• type Message
• type Pipe
  • func NewConnPipe(c net.Conn, proto ProtocolInfo, options map[string]interface{}) (Pipe, error)
  • func NewConnPipeIPC(c net.Conn, proto ProtocolInfo, options map[string]interface{}) (Pipe, error)
• type ProtocolInfo
• type Transport
  • func GetTransport(scheme string) Transport

Functions

func RegisterTransport

func RegisterTransport(t Transport)

RegisterTransport is used to register the transport globally, after which it will be available for all sockets. The transport will override any others registered for the same scheme.

func ResolveTCPAddr

func ResolveTCPAddr(addr string) (*net.TCPAddr, error)

ResolveTCPAddr is like net.ResolveTCPAddr, but it handles the wildcard used in nanomsg URLs, replacing it with an empty string to indicate that all local interfaces be used.

func StripScheme

func StripScheme(t Transport, addr string) (string, error)

StripScheme removes the leading scheme (such as "http://") from an address string. This is mostly a utility for benefit of transport providers.

Types

type Dialer

type Dialer = mangos.TranDialer

Dialer is a factory that creates Pipes by connecting to remote listeners.

type Listener

type Listener = mangos.TranListener

Listener is a factory that creates Pipes by listening to inbound dialers.

type Message

type Message = mangos.Message

Message is an alias for the mangos.Message

type Pipe

type Pipe = mangos.TranPipe

Pipe is a transport pipe.

func NewConnPipe

func NewConnPipe(c net.Conn, proto ProtocolInfo, options map[string]interface{}) (Pipe, error)

NewConnPipe allocates a new Pipe using the supplied net.Conn, and initializes it. It performs the handshake required at the SP layer, only returning the Pipe once the SP layer negotiation is complete.

Stream oriented transports can utilize this to implement a Transport. The implementation will also need to implement PipeDialer, PipeAccepter, and the Transport enclosing structure. Using this layered interface, the implementation needn't bother concerning itself with passing actual SP messages once the lower layer connection is established.

func NewConnPipeIPC

func NewConnPipeIPC(c net.Conn, proto ProtocolInfo, options map[string]interface{}) (Pipe, error)

NewConnPipeIPC allocates a new Pipe using the IPC exchange protocol.

type ProtocolInfo

type ProtocolInfo = mangos.ProtocolInfo

ProtocolInfo is stuff that describes a protocol.

type Transport

type Transport = mangos.Transport

Transport is our transport operations.

func GetTransport

func GetTransport(scheme string) Transport

GetTransport is used by a socket to lookup the transport for a given scheme.