subcmd

Documentation

Index

• Variables
• type BWEConfig
• type BWEFactory
• type BWEFactoryFunc
  • func (f BWEFactoryFunc) MakeBWE(config BWEConfig) (mrtp.BWE, error)
• type BitrateAdapter
• type MoQPub
  • func (m *MoQPub) Exec(cmd string, args []string) error
  • func (m *MoQPub) Help() string
• type MoQSub
  • func (m *MoQSub) Exec(cmd string, args []string) error
  • func (m *MoQSub) Help() string
• type Receive
  • func (r *Receive) Exec(cmd string, args []string) error
  • func (r *Receive) Help() string
• type ReceiveData
  • func (r *ReceiveData) Exec(cmd string, args []string) error
  • func (r *ReceiveData) Help() string
• type ReceiveGo
  • func (r *ReceiveGo) Exec(cmd string, args []string) error
  • func (r *ReceiveGo) Help() string
• type Send
  • func (s *Send) Exec(cmd string, args []string) error
  • func (s *Send) Help() string
• type SendData
  • func (s *SendData) Exec(cmd string, args []string) error
  • func (s *SendData) Help() string
• type SendGo
  • func (s *SendGo) Exec(cmd string, args []string) error
  • func (s *SendGo) Help() string
• type Serve
  • func (s *Serve) Exec(cmd string, args []string) error
  • func (s *Serve) Help() string
• type StreamSinkFactory
• type StreamSourceFactory
• type Version
  • func (v *Version) Exec(cmd string, args []string) error
  • func (v *Version) Help() string
• type WebRTC
  • func (w *WebRTC) Exec(cmd string, args []string) error
  • func (w *WebRTC) Help() string
• type WebRTCCodecParameters

Variables

var BWEFactories = map[string]BWEFactory{
	"nada": BWEFactoryFunc(func(config BWEConfig) (mrtp.BWE, error) {
		nadaConfig := nada.Config{
			MinRate:                  uint64(config.MinTargetRate),
			MaxRate:                  uint64(config.MaxTargetRate),
			StartRate:                uint64(config.InitTargetRate),
			FeedbackDelta:            uint64(20 / time.Millisecond),
			DeactivateQDelayWrapping: true,

			RefCongLevel:           DefaultBweFlags.RefCongLevel,
			QEPS:                   DefaultBweFlags.QEPS,
			MaxRampUpFactor:        DefaultBweFlags.MaxRampUpFactor,
			MaxGradualUpdateFactor: DefaultBweFlags.MaxGradualUpdateFactor,
			Kappa:                  DefaultBweFlags.Kappa,
			Eta:                    DefaultBweFlags.Eta,
			DFILT:                  DefaultBweFlags.DFILT,
			QBOUND:                 DefaultBweFlags.QBOUND,
		}
		return mrtp.NewNadaWithConfig(nadaConfig), nil
	}),
	"gcc": BWEFactoryFunc(func(config BWEConfig) (mrtp.BWE, error) {
		return mrtp.NewGCC(config.InitTargetRate, config.MinTargetRate, config.MaxTargetRate)
	}),
}

var DefaultBweFlags *bweFlags = &bweFlags{}

var WebRTCExtraCodecs = []WebRTCCodecParameters{}

Types

type BWEConfig

type BWEConfig struct {
	InitTargetRate uint
	MinTargetRate  uint
	MaxTargetRate  uint
}

type BWEFactory

type BWEFactory interface {
	MakeBWE(BWEConfig) (mrtp.BWE, error)
}

type BWEFactoryFunc

type BWEFactoryFunc func(BWEConfig) (mrtp.BWE, error)

func (BWEFactoryFunc) MakeBWE

func (f BWEFactoryFunc) MakeBWE(config BWEConfig) (mrtp.BWE, error)

type BitrateAdapter

type BitrateAdapter interface {
	// SetBitrate sets the target bitrate for the stream source.
	SetBitrate(uint) error
}

BitrateAdapter is the interface implemented by source streams that can adapt their bitrate to a target rate.

type MoQPub

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

func (*MoQPub) Exec

func (m *MoQPub) Exec(cmd string, args []string) error

Exec implements cmdmain.SubCmd.

func (*MoQPub) Help

func (m *MoQPub) Help() string

Help implements cmdmain.SubCmd.

type MoQSub

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

func (*MoQSub) Exec

func (m *MoQSub) Exec(cmd string, args []string) error

Exec implements cmdmain.SubCmd.

func (*MoQSub) Help

func (m *MoQSub) Help() string

Help implements cmdmain.SubCmd.

type Receive

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

func (*Receive) Exec

func (r *Receive) Exec(cmd string, args []string) error

func (*Receive) Help

func (r *Receive) Help() string

type ReceiveData

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

ReceiveData is a command to run a receiver pipeline for data channels.

func (*ReceiveData) Exec

func (r *ReceiveData) Exec(cmd string, args []string) error

func (*ReceiveData) Help

func (r *ReceiveData) Help() string

type ReceiveGo

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

func (*ReceiveGo) Exec

func (r *ReceiveGo) Exec(cmd string, args []string) error

func (*ReceiveGo) Help

func (r *ReceiveGo) Help() string

type Send

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

func (*Send) Exec

func (s *Send) Exec(cmd string, args []string) error

func (*Send) Help

func (s *Send) Help() string

type SendData

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

SendData is a command to run a receiver pipeline for data channels.

func (*SendData) Exec

func (s *SendData) Exec(cmd string, args []string) error

func (*SendData) Help

func (s *SendData) Help() string

type SendGo

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

func (*SendGo) Exec

func (s *SendGo) Exec(cmd string, args []string) error

Exec implements cmdmain.SubCmd.

func (*SendGo) Help

func (s *SendGo) Help() string

Help implements cmdmain.SubCmd.

type Serve

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

func (*Serve) Exec

func (s *Serve) Exec(cmd string, args []string) error

func (*Serve) Help

func (s *Serve) Help() string

Help implements cmdmain.SubCmd.

type StreamSinkFactory

type StreamSinkFactory interface {
	ConfigureFlags(*flag.FlagSet)
	MakeStreamSink(name string, payloadType int) (gstreamer.RTPSinkBin, error)
}

var DefaultStreamSinkFactory StreamSinkFactory = &gstreamerVideoStreamSinkFactory{}

type StreamSourceFactory

type StreamSourceFactory interface {
	ConfigureFlags(*flag.FlagSet)
	MakeStreamSource(name string) (gstreamer.RTPSourceBin, error)
}

var DefaultStreamSourceFactory StreamSourceFactory = &gstreamerVideoStreamSourceFactory{}

type Version

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

func (*Version) Exec

func (v *Version) Exec(cmd string, args []string) error

Exec implements cmdmain.SubCmd.

func (*Version) Help

func (v *Version) Help() string

Help implements cmdmain.SubCmd.

type WebRTC

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

func (*WebRTC) Exec

func (w *WebRTC) Exec(cmd string, args []string) error

func (*WebRTC) Help

func (w *WebRTC) Help() string

Help implements cmdmain.SubCmd.

type WebRTCCodecParameters

type WebRTCCodecParameters struct {
	MimeType    string
	ClockRate   uint32
	PayloadType uint8
}