rtprtcp

Documentation

Index

• type Pool
  • func NewPool(poolSize int) *Pool
  • func (pool *Pool) Get(size int) []byte
• type RTCPReceiver
  • func NewRTCPReceiver(clockRate int, receiverSSRC *uint32, period time.Duration, ...) (*RTCPReceiver, error)
• type RTCPSender
  • func NewRTCPSender(clockRate int, period time.Duration, timeNow func() time.Time, ...) *RTCPSender
• type RingBuffer
  • func NewRingBuffer(size uint64) (*RingBuffer, error)
• type RtpLossDetector
  • func NewRtpLossDetector() *RtpLossDetector
• type RtpOverTCP
  • func NewRtpOverTCP() *RtpOverTCP
  • func (tis *RtpOverTCP) CreateApplicationEOF(remoteSSRC uint32) *rtcp_app.App
  • func (tis *RtpOverTCP) ReadRtpOverTCP(reader *bufio.Reader) ([]byte, error)
  • func (tis *RtpOverTCP) WriteRtpOverTCP(writer io.Writer, data []byte) (int, error)
• type RtpReorder
  • func NewRtpReorder(bufferSize int) *RtpReorder
• type RtpTimeEncoder
  • func NewRtpTimeEncoder(clockRate int, initialTimestamp uint32) *RtpTimeEncoder
• type RtpTimeSessionDecoder
  • func NewRtpTimeSessionDecoder() *RtpTimeSessionDecoder

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