beekeeper

Documentation

Index

• func Run(ctx context.Context, cluster orchestration.Cluster, action Action, ...) (err error)
• func RunConcurrently(ctx context.Context, cluster orchestration.Cluster, action Action, ...) (err error)
• type Action
• type Actions
• type Stage
• type Update

Functions

func Run

func Run(ctx context.Context, cluster orchestration.Cluster, action Action, options interface{}, stages []Stage, seed int64) (err error)

Run runs check against the cluster

func RunConcurrently

func RunConcurrently(ctx context.Context, cluster orchestration.Cluster, action Action, options interface{}, stages []Stage, buffer int, seed int64) (err error)

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

Types

type Action

type Action interface {
	Run(ctx context.Context, cluster orchestration.Cluster, o interface{}) (err error)
}

Action defines Beekeeper Action's interface. An action that needs to expose metrics should implement the metrics.Reporter interface.

type Actions

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

Actions represents node group update actions

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