engine

Documentation

Index

• type Engine
  • func New(phases []scheduler.Phase, scenario func(context.Context) (int, error), ...) *Engine
  • func (e *Engine) Run(ctx context.Context) (metrics.Result, error)

Types

type Engine

type Engine struct {
	// contains filtered or unexported fields
}

Engine executes a test definition.

func New

func New(phases []scheduler.Phase, scenario func(context.Context) (int, error), maxConcurrency int) *Engine

New creates an engine for the given execution inputs.

func (*Engine) Run

func (e *Engine) Run(ctx context.Context) (metrics.Result, error)

Run executes each phase in sequence through the scheduler. Scenario errors are recorded in metrics and do not stop the run. A non-nil error indicates scheduler failure or context cancellation.