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)
  • func (h HttpLoadGenerator) SendEndEvent()
  • func (h HttpLoadGenerator) SendGCEvent()
  • func (h HttpLoadGenerator) Warmup(pace common.PaceSpec, msgSize uint)
• 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) (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)