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) ClearSubscribedTrack(trackID livekit.TrackID, subTrack types.SubscribedTrack)
  • 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) SetSubscribedTrack(trackID livekit.TrackID, subTrack types.SubscribedTrack)
  • func (p *ParticipantSupervisor) Stop()
  • func (p *ParticipantSupervisor) UpdateSubscription(trackID livekit.TrackID, isSubscribed bool)
• 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
• type SubscriptionMonitor
  • func NewSubscriptionMonitor(params SubscriptionMonitorParams) *SubscriptionMonitor
  • func (s *SubscriptionMonitor) Check() error
  • func (s *SubscriptionMonitor) IsIdle() bool
  • func (s *SubscriptionMonitor) PostEvent(ome types.OperationMonitorEvent, omd types.OperationMonitorData)
• type SubscriptionMonitorParams

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) ClearSubscribedTrack

func (p *ParticipantSupervisor) ClearSubscribedTrack(trackID livekit.TrackID, subTrack types.SubscribedTrack)

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) SetSubscribedTrack

func (p *ParticipantSupervisor) SetSubscribedTrack(trackID livekit.TrackID, subTrack types.SubscribedTrack)

func (*ParticipantSupervisor) Stop

func (p *ParticipantSupervisor) Stop()

func (*ParticipantSupervisor) UpdateSubscription

func (p *ParticipantSupervisor) UpdateSubscription(trackID livekit.TrackID, isSubscribed bool)

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
}

type SubscriptionMonitor

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

func NewSubscriptionMonitor

func NewSubscriptionMonitor(params SubscriptionMonitorParams) *SubscriptionMonitor

func (*SubscriptionMonitor) Check

func (s *SubscriptionMonitor) Check() error

func (*SubscriptionMonitor) IsIdle

func (s *SubscriptionMonitor) IsIdle() bool

func (*SubscriptionMonitor) PostEvent

func (s *SubscriptionMonitor) PostEvent(ome types.OperationMonitorEvent, omd types.OperationMonitorData)

type SubscriptionMonitorParams

type SubscriptionMonitorParams struct {
	TrackID livekit.TrackID
	Logger  logger.Logger
}