beekeeper

Documentation

Index

• func Run(ctx context.Context, cluster *bee.Cluster, action Action, options interface{}, ...) (err error)
• func RunConcurrently(ctx context.Context, cluster *bee.Cluster, action Action, options interface{}, ...) (err error)
• type Action
• type Actions
• type Stage
• type Update

Functions

func Run

func Run(ctx context.Context, cluster *bee.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 *bee.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 *bee.Cluster, o interface{}) (err error)
}

Action defines Beekeeper Action's interface

type Actions

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

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