[PATCH compass-ci 2/2] feat: redis: add a function to get a seq number
[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
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
participants (1)
-
Ren Wen