Skip to content

Commit 35879ec

Browse files
Merge pull request #84 from enj/enj/i/order_serving_cert
Create the service before waiting for serving certs
2 parents 442eaf1 + 0e5102b commit 35879ec

File tree

1 file changed

+23
-4
lines changed

1 file changed

+23
-4
lines changed

pkg/operator2/operator.go

Lines changed: 23 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -176,6 +176,12 @@ func (c *authOperator) handleSync(operatorConfig *operatorv1.Authentication) err
176176
// we get resource versions so that if either changes, we redeploy our payload
177177
resourceVersions := []string{operatorConfig.GetResourceVersion()}
178178

179+
// The BLOCK sections are highly order dependent
180+
181+
// ==================================
182+
// BLOCK 1: Metadata
183+
// ==================================
184+
179185
route, err := c.handleRoute()
180186
if err != nil {
181187
return err
@@ -195,17 +201,26 @@ func (c *authOperator) handleSync(operatorConfig *operatorv1.Authentication) err
195201
}
196202
resourceVersions = append(resourceVersions, authConfig.GetResourceVersion())
197203

198-
serviceCA, servingCert, err := c.handleServiceCA()
204+
// ==================================
205+
// BLOCK 2: service and service-ca data
206+
// ==================================
207+
208+
// make sure we create the service before we start asking about service certs
209+
service, _, err := resourceapply.ApplyService(c.services, c.recorder, defaultService())
199210
if err != nil {
200211
return err
201212
}
202-
resourceVersions = append(resourceVersions, serviceCA.GetResourceVersion(), servingCert.GetResourceVersion())
213+
resourceVersions = append(resourceVersions, service.GetResourceVersion())
203214

204-
service, _, err := resourceapply.ApplyService(c.services, c.recorder, defaultService())
215+
serviceCA, servingCert, err := c.handleServiceCA()
205216
if err != nil {
206217
return err
207218
}
208-
resourceVersions = append(resourceVersions, service.GetResourceVersion())
219+
resourceVersions = append(resourceVersions, serviceCA.GetResourceVersion(), servingCert.GetResourceVersion())
220+
221+
// ==================================
222+
// BLOCK 3: build cli config
223+
// ==================================
209224

210225
expectedSessionSecret, err := c.expectedSessionSecret()
211226
if err != nil {
@@ -238,6 +253,10 @@ func (c *authOperator) handleSync(operatorConfig *operatorv1.Authentication) err
238253
}
239254
resourceVersions = append(resourceVersions, cliConfig.GetResourceVersion())
240255

256+
// ==================================
257+
// BLOCK 4: deployment
258+
// ==================================
259+
241260
operatorDeployment, err := c.deployments.Deployments(targetNameOperator).Get(targetNameOperator, metav1.GetOptions{})
242261
if err != nil {
243262
return err

0 commit comments

Comments
 (0)