indexer

package
v2.10.0-original Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 2, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AtlasStreamInstanceByConnectionIndex = "atlasstreaminstance.spec.connectionRegistry"
	AtlasStreamInstanceByProjectIndex    = "atlasstreaminstance.spec.projectRef"
)
View Source 
const (
	AtlasBackupScheduleByBackupPolicyIndex = "atlasbackupschedule.spec.policyRef"
)
View Source 
const (
	AtlasCustomRoleByProject = "atlascustomrole.spec.projectRef"
)
View Source 
const (
	AtlasCustomRoleCredentialsIndex = "atlascustomrole.credentials"
)
View Source 
const (
	AtlasDataFederationByProject = "atlasdatafederation.spec.project"
)
View Source 
const (
	AtlasDatabaseUserByProject = "atlasdatabaseuser.spec.projectRef,externalProjectID"
)
View Source 
const (
	AtlasDatabaseUserBySecretsIndex = "atlasdatabaseuser.spec.passwordSecret"
)
View Source 
const (
	AtlasDatabaseUserCredentialsIndex = "atlasdatabaseuser.credentials"
)
View Source 
const (
	AtlasDeploymentByBackupScheduleIndex = "atlasdeployment.spec.backupScheduleRef"
)
View Source 
const (
	AtlasDeploymentBySearchIndexIndex = "atlasdeployment.spec.deploymentSpec.searchIndexes"
)
View Source 
const (
	AtlasDeploymentCredentialsIndex = "atlasdeployment.credentials"
)
View Source 
const (
	AtlasFederatedAuthBySecretsIndex = "atlasfederatedauth.spec.connectionSecret"
)
View Source 
const (
	AtlasIPAccessListByProjectIndex = "atlasipaccesslist.spec.projectRef"
)
View Source 
const (
	AtlasIPAccessListCredentialsIndex = "atlasipaccesslist.credentials"
)
View Source 
const (
	AtlasNetworkContainerByProjectIndex = "atlasnetworkcontainer.spec.projectRef"
)
View Source 
const (
	AtlasNetworkContainerCredentialsIndex = "atlasnetworkcontainer.credentials"
)
View Source 
const (
	AtlasNetworkPeeringByContainerIndex = "atlasnetworkpeering.spec.container"
)
View Source 
const (
	AtlasNetworkPeeringByProjectIndex = "atlasnetworkpeering.spec.projectRef"
)
View Source 
const (
	AtlasNetworkPeeringCredentialsIndex = "atlasnetworkpeering.credentials"
)
View Source 
const (
	AtlasPrivateEndpointByProjectIndex = "atlasprivateendpoint.spec.projectRef"
)
View Source 
const (
	AtlasPrivateEndpointCredentialsIndex = "atlasprivateendpoint.credentials"
)
View Source 
const (
	AtlasProjectByBackupCompliancePolicyIndex = "atlasproject.spec.backupCompliancePolicyRef"
)
View Source 
const (
	AtlasProjectBySecretsIndex = "atlasproject.spec.secrets"
)
View Source 
const (
	AtlasProjectByTeamIndex = "atlasproject.spec.teams"
)
View Source 
const AtlasStreamConnectionBySecretIndex = "atlasstreamconnection.spec.kafkaConfig"

nolint:gosec,stylecheck

View Source 
const (
	AtlasThirdPartyIntegrationByProjectIndex = "atlasThirdPartyIntegration.spec.projectRef"
)
View Source 
const (
	AtlasThirdPartyIntegrationBySecretsIndex = "atlasthirdpartyintegration.spec.secrets"
)
View Source 
const (
	AtlasThirdPartyIntegrationCredentialsIndex = "atlasthirdpartyintegrations.credentials"
)

Variables

This section is empty.

Functions

func AtlasThirdPartyIntegrationRequests added in v2.9.0 

func AtlasThirdPartyIntegrationRequests(list *akov2.AtlasThirdPartyIntegrationList) []reconcile.Request

func CredentialsIndexMapperFunc 

func CredentialsIndexMapperFunc[L client.ObjectList](indexerName string, listGenFn func() L, reqsFn requestsFunc[L], kubeClient client.Client, logger *zap.SugaredLogger) handler.MapFunc

func CustomRoleRequests 

func CustomRoleRequests(list *akov2.AtlasCustomRoleList) []reconcile.Request

func DatabaseUserRequests 

func DatabaseUserRequests(list *akov2.AtlasDatabaseUserList) []reconcile.Request

func DeploymentRequests 

func DeploymentRequests(list *akov2.AtlasDeploymentList) []reconcile.Request

