transportmux

Documentation

Overview

Package transportmux wraps a transport.{Connecter,AuthenticatedListener} to distinguish different connection types based on a label sent from client to server on connection establishment.

Labels are plain text and fixed length.

Index

• Constants
• Variables
• func Demux(ctx context.Context, rawListener transport.AuthenticatedListener, ...) (map[string]transport.AuthenticatedListener, error)
• func MuxConnecter(rawConnecter transport.Connecter, labels []string, timeout time.Duration) (map[string]transport.Connecter, error)
• type Logger

Constants

const LabelLen = 64

Exact length of a label in bytes (0-byte padded if it is shorter). This is a protocol constant, changing it breaks the wire protocol.

Variables

var ErrClosed = &net.OpError{
	Op:     "accept",
	Net:    "demux",
	Source: nil,
	Addr:   nil,
	Err:    syscall.EINVAL,
}

Functions

func Demux

func Demux(ctx context.Context, rawListener transport.AuthenticatedListener, labels []string, timeout time.Duration) (map[string]transport.AuthenticatedListener, error)

func MuxConnecter

func MuxConnecter(rawConnecter transport.Connecter, labels []string, timeout time.Duration) (map[string]transport.Connecter, error)

Types

type Logger

type Logger = logger.Logger