listenmux

Documentation

Index

• Variables
• type Mux
  • func New(base net.Listener, prefixLen int) *Mux
  • func (m *Mux) Default() net.Listener
  • func (m *Mux) Route(prefix string) net.Listener
  • func (m *Mux) Run(ctx context.Context) error

Variables

var Closed = errs.New("listener closed")

Closed is returned by routed listeners when the mux is closed.

Types

type Mux

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

Mux lets one multiplex a listener into different listeners based on the first bytes sent on the connection.

func New

func New(base net.Listener, prefixLen int) *Mux

New creates a mux that reads the prefixLen bytes from any connections Accepted by the passed in listener and dispatches to the appropriate route.

func (*Mux) Default

func (m *Mux) Default() net.Listener

Default returns the net.Listener that is used if no route matches.

func (*Mux) Route

func (m *Mux) Route(prefix string) net.Listener

Route returns a listener that will be used if the first bytes are the given prefix. The length of the prefix must match the original passed in prefixLen.

func (*Mux) Run

func (m *Mux) Run(ctx context.Context) error

Run calls listen on the provided listener and passes connections to the routed listeners.