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
  • func NewActionMiddleware(tracer opentracing.Tracer, action Action, actionName string) 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, logger logging.Logger) (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, logger logging.Logger) (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.

func NewActionMiddleware

func NewActionMiddleware(tracer opentracing.Tracer, action Action, actionName string) Action

ActionMiddleware tracks request, and adds spans to context.

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