inproc

Documentation

Overview

Package inproc provides tools to implement an in-process asynchronous pipe of net.Conns.

Index

• Variables
• func Dial(addr string) (net.Conn, error)
• type Addr
  • func (a Addr) Network() string
  • func (a Addr) String() string
• type Listener
  • func Listen(addr string) (*Listener, error)
  • func (l *Listener) Accept() (net.Conn, error)
  • func (l *Listener) Addr() net.Addr
  • func (l *Listener) Close() error
• type Transport
  • func (Transport) Addr(ep string) (addr string, err error)
  • func (Transport) Dial(ctx context.Context, dialer transport.Dialer, addr string) (net.Conn, error)
  • func (Transport) Listen(ctx context.Context, addr string) (net.Listener, error)

Variables

var (
	ErrClosed      = errors.New("inproc: connection closed")
	ErrConnRefused = errors.New("inproc: connection refused")
)

Functions

func Dial

func Dial(addr string) (net.Conn, error)

Dial connects to the given address.

Types

type Addr

type Addr string

Addr represents an in-process "network" end-point address.

func (Addr) Network

func (a Addr) Network() string

Network returns the name of the network.

func (Addr) String

func (a Addr) String() string

String implements net.Addr.String

type Listener

type Listener struct {
	// contains filtered or unexported fields
}

A Listener is an in-process listener for stream-oriented protocols. Listener implements net.Listener.

Multiple goroutines may invoke methods on a Listener simultaneously.

func Listen

func Listen(addr string) (*Listener, error)

Listen announces on the given address.

func (*Listener) Accept

func (l *Listener) Accept() (net.Conn, error)

Accept waits for and returns the next connection to the listener.

func (*Listener) Addr

func (l *Listener) Addr() net.Addr

Addr returns the listener's netword address.

func (*Listener) Close

func (l *Listener) Close() error

Close closes the listener. Any blocked Accept operations will be unblocked and return errors.

type Transport

type Transport struct{}

Transport implements the zmq4 Transport interface for the inproc transport.

func (Transport) Addr

func (Transport) Addr(ep string) (addr string, err error)

Addr returns the end-point address.

func (Transport) Dial

func (Transport) Dial(ctx context.Context, dialer transport.Dialer, addr string) (net.Conn, error)

Dial connects to the address on the named network using the provided context.

func (Transport) Listen

func (Transport) Listen(ctx context.Context, addr string) (net.Listener, error)

Listen announces on the provided network address.