common

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: Sep 29, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source
const (
	WarmupEventType   = "warmup.perf-test"
	MeasureEventType  = "measure.perf-test"
	GCEventType       = "gc.perf-test"
	EndEventType      = "end.perf-test"
	CEReceiverPort    = "8080"
	WaitForFlush      = 5 * time.Second
	WaitForReceiverGC = 3 * time.Second
	WaitAfterWarmup   = 5 * time.Second
)

Variables

This section is empty.

Functions

func CalculateMemoryConstraintsForPaceSpecs

func CalculateMemoryConstraintsForPaceSpecs(paceSpecs []PaceSpec) (estimatedNumberOfMessagesInsideAChannel uint64, estimatedNumberOfTotalMessages uint64)

We need those estimates to allocate memory before benchmark starts

Types

type EventTimestamp

type EventTimestamp struct {
	EventId string
	At      *timestamp.Timestamp
}

EventTimestamp is the recorded EventTimestamp of an event.

type Executor

type Executor interface {
	Run(ctx context.Context)
}

type Executors

type Executors []Executor

func (Executors) Run

func (e Executors) Run(ctx context.Context)

type PaceSpec

type PaceSpec struct {
	Rps      int
	Duration time.Duration
}

func ParsePaceSpec

func ParsePaceSpec(pace string) ([]PaceSpec, error)

Jump to

Keyboard shortcuts

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