plugins

Documentation

Index

• func IsVP8KeyFrame(pkt *rtp.Packet) bool
• type Buffer
  • func NewBuffer(maxLate uint16) *Buffer
  • func (b *Buffer) CalcLostRateByteRate(cycle uint64) (float64, uint64)
  • func (b *Buffer) GatherJitterInfo()
  • func (b *Buffer) GatherJitterInfoLoop()
  • func (b *Buffer) GetNackPairsAndLostPkts(sns []int, begin uint16, keyFrame bool) ([]rtcp.NackPair, int)
  • func (b *Buffer) GetPacket(sn uint16) *rtp.Packet
  • func (b *Buffer) GetPayloadType() uint8
  • func (b *Buffer) GetRTCPChan() chan rtcp.Packet
  • func (b *Buffer) GetSSRC() uint32
  • func (b *Buffer) GetStat() string
  • func (b *Buffer) Push(pkt *rtp.Packet)
  • func (b *Buffer) SetSSRCPT(ssrc uint32, pt uint8)
  • func (b *Buffer) Stop()
• type JitterBuffer
  • func NewJitterBuffer(id string) *JitterBuffer
  • func (j *JitterBuffer) AddBuffer(ssrc uint32) *Buffer
  • func (j *JitterBuffer) GetBuffer(ssrc uint32) *Buffer
  • func (j *JitterBuffer) GetBuffers() map[uint32]*Buffer
  • func (j *JitterBuffer) GetPacket(ssrc uint32, sn uint16) *rtp.Packet
  • func (j *JitterBuffer) GetRTCPChan() chan rtcp.Packet
  • func (j *JitterBuffer) ID() string
  • func (j *JitterBuffer) Init(args ...interface{})
  • func (j *JitterBuffer) PushRTCP(pkt rtcp.Packet) error
  • func (j *JitterBuffer) PushRTP(pkt *rtp.Packet) error
  • func (j *JitterBuffer) Stat() string
  • func (j *JitterBuffer) Stop()
• type RtpExtensionInfo

Functions

func IsVP8KeyFrame

func IsVP8KeyFrame(pkt *rtp.Packet) bool

Types

type Buffer

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

Buffer contains all packets

func NewBuffer

func NewBuffer(maxLate uint16) *Buffer

NewBuffer constructs a new Buffer

func (*Buffer) CalcLostRateByteRate

func (b *Buffer) CalcLostRateByteRate(cycle uint64) (float64, uint64)

func (*Buffer) GatherJitterInfo

func (b *Buffer) GatherJitterInfo()

func (*Buffer) GatherJitterInfoLoop

func (b *Buffer) GatherJitterInfoLoop()

func (*Buffer) GetNackPairsAndLostPkts

func (b *Buffer) GetNackPairsAndLostPkts(sns []int, begin uint16, keyFrame bool) ([]rtcp.NackPair, int)

GetNackPairsAndLostPkts get nack lost pkts

func (*Buffer) GetPacket

func (b *Buffer) GetPacket(sn uint16) *rtp.Packet

func (*Buffer) GetPayloadType

func (b *Buffer) GetPayloadType() uint8

func (*Buffer) GetRTCPChan

func (b *Buffer) GetRTCPChan() chan rtcp.Packet

GetRTCPChan return rtcp channel

func (*Buffer) GetSSRC

func (b *Buffer) GetSSRC() uint32

func (*Buffer) GetStat

func (b *Buffer) GetStat() string

func (*Buffer) Push

func (b *Buffer) Push(pkt *rtp.Packet)

Push adds a RTP Packet, out of order, new packet may be arrived later

func (*Buffer) SetSSRCPT

func (b *Buffer) SetSSRCPT(ssrc uint32, pt uint8)

func (*Buffer) Stop

func (b *Buffer) Stop()

type JitterBuffer

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

func NewJitterBuffer

func NewJitterBuffer(id string) *JitterBuffer

func (*JitterBuffer) AddBuffer

func (j *JitterBuffer) AddBuffer(ssrc uint32) *Buffer

func (*JitterBuffer) GetBuffer

func (j *JitterBuffer) GetBuffer(ssrc uint32) *Buffer

func (*JitterBuffer) GetBuffers

func (j *JitterBuffer) GetBuffers() map[uint32]*Buffer

func (*JitterBuffer) GetPacket

func (j *JitterBuffer) GetPacket(ssrc uint32, sn uint16) *rtp.Packet

func (*JitterBuffer) GetRTCPChan

func (j *JitterBuffer) GetRTCPChan() chan rtcp.Packet

func (*JitterBuffer) ID

func (j *JitterBuffer) ID() string

func (*JitterBuffer) Init

func (j *JitterBuffer) Init(args ...interface{})

Init args: (ssrc uint32, pt uint8, rembCycle int, pliCycle int)

func (*JitterBuffer) PushRTCP

func (j *JitterBuffer) PushRTCP(pkt rtcp.Packet) error

PushRTCP push rtcp packet which from sub

func (*JitterBuffer) PushRTP

func (j *JitterBuffer) PushRTP(pkt *rtp.Packet) error

PushRTP push rtp packet which from pub

func (*JitterBuffer) Stat

func (j *JitterBuffer) Stat() string

func (*JitterBuffer) Stop

func (j *JitterBuffer) Stop()

type RtpExtensionInfo

type RtpExtensionInfo struct {
	RtpExtensionSN uint16
	Timestamp      int64
}