Help us shape the future of Go! Take the 2026 Go Developer Survey

supervisor

package
v1.13.11 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 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.