@@ -285,15 +285,15 @@ func (hm *Manager) GetHooksInOrder(bindingType htypes.BindingType) ([]string, er
285
285
return hooksNames , nil
286
286
}
287
287
288
- func (hm * Manager ) HandleCreateTasksFromKubeEvent (kubeEvent kemtypes.KubeEvent , createTaskFn func (* Hook , controller.BindingExecutionInfo ) task.Task ) []task.Task {
288
+ func (hm * Manager ) CreateTasksFromKubeEvent (kubeEvent kemtypes.KubeEvent , createTaskFn func (* Hook , controller.BindingExecutionInfo ) task.Task ) []task.Task {
289
289
kubeHooks , _ := hm .GetHooksInOrder (htypes .OnKubernetesEvent )
290
290
tasks := make ([]task.Task , 0 )
291
291
292
292
for _ , hookName := range kubeHooks {
293
293
h := hm .GetHook (hookName )
294
294
295
295
if h .HookController .CanHandleKubeEvent (kubeEvent ) {
296
- task := h .HookController .HandleCreateTaskFromKubeEvent (kubeEvent , func (info controller.BindingExecutionInfo ) task.Task {
296
+ task := h .HookController .HandleKubeEventWithFormTask (kubeEvent , func (info controller.BindingExecutionInfo ) task.Task {
297
297
if createTaskFn != nil {
298
298
return createTaskFn (h , info )
299
299
}
@@ -317,7 +317,7 @@ func (hm *Manager) HandleCreateTasksFromScheduleEvent(crontab string, createTask
317
317
for _ , hookName := range schHooks {
318
318
h := hm .GetHook (hookName )
319
319
if h .HookController .CanHandleScheduleEvent (crontab ) {
320
- newTasks := h .HookController .HandleCreateTasksFromScheduleEvent (crontab , func (info controller.BindingExecutionInfo ) task.Task {
320
+ newTasks := h .HookController .HandleScheduleEventWithFormTasks (crontab , func (info controller.BindingExecutionInfo ) task.Task {
321
321
if createTaskFn != nil {
322
322
return createTaskFn (h , info )
323
323
}
0 commit comments