loadtester

Documentation

Index

• type Layout
  • func LayoutFromString(str string) Layout
• type LoadTest
  • func NewLoadTest(params Params) *LoadTest
  • func (t *LoadTest) Run() error
  • func (t *LoadTest) RunSuite() error
• type LoadTestDepacketizer
  • func (d *LoadTestDepacketizer) IsPartitionHead(payload []byte) bool
  • func (d *LoadTestDepacketizer) IsPartitionTail(marker bool, payload []byte) bool
  • func (d *LoadTestDepacketizer) Unmarshal(packet []byte) ([]byte, error)
• type LoadTestProvider
  • func NewLoadTestProvider(bitrate uint32) (*LoadTestProvider, error)
  • func (p *LoadTestProvider) NextSample() (media.Sample, error)
  • func (p *LoadTestProvider) OnBind() error
  • func (p *LoadTestProvider) OnUnbind() error
• type LoadTester
  • func NewLoadTester(params TesterParams) *LoadTester
  • func (t *LoadTester) IsRunning() bool
  • func (t *LoadTester) PublishAudioTrack(name string) (string, error)
  • func (t *LoadTester) PublishSimulcastTrack(name, resolution, codec string) (string, error)
  • func (t *LoadTester) PublishVideoTrack(name, resolution, codec string) (string, error)
  • func (t *LoadTester) Reset()
  • func (t *LoadTester) Start() error
  • func (t *LoadTester) Stop()
• type Params
• type TesterParams

Types

type Layout

type Layout string

const (
	// LayoutSpeaker - one user at 1280x720, 5 at 356x200
	LayoutSpeaker Layout = "speaker"
	// LayoutGrid3x3 - 9 participants at 400x225
	LayoutGrid3x3 Layout = "3x3"
	// LayoutGrid4x4 - 16 participants at 320x180
	LayoutGrid4x4 Layout = "4x4"
	// LayoutGrid5x5 - 25 participants at 256x144
	LayoutGrid5x5 Layout = "5x5"
)

func LayoutFromString

func LayoutFromString(str string) Layout

type LoadTest

type LoadTest struct {
	Params Params
	// contains filtered or unexported fields
}

func NewLoadTest

func NewLoadTest(params Params) *LoadTest

func (*LoadTest) Run

func (t *LoadTest) Run() error

func (*LoadTest) RunSuite

func (t *LoadTest) RunSuite() error

type LoadTestDepacketizer

type LoadTestDepacketizer struct {
}

func (*LoadTestDepacketizer) IsPartitionHead

func (d *LoadTestDepacketizer) IsPartitionHead(payload []byte) bool

func (*LoadTestDepacketizer) IsPartitionTail

func (d *LoadTestDepacketizer) IsPartitionTail(marker bool, payload []byte) bool

func (*LoadTestDepacketizer) Unmarshal

func (d *LoadTestDepacketizer) Unmarshal(packet []byte) ([]byte, error)

type LoadTestProvider

type LoadTestProvider struct {
	BytesPerSample uint32
	SampleDuration time.Duration
}

LoadTestProvider is designed to be used with the load tester. It provides packets that are encoded with Sequence and timing information, in order determine RTT and loss

func NewLoadTestProvider

func NewLoadTestProvider(bitrate uint32) (*LoadTestProvider, error)

func (*LoadTestProvider) NextSample

func (p *LoadTestProvider) NextSample() (media.Sample, error)

func (*LoadTestProvider) OnBind

func (p *LoadTestProvider) OnBind() error

func (*LoadTestProvider) OnUnbind

func (p *LoadTestProvider) OnUnbind() error

type LoadTester

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

func NewLoadTester

func NewLoadTester(params TesterParams) *LoadTester

func (*LoadTester) IsRunning

func (t *LoadTester) IsRunning() bool

func (*LoadTester) PublishAudioTrack

func (t *LoadTester) PublishAudioTrack(name string) (string, error)

func (*LoadTester) PublishSimulcastTrack

func (t *LoadTester) PublishSimulcastTrack(name, resolution, codec string) (string, error)

func (*LoadTester) PublishVideoTrack

func (t *LoadTester) PublishVideoTrack(name, resolution, codec string) (string, error)

func (*LoadTester) Reset

func (t *LoadTester) Reset()

func (*LoadTester) Start

func (t *LoadTester) Start() error

func (*LoadTester) Stop

func (t *LoadTester) Stop()

type Params

type Params struct {
	Context         context.Context
	VideoPublishers int
	AudioPublishers int
	Subscribers     int
	VideoResolution string
	VideoCodec      string
	Duration        time.Duration
	// number of seconds to spin up per second
	NumPerSecond float64
	Simulcast    bool

	TesterParams
}

type TesterParams

type TesterParams struct {
	URL            string
	APIKey         string
	APISecret      string
	Room           string
	IdentityPrefix string
	Layout         Layout
	// true to subscribe to all published tracks
	Subscribe bool

	Sequence int
	// contains filtered or unexported fields
}