rtp

package

v0.0.0-...-9401d5b Latest Latest Go to latest Published: Nov 3, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/mnfgithub/media-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CodecByPayloadType(typ byte) media.Codec
func HandleLoop(r Reader, h HandlerCloser) error
func ListenUDPPortRange(portMin, portMax int, ip netip.Addr) (*net.UDPConn, error)
type AudioCodec
- func NewAudioCodec[S BytesFrame](info media.CodecInfo, ...) AudioCodec
type AudioEncoder
type Buffer
- func (b *Buffer) String() string
- func (b *Buffer) WriteRTP(h *rtp.Header, payload []byte) (int, error)
type BytesFrame
type Event
type Handler
type HandlerCloser
- func HandleJitter(h HandlerCloser) HandlerCloser
- func NewNopCloser(h Handler) HandlerCloser
type HandlerFunc
- func (fnc HandlerFunc) HandleRTP(h *rtp.Header, payload []byte) error
- func (fnc HandlerFunc) String() string
type Header
type MediaStreamIn
- func NewMediaStreamIn[T BytesFrame](w media.Writer[T]) *MediaStreamIn[T]
- func (s *MediaStreamIn[T]) HandleRTP(_ *rtp.Header, payload []byte) error
- func (s *MediaStreamIn[T]) String() string
type MediaStreamOut
- func NewMediaStreamOut[T BytesFrame](s *Stream, sampleRate int) *MediaStreamOut[T]
- func (s *MediaStreamOut[T]) Close() error
- func (s *MediaStreamOut[T]) SampleRate() int
- func (s *MediaStreamOut[T]) String() string
- func (s *MediaStreamOut[T]) WriteSample(sample T) error
type Mux
- func NewMux(def Handler) *Mux
- func (m *Mux) HandleRTP(h *rtp.Header, payload []byte) error
- func (m *Mux) Register(typ byte, h Handler)
- func (m *Mux) SetDefault(h Handler)
- func (m *Mux) String() string
type Packet
type ReadStream
type Reader
type SeqWriter
- func NewSeqWriter(w Writer) *SeqWriter
- func (s *SeqWriter) NewStream(typ byte, clockRate int) *Stream
- func (s *SeqWriter) NewStreamWithDur(typ byte, packetDur uint32) *Stream
- func (s *SeqWriter) String() string
- func (s *SeqWriter) WriteEvent(ev *Event) error
type Session
- func NewSession(log logger.Logger, conn net.Conn) Session
type Stream
- func (s *Stream) Delay(dur uint32)
- func (s *Stream) GetCurrentTimestamp() uint32
- func (s *Stream) ResetTimestamp(ts uint32)
- func (s *Stream) WritePayload(data []byte, marker bool) error
- func (s *Stream) WritePayloadAtCurrent(data []byte, marker bool) error
type WriteStream
type Writer

Constants ¶

View Source

const (
	// DefClockRate is a default clock rate at which RTP timestamps increment.
	DefClockRate = 8000
	// DefFrameDur is a default duration of an audio frame.
	DefFrameDur = media.DefFrameDur
	// DefFramesPerSec is a default number of audio frames per second.
	DefFramesPerSec = media.DefFramesPerSec
)

View Source

const (
	MTUSize = 1500
)

Variables ¶

View Source

var ErrListenFailed = errors.New("failed to listen on udp port")

Functions ¶

func CodecByPayloadType ¶

func CodecByPayloadType(typ byte) media.Codec

func HandleLoop ¶

func HandleLoop(r Reader, h HandlerCloser) error

func ListenUDPPortRange ¶

func ListenUDPPortRange(portMin, portMax int, ip netip.Addr) (*net.UDPConn, error)

Types ¶

type AudioCodec ¶

type AudioCodec interface {
	media.Codec
	EncodeRTP(w *Stream) media.PCM16Writer
	DecodeRTP(w media.Writer[media.PCM16Sample], typ byte) Handler
}

func NewAudioCodec ¶

func NewAudioCodec[S BytesFrame](
	info media.CodecInfo,
	decode func(writer media.PCM16Writer) media.WriteCloser[S],
	encode func(writer media.WriteCloser[S]) media.PCM16Writer,
) AudioCodec

type AudioEncoder ¶

type AudioEncoder[S BytesFrame] interface {
	AudioCodec
	Decode(writer media.PCM16Writer) media.WriteCloser[S]
	Encode(writer media.WriteCloser[S]) media.PCM16Writer
}

type Buffer ¶

type Buffer []*Packet

Buffer is a Writer that clones and appends RTP packets into a slice.

func (*Buffer) String ¶

func (b *Buffer) String() string

func (*Buffer) WriteRTP ¶

func (b *Buffer) WriteRTP(h *rtp.Header, payload []byte) (int, error)

type BytesFrame ¶

type BytesFrame interface {
	~[]byte
	media.Frame
}

type Event ¶

type Event struct {
	Type      byte
	Timestamp uint32
	Payload   []byte
	Marker    bool
}

type Handler ¶

type Handler interface {
	String() string
	HandleRTP(h *rtp.Header, payload []byte) error
}

