boomer

Jul 6, 2022

Changes in this version

type RunContext

+ BoolStore map[string]bool

+ IntStore map[string]int

+ TaskLoop bool

+ TaskLoopID int

Dec 29, 2021

Changes in this version

+ const DefaultVersion

+ func SetVersion(version string)

type Boomer

+ func (b *Boomer) SetVersion(v string)

Mar 22, 2021

Changes in this version

type RunContext

+ RunHost string

+ func (ctx RunContext) ToString() string

Mar 18, 2021

Changes in this version

type RunContext

+ RspCookie string

+ RspHead string

+ RspJSON string

+ RspStatus int

+ RspText string

+ RunSeq int

+ Store map[string]string

Mar 12, 2021

Changes in this version

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

+ var Events = EventBus.New()

+ func GetCurrentCPUUsage() float64

+ func MD5(slice ...string) string

+ func Now() int64

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

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

+ func Run(tasks ...*Task)

+ func StartCPUProfile(file string, duration time.Duration) (err error)

+ func StartMemoryProfile(file string, duration time.Duration) (err error)

+ type Boomer struct

+ func NewBoomer(masterHost string, masterPort int) *Boomer

+ 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) Run(tasks ...*Task)

+ func (b *Boomer) SetMode(mode Mode)

+ func (b *Boomer) SetRateLimiter(rateLimiter RateLimiter)

+ type ConsoleOutput struct

+ func NewConsoleOutput() *ConsoleOutput

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

+ func (o *ConsoleOutput) OnStart()

+ func (o *ConsoleOutput) OnStop()

+ type Mode int

+ const DistributedMode

+ const StandaloneMode

+ type Output interface

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

+ OnStart func()

+ OnStop func()

+ 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 RunContext struct

+ Data map[string]string

+ ID int

+ func NewRunContext() *RunContext

+ 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(ctx *RunContext)

+ Name string

+ Weight int

+ type TaskSet interface

+ AddTask func(task *Task)

+ GetWeight func() (weight int)

+ Run func()

+ SetWeight func(weight int)

+ type WeighingTaskSet struct

+ func NewWeighingTaskSet() *WeighingTaskSet

+ func (ts *WeighingTaskSet) AddTask(task *Task)

+ func (ts *WeighingTaskSet) GetTask(roll int) (task *Task)

+ func (ts *WeighingTaskSet) GetWeight() (weight int)

+ func (ts *WeighingTaskSet) Run(ctx *RunContext)

+ func (ts *WeighingTaskSet) SetWeight(weight int)