rtprtcp

package
v0.0.0-...-e0b6167 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 12, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Pool

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

func NewPool

func NewPool(poolSize int) *Pool

NewPool poolSize: 500 * 1024

func (*Pool) Get

func (pool *Pool) Get(size int) []byte

type RTCPReceiver

type RTCPReceiver = rtcpreceiver.RTCPReceiver // rtcp receiver

func NewRTCPReceiver

func NewRTCPReceiver(
	clockRate int, receiverSSRC *uint32, period time.Duration,
	timeNow func() time.Time,
	writePacketRTCP func(rtcp.Packet),
) (*RTCPReceiver, error)

NewRTCPReceiver rtcp receiver

type RTCPSender

type RTCPSender = rtcpsender.RTCPSender // rtcp sender

func NewRTCPSender

func NewRTCPSender(
	clockRate int, period time.Duration,
	timeNow func() time.Time,
	writePacketRTCP func(rtcp.Packet),
) *RTCPSender

NewRTCPSender rtcp sender

type RingBuffer

type RingBuffer = ringbuffer.RingBuffer // 循环缓存队列

func NewRingBuffer

func NewRingBuffer(size uint64) (*RingBuffer, error)

NewRingBuffer 循环缓存队列

type RtpLossDetector

type RtpLossDetector = rtplossdetector.LossDetector // 丢包检测(TCP)

func NewRtpLossDetector

func NewRtpLossDetector() *RtpLossDetector

NewRtpLossDetector rtp丢包检测(TCP)

type RtpOverTCP

type RtpOverTCP struct {
}

func NewRtpOverTCP

func NewRtpOverTCP() *RtpOverTCP

func (*RtpOverTCP) CreateApplicationEOF

func (tis *RtpOverTCP) CreateApplicationEOF(remoteSSRC uint32) *rtcp_app.App

CreateApplicationEOF rtcp application EOF

func (*RtpOverTCP) ReadRtpOverTCP

func (tis *RtpOverTCP) ReadRtpOverTCP(reader *bufio.Reader) ([]byte, error)

func (*RtpOverTCP) WriteRtpOverTCP

func (tis *RtpOverTCP) WriteRtpOverTCP(writer io.Writer, data []byte) (int, error)

WriteRtpOverTCP 用tcp传输rtp

type RtpReorder

type RtpReorder = reorder // 重新排序和丢包检测(UDP)

func NewRtpReorder

func NewRtpReorder(bufferSize int) *RtpReorder

NewRtpReorder rtp重新排序和丢包检测(UDP)

type RtpTimeEncoder

type RtpTimeEncoder = rtptime.Encoder // rtp time encoder

func NewRtpTimeEncoder

func NewRtpTimeEncoder(clockRate int, initialTimestamp uint32) *RtpTimeEncoder

NewRtpTimeEncoder rtp time encoder

type RtpTimeSessionDecoder

type RtpTimeSessionDecoder = rtptime.GlobalDecoder // session rtp time decoder

func NewRtpTimeSessionDecoder

func NewRtpTimeSessionDecoder() *RtpTimeSessionDecoder

NewRtpTimeSessionDecoder session rtp time decoder

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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