func IPAccessListRequests added in v2.7.0 

func IPAccessListRequests(list *akov2.AtlasIPAccessListList) []reconcile.Request

func NetworkContainerRequests added in v2.8.0 

func NetworkContainerRequests(list *akov2.AtlasNetworkContainerList) []reconcile.Request

func NetworkPeeringRequests added in v2.8.0 

func NetworkPeeringRequests(list *akov2.AtlasNetworkPeeringList) []reconcile.Request

func PrivateEndpointRequests 

func PrivateEndpointRequests(list *akov2.AtlasPrivateEndpointList) []reconcile.Request

func ProjectsIndexMapperFunc added in v2.8.0 

func ProjectsIndexMapperFunc[L client.ObjectList](indexerName string, listGenFn func() L, reqsFn requestsFunc[L], kubeClient client.Client, logger *zap.SugaredLogger) handler.MapFunc

func Register 

func Register(ctx context.Context, c cluster.Cluster, indexers ...Indexer) error

Register registers the given indexers to the given manager's field indexer.

func RegisterAll 

func RegisterAll(ctx context.Context, c cluster.Cluster, logger *zap.Logger) error

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.

Types

type AtlasBackupScheduleByBackupPolicyIndexer 

type AtlasBackupScheduleByBackupPolicyIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasBackupScheduleByBackupPolicyIndexer 

func NewAtlasBackupScheduleByBackupPolicyIndexer(logger *zap.Logger) *AtlasBackupScheduleByBackupPolicyIndexer

func (*AtlasBackupScheduleByBackupPolicyIndexer) Keys 

func (a *AtlasBackupScheduleByBackupPolicyIndexer) Keys(object client.Object) []string

func (*AtlasBackupScheduleByBackupPolicyIndexer) Name 

func (*AtlasBackupScheduleByBackupPolicyIndexer) Name() string

func (*AtlasBackupScheduleByBackupPolicyIndexer) Object 

func (*AtlasBackupScheduleByBackupPolicyIndexer) Object() client.Object

type AtlasCustomRoleByProjectIndexer 

type AtlasCustomRoleByProjectIndexer struct {
	AtlasReferrerByProjectIndexerBase
}

func NewAtlasCustomRoleByProjectIndexer 

func NewAtlasCustomRoleByProjectIndexer(logger *zap.Logger) *AtlasCustomRoleByProjectIndexer

func (*AtlasCustomRoleByProjectIndexer) Object 

func (*AtlasCustomRoleByProjectIndexer) Object() client.Object

type AtlasDataFederationByProjectIndexer 

type AtlasDataFederationByProjectIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasDataFederationByProjectIndexer 

func NewAtlasDataFederationByProjectIndexer(logger *zap.Logger) *AtlasDataFederationByProjectIndexer

func (*AtlasDataFederationByProjectIndexer) Keys 

func (a *AtlasDataFederationByProjectIndexer) Keys(object client.Object) []string

func (*AtlasDataFederationByProjectIndexer) Name 

func (*AtlasDataFederationByProjectIndexer) Name() string

func (*AtlasDataFederationByProjectIndexer) Object 

func (*AtlasDataFederationByProjectIndexer) Object() client.Object

type AtlasDatabaseUserByProjectIndexer 

type AtlasDatabaseUserByProjectIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasDatabaseUserByProjectIndexer 

func NewAtlasDatabaseUserByProjectIndexer(ctx context.Context, client client.Client, logger *zap.Logger) *AtlasDatabaseUserByProjectIndexer

func (*AtlasDatabaseUserByProjectIndexer) Keys 

func (a *AtlasDatabaseUserByProjectIndexer) Keys(object client.Object) []string

func (*AtlasDatabaseUserByProjectIndexer) Name 

func (*AtlasDatabaseUserByProjectIndexer) Name() string

func (*AtlasDatabaseUserByProjectIndexer) Object 

func (*AtlasDatabaseUserByProjectIndexer) Object() client.Object

type AtlasDatabaseUserBySecretsIndexer 

type AtlasDatabaseUserBySecretsIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasDatabaseUserBySecretsIndexer 

func NewAtlasDatabaseUserBySecretsIndexer(logger *zap.Logger) *AtlasDatabaseUserBySecretsIndexer

func (*AtlasDatabaseUserBySecretsIndexer) Keys 

func (a *AtlasDatabaseUserBySecretsIndexer) Keys(object client.Object) []string

func (*AtlasDatabaseUserBySecretsIndexer) Name 

func (*AtlasDatabaseUserBySecretsIndexer) Name() string

func (*AtlasDatabaseUserBySecretsIndexer) Object 

