sfu

package module

Go to main page

Versions in this module

v0

v0.0.10

Sep 16, 2024

v0.0.9

Sep 16, 2024

v0.0.8

Sep 16, 2024

v0.0.7

Sep 16, 2024

v0.0.6

Sep 16, 2024

Changes in this version

type ClientOptions

+ Channel recorder.Channel

v0.0.5

Sep 16, 2024

v0.0.4

Sep 16, 2024

v0.0.3

Sep 16, 2024

v0.0.2

Sep 16, 2024

Changes in this version

type ClientOptions

+ RecorderConfig *recorder.RecorderConfig

type RoomOptions

+ RecorderConfig *recorder.RecorderConfig

v0.0.1

Sep 16, 2024

Changes in this version

+ const ClientStateActive

+ const ClientStateEnded

+ const ClientStateNew

+ const ClientStateRestart

+ const ClientTypeDownBridge

+ const ClientTypePeer

+ const ClientTypeUpBridge

+ const EventRoomClientLeft

+ const EventRoomClosed

+ const KEEPLAYER

+ const QualityAudio

+ const QualityAudioRed

+ const QualityHigh

+ const QualityLow

+ const QualityMid

+ const QualityNone

+ const SCALEDOWNLAYER

+ const SCALEUPLAYER

+ const SdesRepairRTPStreamIDURI

+ const StateRoomClosed

+ const StateRoomOpen

+ const TrackTypeMedia

+ const TrackTypeScreen

+ var ErrAlreadyClaimed = errors.New("bwcontroller: already claimed")

+ var ErrCLientStatsNotFound = errors.New("client stats not found")

+ var ErrCantDecide = errors.New("can't decide if upscale or downscale the layer")

+ var ErrClientExists = errors.New("client already exists")

+ var ErrClientNotFound = errors.New("client not found")

+ var ErrClientStoped = errors.New("client: error client already stopped")

+ var ErrDataChannelExists = errors.New("error: data channel already exists")

+ var ErrDecodingData = errors.New("error decoding data")

+ var ErrDuplicate = errors.New("packet sequence already exists in the cache")

+ var ErrEncodingData = errors.New("error encoding data")

+ var ErrIncompleteRedBlock = errors.New("util: incomplete RED block")

+ var ErrIncompleteRedHeader = errors.New("util: incomplete RED header")

+ var ErrMetaNotFound = errors.New("meta: metadata not found")

+ var ErrNegotiationIsNotRequested = errors.New("client: error negotiation is called before requested")

+ var ErrNotFound = errors.New("not found")

+ var ErrPacketDuplicate = errors.New("packetbuffers: packet is duplicate")

+ var ErrPacketTooLate = errors.New("packetbuffers: packet is too late")

+ var ErrRemoteRoomConnectTimeout = errors.New("manager: timeout connecting to remote room")

+ var ErrRenegotiationCallback = errors.New("client: error renegotiation callback is not set")

+ var ErrRoomAlreadyExists = errors.New("manager: room already exists")

+ var ErrRoomIsClosed = errors.New("room is closed")

+ var ErrRoomIsNotEmpty = errors.New("room is not empty")

+ var ErrRoomNotFound = errors.New("manager: room not found")

+ var ErrTrackExists = errors.New("client: error track already exists")

+ var ErrTrackIsNotExists = errors.New("client: error track is not exists")

+ var ErrorInsufficientBandwidth = errors.New("bwcontroller: bandwidth is insufficient")

+ var H264KeyFrame2x2 = [][]byte

+ var H264KeyFrame2x2IDR = []byte

+ var H264KeyFrame2x2PPS = []byte

+ var H264KeyFrame2x2SPS = []byte

+ var OpusSilenceFrame = []byte

+ var RoomTypeLocal = "local"

+ var RoomTypeRemote = "remote"

+ func AddSimulcastVideoTracks(ctx, iceConnectedCtx context.Context, pc *webrtc.PeerConnection, ...) error

+ func CountTracks(sdp string) int

