supervisor

package
v1.13.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 14, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ParticipantSupervisor 

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

func NewParticipantSupervisor 

func NewParticipantSupervisor(params ParticipantSupervisorParams) *ParticipantSupervisor

func (*ParticipantSupervisor) AddPublication 

func (p *ParticipantSupervisor) AddPublication(trackID livekit.TrackID)

func (*ParticipantSupervisor) ClearPublishedTrack 

func (p *ParticipantSupervisor) ClearPublishedTrack(trackID livekit.TrackID, pubTrack types.LocalMediaTrack)

func (*ParticipantSupervisor) OnPublicationError added in v1.3.2 

func (p *ParticipantSupervisor) OnPublicationError(f func(trackID livekit.TrackID))

func (*ParticipantSupervisor) RemovePublication added in v1.13.10 

func (p *ParticipantSupervisor) RemovePublication(trackID livekit.TrackID)

RemovePublication drops the monitor of a pending publication. A monitor that still holds a published track is kept, so a live track never loses its monitor.

func (*ParticipantSupervisor) SetPublicationMute 

func (p *ParticipantSupervisor) SetPublicationMute(trackID livekit.TrackID, isMuted bool)

func (*ParticipantSupervisor) SetPublicationTimedOutForTest added in v1.13.10 

func (p *ParticipantSupervisor) SetPublicationTimedOutForTest(trackID livekit.TrackID)

SetPublicationTimedOutForTest puts a publication in the state checkPublications reports once the publish wait passes. Only for tests outside this package.

func (*ParticipantSupervisor) SetPublishedTrack 

func (p *ParticipantSupervisor) SetPublishedTrack(trackID livekit.TrackID, pubTrack types.LocalMediaTrack)

func (*ParticipantSupervisor) SetPublisherPeerConnectionConnected added in v1.2.3 

func (p *ParticipantSupervisor) SetPublisherPeerConnectionConnected(isConnected bool)

func (*ParticipantSupervisor) Stop 

func (p *ParticipantSupervisor) Stop()

func (*ParticipantSupervisor) TimedOutPublications added in v1.13.10 

func (p *ParticipantSupervisor) TimedOutPublications() []livekit.TrackID

TimedOutPublications returns the track IDs whose pending publish timed out.

type ParticipantSupervisorParams 

type ParticipantSupervisorParams struct {
	Logger logger.Logger
}

type PublicationMonitor 

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

func NewPublicationMonitor 

func NewPublicationMonitor(params PublicationMonitorParams) *PublicationMonitor

func (*PublicationMonitor) Check 

func (p *PublicationMonitor) Check() error

func (*PublicationMonitor) IsIdle 

func (p *PublicationMonitor) IsIdle() bool

func (*PublicationMonitor) PostEvent 

func (p *PublicationMonitor) PostEvent(ome types.OperationMonitorEvent, omd types.OperationMonitorData)

type PublicationMonitorParams 

type PublicationMonitorParams struct {
	TrackID                   livekit.TrackID
	IsPeerConnectionConnected bool
	Logger                    logger.Logger
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.