supervisor

Documentation

Index

• type ParticipantSupervisor
  • func NewParticipantSupervisor(params ParticipantSupervisorParams) *ParticipantSupervisor
  • func (p *ParticipantSupervisor) AddPublication(trackID livekit.TrackID)
  • func (p *ParticipantSupervisor) ClearPublishedTrack(trackID livekit.TrackID, pubTrack types.LocalMediaTrack)
  • func (p *ParticipantSupervisor) OnPublicationError(f func(trackID livekit.TrackID))
  • func (p *ParticipantSupervisor) SetPublicationMute(trackID livekit.TrackID, isMuted bool)
  • func (p *ParticipantSupervisor) SetPublishedTrack(trackID livekit.TrackID, pubTrack types.LocalMediaTrack)
  • func (p *ParticipantSupervisor) SetPublisherPeerConnectionConnected(isConnected bool)
  • func (p *ParticipantSupervisor) Stop()
• type ParticipantSupervisorParams
• type PublicationMonitor
  • func NewPublicationMonitor(params PublicationMonitorParams) *PublicationMonitor
  • func (p *PublicationMonitor) Check() error
  • func (p *PublicationMonitor) IsIdle() bool
  • func (p *PublicationMonitor) PostEvent(ome types.OperationMonitorEvent, omd types.OperationMonitorData)
• type PublicationMonitorParams

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

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

func (*ParticipantSupervisor) SetPublicationMute

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

func (*ParticipantSupervisor) SetPublishedTrack

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

func (*ParticipantSupervisor) SetPublisherPeerConnectionConnected

func (p *ParticipantSupervisor) SetPublisherPeerConnectionConnected(isConnected bool)

func (*ParticipantSupervisor) Stop

func (p *ParticipantSupervisor) Stop()

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
}