+ func CreatePeerPair(ctx context.Context, log logging.LeveledLogger, room *Room, ...) (*PC, *Client, stats.Getter, chan bool)

+ func FlattenErrors(errs []error) error

+ func GenerateID(length int) string

+ func GenerateSecureToken() string

+ func GetLocalIp() (net.IP, error)

+ func GetMediaEngine() *webrtc.MediaEngine

+ func GetReceiverStats(pc *webrtc.PeerConnection, statsGetter stats.Getter) map[webrtc.SSRC]stats.Stats

+ func GetSenderStats(pc *webrtc.PeerConnection, statsGetter stats.Getter) map[webrtc.SSRC]stats.Stats

+ func GetStaticAudioTrack(ctx, iceConnectedCtx context.Context, trackID, streamID string, loop bool) (*webrtc.TrackLocalStaticSample, chan bool)

+ func GetStaticTracks(ctx, iceConnectedCtx context.Context, streamID string, loop bool) ([]*webrtc.TrackLocalStaticSample, chan bool)

+ func GetStaticVideoTrack(ctx, iceConnectedCtx context.Context, trackID, streamID string, loop bool, ...) (*webrtc.TrackLocalStaticSample, chan bool)

+ func GetUfragAndPass(sdp string) (ufrag, pass string)

+ func IsKeyframe(codec string, packet *rtp.Packet) bool

+ func IsRTPPacketLate(packetSeqNum uint16, lastSeqNum uint16) bool

+ func Keyframe(codec string, packet *rtp.Packet) (bool, bool)

+ func KeyframeDimensions(codec string, packet *rtp.Packet) (uint32, uint32)

+ func LoadVp9Track(ctx context.Context, log logging.LeveledLogger, pc *webrtc.PeerConnection, ...) *webrtc.RTPSender

+ func RegisterCodecs(m *webrtc.MediaEngine, codecs []string) error

+ func RegisterDefaultCodecs(m *webrtc.MediaEngine) error

+ func RegisterSimulcastHeaderExtensions(m *webrtc.MediaEngine, codecType webrtc.RTPCodecType)

+ func SendBlackImageFrames(startSequence uint16, localRTP *webrtc.TrackLocalStaticRTP, ...) (uint16, error)

+ func SetPeerConnectionTracks(ctx context.Context, peerConnection *webrtc.PeerConnection, ...)

+ func StartStunServer(ctx context.Context, publicIP string) *turn.Server

+ func StartTurnServer(ctx context.Context, publicIP string) *turn.Server

+ func ThousandSeparator(n int) string

+ type BitrateConfigs struct

+ Audio uint32

+ AudioRed uint32

+ InitialBandwidth uint32

+ Video uint32

+ VideoHigh uint32

+ VideoHighPixels uint32

+ VideoLow uint32

+ VideoLowPixels uint32

+ VideoMid uint32

+ VideoMidPixels uint32

+ func DefaultBitrates() BitrateConfigs

+ type Cache struct

+ BaseSeq uint16

+ PSID uint8

+ PTID uint8

+ SID uint8

+ SeqNum uint16

+ TID uint8

+ Timestamp uint32

+ type Client struct

+ func CreateDataPair(ctx context.Context, log logging.LeveledLogger, room *Room, ...) (*webrtc.PeerConnection, *Client, stats.Getter, chan webrtc.PeerConnectionState)

+ func NewClient(s *SFU, id string, name string, peerConnectionConfig webrtc.Configuration, ...) *Client

+ func (c *Client) AddICECandidate(candidate webrtc.ICECandidateInit) error

+ func (c *Client) ClientTracks() map[string]iClientTrack

+ func (c *Client) CompleteNegotiation(answer webrtc.SessionDescription)

+ func (c *Client) Context() context.Context

+ func (c *Client) ContinueClientRecording()

+ func (c *Client) EnableDebug()

+ func (c *Client) End()

+ func (c *Client) GetEstimatedBandwidth() uint32

+ func (c *Client) ID() string