func (*AtlasDatabaseUserBySecretsIndexer) Object() client.Object

type AtlasDeploymentByBackupScheduleIndexer 

type AtlasDeploymentByBackupScheduleIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasDeploymentByBackupScheduleIndexer 

func NewAtlasDeploymentByBackupScheduleIndexer(logger *zap.Logger) *AtlasDeploymentByBackupScheduleIndexer

func (*AtlasDeploymentByBackupScheduleIndexer) Keys 

func (a *AtlasDeploymentByBackupScheduleIndexer) Keys(object client.Object) []string

func (*AtlasDeploymentByBackupScheduleIndexer) Name 

func (*AtlasDeploymentByBackupScheduleIndexer) Name() string

func (*AtlasDeploymentByBackupScheduleIndexer) Object 

func (*AtlasDeploymentByBackupScheduleIndexer) Object() client.Object

type AtlasDeploymentBySearchIndexIndexer 

type AtlasDeploymentBySearchIndexIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasDeploymentBySearchIndexIndexer 

func NewAtlasDeploymentBySearchIndexIndexer(logger *zap.Logger) *AtlasDeploymentBySearchIndexIndexer

func (*AtlasDeploymentBySearchIndexIndexer) Keys 

func (a *AtlasDeploymentBySearchIndexIndexer) Keys(object client.Object) []string

func (*AtlasDeploymentBySearchIndexIndexer) Name 

func (*AtlasDeploymentBySearchIndexIndexer) Name() string

func (*AtlasDeploymentBySearchIndexIndexer) Object 

func (*AtlasDeploymentBySearchIndexIndexer) Object() client.Object

type AtlasFederatedAuthBySecretsIndexer 

type AtlasFederatedAuthBySecretsIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasFederatedAuthBySecretsIndexer 

func NewAtlasFederatedAuthBySecretsIndexer(logger *zap.Logger) *AtlasFederatedAuthBySecretsIndexer

func (*AtlasFederatedAuthBySecretsIndexer) Keys 

func (a *AtlasFederatedAuthBySecretsIndexer) Keys(object client.Object) []string

func (*AtlasFederatedAuthBySecretsIndexer) Name 

func (*AtlasFederatedAuthBySecretsIndexer) Name() string

func (*AtlasFederatedAuthBySecretsIndexer) Object 

func (*AtlasFederatedAuthBySecretsIndexer) Object() client.Object

type AtlasIPAccessListByProjectIndexer added in v2.7.0 

type AtlasIPAccessListByProjectIndexer struct {
	AtlasReferrerByProjectIndexerBase
}

func NewAtlasIPAccessListByProjectIndexer added in v2.7.0 

func NewAtlasIPAccessListByProjectIndexer(logger *zap.Logger) *AtlasIPAccessListByProjectIndexer

func (*AtlasIPAccessListByProjectIndexer) Object added in v2.7.0 

func (*AtlasIPAccessListByProjectIndexer) Object() client.Object

type AtlasNetworkContainerByProjectIndexer added in v2.8.0 

type AtlasNetworkContainerByProjectIndexer struct {
	AtlasReferrerByProjectIndexerBase
}

func NewAtlasNetworkContainerByProjectIndexer added in v2.8.0 

func NewAtlasNetworkContainerByProjectIndexer(logger *zap.Logger) *AtlasNetworkContainerByProjectIndexer

func (*AtlasNetworkContainerByProjectIndexer) Object added in v2.8.0 

func (*AtlasNetworkContainerByProjectIndexer) Object() client.Object

type AtlasNetworkPeeringByProjectIndexer added in v2.8.0 

type AtlasNetworkPeeringByProjectIndexer struct {
	AtlasReferrerByProjectIndexerBase
}

func NewAtlasNetworkPeeringByProjectIndexer added in v2.8.0 

func NewAtlasNetworkPeeringByProjectIndexer(logger *zap.Logger) *AtlasNetworkPeeringByProjectIndexer

func (*AtlasNetworkPeeringByProjectIndexer) Object added in v2.8.0 

func (*AtlasNetworkPeeringByProjectIndexer) Object() client.Object

type AtlasPrivateEndpointByProjectIndexer 

type AtlasPrivateEndpointByProjectIndexer struct {
	AtlasReferrerByProjectIndexerBase
}

func NewAtlasPrivateEndpointByProjectIndexer 

func NewAtlasPrivateEndpointByProjectIndexer(logger *zap.Logger) *AtlasPrivateEndpointByProjectIndexer

func (*AtlasPrivateEndpointByProjectIndexer) Object 

