R/register.R

Defines functions register_worker remove_worker get_worker_table

#'@export
register_worker <- function(worker_id) {
  rredis::redisHSet("worker_table", worker_id, TRUE)
}

#'@export
remove_worker <- function(worker_id) {
  rredis::redisHDel("worker_table", worker_id)
}

#'@export
get_worker_table <- function() {
  rredis::redisHGetAll("worker_Table")
}
wush978/RzmqJobQueue documentation built on May 4, 2019, 12:02 p.m.