+ func (c *Client) InitNegotiation() *webrtc.SessionDescription

+ func (c *Client) IsAllowNegotiation() bool

+ func (c *Client) IsBridge() bool

+ func (c *Client) IsDebugEnabled() bool

+ func (c *Client) IsMuted() bool

+ func (c *Client) IsVADEnabled() bool

+ func (c *Client) Mute()

+ func (c *Client) Name() string

+ func (c *Client) Negotiate(offer webrtc.SessionDescription) (*webrtc.SessionDescription, error)

+ func (c *Client) OnAllowedRemoteRenegotiation(callback func())

+ func (c *Client) OnBeforeRenegotiation(callback func(context.Context) bool)

+ func (c *Client) OnConnectionStateChanged(callback func(webrtc.PeerConnectionState))

+ func (c *Client) OnIceCandidate(callback func(context.Context, *webrtc.ICECandidate))

+ func (c *Client) OnJoined(callback func())

+ func (c *Client) OnLeft(callback func())

+ func (c *Client) OnNetworkConditionChanged(callback func(networkmonitor.NetworkConditionType))

+ func (c *Client) OnRenegotiation(...)

+ func (c *Client) OnTrackRemoved(callback func(sourceType string, track *webrtc.TrackLocalStaticRTP))

+ func (c *Client) OnTracksAdded(callback func(addedTracks []ITrack))

+ func (c *Client) OnTracksAvailable(callback func([]ITrack))

+ func (c *Client) OnVoiceDetected(callback func(activity voiceactivedetector.VoiceActivity))

+ func (c *Client) PauseClientRecording()

+ func (c *Client) PeerConnection() *PeerConnection

+ func (c *Client) PublishedTracks() []ITrack

+ func (c *Client) SFU() *SFU

+ func (c *Client) SetName(name string)

+ func (c *Client) SetQuality(quality QualityLevel)

+ func (c *Client) SetReceivingBandwidthLimit(bandwidth uint32)

+ func (c *Client) SetTracksSourceType(trackTypes map[string]TrackType)

+ func (c *Client) StartClientRecording(bucketName, filename string) error

+ func (c *Client) Stats() ClientTrackStats

+ func (c *Client) StopClientRecording(stopConfig recorder.StopConfig)

+ func (c *Client) SubscribeTracks(req []SubscribeTrackRequest) error

+ func (c *Client) Tracks() []ITrack

+ func (c *Client) Type() string

+ func (c *Client) Unmute()

+ func (c *Client) UpdatePublisherBandwidth(bitrate uint32)

+ type ClientOptions struct

+ EnableOpusDTX bool

+ EnableOpusInbandFEC bool

+ EnablePlayoutDelay bool

+ EnableVoiceDetection bool

+ IdleTimeout time.Duration

+ JitterBufferMaxWait time.Duration

+ JitterBufferMinWait time.Duration

+ Log logging.LeveledLogger

+ MaxPlayoutDelay uint16

+ MinPlayoutDelay uint16

+ QuicConfig []*recorder.QuicConfig

+ QuicConnection quic.Connection

+ ReorderPackets bool

+ Type string

+ func DefaultClientOptions() ClientOptions

+ type ClientState int

+ type ClientStats struct

+ Client *Client

+ func (c *ClientStats) GetReceiver(id, rid string) (stats.Stats, error)

+ func (c *ClientStats) GetReceiverBitrate(id, rid string) (uint32, error)

+ func (c *ClientStats) GetSender(id string) (stats.Stats, error)

+ func (c *ClientStats) GetSenderBitrate(id string) (uint32, error)

+ func (c *ClientStats) Receivers() map[string]stats.Stats

+ func (c *ClientStats) Senders() map[string]stats.Stats

+ func (c *ClientStats) SetReceiver(id, rid string, stats stats.Stats)

+ func (c *ClientStats) SetSender(id string, stats stats.Stats)

+ func (c *ClientStats) UpdateVoiceActivity(ts uint32)

+ func (c *ClientStats) VoiceActivity() time.Duration

