The heartbeat loop updates the heartbeat key if the worker is still alive. If the kill key is set, the worker is killed. This function is called in a callr session.
Usage
heartbeat(
network_id,
config,
worker_id,
heartbeat_key,
heartbeat_period,
heartbeat_expire,
pid
)Arguments
- network_id
(
character(1))
Identifier of the rush network. Manager and workers must have the same id. Keys in Redis are prefixed with the instance id.- config
(redux::redis_config)
Redis configuration options.- worker_id
(
character(1))
Identifier of the worker. Keys in redis specific to the worker are prefixed with the worker id.- heartbeat_key
(
character(1))
Heartbeat key.- heartbeat_period
(
integer(1))
Period of the heartbeat in seconds. The heartbeat is updated everyheartbeat_periodseconds. Must be at least 1 second.- heartbeat_expire
(
integer(1))
Time to live of the heartbeat in seconds. The heartbeat key is set to expire afterheartbeat_expireseconds. Must be at leastheartbeat_period, otherwise a live worker is reaped as lost between two heartbeats. Set it larger than the longest pause a worker may experience, for example from garbage collection or swapping, because a live worker wrongly declared lost can leave a task in an inconsistent state.- pid
(
integer(1))
Process ID of the worker.