beekeeper

package
v0.15.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2024 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v0.11.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.