I’m trying to build a chain where I test a system consisting of following:
ComponentA (Storage) → ComponentB (Feed) → ComponentC (Search).
When a new event is posted into ComponentA, it is pushed to ComponentB and eventually it will be available for search in ComponentC (which is reading the feed and indexing new events).
Usually it is around 300ms to 1second from a event is stored in Component A until it is available on the feed on Component B, and around 5 seconds untill it is possible to find the event in component C.
My goal is to create a test that both validates that the chain is working as it should, but also to check the time it takes to complete the tests. (To be able to determine if changes we make to the system is improving the systems performance, or
if we are making it worse).
Setup:
Component A - B and C are running on different servers:
Component A: host1 - port 9000
Component B: host1 - port 10000
Component C: host2 - port 14000
I’ve been looking at using Group() together with tryMax() for the total duration a chain takes (with the useGroupDurationMetric option set to true). But I think I have misunderstood how to set this up correctly.
Example code (might have spelling errors):
`
class ValueChain extends Simulation {
object Test {
val test = during(duration) {
group(“Post to feed to search”){
exec(http(“Post event”)
.post(“http://host1:9000/path/to/post”)
.body(StringBody("""{}"""").asJSON
.check(status.is(201),
jsonPath("$.id").is(“CorrectID”).saveAs(“createdID”))
)
// Read the Feed - check that it contains the ID
tryMax(1000) {
.exec(http(“Read Feed”)
.get(“http://host1:10000/feed/url”)
.check(status.is(200),
regex("${createdID}").find(1)))
}
tryMax(1000)
// Search for the createdID
.exec(http(“Perform serach after the createdID”)
.get(“http://host2:14000/search”)
.queryParam(“query”,“id:${createdID}”)
.check(status.is(200),jsonPath(".$result.hits").ofType[Int].is(1)))
}
}
}
val scn = scenario(“Testing chain”).exec(Test.test)
setUp(scn.inject(atOnceUsers(1)))
}
`
The example give above does not work. What I’m trying to do is:
- Post an event to ComponentA
- Poll the feed untill it contains the created event
- Poll the search untill it has the event as a result.
I’ve also looked at https://groups.google.com/d/msg/gatling/0VIBWIS_sNE/ER500ZIOEf0J to be attempt to create a back-off delay between retries when polling, but that has unfortunately not worked for me either…
Hopefully someone has an idea of how this should be done correctly. Any help is deeply appreciated!