rio
rio copied to clipboard
susamn
A lightweight job scheduler based on priority queue with timeout, retry, replica, context cancellation and easy semantics for job chaining. Build for golang web apps.
It would be cool to have a fanout of dependent calls based on one parent call response. Like this: Call 1 -->Bridge data ==> Call 2 & Call 3 in...
There should be a method in balancer to know how many jobs are queued and how the workers are responding
If * timeout is unset * Context is not cancelled * Network call is not responding The worker should abandon the request and continue, closing the request CompletedChannel with the...
We need to write test cases for calculating the resource utilization and if there are any unaccounted goroutines leaks. Use the following package to count the number of goroutines. `runtime.NumGoroutine()`
We have to write proper test case for the `pool.go file`. It's a priority queue based on the `heap` interface. The existing `pool_test.go` file does not have enough test case...
Currently, we post new job to balancer and wait on the request CompletedChannel from the user side, like this: `balancer.PostJob(request)` `