@@ -21,10 +21,6 @@ import (
21
21
)
22
22
23
23
const (
24
- envOperatorName = "OPERATOR_NAME"
25
- envOperatorNamespace = "OPERATOR_NAMESPACE"
26
- ALMManagedAnnotationKey = "alm-manager"
27
-
28
24
defaultWakeupInterval = 5 * time .Minute
29
25
)
30
26
@@ -75,17 +71,6 @@ func main() {
75
71
os .Exit (0 )
76
72
}
77
73
78
- // Env Vars
79
- operatorNamespace := envOrDie (
80
- envOperatorNamespace , "used to set annotation indicating which ALM operator manages a namespace" )
81
-
82
- operatorName := envOrDie (
83
- envOperatorName , "used to distinguish ALM operators of the same name" )
84
-
85
- annotation := map [string ]string {
86
- ALMManagedAnnotationKey : fmt .Sprintf ("%s.%s" , operatorNamespace , operatorName ),
87
- }
88
-
89
74
// Set log level to debug if `debug` flag set
90
75
if * debug {
91
76
log .SetLevel (log .DebugLevel )
@@ -104,12 +89,11 @@ func main() {
104
89
opClient := operatorclient .NewClientFromConfig (* kubeConfigPath )
105
90
106
91
// Create a new instance of the operator.
107
- operator , err := olm .NewOperator (crClient , opClient , & install.StrategyResolver {}, * wakeupInterval , annotation , namespaces )
92
+ operator , err := olm .NewOperator (crClient , opClient , & install.StrategyResolver {}, * wakeupInterval , namespaces )
108
93
109
94
if err != nil {
110
95
log .Fatalf ("error configuring operator: %s" , err .Error ())
111
96
}
112
- defer operator .Cleanup ()
113
97
114
98
// Serve a health check.
115
99
http .HandleFunc ("/healthz" , func (w http.ResponseWriter , r * http.Request ) {
0 commit comments