Ktor client load test

LoadTest.kt

class InvocationService(val client: HttpClient) {
    val tasks = mutableListOf<InvocationTask>()

    fun start(invocations: Int){
        val invocation = InvocationTask(invocations, client)
        tasks.add(invocation)
        invocation.start()
    }
}

class InvocationTask(val invocations: Int, @JsonIgnore val client: HttpClient) : CoroutineScope {
    var status = TaskStatus.STOPPED
    @JsonIgnore
    private val host = "<redacted>"
    @JsonIgnore
    private val job = Job()
    var startTime: LocalDateTime? = null
    var endTime: LocalDateTime? = null
    val id = UUID.randomUUID().toString()
    override val coroutineContext: CoroutineContext
        @JsonIgnore
        get() = Dispatchers.Default + job

    @JsonIgnore
    private val channel = Channel<ExecutionEvent>()
    val invocationCount = AtomicInteger(0)
    val requestTime = AtomicLong(0)
    val delayTime = AtomicInteger(0)

    fun start() {
        status = TaskStatus.RUNNING
        launch(Dispatchers.Default) {
            for(event in channel){
                requestTime.addAndGet(event.requestTime)
                delayTime.addAndGet(event.pause)
                if(invocationCount.get() == 0) {
                    startTime = LocalDateTime.now()
                }
                if(invocationCount.get() == invocations){
                    endTime = LocalDateTime.now()
                    status = TaskStatus.FINISHED
                }
                invocationCount.incrementAndGet()
            }
        }
        for(i in 0..invocations){
            launch {
                val response = client.call(host).response
                val result = mapper.readValue<FunctionResponse>(response.readBytes())
                val requestTime = response.responseTime.timestamp - response.requestTime.timestamp
                channel.send(ExecutionEvent(requestTime = requestTime, pause = result.pause))
            }
        }
    }
}