media

package module

Go to main page

Versions in this module

v0

v0.2.0

Jul 27, 2024

Changes in this version

+ var CodecAudioAlaw = Codec

+ var CodecAudioUlaw = Codec

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

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

+ type Codec struct

+ PayloadType uint8

+ SampleDur time.Duration

+ SampleRate uint32

+ func (c *Codec) SampleTimestamp() uint32

type MediaSession

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

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

+ 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 RTPPacketReader struct

+ OnRTP func(pkt *rtp.Packet)

+ PacketHeader rtp.Header

+ PayloadType uint8

+ RTPSession *RTPSession

+ Reader RTPReader

+ Sess *MediaSession

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

+ func NewRTPPacketReaderMedia(sess *MediaSession) *RTPPacketReader

+ func NewRTPPacketReaderSession(sess *RTPSession) *RTPPacketReader

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

+ type RTPPacketReaderConcurent struct

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

+ func (r *RTPPacketReaderConcurent) SetRTPReader(rtpReader *RTPPacketReader)

+ func (r *RTPPacketReaderConcurent) SetRTPSession(rtpSess *RTPSession)

+ type RTPPacketWriter struct

+ LastPacket rtp.Packet

+ OnRTP func(pkt *rtp.Packet)

+ PayloadType uint8

+ RTPSession *RTPSession

+ SSRC uint32

+ SampleRate uint32

+ Sess *MediaSession

+ Writer RTPWriter

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

+ func NewRTPPacketWriterMedia(sess *MediaSession) *RTPPacketWriter

+ func NewRTPPacketWriterSession(sess *RTPSession) *RTPPacketWriter

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

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

+ type RTPPacketWriterConcurent struct

+ func (w *RTPPacketWriterConcurent) SetRTPSession(rtpSess *RTPSession)

+ func (w *RTPPacketWriterConcurent) SetRTPWriter(rtpWriter *RTPPacketWriter)

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

type RTPReader

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

+ type RTPReaderRaw interface

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

type RTPSession

+ func (s *RTPSession) MonitorBackground()

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

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

type RTPWriter

+ WriteRTP func(p *rtp.Packet) error

+ type RTPWriterRaw interface

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

v0.1.0

Jun 5, 2024

Changes in this version

+ 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

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

+ func DTMFEncode(d DTMFEvent) []byte

+ func FractionLostFloat(f uint8) float64

+ func GetCurrentNTPTimestamp() uint64

+ func NTPTimestamp(now time.Time) uint64

+ func NTPToTime(ntp uint64) time.Time

+ func SendDummyRTP(rtpConn *net.UDPConn, raddr net.Addr)

+ type DTMFEvent struct

+ Duration uint16

+ EndOfEvent bool

+ Event uint8

+ Volume uint8

+ func RTPDTMFEncode(char rune) []DTMFEvent

+ func (ev *DTMFEvent) String() string

+ type MediaSession struct

+ Formats sdp.Formats

+ Laddr *net.UDPAddr

+ Mode sdp.Mode

+ Raddr *net.UDPAddr

+ func NewMediaSession(laddr *net.UDPAddr) (s *MediaSession, e error)

+ func (m *MediaSession) ReadRTCP(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) 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) 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()

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

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

+ func (s *MediaSession) SetLogger(log zerolog.Logger)

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

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

+ type MediaStreamer interface

+ MediaStream func(s *MediaSession) 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 RTPReadStats struct

+ FirstPktSequenceNumber uint16

+ IntervalFirstPktSeqNum uint16

+ IntervalTotalPackets uint16

+ LastSequenceNumber uint16

+ RTT time.Duration

+ SSRC uint32

+ TotalPackets uint64

+ type RTPReader struct

+ OnRTP func(pkt *rtp.Packet)

+ PacketHeader rtp.Header

+ PayloadType uint8

+ RTPSession *RTPSession

+ Sess *MediaSession

+ func NewRTPReader(sess *RTPSession) *RTPReader

+ func NewRTPReaderMedia(sess *MediaSession) *RTPReader

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

+ type RTPSession struct

+ OnReadRTCP func(pkt rtcp.Packet, rtpStats RTPReadStats)

+ OnWriteRTCP func(pkt rtcp.Packet, rtpStats RTPWriteStats)

+ Sess *MediaSession

+ func NewRTPSession(sess *MediaSession) *RTPSession

+ func (s *RTPSession) Close() error

+ func (s *RTPSession) Monitor()

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

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

+ type RTPWriteStats struct

+ OctetCount uint32

+ PacketsCount uint32

+ SSRC uint32

+ type RTPWriter struct

+ LastPacket rtp.Packet

+ OnRTP func(pkt *rtp.Packet)

+ PayloadType uint8

+ RTPSession *RTPSession

+ SSRC uint32

+ SampleRate uint32

+ Sess *MediaSession

+ func NewRTPWriter(sess *RTPSession) *RTPWriter

+ func NewRTPWriterMedia(sess *MediaSession) *RTPWriter

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

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

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