Skip to content

Commit b133c25

Browse files
authored
[Feature] [Platform] Kubernetes Events (#1983)
1 parent 8761cf6 commit b133c25

File tree

3 files changed

+11
-0
lines changed

3 files changed

+11
-0
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
- (Feature) (Platform) Allows to opt out in the Inventory Telemetry
1111
- (Feature) Simplify Operator ID Process
1212
- (Feature) (License) Activation API Integration
13+
- (Feature) (Platform) Chart & Service Kubernetes Events
1314

1415
## [1.3.1](https://github.com/arangodb/kube-arangodb/tree/1.3.1) (2025-10-07)
1516
- (Documentation) Add ArangoPlatformStorage Docs & Examples

pkg/handlers/platform/chart/handler.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -179,6 +179,8 @@ func (h *handler) HandleSpecData(ctx context.Context, item operation.Item, exten
179179
Details: chartInfoExtract(chart.Chart(), platform),
180180
}
181181

182+
h.eventRecorder.Normal(extension, "Chart Accepted", "Chart Accepted with checksum: %s", checksum)
183+
182184
return true, operator.Reconcile("Spec changed")
183185
}
184186

pkg/handlers/platform/service/handler.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -368,11 +368,14 @@ func (h *handler) HandleRelease(ctx context.Context, item operation.Item, extens
368368
in.Timeout = 20 * time.Minute
369369
})
370370
if err != nil {
371+
h.eventRecorder.Warning(extension, "Release Install Failed", "Release Install failed: %s", err.Error())
371372
return false, err
372373
}
373374

374375
status.Release = extractReleaseStatus(release, expectedChecksum)
375376

377+
h.eventRecorder.Normal(extension, "Release Installed", "Release installed with version %d on chart %s (%s)", status.Release.Version, status.ChartInfo.Details.Name, status.ChartInfo.Details.Version)
378+
376379
return true, operator.Reconcile("Release Installed")
377380
} else if !labels.IsPlatformManaged(release) {
378381
return false, operator.Stop("Release already installed")
@@ -398,10 +401,15 @@ func (h *handler) HandleRelease(ctx context.Context, item operation.Item, extens
398401
in.Timeout = 20 * time.Minute
399402
})
400403
if err != nil {
404+
h.eventRecorder.Warning(extension, "Release Upgrade Failed", "Release upgrade failed: %s", err.Error())
405+
401406
return false, err
402407
}
403408

404409
status.Release = extractReleaseStatus(release, expectedChecksum)
410+
411+
h.eventRecorder.Normal(extension, "Release Upgraded", "Release upgraded with version %d on chart %s (%s)", status.Release.Version, status.ChartInfo.Details.Name, status.ChartInfo.Details.Version)
412+
405413
return true, operator.Reconcile("Release Upgraded")
406414
}
407415

0 commit comments

Comments
 (0)