type HandlerCloser ¶

type HandlerCloser interface {
	Handler
	Close()
}

func HandleJitter ¶

func HandleJitter(h HandlerCloser) HandlerCloser

func NewNopCloser ¶

func NewNopCloser(h Handler) HandlerCloser

type HandlerFunc ¶

type HandlerFunc func(h *rtp.Header, payload []byte) error

func (HandlerFunc) HandleRTP ¶

func (fnc HandlerFunc) HandleRTP(h *rtp.Header, payload []byte) error

func (HandlerFunc) String ¶

func (fnc HandlerFunc) String() string

type Header ¶

type Header = rtp.Header

type MediaStreamIn ¶

type MediaStreamIn[T BytesFrame] struct {
	Writer media.Writer[T]
}

func NewMediaStreamIn ¶

func NewMediaStreamIn[T BytesFrame](w media.Writer[T]) *MediaStreamIn[T]

func (*MediaStreamIn[T]) HandleRTP ¶

func (s *MediaStreamIn[T]) HandleRTP(_ *rtp.Header, payload []byte) error

func (*MediaStreamIn[T]) String ¶

func (s *MediaStreamIn[T]) String() string

type MediaStreamOut ¶

type MediaStreamOut[T BytesFrame] struct {
	// contains filtered or unexported fields
}

func NewMediaStreamOut ¶

func NewMediaStreamOut[T BytesFrame](s *Stream, sampleRate int) *MediaStreamOut[T]

func (*MediaStreamOut[T]) Close ¶

func (s *MediaStreamOut[T]) Close() error

func (*MediaStreamOut[T]) SampleRate ¶

func (s *MediaStreamOut[T]) SampleRate() int

func (*MediaStreamOut[T]) String ¶

func (s *MediaStreamOut[T]) String() string

func (*MediaStreamOut[T]) WriteSample ¶

func (s *MediaStreamOut[T]) WriteSample(sample T) error

type Mux ¶

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

func NewMux ¶

func NewMux(def Handler) *Mux

NewMux creates an RTP handler mux that selects a Handler based on RTP payload type. See Mux.HandleRTP for details.

func (*Mux) HandleRTP ¶

func (m *Mux) HandleRTP(h *rtp.Header, payload []byte) error

HandleRTP selects a Handler based on payload type. Types can be registered with Register. If no handler is set, a default one will be used.

func (*Mux) Register ¶

func (m *Mux) Register(typ byte, h Handler)

Register RTP handler for a payload type. Setting nil removes the handler.

func (*Mux) SetDefault ¶

func (m *Mux) SetDefault(h Handler)

SetDefault sets a default RTP handler. Setting nil will drop packets with unregistered type.

func (*Mux) String ¶

func (m *Mux) String() string

type Packet ¶

type Packet = rtp.Packet

type ReadStream ¶

type ReadStream interface {
	// ReadRTP reads RTP packet and its header from the connection.
	ReadRTP(h *rtp.Header, payload []byte) (int, error)
}

type Reader ¶

type Reader interface {
	ReadRTP() (*rtp.Packet, interceptor.Attributes, error)
}

type SeqWriter ¶

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

func NewSeqWriter ¶

func NewSeqWriter(w Writer) *SeqWriter

NewSeqWriter creates an RTP writer that automatically increments the sequence number.

func (*SeqWriter) NewStream ¶

func (s *SeqWriter) NewStream(typ byte, clockRate int) *Stream

NewStream creates a new media stream in RTP and tracks timestamps associated with it.

func (*SeqWriter) NewStreamWithDur ¶

func (s *SeqWriter) NewStreamWithDur(typ byte, packetDur uint32) *Stream

func (*SeqWriter) String ¶

func (s *SeqWriter) String() string

func (*SeqWriter) WriteEvent ¶

func (s *SeqWriter) WriteEvent(ev *Event) error

type Session ¶

type Session interface {
	OpenWriteStream() (WriteStream, error)
	AcceptStream() (ReadStream, uint32, error)
	Close() error
}

func NewSession ¶

func NewSession(log logger.Logger, conn net.Conn) Session

type Stream ¶

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

func (*Stream) Delay ¶

func (s *Stream) Delay(dur uint32)

func (*Stream) GetCurrentTimestamp ¶

func (s *Stream) GetCurrentTimestamp() uint32

func (*Stream) ResetTimestamp ¶

func (s *Stream) ResetTimestamp(ts uint32)

func (*Stream) WritePayload ¶

func (s *Stream) WritePayload(data []byte, marker bool) error

WritePayload writes the payload to RTP and increments the timestamp.

func (*Stream) WritePayloadAtCurrent ¶

func (s *Stream) WritePayloadAtCurrent(data []byte, marker bool) error

WritePayloadAtCurrent writes the payload to RTP at the current timestamp.

type WriteStream ¶

type WriteStream interface {
	String() string
	// WriteRTP writes RTP packet to the connection.
	WriteRTP(h *rtp.Header, payload []byte) (int, error)
}

type Writer ¶

type Writer interface {
	String() string
	WriteRTP(h *rtp.Header, payload []byte) (int, error)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL