check

Documentation

Index

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

Functions

func Run

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

Run runs check against the cluster

func RunConcurrently

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

RunConcurrently runs check 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 Check

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

Check defines Bee check

type Options

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

Options for Bee checks

type Stage

type Stage []Update

Stage define stages for updating Bee

type Update

type Update struct {
	NodeGroup string
	Actions   Actions
}

Update represents details for updating a node group