media

Dec 4, 2025

Changes in this version

+ var CodecVideoH264 = Codec

+ var CodecVideoVP8 = Codec

+ var CodecVideoVP9 = Codec

+ func CombineSDP(sessions []*MediaSession) []byte

type MediaSession

+ MediaType string

+ func NewVideoMediaSession(ip net.IP, port int) (s *MediaSession, e error)

Oct 14, 2025

Changes in this version

+ const SRTPAes128CmHmacSha1_80

+ const SRTPAes256CmHmacSha1_80

+ var CodecAudioAlaw = Codec

+ var CodecAudioOpus = Codec

+ var CodecAudioUlaw = Codec

+ var CodecTelephoneEvent8000 = Codec

+ var DefaultOnReadRTCP func(pkt rtcp.Packet, rtpStats RTPReadStats) = nil

+ var DefaultOnWriteRTCP func(pkt rtcp.Packet, rtpStats RTPWriteStats) = nil

+ var ErrRTPSequenceBad = errors.New("bad sequence")

+ var ErrRTPSequenceOutOfOrder = errors.New("out of order")

+ var ErrRTPSequnceDuplicate = errors.New("sequence duplicate")

+ var RTCPDebug = false

+ var RTPBufSize = 1500

+ var RTPDebug = false

+ var RTPPortEnd = 0

+ var RTPPortStart = 0

+ var RTPProfileSAVPDisable = false

+ func CodecsFromSDPRead(formats []string, attrs []string, codecsAudio []Codec) (int, error)

+ func Copy(reader io.Reader, writer io.Writer) (int64, error)

+ func CopyWithBuf(reader io.Reader, writer io.Writer, payloadBuf []byte) (int64, error)

+ func DTMFDecode(payload []byte, d *DTMFEvent) error

+ func DTMFEncode(d DTMFEvent) []byte

+ func DTMFToRune(dtmf uint8) rune

+ func DefaultLogger() *slog.Logger

+ func ErrorIsTimeout(err error) bool

+ func FractionLostFloat(f uint8) float64

+ func GetCurrentNTPTimestamp() uint64

+ func NTPTimestamp(t time.Time) uint64

+ func NTPToTime(ntpTimestamp uint64) time.Time

+ func RTCPUnmarshal(data []byte, packets []rtcp.Packet) (n int, err error)

+ func RTPUnmarshal(buf []byte, p *rtp.Packet) error

+ func ReadAll(reader io.Reader, sampleSize int) ([]byte, error)

+ func SetDefaultLogger(l *slog.Logger)

+ func StringRTCP(p rtcp.Packet) string

+ func WriteAll(w io.Writer, data []byte, sampleSize int) (int64, error)

+ type Codec struct

+ Name string

+ NumChannels int

+ PayloadType uint8

+ SampleDur time.Duration

+ SampleRate uint32

+ func CodecAudioFromList(codecs []Codec) (Codec, bool)

+ func CodecAudioFromPayloadType(payloadType uint8) (Codec, error)

+ func CodecAudioFromSession(s *MediaSession) Codec

+ func CodecFromPayloadType(payloadType uint8) Codec

+ func CodecFromSession(s *MediaSession) Codec

+ func (c *Codec) SampleTimestamp() uint32

+ func (c *Codec) Samples16() int

+ func (c *Codec) SamplesPCM(bitSize int) int

+ func (c *Codec) String() string

+ type DTMFEvent struct

+ Duration uint16

+ EndOfEvent bool

+ Event uint8

+ Volume uint8

+ func RTPDTMFEncode8000(char rune) []DTMFEvent

+ func (ev *DTMFEvent) String() string

+ type MediaSession struct

+ Codecs []Codec

+ ExternalIP net.IP

+ Laddr net.UDPAddr

+ Mode string

+ Raddr net.UDPAddr

+ SRTPAlg uint16

+ SecureRTP int

+ func NewMediaSession(ip net.IP, port int) (s *MediaSession, e error)

+ func (m *MediaSession) ReadRTCP(buf []byte, pkts []rtcp.Packet) (n int, err error)

+ func (m *MediaSession) ReadRTCPRaw(buf []byte) (int, error)

+ func (m *MediaSession) ReadRTCPRawDeadline(buf []byte, t time.Time) (int, error)

+ func (m *MediaSession) ReadRTP(buf []byte, pkt *rtp.Packet) (int, error)

+ func (m *MediaSession) ReadRTPRaw(buf []byte) (int, error)

+ func (m *MediaSession) ReadRTPRawDeadline(buf []byte, t time.Time) (int, error)

+ func (m *MediaSession) WriteRTCP(p rtcp.Packet) error

+ func (m *MediaSession) WriteRTCPDeadline(p rtcp.Packet, deadline time.Time) error

+ func (m *MediaSession) WriteRTCPRaw(data []byte) (int, error)

+ func (m *MediaSession) WriteRTCPs(pkts []rtcp.Packet) error

+ func (m *MediaSession) WriteRTP(p *rtp.Packet) error

+ func (m *MediaSession) WriteRTPRaw(data []byte) (n int, err error)

+ func (s *MediaSession) Close() error

+ func (s *MediaSession) CommonCodecs() []Codec

+ func (s *MediaSession) Fork() *MediaSession

+ func (s *MediaSession) Init() error

+ func (s *MediaSession) InitWithListeners(lRTP net.PacketConn, lRTCP net.PacketConn, raddr *net.UDPAddr)

+ func (s *MediaSession) InitWithSDP(localSDP []byte) error

+ func (s *MediaSession) LocalSDP() []byte

+ func (s *MediaSession) RemoteSDP(sdpReceived []byte) error

+ func (s *MediaSession) SetRemoteAddr(raddr *net.UDPAddr)

