common

Documentation

Index

• Constants
• func CalculateMemoryConstraintsForPaceSpecs(paceSpecs []PaceSpec) (estimatedNumberOfMessagesInsideAChannel uint64, ...)
• type EventTimestamp
• type Executor
• type Executors
  • func (e Executors) Run(ctx context.Context)
• type PaceSpec
  • func ParsePaceSpec(pace string) ([]PaceSpec, error)

Constants

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
)

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)