stress

Documentation

Index

• func Run(ctx context.Context, cluster *bee.Cluster, stress Stress, options Options, ...) (err error)
• func RunConcurrently(ctx context.Context, cluster *bee.Cluster, stress Stress, options Options, ...) (err error)
• type Actions
• type Options
• type Stage
• type Stress
• type Update

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