smoke

Documentation

Index

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

Functions

func NewCheck

func NewCheck(logger logging.Logger) beekeeper.Action

NewCheck returns new check

func NewLoadCheck

func NewLoadCheck(log logging.Logger) beekeeper.Action

NewCheck returns new check

Types

type Check

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

Check instance

func (*Check) Report

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

func (*Check) Run

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

Run creates file of specified size that is uploaded and downloaded.

type LoadCheck

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

Check instance

func (*LoadCheck) Report

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

func (*LoadCheck) Run

func (c *LoadCheck) Run(ctx context.Context, cluster orchestration.Cluster, opts interface{}) error

Run creates file of specified size that is uploaded and downloaded.

type Options

type Options struct {
	ContentSize     int64
	RndSeed         int64
	PostageAmount   int64
	PostageDepth    uint64
	TxOnErrWait     time.Duration
	RxOnErrWait     time.Duration
	NodesSyncWait   time.Duration
	Duration        time.Duration
	UploadTimeout   time.Duration
	DownloadTimeout time.Duration
	// load test params
	UploaderCount          int
	UploadGroups           []string
	DownloaderCount        int
	DownloadGroups         []string
	MaxUseBatch            time.Duration
	MaxStorageRadius       uint8
	StorageRadiusCheckWait time.Duration
	IterationWait          time.Duration
}

Options represents smoke test options

func NewDefaultOptions

func NewDefaultOptions() Options

NewDefaultOptions returns new default options