mirror of
https://github.com/projectcapsule/capsule.git
synced 2026-08-19 20:46:42 +00:00
Oliver BählerandGitHub
99e05220ab
* feat: implement performance optimizations --------- Signed-off-by: Oliver Baehler <oliver@sudo-i.net>
65 lines
1.7 KiB
Go
65 lines
1.7 KiB
Go
// Copyright 2020-2026 Project Capsule Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package tenant
|
|
|
|
import (
|
|
"context"
|
|
|
|
"k8s.io/client-go/util/workqueue"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
"sigs.k8s.io/controller-runtime/pkg/event"
|
|
"sigs.k8s.io/controller-runtime/pkg/handler"
|
|
"sigs.k8s.io/controller-runtime/pkg/reconcile"
|
|
|
|
capsulev1beta2 "github.com/projectcapsule/capsule/api/v1beta2"
|
|
)
|
|
|
|
type tenantClassCollector func(context.Context, *capsulev1beta2.Tenant) error
|
|
|
|
func (r *Manager) tenantClassEventHandler(collector tenantClassCollector) handler.Funcs {
|
|
syncClasses := func(ctx context.Context) {
|
|
r.syncTenantClasses(ctx, collector)
|
|
}
|
|
|
|
return handler.Funcs{
|
|
CreateFunc: func(
|
|
ctx context.Context,
|
|
_ event.TypedCreateEvent[client.Object],
|
|
_ workqueue.TypedRateLimitingInterface[reconcile.Request],
|
|
) {
|
|
syncClasses(ctx)
|
|
},
|
|
UpdateFunc: func(
|
|
ctx context.Context,
|
|
_ event.TypedUpdateEvent[client.Object],
|
|
_ workqueue.TypedRateLimitingInterface[reconcile.Request],
|
|
) {
|
|
syncClasses(ctx)
|
|
},
|
|
DeleteFunc: func(
|
|
ctx context.Context,
|
|
_ event.TypedDeleteEvent[client.Object],
|
|
_ workqueue.TypedRateLimitingInterface[reconcile.Request],
|
|
) {
|
|
syncClasses(ctx)
|
|
},
|
|
}
|
|
}
|
|
|
|
func (r *Manager) syncTenantClasses(ctx context.Context, collector tenantClassCollector) {
|
|
var tenants capsulev1beta2.TenantList
|
|
if err := r.List(ctx, &tenants); err != nil {
|
|
r.Log.Error(err, "cannot list Tenants for class sync")
|
|
|
|
return
|
|
}
|
|
|
|
for i := range tenants.Items {
|
|
name := tenants.Items[i].Name
|
|
if err := r.updateTenantClassStatus(ctx, name, collector); err != nil {
|
|
r.Log.Error(err, "cannot update Tenant class status", "tenant", name)
|
|
}
|
|
}
|
|
}
|