mirror of
https://github.com/projectcapsule/capsule.git
synced 2026-08-21 05:26:56 +00:00
Oliver BählerandGitHub
99e05220ab
* feat: implement performance optimizations --------- Signed-off-by: Oliver Baehler <oliver@sudo-i.net>
74 lines
2.5 KiB
Go
74 lines
2.5 KiB
Go
// Copyright 2020-2026 Project Capsule Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package indexers
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/go-logr/logr"
|
|
extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
|
|
networkingv1 "k8s.io/api/networking/v1"
|
|
networkingv1beta1 "k8s.io/api/networking/v1beta1"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
"sigs.k8s.io/controller-runtime/pkg/manager"
|
|
|
|
capsulev1beta2 "github.com/projectcapsule/capsule/api/v1beta2"
|
|
"github.com/projectcapsule/capsule/pkg/runtime/indexers/customquota"
|
|
"github.com/projectcapsule/capsule/pkg/runtime/indexers/ingress"
|
|
"github.com/projectcapsule/capsule/pkg/runtime/indexers/namespace"
|
|
"github.com/projectcapsule/capsule/pkg/runtime/indexers/resourcepool"
|
|
"github.com/projectcapsule/capsule/pkg/runtime/indexers/tenant"
|
|
"github.com/projectcapsule/capsule/pkg/runtime/indexers/tenantowner"
|
|
"github.com/projectcapsule/capsule/pkg/runtime/indexers/tenantresource"
|
|
"github.com/projectcapsule/capsule/pkg/utils"
|
|
)
|
|
|
|
type CustomIndexer interface {
|
|
Object() client.Object
|
|
Field() string
|
|
Func() client.IndexerFunc
|
|
}
|
|
|
|
func AddToManager(ctx context.Context, log logr.Logger, mgr manager.Manager) error {
|
|
indexers := []CustomIndexer{
|
|
tenantowner.OwnerNameReference{},
|
|
tenant.NamespacesReference{Obj: &capsulev1beta2.Tenant{}},
|
|
tenantresource.GlobalServiceAccount{},
|
|
tenantresource.GlobalProcessedItems{},
|
|
tenantresource.GlobalCreatedItems{},
|
|
tenantresource.NamespacedServiceAccount{},
|
|
tenantresource.NamespacedProcessedItems{},
|
|
tenantresource.NamespacedResourceNamespace{},
|
|
tenantresource.NamespacedCreatedItems{},
|
|
tenantresource.GlobalDependencies{},
|
|
tenantresource.NamespacedDependencies{},
|
|
customquota.NamespacedTargetReference{},
|
|
customquota.NamespacedObjectUIDReference{},
|
|
customquota.GlobalTargetReference{},
|
|
customquota.GlobalObjectUIDReference{},
|
|
resourcepool.NamespacesReference{Obj: &capsulev1beta2.ResourcePool{}},
|
|
resourcepool.PoolUIDReference{Obj: &capsulev1beta2.ResourcePoolClaim{}},
|
|
tenant.OwnerReference{},
|
|
namespace.OwnerReference{},
|
|
ingress.HostnamePath{Obj: &extensionsv1beta1.Ingress{}},
|
|
ingress.HostnamePath{Obj: &networkingv1beta1.Ingress{}},
|
|
ingress.HostnamePath{Obj: &networkingv1.Ingress{}},
|
|
}
|
|
|
|
for _, f := range indexers {
|
|
if err := mgr.GetFieldIndexer().IndexField(ctx, f.Object(), f.Field(), f.Func()); err != nil {
|
|
if utils.IsUnsupportedAPI(err) {
|
|
log.Info(fmt.Sprintf("skipping setup of Indexer %T for object %T", f, f.Object()), "error", err.Error())
|
|
|
|
continue
|
|
}
|
|
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|