+ type ClientTrackStats struct

+ ConsumerBandwidth uint32

+ CurrentConsumerBitrate uint32

+ CurrentPublishLimitation string

+ ID string

+ Name string

+ PublisherBandwidth uint32

+ Receives []TrackReceivedStats

+ Sents []TrackSentStats

+ VoiceActivityDuration uint32

+ type ClientType string

+ type Data struct

+ Data interface{}

+ FromID string

+ SentAt time.Time

+ ToID string

+ type DataChannelList struct

+ func NewDataChannelList(ctx context.Context) *DataChannelList

+ func (d *DataChannelList) Add(dc *webrtc.DataChannel)

+ func (d *DataChannelList) Clear()

+ func (d *DataChannelList) Get(label string) *webrtc.DataChannel

+ func (d *DataChannelList) Remove(dc *webrtc.DataChannel)

+ type DataChannelOptions struct

+ ClientIDs []string

+ Ordered bool

+ func DefaultDataChannelOptions() DataChannelOptions

+ type Event struct

+ Data map[string]interface{}

+ Time time.Time

+ Type string

+ type IExtension interface

+ OnBeforeClientAdded func(room *Room, clientID string) error

+ OnClientAdded func(room *Room, client *Client)

+ OnClientRemoved func(room *Room, client *Client)

+ type IManagerExtension interface

+ OnBeforeNewRoom func(id, name, roomType string) error

+ OnGetRoom func(manager *Manager, roomID string) (*Room, error)

+ OnNewRoom func(manager *Manager, room *Room)

+ OnRoomClosed func(manager *Manager, room *Room)

+ type IQualityPreset interface

+ GetSID func() uint8

+ GetTID func() uint8

+ type IRemoteTrack interface

+ Codec func() webrtc.RTPCodecParameters

+ ID func() string

+ Kind func() webrtc.RTPCodecType

+ Msid func() string

+ PayloadType func() webrtc.PayloadType

+ RID func() string

+ Read func(b []byte) (n int, attributes interceptor.Attributes, err error)

+ ReadRTP func() (*rtp.Packet, interceptor.Attributes, error)

+ SSRC func() webrtc.SSRC

+ SetReadDeadline func(deadline time.Time) error

+ StreamID func() string

+ func NewTrackRelay(id, streamid, rid string, kind webrtc.RTPCodecType, ssrc webrtc.SSRC, ...) IRemoteTrack

+ type ITrack interface

+ ClientID func() string

+ Context func() context.Context

+ ContinueRecording func()

+ ID func() string

+ IsProcessed func() bool

+ IsRelay func() bool

+ IsScaleable func() bool

+ IsScreen func() bool

+ IsSimulcast func() bool

+ Kind func() webrtc.RTPCodecType

+ MimeType func() string

+ Mute func()

+ OnEnded func(func())

+ OnRead func(func(*rtp.Packet, QualityLevel))

+ PauseRecording func()

+ PayloadType func() webrtc.PayloadType

+ Relay func(func(webrtc.SSRC, *rtp.Packet))

+ SetAsProcessed func()

+ SetSourceType func(TrackType)

+ SourceType func() TrackType

+ StartRecording func(quic.SendStream) error

+ StopRecording func()

+ StreamID func() string

+ TotalTracks func() int

+ Unmute func()

+ type Manager struct

+ func NewManager(ctx context.Context, name string, options Options) *Manager

+ func (m *Manager) AddExtension(extension IManagerExtension)

+ func (m *Manager) Close()

+ func (m *Manager) CloseRoom(id string) error

+ func (m *Manager) Context() context.Context

+ func (m *Manager) CreateRoomID() string

+ func (m *Manager) GetRoom(id string) (*Room, error)

+ func (m *Manager) Log() logging.LeveledLogger

+ func (m *Manager) Name() string

+ func (m *Manager) NewRoom(id, name, roomType string, opts RoomOptions) (*Room, error)

+ func (m *Manager) RoomsCount() int

+ type Metadata struct

