mux

Documentation

Index

• Variables
• type Endpoint
  • func (e *Endpoint) Close() error
  • func (e *Endpoint) LocalAddr() net.Addr
  • func (e *Endpoint) Read(p []byte) (int, error)
  • func (e *Endpoint) RemoteAddr() net.Addr
  • func (e *Endpoint) SetDeadline(t time.Time) error
  • func (e *Endpoint) SetReadDeadline(t time.Time) error
  • func (e *Endpoint) SetWriteDeadline(t time.Time) error
  • func (e *Endpoint) Write(p []byte) (n int, err error)
• type MatchFunc
  • func MatchRange(lower, upper byte) MatchFunc
• type Mux
  • func NewMux(conn net.Conn, bufferSize int) *Mux
  • func (m *Mux) Close() error
  • func (m *Mux) NewEndpoint(f MatchFunc) *Endpoint
  • func (m *Mux) RemoveEndpoint(e *Endpoint)

Variables

var MatchDTLS = MatchRange(20, 63)

MatchDTLS is a MatchFunc that accepts packets with the first byte in [20..63] as defied in RFC7983

var MatchSRTP = MatchRange(128, 191)

MatchSRTP is a MatchFunc that accepts packets with the first byte in [128..191] as defied in RFC7983

var MatchSTUN = MatchRange(0, 3)

MatchSTUN is a MatchFunc that accepts packets with the first byte in [0..3] as defied in RFC7983

var MatchTURN = MatchRange(64, 79)

MatchTURN is a MatchFunc that accepts packets with the first byte in [64..79] as defied in RFC7983

var MatchZRTP = MatchRange(16, 19)

MatchZRTP is a MatchFunc that accepts packets with the first byte in [16..19] as defied in RFC7983

Types

type Endpoint

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

Endpoint implements net.Conn. It is used to read muxed packets.

func (*Endpoint) Close

func (e *Endpoint) Close() error

Close unregisters the endpoint from the Mux

func (*Endpoint) LocalAddr

func (e *Endpoint) LocalAddr() net.Addr

LocalAddr is a stub

func (*Endpoint) Read

func (e *Endpoint) Read(p []byte) (int, error)

Read reads a packet of len(p) bytes from the underlying conn that are matched by the associated MuxFunc

func (*Endpoint) RemoteAddr

func (e *Endpoint) RemoteAddr() net.Addr

RemoteAddr is a stub

func (*Endpoint) SetDeadline

func (e *Endpoint) SetDeadline(t time.Time) error

SetDeadline is a stub

func (*Endpoint) SetReadDeadline

func (e *Endpoint) SetReadDeadline(t time.Time) error

SetReadDeadline is a stub

func (*Endpoint) SetWriteDeadline

func (e *Endpoint) SetWriteDeadline(t time.Time) error

SetWriteDeadline is a stub

func (*Endpoint) Write

func (e *Endpoint) Write(p []byte) (n int, err error)

Write writes len(p) bytes to the underlying conn

type MatchFunc

type MatchFunc func([]byte) bool

MatchFunc allows custom logic for mapping packets to an Endpoint

func MatchRange

func MatchRange(lower, upper byte) MatchFunc

MatchRange is a MatchFunc that accepts packets with the first byte in [lower..upper]

type Mux

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

Mux allows multiplexing

func NewMux

func NewMux(conn net.Conn, bufferSize int) *Mux

NewMux creates a new Mux

func (*Mux) Close

func (m *Mux) Close() error

Close closes the Mux and all associated Endpoints.

func (*Mux) NewEndpoint

func (m *Mux) NewEndpoint(f MatchFunc) *Endpoint

NewEndpoint creates a new Endpoint

func (*Mux) RemoveEndpoint

func (m *Mux) RemoveEndpoint(e *Endpoint)

RemoveEndpoint removes an endpoint from the Mux