func (*AtlasPrivateEndpointByProjectIndexer) Object() client.Object

type AtlasProjectByBackupCompliancePolicyIndexer 

type AtlasProjectByBackupCompliancePolicyIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasProjectByBackupCompliancePolicyIndexer 

func NewAtlasProjectByBackupCompliancePolicyIndexer(logger *zap.Logger) *AtlasProjectByBackupCompliancePolicyIndexer

func (*AtlasProjectByBackupCompliancePolicyIndexer) Keys 

func (a *AtlasProjectByBackupCompliancePolicyIndexer) Keys(object client.Object) []string

func (*AtlasProjectByBackupCompliancePolicyIndexer) Name 

func (*AtlasProjectByBackupCompliancePolicyIndexer) Name() string

func (AtlasProjectByBackupCompliancePolicyIndexer) Object 

func (AtlasProjectByBackupCompliancePolicyIndexer) Object() client.Object

type AtlasProjectByConnectionSecretIndexer 

type AtlasProjectByConnectionSecretIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasProjectByConnectionSecretIndexer 

func NewAtlasProjectByConnectionSecretIndexer(logger *zap.Logger) *AtlasProjectByConnectionSecretIndexer

func (*AtlasProjectByConnectionSecretIndexer) Keys 

func (a *AtlasProjectByConnectionSecretIndexer) Keys(object client.Object) []string

func (*AtlasProjectByConnectionSecretIndexer) Name 

func (*AtlasProjectByConnectionSecretIndexer) Name() string

func (AtlasProjectByConnectionSecretIndexer) Object 

func (AtlasProjectByConnectionSecretIndexer) Object() client.Object

type AtlasProjectByTeamIndexer 

type AtlasProjectByTeamIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasProjectByTeamIndexer 

func NewAtlasProjectByTeamIndexer(logger *zap.Logger) *AtlasProjectByTeamIndexer

func (*AtlasProjectByTeamIndexer) Keys 

func (a *AtlasProjectByTeamIndexer) Keys(object client.Object) []string

func (*AtlasProjectByTeamIndexer) Name 

func (*AtlasProjectByTeamIndexer) Name() string

func (*AtlasProjectByTeamIndexer) Object 

func (*AtlasProjectByTeamIndexer) Object() client.Object

type AtlasReferrerByProjectIndexerBase added in v2.7.0 

type AtlasReferrerByProjectIndexerBase struct {
	// contains filtered or unexported fields
}

func NewAtlasReferrerByProjectIndexer added in v2.7.0 

func NewAtlasReferrerByProjectIndexer(logger *zap.Logger, name string) *AtlasReferrerByProjectIndexerBase

func (*AtlasReferrerByProjectIndexerBase) Keys added in v2.7.0 

func (rb *AtlasReferrerByProjectIndexerBase) Keys(object client.Object) []string

func (*AtlasReferrerByProjectIndexerBase) Name added in v2.7.0 

func (rb *AtlasReferrerByProjectIndexerBase) Name() string

type AtlasStreamConnectionBySecretIndexer 

type AtlasStreamConnectionBySecretIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasStreamConnectionBySecretIndexer 

func NewAtlasStreamConnectionBySecretIndexer(logger *zap.Logger) *AtlasStreamConnectionBySecretIndexer

func (*AtlasStreamConnectionBySecretIndexer) Keys 

func (a *AtlasStreamConnectionBySecretIndexer) Keys(object client.Object) []string

func (*AtlasStreamConnectionBySecretIndexer) Name 

func (*AtlasStreamConnectionBySecretIndexer) Name() string

func (*AtlasStreamConnectionBySecretIndexer) Object 

func (*AtlasStreamConnectionBySecretIndexer) Object() client.Object

type AtlasStreamInstanceByConnectionIndexer 

type AtlasStreamInstanceByConnectionIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasStreamInstanceByConnectionIndexer 

func NewAtlasStreamInstanceByConnectionIndexer(logger *zap.Logger) *AtlasStreamInstanceByConnectionIndexer

func (*AtlasStreamInstanceByConnectionIndexer) Keys 

func (a *AtlasStreamInstanceByConnectionIndexer) Keys(object client.Object) []string

func (*AtlasStreamInstanceByConnectionIndexer) Name 

func (*AtlasStreamInstanceByConnectionIndexer) Name() string

func (*AtlasStreamInstanceByConnectionIndexer) Object 

func (*AtlasStreamInstanceByConnectionIndexer) Object() client.Object

type AtlasStreamInstanceByProjectIndexer 

type AtlasStreamInstanceByProjectIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasStreamInstanceByProjectIndexer 

func NewAtlasStreamInstanceByProjectIndexer(logger *zap.Logger) *AtlasStreamInstanceByProjectIndexer

func (*AtlasStreamInstanceByProjectIndexer) Keys 

func (a *AtlasStreamInstanceByProjectIndexer) Keys(object client.Object) []string

func (*AtlasStreamInstanceByProjectIndexer) Name 

func (*AtlasStreamInstanceByProjectIndexer) Name() string

func (*AtlasStreamInstanceByProjectIndexer) Object 

func (*AtlasStreamInstanceByProjectIndexer) Object() client.Object

type AtlasThirdPartyIntegrationByProjectIndexer added in v2.9.0 

type AtlasThirdPartyIntegrationByProjectIndexer struct {
	AtlasReferrerByProjectIndexerBase
}

func NewAtlasThirdPartyIntegrationByProjectIndexer added in v2.9.0 

func NewAtlasThirdPartyIntegrationByProjectIndexer(logger *zap.Logger) *AtlasThirdPartyIntegrationByProjectIndexer

func (*AtlasThirdPartyIntegrationByProjectIndexer) Object added in v2.9.0 

func (*AtlasThirdPartyIntegrationByProjectIndexer) Object() client.Object

type AtlasThirdPartyIntegrationBySecretsIndexer added in v2.9.0 

type AtlasThirdPartyIntegrationBySecretsIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasThirdPartyIntegrationBySecretsIndexer added in v2.9.0 

func NewAtlasThirdPartyIntegrationBySecretsIndexer(logger *zap.Logger) *AtlasThirdPartyIntegrationBySecretsIndexer

func (*AtlasThirdPartyIntegrationBySecretsIndexer) Keys added in v2.9.0 

func (a *AtlasThirdPartyIntegrationBySecretsIndexer) Keys(object client.Object) []string

func (*AtlasThirdPartyIntegrationBySecretsIndexer) Name added in v2.9.0 

func (*AtlasThirdPartyIntegrationBySecretsIndexer) Name() string

func (*AtlasThirdPartyIntegrationBySecretsIndexer) Object added in v2.9.0 

func (*AtlasThirdPartyIntegrationBySecretsIndexer) Object() client.Object

type Indexer 

type Indexer interface {
	Object() client.Object
	Name() string
	Keys(client.Object) []string
}

type LocalCredentialIndexer 

type LocalCredentialIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasCustomRoleByCredentialIndexer 

func NewAtlasCustomRoleByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasDatabaseUserByCredentialIndexer 

func NewAtlasDatabaseUserByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasDeploymentByCredentialIndexer 

func NewAtlasDeploymentByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasIPAccessListCredentialsByCredentialIndexer added in v2.7.0 

func NewAtlasIPAccessListCredentialsByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasNetworkContainerByCredentialIndexer added in v2.8.0 

func NewAtlasNetworkContainerByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasNetworkPeeringByCredentialIndexer added in v2.8.0 

func NewAtlasNetworkPeeringByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasPrivateEndpointByCredentialIndexer 

func NewAtlasPrivateEndpointByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasThirdPartyIntegrationByCredentialIndexer added in v2.9.0 

func NewAtlasThirdPartyIntegrationByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewLocalCredentialsIndexer 

func NewLocalCredentialsIndexer(name string, obj api.ObjectWithCredentials, logger *zap.Logger) *LocalCredentialIndexer

func (*LocalCredentialIndexer) Keys 

func (lc *LocalCredentialIndexer) Keys(object client.Object) []string

func (*LocalCredentialIndexer) Name 

func (lc *LocalCredentialIndexer) Name() string

func (*LocalCredentialIndexer) Object 

func (lc *LocalCredentialIndexer) Object() client.Object

type NetworkPeeringByContainerIndexer added in v2.8.0 

type NetworkPeeringByContainerIndexer struct {
	// contains filtered or unexported fields
}

func NewAtlasNetworkPeeringByContainerIndexer added in v2.8.0 

func NewAtlasNetworkPeeringByContainerIndexer(logger *zap.Logger) *NetworkPeeringByContainerIndexer

func (*NetworkPeeringByContainerIndexer) Keys added in v2.8.0 

func (p *NetworkPeeringByContainerIndexer) Keys(object client.Object) []string

func (*NetworkPeeringByContainerIndexer) Name added in v2.8.0 

func (*NetworkPeeringByContainerIndexer) Name() string

func (*NetworkPeeringByContainerIndexer) Object added in v2.8.0 

func (*NetworkPeeringByContainerIndexer) Object() client.Object

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.