+ func NewMetadata() *Metadata

+ func (m *Metadata) Delete(key string) error

+ func (m *Metadata) ForEach(f func(key string, value interface{}))

+ func (m *Metadata) Get(key string) (interface{}, error)

+ func (m *Metadata) OnChanged(f func(key string, value interface{})) *OnMetaChangedCallback

+ func (m *Metadata) Set(key string, value interface{})

+ type OnMetaChangedCallback struct

+ func (s *OnMetaChangedCallback) Remove()

+ type OperationType uint8

+ type Options struct

+ EnableBandwidthEstimator bool

+ EnableBridging bool

+ IceServers []webrtc.ICEServer

+ MaxPlayoutDelay uint16

+ MinPlayoutDelay uint16

+ SettingEngine *webrtc.SettingEngine

+ func DefaultOptions() Options

+ type PC struct

+ IsInRenegotiation bool

+ Mu *sync.Mutex

+ PeerConnection *webrtc.PeerConnection

+ type PeerConnection struct

+ func (p *PeerConnection) AddTrack(track webrtc.TrackLocal) (*webrtc.RTPSender, error)

+ func (p *PeerConnection) Close() error

+ func (p *PeerConnection) PC() *webrtc.PeerConnection

+ func (p *PeerConnection) RemoveTrack(sender *webrtc.RTPSender) error

+ type PublishedTrack struct

+ ClientID string

+ Track webrtc.TrackLocal

+ type QualityLevel uint32

+ func RIDToQuality(RID string) QualityLevel

+ func Uint32ToQualityLevel(quality uint32) QualityLevel

+ type QualityPreset struct

+ SID uint8

+ TID uint8

+ func (q QualityPreset) GetSID() uint8

+ func (q QualityPreset) GetTID() uint8

+ type QualityPresets struct

+ High QualityPreset

+ Low QualityPreset

+ Mid QualityPreset

+ func DefaultQualityPresets() *QualityPresets

+ type RelayTrack struct

+ func (t *RelayTrack) Codec() webrtc.RTPCodecParameters

+ func (t *RelayTrack) ID() string

+ func (t *RelayTrack) IsRelay() bool

+ func (t *RelayTrack) Kind() webrtc.RTPCodecType

+ func (t *RelayTrack) Msid() string

+ func (t *RelayTrack) PayloadType() webrtc.PayloadType

+ func (t *RelayTrack) RID() string

+ func (t *RelayTrack) Read(b []byte) (n int, attributes interceptor.Attributes, err error)

+ func (t *RelayTrack) ReadRTP() (*rtp.Packet, interceptor.Attributes, error)

+ func (t *RelayTrack) SSRC() webrtc.SSRC

+ func (t *RelayTrack) SetReadDeadline(deadline time.Time) error

+ func (t *RelayTrack) StreamID() string

+ type Room struct

+ OnEvent func(event Event)

+ RenegotiationChan map[string]chan bool

+ func (r *Room) AddClient(id, name string, opts ClientOptions) (*Client, error)

+ func (r *Room) AddExtension(extension IExtension)

+ func (r *Room) BitrateConfigs() BitrateConfigs

+ func (r *Room) Close() error

+ func (r *Room) CodecPreferences() []string

+ func (r *Room) Context() context.Context

+ func (r *Room) ContinueRecording()

+ func (r *Room) CreateClientID() string

+ func (r *Room) CreateDataChannel(label string, opts DataChannelOptions) error

+ func (r *Room) ID() string

+ func (r *Room) Kind() string

+ func (r *Room) Meta() *Metadata

+ func (r *Room) Name() string

+ func (r *Room) OnClientJoined(callback func(client *Client))

+ func (r *Room) OnClientLeft(callback func(client *Client))

+ func (r *Room) OnRoomClosed(callback func(id string))

+ func (r *Room) Options() RoomOptions

+ func (r *Room) PauseRecording()

+ func (r *Room) SFU() *SFU

+ func (r *Room) StartRecording(bucketName, filename string) error

