setWorkerHeartbeat method

@override Future<void> setWorkerHeartbeat(WorkerHeartbeat heartbeat)

Stores or refreshes a worker heartbeat entry.

Implementation

@override
/// Stores or refreshes a worker heartbeat entry.
Future<void> setWorkerHeartbeat(WorkerHeartbeat heartbeat) async {
  final expiresAt = stemNow().add(heartbeatTtl);
  _heartbeats[heartbeat.workerId] = _HeartbeatEntry(
    heartbeat: heartbeat,
    expiresAt: expiresAt,
  );
  _scheduleHeartbeatExpiry(heartbeat.workerId, heartbeatTtl);
}