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 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 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)