A Kubernetes operator that bridges Hardware Security Module (HSM) data storage with Kubernetes Secrets, providing true secret portability th
fix tests
+12
-8
+6
-2
internal/controller/hsmpool_agent_controller.go
+6
-2
internal/controller/hsmpool_agent_controller.go
···
76
76
continue
77
77
}
78
78
79
-
if err := r.AgentManager.EnsureAgent(ctx, &hsmDevice, nil); err != nil {
80
-
logger.Error(err, "Failed to ensure HSM agents for pool", "device", deviceRef)
79
+
if r.AgentManager != nil {
80
+
if err := r.AgentManager.EnsureAgent(ctx, &hsmDevice, nil); err != nil {
81
+
logger.Error(err, "Failed to ensure HSM agents for pool", "device", deviceRef)
82
+
}
83
+
} else {
84
+
logger.Error(fmt.Errorf("agent manager not configured"), "Cannot ensure agents without agent manager")
81
85
}
82
86
}
83
87
} else {
+6
-6
internal/controller/hsmpool_agent_controller_test.go
+6
-6
internal/controller/hsmpool_agent_controller_test.go
···
149
149
}
150
150
151
151
// Clean up any agent deployments that might have been created
152
-
agentName := fmt.Sprintf("hsm-agent-%s", hsmDeviceName)
152
+
agentName := fmt.Sprintf("hsm-agent-%s-0", hsmDeviceName)
153
153
deployment := &appsv1.Deployment{
154
154
ObjectMeta: metav1.ObjectMeta{
155
155
Name: agentName,
···
184
184
Expect(err).NotTo(HaveOccurred())
185
185
186
186
By("Checking that agent deployment was created")
187
-
agentName := fmt.Sprintf("hsm-agent-%s", hsmDeviceName)
187
+
agentName := fmt.Sprintf("hsm-agent-%s-0", hsmDeviceName)
188
188
deployment := &appsv1.Deployment{}
189
189
Eventually(func() error {
190
190
return k8sClient.Get(ctx, types.NamespacedName{
···
256
256
Expect(err).NotTo(HaveOccurred())
257
257
258
258
By("Checking that no agent deployment was created")
259
-
agentName := fmt.Sprintf("hsm-agent-%s", hsmDeviceName)
259
+
agentName := fmt.Sprintf("hsm-agent-%s-0", hsmDeviceName)
260
260
deployment := &appsv1.Deployment{}
261
261
Consistently(func() error {
262
262
return k8sClient.Get(ctx, types.NamespacedName{
···
296
296
Expect(err).NotTo(HaveOccurred())
297
297
298
298
By("Checking that no agent deployment was created")
299
-
agentName := fmt.Sprintf("hsm-agent-%s", hsmDeviceName)
299
+
agentName := fmt.Sprintf("hsm-agent-%s-0", hsmDeviceName)
300
300
deployment := &appsv1.Deployment{}
301
301
Consistently(func() error {
302
302
return k8sClient.Get(ctx, types.NamespacedName{
···
391
391
Expect(err).NotTo(HaveOccurred())
392
392
393
393
By("Checking that no agent deployment was created")
394
-
agentName := fmt.Sprintf("hsm-agent-%s", hsmDeviceName)
394
+
agentName := fmt.Sprintf("hsm-agent-%s-0", hsmDeviceName)
395
395
deployment := &appsv1.Deployment{}
396
396
Consistently(func() error {
397
397
return k8sClient.Get(ctx, types.NamespacedName{
···
418
418
Expect(err).NotTo(HaveOccurred())
419
419
420
420
By("Verifying agent deployment exists")
421
-
agentName := fmt.Sprintf("hsm-agent-%s", hsmDeviceName)
421
+
agentName := fmt.Sprintf("hsm-agent-%s-0", hsmDeviceName)
422
422
deployment := &appsv1.Deployment{}
423
423
Eventually(func() error {
424
424
return k8sClient.Get(ctx, types.NamespacedName{