Package org.apache.storm.nimbus

# Interface IWorkerHeartbeatsRecoveryStrategy

All Known Implementing Classes:
  `TimeOutWorkerHeartbeatsRecoveryStrategy`

public interface IWorkerHeartbeatsRecoveryStrategy
Interface for strategy to recover heartbeats when master gains leadership.

- ## Method Summary

  Modifier and Type
  Method
  Description
  `boolean`
  `isReady(Set<String> nodeIds)`
  Function to decide if the heartbeats is ready.
  `void`
  `prepare(Map conf)`
  Function to prepare the strategy.
  `void`
  `reportNodeId(String nodeId)`
  report the node id to this strategy to help to decide `isReady`.

- ## Method Details

  - ### prepare

    void prepare(Map conf)
    Function to prepare the strategy.
    Parameters:
      `conf` - config

  - ### isReady

    boolean isReady(Set<String> nodeIds)
    Function to decide if the heartbeats is ready.
    Parameters:
      `nodeIds` - all the node ids from current physical plan[assignments], read from `ClusterState`
    Returns:
      true if all node worker heartbeats reported

  - ### reportNodeId

    void reportNodeId(String nodeId)
    report the node id to this strategy to help to decide `isReady`.
    Parameters:
      `nodeId` - the node id from reported SupervisorWorkerHeartbeats