load

Documentation

Index

• func NewCheck(log logging.Logger) beekeeper.Action
• type Check
  • func (c *Check) Report() []prometheus.Collector
  • func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, opts any) error
• type Options
  • func NewDefaultOptions() Options

Functions

func NewCheck

func NewCheck(log logging.Logger) beekeeper.Action

Types

type Check

type Check struct {
	// contains filtered or unexported fields
}

func (*Check) Report

func (c *Check) Report() []prometheus.Collector

func (*Check) Run

func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, opts any) error

type Options

type Options struct {
	ContentSize             int64
	RndSeed                 int64
	PostageTTL              time.Duration
	PostageDepth            uint64
	PostageLabel            string
	TxOnErrWait             time.Duration
	RxOnErrWait             time.Duration
	NodesSyncWait           time.Duration
	Duration                time.Duration
	UploaderCount           int
	UploadGroups            []string
	DownloaderCount         int
	DownloadGroups          []string
	MaxCommittedDepth       uint8
	CommittedDepthCheckWait time.Duration
	IterationWait           time.Duration
}

func NewDefaultOptions

func NewDefaultOptions() Options