pushsync

Documentation

Index

• func GetIPFromUnderlays(addrs []string) string
• func NewSimulation(logger logging.Logger) beekeeper.Action
• func ToBuckets(arr []string, start float64, end float64, step float64) [][]string
• type Options
  • func NewDefaultOptions() Options
• type Simulation
  • func (s *Simulation) Report() []prometheus.Collector
  • func (s *Simulation) Run(ctx context.Context, cluster orchestration.Cluster, opts interface{}) (err error)

Functions

func GetIPFromUnderlays

func GetIPFromUnderlays(addrs []string) string

func NewSimulation

func NewSimulation(logger logging.Logger) beekeeper.Action

NewSimulation returns new upload simulation

func ToBuckets

func ToBuckets(arr []string, start float64, end float64, step float64) [][]string

toBuckets splits arr into buckets where the first bucket is 0-th index upto start percentage number of elements, subsequent buckets are step percentage number of elements until the end percentage is reached, ex: arr = [1,2,3,4,5,6,7,8,9,10], start=0.4, end=0.8, step=0.2, last bucket is the remaining items that are outside of the start - end range, so when end is 1.0, last bucket is empty returned is [[1,2,3,4], [5,6], [7,8], [9,10]]

Types

type Options

type Options struct {
	GasPrice         string
	PostageAmount    int64
	PostageDepth     uint64
	DownloadWait     time.Duration
	UploadWait       time.Duration
	DownloadCount    int64
	DownloadRetry    int64
	Seed             int64
	ProxyApiEndpoint string
	ChunkCount       int64

	// percentages must be in the range of [0, 1.0]
	StartPercentage float64
	EndPercentage   float64
	StepPercentage  float64
}

Options represents simulation options

func NewDefaultOptions

func NewDefaultOptions() Options

NewDefaultOptions returns new default options

type Simulation

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

Simulation instance

func (*Simulation) Report

func (s *Simulation) Report() []prometheus.Collector

func (*Simulation) Run

func (s *Simulation) Run(ctx context.Context, cluster orchestration.Cluster, opts interface{}) (err error)

Run executes upload stress