sender

package
v0.99.0 Latest Latest
Warning

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

Go to latest
Published: Jan 21, 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) (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) 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)

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)

type LoadGenerator

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

	// This method blocks till the pace is complete
	RunPace(i int, pace common.PaceSpec, msgSize uint)
	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