router

Documentation

Index

• func WithPubIRFBuilderFactory(irfbf signaller.PubIRFBuilderFactory) func(ForwardRouter)
• type ForwardRouter
  • func NewForwardRouter(sfu *ion_sfu.SFU, cp signaller.ConnPool, with ...func(ForwardRouter)) ForwardRouter
  • func (f ForwardRouter) ReplaceForwardTrack(oldTrackInfo *pb.ForwardTrack, newTrackInfo *pb.ForwardTrack)
  • func (f ForwardRouter) StartForwardTrack(trackInfo *pb.ForwardTrack)
  • func (f ForwardRouter) StopForwardTrack(trackInfo *pb.ForwardTrack)
• type ProceedRouter
  • func NewProceedRouter(sfu *ion_sfu.SFU, factory algorithms.ProcessorFactory) ProceedRouter
  • func (p ProceedRouter) ReplaceProceedTrack(oldTrackInfo *pb.ProceedTrack, newTrackInfo *pb.ProceedTrack)
  • func (p ProceedRouter) StartProceedTrack(trackInfo *pb.ProceedTrack)
  • func (p ProceedRouter) StopProceedTrack(trackInfo *pb.ProceedTrack)

Functions

func WithPubIRFBuilderFactory

func WithPubIRFBuilderFactory(irfbf signaller.PubIRFBuilderFactory) func(ForwardRouter)

Types

type ForwardRouter

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

func NewForwardRouter

func NewForwardRouter(sfu *ion_sfu.SFU, cp signaller.ConnPool, with ...func(ForwardRouter)) ForwardRouter

func (ForwardRouter) ReplaceForwardTrack

func (f ForwardRouter) ReplaceForwardTrack(oldTrackInfo *pb.ForwardTrack, newTrackInfo *pb.ForwardTrack)

func (ForwardRouter) StartForwardTrack

func (f ForwardRouter) StartForwardTrack(trackInfo *pb.ForwardTrack)

func (ForwardRouter) StopForwardTrack

func (f ForwardRouter) StopForwardTrack(trackInfo *pb.ForwardTrack)

type ProceedRouter

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

ProceedRouter controls the track proceed in SFU

func NewProceedRouter

func NewProceedRouter(sfu *ion_sfu.SFU, factory algorithms.ProcessorFactory) ProceedRouter

func (ProceedRouter) ReplaceProceedTrack

func (p ProceedRouter) ReplaceProceedTrack(oldTrackInfo *pb.ProceedTrack, newTrackInfo *pb.ProceedTrack)

func (ProceedRouter) StartProceedTrack

func (p ProceedRouter) StartProceedTrack(trackInfo *pb.ProceedTrack)

func (ProceedRouter) StopProceedTrack

func (p ProceedRouter) StopProceedTrack(trackInfo *pb.ProceedTrack)