+ func (r *Room) Stats() RoomStats

+ func (r *Room) StopClient(id string) error

+ func (r *Room) StopRecording(stopConfig recorder.StopConfig)

+ type RoomOptions struct

+ Bitrates BitrateConfigs

+ Codecs *[]string

+ EmptyRoomTimeout *time.Duration

+ PLIInterval *time.Duration

+ QualityPresets *QualityPresets

+ QuicConfig []*recorder.QuicConfig

+ func DefaultRoomOptions() RoomOptions

+ type RoomStats struct

+ ActiveSessions int

+ BitrateReceived uint64

+ BitrateSent uint64

+ BytesEgress uint64

+ BytesIngress uint64

+ ClientStats map[string]ClientTrackStats

+ ClientsCount int

+ ReceivedTracks StatTracks

+ SentTracks StatTracks

+ Timestamp time.Time

+ type SFU struct

+ func New(ctx context.Context, opts sfuOptions) *SFU

+ func (s *SFU) AddRelayTrack(ctx context.Context, id, streamid, rid string, client *Client, ...) error

+ func (s *SFU) AvailableTracks() []ITrack

+ func (s *SFU) CreateDataChannel(label string, opts DataChannelOptions) error

+ func (s *SFU) GetClient(id string) (*Client, error)

+ func (s *SFU) NewClient(id, name string, opts ClientOptions) *Client

+ func (s *SFU) OnClientAdded(callback func(*Client))

+ func (s *SFU) OnClientRemoved(callback func(*Client))

+ func (s *SFU) OnStopped(callback func())

+ func (s *SFU) OnTracksAvailable(callback func(tracks []ITrack))

+ func (s *SFU) PLIInterval() time.Duration

+ func (s *SFU) QualityPresets() QualityPresets

+ func (s *SFU) Stop()

+ func (s *SFU) TotalActiveSessions() int

+ type SFUClients struct

+ func (s *SFUClients) Add(client *Client) error

+ func (s *SFUClients) GetClient(id string) (*Client, error)

+ func (s *SFUClients) GetClients() map[string]*Client

+ func (s *SFUClients) Length() int

+ func (s *SFUClients) Remove(client *Client) error

+ type SFUDataChannel struct

+ func NewSFUDataChannel(label string, opts DataChannelOptions) *SFUDataChannel

+ func (s *SFUDataChannel) ClientIDs() []string

+ func (s *SFUDataChannel) IsOrdered() bool

+ type SFUDataChannelList struct

+ func NewSFUDataChannelList() *SFUDataChannelList

+ func (s *SFUDataChannelList) Add(label string, opts DataChannelOptions) *SFUDataChannel

+ func (s *SFUDataChannelList) Get(label string) *SFUDataChannel

+ func (s *SFUDataChannelList) Remove(dc *SFUDataChannel)

+ type SimulcastTrack struct

+ func (t *SimulcastTrack) AddRemoteTrack(track IRemoteTrack, minWait, maxWait time.Duration, stats stats.Getter, ...) *remoteTrack

+ func (t *SimulcastTrack) ClientID() string

+ func (t *SimulcastTrack) Context() context.Context

+ func (t *SimulcastTrack) ContinueRecording()

+ func (t *SimulcastTrack) ID() string

+ func (t *SimulcastTrack) IsProcessed() bool

+ func (t *SimulcastTrack) IsRelay() bool

+ func (t *SimulcastTrack) IsScaleable() bool

+ func (t *SimulcastTrack) IsScreen() bool

+ func (t *SimulcastTrack) IsSimulcast() bool

+ func (t *SimulcastTrack) IsTrackComplete() bool

+ func (t *SimulcastTrack) Kind() webrtc.RTPCodecType

+ func (t *SimulcastTrack) MimeType() string

+ func (t *SimulcastTrack) Mute()

+ func (t *SimulcastTrack) OnEnded(f func())

+ func (t *SimulcastTrack) OnRead(callback func(*rtp.Packet, QualityLevel))

