package christie.topology.manager.keepalive;

import christie.annotation.Peek;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;

import java.util.List;

public class CreateTask extends CodeGear{
    @Peek
    List<String> _CLIST;
    @Peek
    ListManager _SCHEDULER;

    public static int INTERVAL = 5;

    public CreateTask(){
    }

    @Override
    protected void run(CodeGearManager cgm){
        int i = INTERVAL;
        for (String manager : _CLIST){
            TaskInfo task = new TaskInfo(TaskType.PING);
            task.setInfo(manager, "_FORM_"+manager, i * 1000);
            _SCHEDULER.addTask(task);
            i +=INTERVAL;
        }
        getLocalDGM().put("_SCHEDULER", _SCHEDULER);

    }
}