pingpong

package

v0.6.0 Latest Latest Go to latest Published: Apr 27, 2021 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

func Check(ctx context.Context, cluster *bee.Cluster, o Options) (err error)

Check executes ping from all nodes to all other nodes in the cluster

func CheckD(ctx context.Context, cluster *bee.Cluster, o Options) (err error)

CheckD executes ping from all nodes to all other nodes in the cluster

func CheckDynamic(ctx context.Context, cluster *bee.Cluster, o Options) (err error)

CheckDynamic executes PingPong check on dynamic cluster

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

Actions for dynamic behavior

type Options struct {
	DynamicActions []Actions
	MetricsEnabled bool
	MetricsPusher  *push.Pusher
	Seed           int64
}

Options represents pingpong check options

type Ping struct{}

Ping check

func NewPing() *Ping

NewPing returns new ping check

func (p *Ping) Run(ctx context.Context, cluster *bee.Cluster, o check.Options) (err error)

Run executes ping check