[Why] Need to allocate ips to nodes when running a cluster job. A seq number 'n' used to divide ip regions, to avoid ip conflict when more than 1 cluster jobs running at same time.
Signed-off-by: Ren Wen 15991987063@163.com --- src/scheduler/redis_client.cr | 4 ++++ 1 file changed, 4 insertions(+)
diff --git a/src/scheduler/redis_client.cr b/src/scheduler/redis_client.cr index b816d67..7675056 100644 --- a/src/scheduler/redis_client.cr +++ b/src/scheduler/redis_client.cr @@ -28,6 +28,10 @@ class Redis::Client @client.hdel(key, field.to_s) end
+ def get_seqno + @client.incr("sched/seqno") + end + def get_job(job_id : String) job_hash = @client.hget("sched/id2job", job_id) if !job_hash
Please ignore this mail.
On Wed, Oct 21, 2020 at 04:32:30PM +0800, Ren Wen wrote:
[Why] Need to allocate ips to nodes when running a cluster job. A seq number 'n' used to divide ip regions, to avoid ip conflict when more than 1 cluster jobs running at same time.
Signed-off-by: Ren Wen 15991987063@163.com
src/scheduler/redis_client.cr | 4 ++++ 1 file changed, 4 insertions(+)
diff --git a/src/scheduler/redis_client.cr b/src/scheduler/redis_client.cr index b816d67..7675056 100644 --- a/src/scheduler/redis_client.cr +++ b/src/scheduler/redis_client.cr @@ -28,6 +28,10 @@ class Redis::Client @client.hdel(key, field.to_s) end
- def get_seqno
- @client.incr("sched/seqno")
- end
- def get_job(job_id : String) job_hash = @client.hget("sched/id2job", job_id) if !job_hash
-- 2.23.0
-
Ren Wen