jitterbuffer

Documentation

Index

• type Buffer
  • func NewBuffer(ssrc uint32, payloadType uint8, isVideo bool) *Buffer
  • func (b *Buffer) GetCurrentRates() (lostRate, byteRate uint64)
  • func (b *Buffer) GetLostRateBandwidth(cycle uint64) (float64, uint64)
  • func (b *Buffer) GetNackPair(buffer [maxSN]*rtp.Packet, begin, end uint16) (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) IsVideo() bool
  • func (b *Buffer) Push(p *rtp.Packet)
  • func (b *Buffer) Stop()
• type Config
• type JitterBuffer
  • func New(id string, config *Config) *JitterBuffer
  • func (j *JitterBuffer) AddBuffer(ssrc uint32, payloadType uint8, isVideo bool) *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) PushRTP(pkt *rtp.Packet, isVideo bool) error
  • func (j *JitterBuffer) RemoveBuffer(ssrc uint32)
  • func (j *JitterBuffer) Start(ctx context.Context) error
  • func (j *JitterBuffer) Stop()

Types

type Buffer

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

func NewBuffer

func NewBuffer(ssrc uint32, payloadType uint8, isVideo bool) *Buffer

func (*Buffer) GetCurrentRates

func (b *Buffer) GetCurrentRates() (lostRate, byteRate uint64)

func (*Buffer) GetLostRateBandwidth

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

func (*Buffer) GetNackPair

func (b *Buffer) GetNackPair(buffer [maxSN]*rtp.Packet, begin, end uint16) (rtcp.NackPair, int)

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

func (*Buffer) GetSSRC

func (b *Buffer) GetSSRC() uint32

func (*Buffer) IsVideo

func (b *Buffer) IsVideo() bool

func (*Buffer) Push

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

func (*Buffer) Stop

func (b *Buffer) Stop()

type Config

type Config struct {
	Logger logrus.FieldLogger

	PLIInterval  int
	RembInterval int
	Bandwidth    uint64
	MaxBandwidth uint64
	MinBandwidth uint64
}

type JitterBuffer

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

func New

func New(id string, config *Config) *JitterBuffer

func (*JitterBuffer) AddBuffer

func (j *JitterBuffer) AddBuffer(ssrc uint32, payloadType uint8, isVideo bool) *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) PushRTP

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

func (*JitterBuffer) RemoveBuffer

func (j *JitterBuffer) RemoveBuffer(ssrc uint32)

func (*JitterBuffer) Start

func (j *JitterBuffer) Start(ctx context.Context) error

func (*JitterBuffer) Stop

func (j *JitterBuffer) Stop()