boomer

Mar 22, 2022

Changes in this version

type Boomer

+ func (b *Boomer) EnableGracefulQuit()

Mar 15, 2022

Changes in this version

type Boomer

+ func (b *Boomer) GetDisableCompression() bool

+ func (b *Boomer) GetDisableKeepAlive() bool

+ func (b *Boomer) SetDisableCompression(disableCompression bool)

+ func (b *Boomer) SetDisableKeepAlive(disableKeepalive bool)

Feb 17, 2022

Changes in this version

type Boomer

+ func (b *Boomer) GetSpawnDoneChan() chan struct{}

Jan 26, 2022

Changes in this version

type Boomer

+ func (b *Boomer) GetSpawnCount() int

+ func (b *Boomer) IsSpawnDone() bool

Jan 13, 2022

Changes in this version

type Boomer

+ func (b *Boomer) SetLoopCount(loopCount int64)

+ type Loop struct

Dec 30, 2021

Changes in this version

+ func SetUlimit(limit uint64)

Dec 24, 2021

Changes in this version

+ var ErrParsingRampUpRate = errors.New("ratelimiter: invalid format of rampUpRate, try \"1\" or \"1/1s\"")

+ type Boomer struct

+ func NewStandaloneBoomer(spawnCount int, spawnRate float64) *Boomer

+ func (b *Boomer) AddOutput(o Output)

+ func (b *Boomer) EnableCPUProfile(cpuProfile string, duration time.Duration)

+ func (b *Boomer) EnableMemoryProfile(memoryProfile string, duration time.Duration)

+ func (b *Boomer) Quit()

+ func (b *Boomer) RecordFailure(requestType, name string, responseTime int64, exception string)

+ func (b *Boomer) RecordSuccess(requestType, name string, responseTime int64, responseLength int64)

+ func (b *Boomer) RecordTransaction(name string, success bool, elapsedTime int64, contentSize int64)

+ func (b *Boomer) Run(tasks ...*Task)

+ func (b *Boomer) SetRateLimiter(maxRPS int64, requestIncreaseRate string)

+ type ConsoleOutput struct

+ func NewConsoleOutput() *ConsoleOutput

+ func (o *ConsoleOutput) OnEvent(data map[string]interface{})

+ func (o *ConsoleOutput) OnStart()

+ func (o *ConsoleOutput) OnStop()

+ type Output interface

+ OnEvent func(data map[string]interface{})

+ OnStart func()

+ OnStop func()

+ type PrometheusPusherOutput struct

+ func NewPrometheusPusherOutput(gatewayURL, jobName string) *PrometheusPusherOutput

+ func (o *PrometheusPusherOutput) OnEvent(data map[string]interface{})

+ func (o *PrometheusPusherOutput) OnStart()

+ func (o *PrometheusPusherOutput) OnStop()

+ type RampUpRateLimiter struct

+ func NewRampUpRateLimiter(maxThreshold int64, rampUpRate string, refillPeriod time.Duration) (rateLimiter *RampUpRateLimiter, err error)

+ func (limiter *RampUpRateLimiter) Acquire() (blocked bool)

+ func (limiter *RampUpRateLimiter) Start()

+ func (limiter *RampUpRateLimiter) Stop()

+ type RateLimiter interface

+ Acquire func() bool

+ Start func()

+ Stop func()

+ type StableRateLimiter struct

+ func NewStableRateLimiter(threshold int64, refillPeriod time.Duration) (rateLimiter *StableRateLimiter)

+ func (limiter *StableRateLimiter) Acquire() (blocked bool)

+ func (limiter *StableRateLimiter) Start()

+ func (limiter *StableRateLimiter) Stop()

+ type Task struct

+ Fn func()

+ Name string

+ Weight int