75
logger log.Logger,
76
metricsHandler metrics.Handler,
78
>
return &reschedulerImpl{
79
>
scheduler: scheduler,
80
>
timeSource: timeSource,
81
>
logger: logger,
82
>
metricsHandler: metricsHandler,
83
>
84
>
status: common.DaemonStatusInitialized,
85
>
shutdownCh: make(chan struct{}),
86
>
87
>
timerGate: timer.NewLocalGate(timeSource),
88
>
taskChannelKeyFn: scheduler.TaskChannelKeyFn(),
89
>
90
>
pqMap: make(map[TaskChannelKey]collection.Queue[rescheduledExecuable]),
91
>
}
92
>
}
93
94
func (r *reschedulerImpl) Start() {