+ func (t *SimulcastTrack) OnTrackComplete(f func())

+ func (t *SimulcastTrack) PauseRecording()

+ func (t *SimulcastTrack) PayloadType() webrtc.PayloadType

+ func (t *SimulcastTrack) RIDHigh() string

+ func (t *SimulcastTrack) RIDLow() string

+ func (t *SimulcastTrack) RIDMid() string

+ func (t *SimulcastTrack) Relay(f func(webrtc.SSRC, *rtp.Packet))

+ func (t *SimulcastTrack) SSRCHigh() webrtc.SSRC

+ func (t *SimulcastTrack) SSRCLow() webrtc.SSRC

+ func (t *SimulcastTrack) SSRCMid() webrtc.SSRC

+ func (t *SimulcastTrack) SetAsProcessed()

+ func (t *SimulcastTrack) SetSourceType(sourceType TrackType)

+ func (t *SimulcastTrack) SourceType() TrackType

+ func (t *SimulcastTrack) StartRecording(stream quic.SendStream) error

+ func (t *SimulcastTrack) StopRecording()

+ func (t *SimulcastTrack) StreamID() string

+ func (t *SimulcastTrack) TotalTracks() int

+ func (t *SimulcastTrack) Unmute()

+ type StatTracks struct

+ Audio int

+ Video int

+ type SubscribeTrackRequest struct

+ ClientID string

+ TrackID string

+ type Track struct

+ func (t *Track) ClientID() string

+ func (t *Track) Context() context.Context

+ func (t *Track) ContinueRecording()

+ func (t *Track) ID() string

+ func (t *Track) IsPaused() bool

+ func (t *Track) IsProcessed() bool

+ func (t *Track) IsRecording() bool

+ func (t *Track) IsRelay() bool

+ func (t *Track) IsScaleable() bool

+ func (t *Track) IsScreen() bool

+ func (t *Track) IsSimulcast() bool

+ func (t *Track) Kind() webrtc.RTPCodecType

+ func (t *Track) MimeType() string

+ func (t *Track) Mute()

+ func (t *Track) OnEnded(f func())

+ func (t *Track) OnRead(callback func(*rtp.Packet, QualityLevel))

+ func (t *Track) PauseRecording()

+ func (t *Track) PayloadType() webrtc.PayloadType

+ func (t *Track) Relay(f func(webrtc.SSRC, *rtp.Packet))

+ func (t *Track) RemoteTrack() *remoteTrack

+ func (t *Track) SSRC() webrtc.SSRC

+ func (t *Track) SSRCHigh() webrtc.SSRC

+ func (t *Track) SSRCLow() webrtc.SSRC

+ func (t *Track) SSRCMid() webrtc.SSRC

+ func (t *Track) SetAsProcessed()

+ func (t *Track) SetSourceType(sourceType TrackType)

+ func (t *Track) SourceType() TrackType

+ func (t *Track) StartRecording(stream quic.SendStream) error

+ func (t *Track) StopRecording()

+ func (t *Track) StreamID() string

+ func (t *Track) TotalTracks() int

+ func (t *Track) Unmute()

+ type TrackReceivedStats struct

+ BytesReceived int64

+ Codec string

+ CurrentBitrate uint32

+ ID string

+ Kind webrtc.RTPCodecType

+ PacketsLost int64

+ PacketsReceived uint64

+ RID string

+ StreamID string

+ type TrackSentStats struct

+ BytesSent uint64

+ Codec string

+ CurrentBitrate uint32

+ FractionLost float64

+ ID string

+ Kind webrtc.RTPCodecType

+ PacketSent uint64

+ PacketsLost int64

+ Quality QualityLevel

+ Source string

+ StreamID string

+ type TrackStats struct

+ type TrackType string

+ func (t TrackType) String() string

+ type UDPMux struct

+ Port int

+ func NewUDPMux(ctx context.Context, port int) *UDPMux

+ func (u *UDPMux) Close() error

+ func (u *UDPMux) Mux() *ice.MultiUDPMuxDefault

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL