Skip to content

Commit

Permalink
inedexer: use cluster rather than manager (#2057)
Browse files Browse the repository at this point in the history
  • Loading branch information
s-urbaniak authored Jan 21, 2025
1 parent 0f1f800 commit ffa5e30
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions internal/indexer/indexer.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (

"go.uber.org/zap"
"sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/manager"
"sigs.k8s.io/controller-runtime/pkg/cluster"
)

type Indexer interface {
Expand All @@ -18,9 +18,9 @@ type Indexer interface {
// RegisterAll registers all known indexers to the given manager.
// It uses the given logger to create a new named "indexer" logger,
// passing that to each indexer.
func RegisterAll(ctx context.Context, mgr manager.Manager, logger *zap.Logger) error {
func RegisterAll(ctx context.Context, c cluster.Cluster, logger *zap.Logger) error {
logger = logger.Named("indexer")
return Register(ctx, mgr,
return Register(ctx, c,
NewAtlasBackupScheduleByBackupPolicyIndexer(logger),
NewAtlasDeploymentByBackupScheduleIndexer(logger),
NewAtlasDeploymentBySearchIndexIndexer(logger),
Expand All @@ -34,7 +34,7 @@ func RegisterAll(ctx context.Context, mgr manager.Manager, logger *zap.Logger) e
NewAtlasDatabaseUserBySecretsIndexer(logger),
NewAtlasDatabaseUserByCredentialIndexer(logger),
NewAtlasDeploymentByCredentialIndexer(logger),
NewAtlasDatabaseUserByProjectIndexer(ctx, mgr.GetClient(), logger),
NewAtlasDatabaseUserByProjectIndexer(ctx, c.GetClient(), logger),
NewAtlasDataFederationByProjectIndexer(logger),
NewAtlasCustomRoleByCredentialIndexer(logger),
NewAtlasCustomRoleByProjectIndexer(logger),
Expand All @@ -44,9 +44,9 @@ func RegisterAll(ctx context.Context, mgr manager.Manager, logger *zap.Logger) e
}

// Register registers the given indexers to the given manager's field indexer.
func Register(ctx context.Context, mgr manager.Manager, indexers ...Indexer) error {
func Register(ctx context.Context, c cluster.Cluster, indexers ...Indexer) error {
for _, indexer := range indexers {
err := mgr.GetFieldIndexer().IndexField(ctx, indexer.Object(), indexer.Name(), indexer.Keys)
err := c.GetFieldIndexer().IndexField(ctx, indexer.Object(), indexer.Name(), indexer.Keys)
if err != nil {
return fmt.Errorf("error registering indexer %q: %w", indexer.Name(), err)
}
Expand Down

0 comments on commit ffa5e30

Please sign in to comment.