README
¶
LoadTester Trigger
This trigger provides your flogo application the ability to run simple load test on a specified action
Implementation based off go-wrk.
Installation
flogo install github.com/project-flogo/contrib/trigger/loadtester
Configuration
Settings:
| Name | Type | Description |
|---|---|---|
| startDelay | int | The start delay of the test in seconds, default: 30 |
| duration | int | The duration of the test in seconds, default: 60 |
| concurrency | int | The level of concurrency, default: 5 |
| data | any | Optional data to pass along to the action |
| handler | string | The named handler to test, defaults to the first handler |
Output:
| Name | Type | Description |
|---|---|---|
| data | any | The data from the settings to pass along |
Example Configuration
Test Flow
Configure the Trigger to load test the 'flow:testflow'
{
"triggers": [
{
"id": "tester",
"ref": "github.com/project-flogo/contrib/trigger/loadtester",
"settings": {
"startDelay": 15,
"duration": 120,
"concurrency" : 5,
"handler": "test"
},
"handlers": [
{
"name": "test",
"action": {
"ref": "github.com/project-flogo/flow",
"settings": {
"flowURI": "res://flow:testflow"
}
}
}
]
}
]
}
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Factory ¶
type Factory struct {
}
type LoadSession ¶
type LoadSession struct {
// contains filtered or unexported fields
}
func NewLoadSession ¶
func NewLoadSession(duration int, statsAggregator chan *RequesterStats) *LoadSession
func (*LoadSession) Run ¶
func (lt *LoadSession) Run(handler trigger.Handler, data interface{})
func (*LoadSession) Stop ¶
func (lt *LoadSession) Stop()
type LoadTest ¶
type LoadTest struct {
// contains filtered or unexported fields
}
func NewLoadTest ¶
type Output ¶
type Output struct {
Data interface{} `md:"data"` // The data from the settings to pass along
}
type RequesterStats ¶
type RequesterStats struct {
TotDuration time.Duration
MinRequestTime time.Duration
MaxRequestTime time.Duration
NumRequests int
NumErrs int
}
RequesterStats used for collection aggregate statistics
type Settings ¶
type Settings struct {
Concurrency int `md:"concurrency"` // The level of concurrency, default: 5
Duration int `md:"duration"` // The duration of the test in seconds, default: 60
Data interface{} `md:"data"` // Optional data to pass along to the action
Handler string `md:"handler"` // The named handler to test, defaults to the first handler
StartDelay int `md:"startDelay"` // The start delay of the test in seconds, default: 30
}
type Trigger ¶
type Trigger struct {
// contains filtered or unexported fields
}
func (*Trigger) Initialize ¶
func (t *Trigger) Initialize(ctx trigger.InitContext) error
Source Files
Click to show internal directories.
Click to hide internal directories.