sender

Documentation

Index

• func NewSender(loadGeneratorFactory LoadGeneratorFactory, aggregAddr string, msgSize uint, ...) (common.Executor, error)
• type CloudEventsTargeter
  • func NewCloudEventsTargeter(sinkUrl string, msgSize uint, eventType string, eventSource string, ...) CloudEventsTargeter
  • func (cet CloudEventsTargeter) VegetaTargeter() vegeta.Targeter
• type HttpLoadGenerator
  • func (h HttpLoadGenerator) RunPace(i int, pace common.PaceSpec, msgSize uint, fixedBody bool)
  • func (h HttpLoadGenerator) SendEndEvent()
  • func (h HttpLoadGenerator) SendGCEvent()
  • func (h HttpLoadGenerator) Warmup(pace common.PaceSpec, msgSize uint, fixedBody bool)
• type LoadGenerator
• type LoadGeneratorFactory
  • func NewHttpLoadGeneratorFactory(sinkUrl string, minWorkers uint64) LoadGeneratorFactory
• type Sender
  • func (s *Sender) Run(ctx context.Context)

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)