streamtracker

Documentation

Index

• type StreamStatus
  • func (s StreamStatus) String() string
• type StreamStatusChange
  • func (s StreamStatusChange) String() string
• type StreamTracker
  • func NewStreamTracker(params StreamTrackerParams) *StreamTracker
  • func (s *StreamTracker) BitrateTemporalCumulative() []int64
  • func (s *StreamTracker) Observe(temporalLayer int32, pktSize int, payloadSize int, hasMarker bool, ts uint32)
  • func (s *StreamTracker) OnBitrateAvailable(f func())
  • func (s *StreamTracker) OnStatusChanged(f func(status StreamStatus))
  • func (s *StreamTracker) Reset()
  • func (s *StreamTracker) SetPaused(paused bool)
  • func (s *StreamTracker) Start()
  • func (s *StreamTracker) Status() StreamStatus
  • func (s *StreamTracker) Stop()
• type StreamTrackerFrame
  • func (s *StreamTrackerFrame) CheckStatus() StreamStatusChange
  • func (s *StreamTrackerFrame) GetCheckInterval() time.Duration
  • func (s *StreamTrackerFrame) Observe(hasMarker bool, ts uint32) StreamStatusChange
  • func (s *StreamTrackerFrame) Reset()
  • func (s *StreamTrackerFrame) Start()
  • func (s *StreamTrackerFrame) Stop()
• type StreamTrackerFrameParams
• type StreamTrackerImpl
  • func NewStreamTrackerFrame(params StreamTrackerFrameParams) StreamTrackerImpl
  • func NewStreamTrackerPacket(params StreamTrackerPacketParams) StreamTrackerImpl
• type StreamTrackerPacket
  • func (s *StreamTrackerPacket) CheckStatus() StreamStatusChange
  • func (s *StreamTrackerPacket) GetCheckInterval() time.Duration
  • func (s *StreamTrackerPacket) Observe(_hasMarker bool, _ts uint32) StreamStatusChange
  • func (s *StreamTrackerPacket) Reset()
  • func (s *StreamTrackerPacket) Start()
  • func (s *StreamTrackerPacket) Stop()
• type StreamTrackerPacketParams
• type StreamTrackerParams

Types

type StreamStatus

type StreamStatus int32

const (
	StreamStatusStopped StreamStatus = iota
	StreamStatusActive
)

func (StreamStatus) String

func (s StreamStatus) String() string

type StreamStatusChange

type StreamStatusChange int32

const (
	StreamStatusChangeNone StreamStatusChange = iota
	StreamStatusChangeStopped
	StreamStatusChangeActive
)

func (StreamStatusChange) String

func (s StreamStatusChange) String() string

type StreamTracker

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

func NewStreamTracker

func NewStreamTracker(params StreamTrackerParams) *StreamTracker

func (*StreamTracker) BitrateTemporalCumulative

func (s *StreamTracker) BitrateTemporalCumulative() []int64

BitrateTemporalCumulative returns the current stream bitrate temporal layer accumulated with lower temporal layers.

func (*StreamTracker) Observe

func (s *StreamTracker) Observe(
	temporalLayer int32,
	pktSize int,
	payloadSize int,
	hasMarker bool,
	ts uint32,
)

func (*StreamTracker) OnBitrateAvailable

func (s *StreamTracker) OnBitrateAvailable(f func())

func (*StreamTracker) OnStatusChanged

func (s *StreamTracker) OnStatusChanged(f func(status StreamStatus))

func (*StreamTracker) Reset

func (s *StreamTracker) Reset()

func (*StreamTracker) SetPaused

func (s *StreamTracker) SetPaused(paused bool)

func (*StreamTracker) Start

func (s *StreamTracker) Start()

func (*StreamTracker) Status

func (s *StreamTracker) Status() StreamStatus

func (*StreamTracker) Stop

func (s *StreamTracker) Stop()

type StreamTrackerFrame

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

func (*StreamTrackerFrame) CheckStatus

func (s *StreamTrackerFrame) CheckStatus() StreamStatusChange

func (*StreamTrackerFrame) GetCheckInterval

func (s *StreamTrackerFrame) GetCheckInterval() time.Duration

func (*StreamTrackerFrame) Observe

func (s *StreamTrackerFrame) Observe(hasMarker bool, ts uint32) StreamStatusChange

func (*StreamTrackerFrame) Reset

func (s *StreamTrackerFrame) Reset()

func (*StreamTrackerFrame) Start

func (s *StreamTrackerFrame) Start()

func (*StreamTrackerFrame) Stop

func (s *StreamTrackerFrame) Stop()

type StreamTrackerFrameParams

type StreamTrackerFrameParams struct {
	Config    config.StreamTrackerFrameConfig
	ClockRate uint32
	Logger    logger.Logger
}

type StreamTrackerImpl

type StreamTrackerImpl interface {
	Start()
	Stop()
	Reset()

	GetCheckInterval() time.Duration

	Observe(hasMarker bool, ts uint32) StreamStatusChange
	CheckStatus() StreamStatusChange
}

func NewStreamTrackerFrame

func NewStreamTrackerFrame(params StreamTrackerFrameParams) StreamTrackerImpl

func NewStreamTrackerPacket

func NewStreamTrackerPacket(params StreamTrackerPacketParams) StreamTrackerImpl

type StreamTrackerPacket

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

func (*StreamTrackerPacket) CheckStatus

func (s *StreamTrackerPacket) CheckStatus() StreamStatusChange

func (*StreamTrackerPacket) GetCheckInterval

func (s *StreamTrackerPacket) GetCheckInterval() time.Duration

func (*StreamTrackerPacket) Observe

func (s *StreamTrackerPacket) Observe(_hasMarker bool, _ts uint32) StreamStatusChange

func (*StreamTrackerPacket) Reset

func (s *StreamTrackerPacket) Reset()

func (*StreamTrackerPacket) Start

func (s *StreamTrackerPacket) Start()

func (*StreamTrackerPacket) Stop

func (s *StreamTrackerPacket) Stop()

type StreamTrackerPacketParams

type StreamTrackerPacketParams struct {
	Config config.StreamTrackerPacketConfig
	Logger logger.Logger
}

type StreamTrackerParams

type StreamTrackerParams struct {
	StreamTrackerImpl     StreamTrackerImpl
	BitrateReportInterval time.Duration

	Logger logger.Logger
}