Versions in this module Expand all Collapse all v0 v0.0.2 Dec 19, 2023 Changes in this version + type Getter interface + Get func(ssrc uint32) *Stats + type InboundRTPStreamStats struct + BytesReceived uint64 + FIRCount uint32 + HeaderBytesReceived uint64 + LastPacketReceivedTimestamp time.Time + NACKCount uint32 + PLICount uint32 + func (s InboundRTPStreamStats) String() string + type Interceptor struct + RecorderFactory RecorderFactory + func (r *Interceptor) BindLocalStream(info *interceptor.StreamInfo, writer interceptor.RTPWriter) interceptor.RTPWriter + func (r *Interceptor) BindRTCPReader(reader interceptor.RTCPReader) interceptor.RTCPReader + func (r *Interceptor) BindRTCPWriter(writer interceptor.RTCPWriter) interceptor.RTCPWriter + func (r *Interceptor) BindRemoteStream(info *interceptor.StreamInfo, reader interceptor.RTPReader) interceptor.RTPReader + func (r *Interceptor) Close() error + func (r *Interceptor) Get(ssrc uint32) *Stats + type InterceptorFactory struct + func NewInterceptor(opts ...Option) (*InterceptorFactory, error) + func (r *InterceptorFactory) NewInterceptor(id string) (interceptor.Interceptor, error) + func (r *InterceptorFactory) OnNewPeerConnection(cb NewPeerConnectionCallback) + type NewPeerConnectionCallback func(string, Getter) + type Option func(*Interceptor) error + func SetNowFunc(now func() time.Time) Option + func SetRecorderFactory(f RecorderFactory) Option + type OutboundRTPStreamStats struct + FIRCount uint32 + HeaderBytesSent uint64 + NACKCount uint32 + PLICount uint32 + func (s OutboundRTPStreamStats) String() string + type ReceivedRTPStreamStats struct + Jitter float64 + PacketsLost int64 + PacketsReceived uint64 + func (s ReceivedRTPStreamStats) String() string + type Recorder interface + GetStats func() Stats + QueueIncomingRTCP func(ts time.Time, buf []byte, attr interceptor.Attributes) + QueueIncomingRTP func(ts time.Time, buf []byte, attr interceptor.Attributes) + QueueOutgoingRTCP func(ts time.Time, pkts []rtcp.Packet, attr interceptor.Attributes) + QueueOutgoingRTP func(ts time.Time, header *rtp.Header, payload []byte, attr interceptor.Attributes) + Start func() + Stop func() + type RecorderFactory func(ssrc uint32, clockRate float64) Recorder + type RemoteInboundRTPStreamStats struct + FractionLost float64 + RoundTripTime time.Duration + RoundTripTimeMeasurements uint64 + TotalRoundTripTime time.Duration + func (s RemoteInboundRTPStreamStats) String() string + type RemoteOutboundRTPStreamStats struct + RemoteTimeStamp time.Time + ReportsSent uint64 + RoundTripTime time.Duration + RoundTripTimeMeasurements uint64 + TotalRoundTripTime time.Duration + func (s RemoteOutboundRTPStreamStats) String() string + type SentRTPStreamStats struct + BytesSent uint64 + PacketsSent uint64 + func (s SentRTPStreamStats) String() string + type Stats struct