mux

Oct 4, 2024

Changes in this version

+ func MatchAll([]byte) bool

+ func MatchDTLS(b []byte) bool

+ func MatchRange(lower, upper byte, buf []byte) bool

+ func MatchSRTCP(buf []byte) bool

+ func MatchSRTP(buf []byte) bool

+ func MatchSRTPOrSRTCP(b []byte) bool

+ type Config struct

+ BufferSize int

+ Conn net.Conn

+ LoggerFactory logging.LoggerFactory

+ type Endpoint struct

+ func (e *Endpoint) Close() (err error)

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

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

+ func (e *Endpoint) ReadFrom(p []byte) (int, net.Addr, error)

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

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

+ func (e *Endpoint) SetOnClose(onClose func())

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

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

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

+ func (e *Endpoint) WriteTo(p []byte, _ net.Addr) (int, error)

+ type MatchFunc func([]byte) bool

+ type Mux struct

+ func NewMux(config Config) *Mux

+ func (m *Mux) Close() error

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

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