indexer

package
v2.6.1 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2025 License: Apache-2.0 Imports: 15 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,externalProjectID"
)
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 (
	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

Variables

This section is empty.

Functions

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 PrivateEndpointRequests 

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

func Register 

func Register(ctx context.Context, mgr manager.Manager, indexers ...Indexer) error

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

func RegisterAll 

func RegisterAll(ctx context.Context, mgr manager.Manager, 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 {
	// contains filtered or unexported fields
}

func NewAtlasCustomRoleByProjectIndexer 

func NewAtlasCustomRoleByProjectIndexer(logger *zap.Logger) *AtlasCustomRoleByProjectIndexer

func (*AtlasCustomRoleByProjectIndexer) Keys 

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

func (*AtlasCustomRoleByProjectIndexer) Name 

func (*AtlasCustomRoleByProjectIndexer) Name() string

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 AtlasPrivateEndpointByProjectIndexer 

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

func NewAtlasPrivateEndpointByProjectIndexer 

func NewAtlasPrivateEndpointByProjectIndexer(logger *zap.Logger) *AtlasPrivateEndpointByProjectIndexer

func (*AtlasPrivateEndpointByProjectIndexer) Keys 

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

func (*AtlasPrivateEndpointByProjectIndexer) Name 

func (*AtlasPrivateEndpointByProjectIndexer) Name() string

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 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 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 NewAtlasPrivateEndpointByCredentialIndexer 

func NewAtlasPrivateEndpointByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewLocalCredentialsIndexer 

func NewLocalCredentialsIndexer(name string, obj client.Object, 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

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.