stress

package
v0.5.4 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2021 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Run

func Run(ctx context.Context, cluster *bee.Cluster, stress Stress, options Options, stages []Stage, seed int64) (err error)

Run runs stress against the cluster

func RunConcurrently

func RunConcurrently(ctx context.Context, cluster *bee.Cluster, stress Stress, options Options, stages []Stage, buffer int, seed int64) (err error)

RunConcurrently runs stress against the cluster, cluster updates are executed concurrently

Types

type Actions

type Actions struct {
	AddCount    int
	StartCount  int
	StopCount   int
	DeleteCount int
}

Actions represents node group update actions

type Options

type Options struct {
	FileSize              int64
	MetricsEnabled        bool
	MetricsPusher         *push.Pusher
	Retries               int
	RetryDelay            time.Duration
	Seed                  int64
	Timeout               time.Duration
	UploadNodesPercentage int
}

Options for Bee stress

type Stage

type Stage []Update

Stage define stages for updating Bee

type Stress

type Stress interface {
	Run(ctx context.Context, cluster *bee.Cluster, o Options) (err error)
}

Stress defines Bee stress

type Update

type Update struct {
	NodeGroup string
	Actions   Actions
}

Update represents details for updating a node group

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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