@@ -26,7 +26,6 @@ import (
26
26
"github.com/deckhouse/module-sdk/pkg"
27
27
"github.com/deckhouse/module-sdk/pkg/app"
28
28
"github.com/deckhouse/module-sdk/pkg/registry"
29
- "k8s.io/utils/ptr"
30
29
31
30
"hooks/pkg/common"
32
31
@@ -55,7 +54,7 @@ var kvmLabelPatch = []map[string]string{
55
54
var _ = registry .RegisterFunc (configDiscoveryService , handleDiscoveryVirtHandlerNodes )
56
55
57
56
var configDiscoveryService = & pkg.HookConfig {
58
- OnBeforeHelm : & pkg.OrderedConfig {Order : 1 },
57
+ OnBeforeHelm : & pkg.OrderedConfig {Order : 5 },
59
58
Kubernetes : []pkg.KubernetesConfig {
60
59
{
61
60
Name : nodesSnapshot ,
@@ -67,15 +66,16 @@ var configDiscoveryService = &pkg.HookConfig{
67
66
virtHandlerLabel : virtHandlerLabelValue ,
68
67
},
69
68
},
70
- ExecuteHookOnSynchronization : ptr .To (false ),
71
- ExecuteHookOnEvents : ptr .To (false ),
69
+ // ExecuteHookOnSynchronization: ptr.To(false),
70
+ // ExecuteHookOnEvents: ptr.To(false),
72
71
},
73
72
},
74
73
75
74
Queue : fmt .Sprintf ("modules/%s" , common .MODULE_NAME ),
76
75
}
77
76
78
77
func handleDiscoveryVirtHandlerNodes (_ context.Context , input * pkg.HookInput ) error {
78
+ input .Logger .Info ("🟨start🟨" )
79
79
nodes := input .Snapshots .Get (nodesSnapshot )
80
80
if len (nodes ) == 0 {
81
81
return nil
@@ -90,10 +90,10 @@ func handleDiscoveryVirtHandlerNodes(_ context.Context, input *pkg.HookInput) er
90
90
91
91
if _ , ok := nodeInfo .Labels [kvmEnabledLabel ]; ! ok {
92
92
input .PatchCollector .PatchWithJSON (kvmLabelPatch , "v1" , "Node" , "" , nodeInfo .Name )
93
- input .Logger .Error (fmt .Sprintf (logMessageTemplate , kvmEnabledLabel , nodeInfo .Name ))
93
+ input .Logger .Info (fmt .Sprintf (logMessageTemplate , kvmEnabledLabel , nodeInfo .Name ))
94
94
}
95
95
}
96
-
96
+ input . Logger . Info ( "🟧finish🟧" )
97
97
return nil
98
98
}
99
99
0 commit comments