+ func (s *MediaSession) StartRTP(rw int8) error

+ func (s *MediaSession) StopRTP(rw int8, dur time.Duration) error

+ type MediaStreamer interface

+ MediaStream func(s *MediaSession) error

+ type OnRTPReadStats func(stats RTPReadStats)

+ type OnRTPWriteStats func(stats RTPWriteStats)

+ type RTCPReader interface

+ ReadRTCP func(buf []byte, pkts []rtcp.Packet) (n int, err error)

+ type RTCPWriter interface

+ WriteRTCP func(p rtcp.Packet) error

+ type RTCPWriterRaw interface

+ WriteRTCPRaw func(buf []byte) (int, error)

+ type RTPCReaderRaw interface

+ ReadRTCPRaw func(buf []byte) (int, error)

+ type RTPDtmfReader struct

+ func NewRTPDTMFReader(codec Codec, packetReader *RTPPacketReader, reader io.Reader) *RTPDtmfReader

+ func (w *RTPDtmfReader) Read(b []byte) (int, error)

+ func (w *RTPDtmfReader) ReadDTMF() (rune, bool)

+ type RTPDtmfWriter struct

+ func NewRTPDTMFWriter(codec Codec, rtpPacketizer *RTPPacketWriter, writer io.Writer) *RTPDtmfWriter

+ func (w *RTPDtmfWriter) Write(b []byte) (int, error)

+ func (w *RTPDtmfWriter) WriteDTMF(dtmf rune) error

+ type RTPExtendedSequenceNumber struct

+ func NewRTPSequencer() RTPExtendedSequenceNumber

+ func (s *RTPExtendedSequenceNumber) NextSeqNumber() uint16

+ func (sn *RTPExtendedSequenceNumber) InitSeq(seq uint16)

+ func (sn *RTPExtendedSequenceNumber) ReadExtendedSeq() uint64

+ func (sn *RTPExtendedSequenceNumber) UpdateSeq(seq uint16) error

+ type RTPPacketReader struct

+ PacketHeader rtp.Header

+ func NewRTPPacketReader(reader RTPReader, codec Codec) *RTPPacketReader

+ func NewRTPPacketReaderSession(sess *RTPSession) *RTPPacketReader

+ func (r *RTPPacketReader) Read(b []byte) (int, error)

+ func (r *RTPPacketReader) Reader() RTPReader

+ func (r *RTPPacketReader) UpdateRTPSession(rtpSess *RTPSession)

+ func (r *RTPPacketReader) UpdateReader(reader RTPReader)

+ type RTPPacketWriter struct

+ PacketHeader rtp.Header

+ SSRC uint32

+ func NewRTPPacketWriter(writer RTPWriter, codec Codec) *RTPPacketWriter

+ func NewRTPPacketWriterSession(sess *RTPSession) *RTPPacketWriter

+ func (p *RTPPacketWriter) DelayTimestamp(ofsset uint32)

+ func (p *RTPPacketWriter) InitTimestamp() uint32

+ func (p *RTPPacketWriter) ResetTimestamp()

+ func (p *RTPPacketWriter) Write(b []byte) (int, error)

+ func (p *RTPPacketWriter) WriteSamples(payload []byte, sampleRateTimestamp uint32, marker bool, payloadType uint8) (int, error)

+ func (w *RTPPacketWriter) UpdateRTPSession(rtpSess *RTPSession)

+ func (w *RTPPacketWriter) Writer() RTPWriter

+ type RTPReadStats struct

+ FirstPktSequenceNumber uint16

+ IntervalFirstPktSeqNum uint16

+ IntervalPacketsCount uint16

+ LastSequenceNumber uint16

+ OctetCount uint64

+ PacketsCount uint64

+ RTT time.Duration

+ SSRC uint32

+ SampleRate uint32

+ type RTPReader interface

+ ReadRTP func(buf []byte, p *rtp.Packet) (int, error)

+ type RTPReaderRaw interface

+ ReadRTPRaw func(buf []byte) (int, error)

+ type RTPSession struct

+ Sess *MediaSession

+ func NewRTPSession(sess *MediaSession) *RTPSession

+ func (s *RTPSession) Close() error

+ func (s *RTPSession) Monitor() error

+ func (s *RTPSession) MonitorBackground() error

+ func (s *RTPSession) OnReadRTCP(f func(pkt rtcp.Packet, rtpStats RTPReadStats))

+ func (s *RTPSession) OnWriteRTCP(f func(pkt rtcp.Packet, rtpStats RTPWriteStats))

+ func (s *RTPSession) ReadRTP(b []byte, readPkt *rtp.Packet) (n int, err error)

+ func (s *RTPSession) ReadRTPRaw(buf []byte) (int, error)

+ func (s *RTPSession) ReadStats() RTPReadStats

+ func (s *RTPSession) WriteRTP(pkt *rtp.Packet) error

+ func (s *RTPSession) WriteRTPRaw(buf []byte) (int, error)

+ func (s *RTPSession) WriteStats() RTPWriteStats

+ type RTPStatsReader struct

+ OnRTPReadStats OnRTPReadStats

+ RTPSession *RTPSession

+ Reader io.Reader

+ func (i *RTPStatsReader) Read(b []byte) (int, error)

+ type RTPStatsWriter struct

+ OnRTPWriteStats OnRTPWriteStats

+ RTPSession *RTPSession

+ Writer io.Writer

+ func (i *RTPStatsWriter) Write(b []byte) (int, error)

+ type RTPWriteStats struct

+ OctetCount uint64

+ PacketsCount uint64

+ SSRC uint32

+ type RTPWriter interface

+ WriteRTP func(p *rtp.Packet) error

+ type RTPWriterRaw interface

+ WriteRTPRaw func(buf []byte) (int, error)