sender

package
v0.14.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 30, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSender

func NewSender(loadGeneratorFactory LoadGeneratorFactory, aggregAddr string, msgSize uint, warmupSeconds uint, paceFlag string, fixedBody bool) (common.Executor, error)

Types

type CloudEventsTargeter

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

func NewCloudEventsTargeter

func NewCloudEventsTargeter(sinkUrl string, msgSize uint, eventType string, eventSource string, fixedBody bool) CloudEventsTargeter

func (CloudEventsTargeter) VegetaTargeter

func (cet CloudEventsTargeter) VegetaTargeter() vegeta.Targeter

type HttpLoadGenerator

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

func (HttpLoadGenerator) RunPace

func (h HttpLoadGenerator) RunPace(i int, pace common.PaceSpec, msgSize uint, fixedBody bool)

func (HttpLoadGenerator) SendEndEvent

func (h HttpLoadGenerator) SendEndEvent()

func (HttpLoadGenerator) SendGCEvent

func (h HttpLoadGenerator) SendGCEvent()

func (HttpLoadGenerator) Warmup

func (h HttpLoadGenerator) Warmup(pace common.PaceSpec, msgSize uint, fixedBody bool)

type LoadGenerator

type LoadGenerator interface {
	// This method blocks till the warmup is complete
	Warmup(pace common.PaceSpec, msgSize uint, fixedBody bool)

	// This method blocks till the pace is complete
	RunPace(i int, pace common.PaceSpec, msgSize uint, fixedBody bool)
	SendGCEvent()
	SendEndEvent()
}

type LoadGeneratorFactory

type LoadGeneratorFactory func(eventSource string, sentCh chan common.EventTimestamp,
	acceptedCh chan common.EventTimestamp) (LoadGenerator, error)

func NewHttpLoadGeneratorFactory

func NewHttpLoadGeneratorFactory(sinkUrl string, minWorkers uint64) LoadGeneratorFactory

type Sender

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

func (*Sender) Run

func (s *Sender) Run(ctx context.Context)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL