Page History

public interface BlocklistTracker {
    /** Starts the blocklist tracker. */
    void start(ComponentMainThreadExecutor mainThreadExecutor);

    /**
     * Add new blocked items or update existing items.
     *
     * @param items The items to add or update
     * @return Newly added or updated items.
     */
    Collection<BlockedItem<?>> addNewBlockedItems(Collection<BlockedItem<?>> items);

    /** Returns whether the given task manager is blocked. */
    boolean isBlockedTaskManager(ResourceID resourceID);

    /** Get all blocked nodes. */
    Set<String> getBlockedNodes();

    /** CloseRemove the blocklisttimeout trackeritems. */
    void closeremoveTimeoutItems();
}
     

public interface BlocklistHandler extends BlocklistTracker {

    /** Add a new blocked node. */
    void blockNode(String nodeId, BlockAction action, String cause, long startTimestamp, long endTimestamp);

    /** Add a new blocked task manager. */
    void blockTaskManager(ResourceID taskManagerId, BlockAction action, String cause, long startTimestamp, long endTimestamp);

    /** Returns whether the given task manager is blocked. */
    boolean isBlockedTaskManager(ResourceID resourceID);

    /** Get all blocked nodes. */
    Set<String> getBlockedNodes();    
}

public interface JobMasterBlocklistHandler extends BlocklistHandler {
}