autogen indexers

Author: helderjs

internal/generated/indexer/backupcompliancepolicybygroup.go

@@ -0,0 +1,52 @@
+// Copyright 2025 MongoDB Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// 	http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package indexer
+
+import (
+	v1 "github.com/mongodb/mongodb-atlas-kubernetes/v2/internal/nextapi/generated/v1"
+	zap "go.uber.org/zap"
+	client "sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// nolint:dupl
+const BackupCompliancePolicyByGroupIndex = "backupcompliancepolicy.groupRef"
+
+type BackupCompliancePolicyByGroupIndexer struct {
+	logger *zap.SugaredLogger
+}
+
+func NewBackupCompliancePolicyByGroupIndexer(logger *zap.Logger) *BackupCompliancePolicyByGroupIndexer {
+	return &BackupCompliancePolicyByGroupIndexer{logger: logger.Named(BackupCompliancePolicyByGroupIndex).Sugar()}
+}
+func (*BackupCompliancePolicyByGroupIndexer) Object() client.Object {
+	return &v1.BackupCompliancePolicy{}
+}
+func (*BackupCompliancePolicyByGroupIndexer) Name() string {
+	return BackupCompliancePolicyByGroupIndex
+}
+
+// Keys extracts the index key(s) from the given object
+func (i *BackupCompliancePolicyByGroupIndexer) Keys(object client.Object) []string {
+	resource, ok := object.(*v1.BackupCompliancePolicy)
+	if !ok {
+		i.logger.Errorf("expected *v1.BackupCompliancePolicy but got %T", object)
+		return nil
+	}
+	var keys []string
+	if resource.Spec.V20250312.GroupRef != nil && resource.Spec.V20250312.GroupRef.Name != "" {
+		keys = append(keys, resource.Namespace+"/"+resource.Spec.V20250312.GroupRef.Name)
+	}
+	return keys
+}

internal/generated/indexer/backupschedulebygroup.go

@@ -0,0 +1,52 @@
+// Copyright 2025 MongoDB Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// 	http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package indexer
+
+import (
+	v1 "github.com/mongodb/mongodb-atlas-kubernetes/v2/internal/nextapi/generated/v1"
+	zap "go.uber.org/zap"
+	client "sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// nolint:dupl
+const BackupScheduleByGroupIndex = "backupschedule.groupRef"
+
+type BackupScheduleByGroupIndexer struct {
+	logger *zap.SugaredLogger
+}
+
+func NewBackupScheduleByGroupIndexer(logger *zap.Logger) *BackupScheduleByGroupIndexer {
+	return &BackupScheduleByGroupIndexer{logger: logger.Named(BackupScheduleByGroupIndex).Sugar()}
+}
+func (*BackupScheduleByGroupIndexer) Object() client.Object {
+	return &v1.BackupSchedule{}
+}
+func (*BackupScheduleByGroupIndexer) Name() string {
+	return BackupScheduleByGroupIndex
+}
+
+// Keys extracts the index key(s) from the given object
+func (i *BackupScheduleByGroupIndexer) Keys(object client.Object) []string {
+	resource, ok := object.(*v1.BackupSchedule)
+	if !ok {
+		i.logger.Errorf("expected *v1.BackupSchedule but got %T", object)
+		return nil
+	}
+	var keys []string
+	if resource.Spec.V20250312.GroupRef != nil && resource.Spec.V20250312.GroupRef.Name != "" {
+		keys = append(keys, resource.Namespace+"/"+resource.Spec.V20250312.GroupRef.Name)
+	}
+	return keys
+}

internal/generated/indexer/clusterbygroup.go

@@ -0,0 +1,52 @@
+// Copyright 2025 MongoDB Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// 	http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package indexer
+
+import (
+	v1 "github.com/mongodb/mongodb-atlas-kubernetes/v2/internal/nextapi/generated/v1"
+	zap "go.uber.org/zap"
+	client "sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// nolint:dupl
+const ClusterByGroupIndex = "cluster.groupRef"
+
+type ClusterByGroupIndexer struct {
+	logger *zap.SugaredLogger
+}
+
+func NewClusterByGroupIndexer(logger *zap.Logger) *ClusterByGroupIndexer {
+	return &ClusterByGroupIndexer{logger: logger.Named(ClusterByGroupIndex).Sugar()}
+}
+func (*ClusterByGroupIndexer) Object() client.Object {
+	return &v1.Cluster{}
+}
+func (*ClusterByGroupIndexer) Name() string {
+	return ClusterByGroupIndex
+}
+
+// Keys extracts the index key(s) from the given object
+func (i *ClusterByGroupIndexer) Keys(object client.Object) []string {
+	resource, ok := object.(*v1.Cluster)
+	if !ok {
+		i.logger.Errorf("expected *v1.Cluster but got %T", object)
+		return nil
+	}
+	var keys []string
+	if resource.Spec.V20250312.GroupRef != nil && resource.Spec.V20250312.GroupRef.Name != "" {
+		keys = append(keys, resource.Namespace+"/"+resource.Spec.V20250312.GroupRef.Name)
+	}
+	return keys
+}

internal/generated/indexer/customrolebygroup.go

@@ -0,0 +1,52 @@
+// Copyright 2025 MongoDB Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// 	http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package indexer
+
+import (
+	v1 "github.com/mongodb/mongodb-atlas-kubernetes/v2/internal/nextapi/generated/v1"
+	zap "go.uber.org/zap"
+	client "sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// nolint:dupl
+const CustomRoleByGroupIndex = "customrole.groupRef"
+
+type CustomRoleByGroupIndexer struct {
+	logger *zap.SugaredLogger
+}
+
+func NewCustomRoleByGroupIndexer(logger *zap.Logger) *CustomRoleByGroupIndexer {
+	return &CustomRoleByGroupIndexer{logger: logger.Named(CustomRoleByGroupIndex).Sugar()}
+}
+func (*CustomRoleByGroupIndexer) Object() client.Object {
+	return &v1.CustomRole{}
+}
+func (*CustomRoleByGroupIndexer) Name() string {
+	return CustomRoleByGroupIndex
+}
+
+// Keys extracts the index key(s) from the given object
+func (i *CustomRoleByGroupIndexer) Keys(object client.Object) []string {
+	resource, ok := object.(*v1.CustomRole)
+	if !ok {
+		i.logger.Errorf("expected *v1.CustomRole but got %T", object)
+		return nil
+	}
+	var keys []string
+	if resource.Spec.V20250312.GroupRef != nil && resource.Spec.V20250312.GroupRef.Name != "" {
+		keys = append(keys, resource.Namespace+"/"+resource.Spec.V20250312.GroupRef.Name)
+	}
+	return keys
+}

internal/generated/indexer/databaseuserbygroup.go

@@ -0,0 +1,52 @@
+// Copyright 2025 MongoDB Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// 	http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package indexer
+
+import (
+	v1 "github.com/mongodb/mongodb-atlas-kubernetes/v2/internal/nextapi/generated/v1"
+	zap "go.uber.org/zap"
+	client "sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// nolint:dupl
+const DatabaseUserByGroupIndex = "databaseuser.groupRef"
+
+type DatabaseUserByGroupIndexer struct {
+	logger *zap.SugaredLogger
+}
+
+func NewDatabaseUserByGroupIndexer(logger *zap.Logger) *DatabaseUserByGroupIndexer {
+	return &DatabaseUserByGroupIndexer{logger: logger.Named(DatabaseUserByGroupIndex).Sugar()}
+}
+func (*DatabaseUserByGroupIndexer) Object() client.Object {
+	return &v1.DatabaseUser{}
+}
+func (*DatabaseUserByGroupIndexer) Name() string {
+	return DatabaseUserByGroupIndex
+}
+
+// Keys extracts the index key(s) from the given object
+func (i *DatabaseUserByGroupIndexer) Keys(object client.Object) []string {
+	resource, ok := object.(*v1.DatabaseUser)
+	if !ok {
+		i.logger.Errorf("expected *v1.DatabaseUser but got %T", object)
+		return nil
+	}
+	var keys []string
+	if resource.Spec.V20250312.GroupRef != nil && resource.Spec.V20250312.GroupRef.Name != "" {
+		keys = append(keys, resource.Namespace+"/"+resource.Spec.V20250312.GroupRef.Name)
+	}
+	return keys
+}

internal/generated/indexer/datafederationbygroup.go

@@ -0,0 +1,52 @@
+// Copyright 2025 MongoDB Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// 	http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package indexer
+
+import (
+	v1 "github.com/mongodb/mongodb-atlas-kubernetes/v2/internal/nextapi/generated/v1"
+	zap "go.uber.org/zap"
+	client "sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// nolint:dupl
+const DataFederationByGroupIndex = "datafederation.groupRef"
+
+type DataFederationByGroupIndexer struct {
+	logger *zap.SugaredLogger
+}
+
+func NewDataFederationByGroupIndexer(logger *zap.Logger) *DataFederationByGroupIndexer {
+	return &DataFederationByGroupIndexer{logger: logger.Named(DataFederationByGroupIndex).Sugar()}
+}
+func (*DataFederationByGroupIndexer) Object() client.Object {
+	return &v1.DataFederation{}
+}
+func (*DataFederationByGroupIndexer) Name() string {
+	return DataFederationByGroupIndex
+}
+
+// Keys extracts the index key(s) from the given object
+func (i *DataFederationByGroupIndexer) Keys(object client.Object) []string {
+	resource, ok := object.(*v1.DataFederation)
+	if !ok {
+		i.logger.Errorf("expected *v1.DataFederation but got %T", object)
+		return nil
+	}
+	var keys []string
+	if resource.Spec.V20250312.GroupRef != nil && resource.Spec.V20250312.GroupRef.Name != "" {
+		keys = append(keys, resource.Namespace+"/"+resource.Spec.V20250312.GroupRef.Name)
+	}
+	return keys
+}

internal/generated/indexer/flexclusterbygroup.go

@@ -0,0 +1,52 @@
+// Copyright 2025 MongoDB Inc
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// 	http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package indexer
+
+import (
+	v1 "github.com/mongodb/mongodb-atlas-kubernetes/v2/internal/nextapi/generated/v1"
+	zap "go.uber.org/zap"
+	client "sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// nolint:dupl
+const FlexClusterByGroupIndex = "flexcluster.groupRef"
+
+type FlexClusterByGroupIndexer struct {
+	logger *zap.SugaredLogger
+}
+
+func NewFlexClusterByGroupIndexer(logger *zap.Logger) *FlexClusterByGroupIndexer {
+	return &FlexClusterByGroupIndexer{logger: logger.Named(FlexClusterByGroupIndex).Sugar()}
+}
+func (*FlexClusterByGroupIndexer) Object() client.Object {
+	return &v1.FlexCluster{}
+}
+func (*FlexClusterByGroupIndexer) Name() string {
+	return FlexClusterByGroupIndex
+}
+
+// Keys extracts the index key(s) from the given object
+func (i *FlexClusterByGroupIndexer) Keys(object client.Object) []string {
+	resource, ok := object.(*v1.FlexCluster)
+	if !ok {
+		i.logger.Errorf("expected *v1.FlexCluster but got %T", object)
+		return nil
+	}
+	var keys []string
+	if resource.Spec.V20250312.GroupRef != nil && resource.Spec.V20250312.GroupRef.Name != "" {
+		keys = append(keys, resource.Namespace+"/"+resource.Spec.V20250312.GroupRef.Name)
+	}
+	return keys
+}