indexer

package
v2.6.0 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 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 added in v2.5.0 

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

func CustomRoleRequests added in v2.6.0 

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

func DatabaseUserRequests added in v2.5.0 

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

func DeploymentRequests added in v2.5.0 

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

func PrivateEndpointRequests added in v2.6.0 

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

func Register added in v2.3.1 

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 added in v2.3.1 

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 added in v2.3.1 

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

func NewAtlasBackupScheduleByBackupPolicyIndexer added in v2.3.1 

func NewAtlasBackupScheduleByBackupPolicyIndexer(logger *zap.Logger) *AtlasBackupScheduleByBackupPolicyIndexer

func (*AtlasBackupScheduleByBackupPolicyIndexer) Keys added in v2.3.1 

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

func (*AtlasBackupScheduleByBackupPolicyIndexer) Name added in v2.3.1 

func (*AtlasBackupScheduleByBackupPolicyIndexer) Name() string

func (*AtlasBackupScheduleByBackupPolicyIndexer) Object added in v2.3.1 

func (*AtlasBackupScheduleByBackupPolicyIndexer) Object() client.Object

type AtlasCustomRoleByProjectIndexer added in v2.6.0 

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

func NewAtlasCustomRoleByProjectIndexer added in v2.6.0 

func NewAtlasCustomRoleByProjectIndexer(logger *zap.Logger) *AtlasCustomRoleByProjectIndexer

func (*AtlasCustomRoleByProjectIndexer) Keys added in v2.6.0 

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

func (*AtlasCustomRoleByProjectIndexer) Name added in v2.6.0 

func (*AtlasCustomRoleByProjectIndexer) Name() string

func (*AtlasCustomRoleByProjectIndexer) Object added in v2.6.0 

func (*AtlasCustomRoleByProjectIndexer) Object() client.Object

type AtlasDataFederationByProjectIndexer added in v2.6.0 

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

func NewAtlasDataFederationByProjectIndexer added in v2.6.0 

func NewAtlasDataFederationByProjectIndexer(logger *zap.Logger) *AtlasDataFederationByProjectIndexer

func (*AtlasDataFederationByProjectIndexer) Keys added in v2.6.0 

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

func (*AtlasDataFederationByProjectIndexer) Name added in v2.6.0 

func (*AtlasDataFederationByProjectIndexer) Name() string

func (*AtlasDataFederationByProjectIndexer) Object added in v2.6.0 

func (*AtlasDataFederationByProjectIndexer) Object() client.Object

type AtlasDatabaseUserByProjectIndexer added in v2.5.0 

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

func NewAtlasDatabaseUserByProjectIndexer added in v2.5.0 

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

func (*AtlasDatabaseUserByProjectIndexer) Keys added in v2.5.0 

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

func (*AtlasDatabaseUserByProjectIndexer) Name added in v2.5.0 

func (*AtlasDatabaseUserByProjectIndexer) Name() string

func (*AtlasDatabaseUserByProjectIndexer) Object added in v2.5.0 

func (*AtlasDatabaseUserByProjectIndexer) Object() client.Object

type AtlasDatabaseUserBySecretsIndexer added in v2.4.1 

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

func NewAtlasDatabaseUserBySecretsIndexer added in v2.4.1 

func NewAtlasDatabaseUserBySecretsIndexer(logger *zap.Logger) *AtlasDatabaseUserBySecretsIndexer

func (*AtlasDatabaseUserBySecretsIndexer) Keys added in v2.4.1 

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

func (*AtlasDatabaseUserBySecretsIndexer) Name added in v2.4.1 

func (*AtlasDatabaseUserBySecretsIndexer) Name() string

func (*AtlasDatabaseUserBySecretsIndexer) Object added in v2.4.1 

func (*AtlasDatabaseUserBySecretsIndexer) Object() client.Object

type AtlasDeploymentByBackupScheduleIndexer added in v2.3.1 

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

func NewAtlasDeploymentByBackupScheduleIndexer added in v2.3.1 

func NewAtlasDeploymentByBackupScheduleIndexer(logger *zap.Logger) *AtlasDeploymentByBackupScheduleIndexer

func (*AtlasDeploymentByBackupScheduleIndexer) Keys added in v2.3.1 

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

func (*AtlasDeploymentByBackupScheduleIndexer) Name added in v2.3.1 

func (*AtlasDeploymentByBackupScheduleIndexer) Name() string

func (*AtlasDeploymentByBackupScheduleIndexer) Object added in v2.3.1 

func (*AtlasDeploymentByBackupScheduleIndexer) Object() client.Object

type AtlasDeploymentBySearchIndexIndexer added in v2.3.1 

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

func NewAtlasDeploymentBySearchIndexIndexer added in v2.3.1 

func NewAtlasDeploymentBySearchIndexIndexer(logger *zap.Logger) *AtlasDeploymentBySearchIndexIndexer

func (*AtlasDeploymentBySearchIndexIndexer) Keys added in v2.3.1 

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

func (*AtlasDeploymentBySearchIndexIndexer) Name added in v2.3.1 

func (*AtlasDeploymentBySearchIndexIndexer) Name() string

func (*AtlasDeploymentBySearchIndexIndexer) Object added in v2.3.1 

func (*AtlasDeploymentBySearchIndexIndexer) Object() client.Object

type AtlasFederatedAuthBySecretsIndexer added in v2.4.1 

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

func NewAtlasFederatedAuthBySecretsIndexer added in v2.4.1 

func NewAtlasFederatedAuthBySecretsIndexer(logger *zap.Logger) *AtlasFederatedAuthBySecretsIndexer

func (*AtlasFederatedAuthBySecretsIndexer) Keys added in v2.4.1 

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

func (*AtlasFederatedAuthBySecretsIndexer) Name added in v2.4.1 

func (*AtlasFederatedAuthBySecretsIndexer) Name() string

func (*AtlasFederatedAuthBySecretsIndexer) Object added in v2.4.1 

func (*AtlasFederatedAuthBySecretsIndexer) Object() client.Object

type AtlasPrivateEndpointByProjectIndexer added in v2.6.0 

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

func NewAtlasPrivateEndpointByProjectIndexer added in v2.6.0 

func NewAtlasPrivateEndpointByProjectIndexer(logger *zap.Logger) *AtlasPrivateEndpointByProjectIndexer

func (*AtlasPrivateEndpointByProjectIndexer) Keys added in v2.6.0 

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

func (*AtlasPrivateEndpointByProjectIndexer) Name added in v2.6.0 

func (*AtlasPrivateEndpointByProjectIndexer) Name() string

func (*AtlasPrivateEndpointByProjectIndexer) Object added in v2.6.0 

func (*AtlasPrivateEndpointByProjectIndexer) Object() client.Object

type AtlasProjectByBackupCompliancePolicyIndexer added in v2.4.0 

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

func NewAtlasProjectByBackupCompliancePolicyIndexer added in v2.4.0 

func NewAtlasProjectByBackupCompliancePolicyIndexer(logger *zap.Logger) *AtlasProjectByBackupCompliancePolicyIndexer

func (*AtlasProjectByBackupCompliancePolicyIndexer) Keys added in v2.4.0 

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

func (*AtlasProjectByBackupCompliancePolicyIndexer) Name added in v2.4.0 

func (*AtlasProjectByBackupCompliancePolicyIndexer) Name() string

func (AtlasProjectByBackupCompliancePolicyIndexer) Object added in v2.4.0 

func (AtlasProjectByBackupCompliancePolicyIndexer) Object() client.Object

type AtlasProjectByConnectionSecretIndexer added in v2.4.0 

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

func NewAtlasProjectByConnectionSecretIndexer added in v2.4.0 

func NewAtlasProjectByConnectionSecretIndexer(logger *zap.Logger) *AtlasProjectByConnectionSecretIndexer

func (*AtlasProjectByConnectionSecretIndexer) Keys added in v2.4.0 

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

func (*AtlasProjectByConnectionSecretIndexer) Name added in v2.4.0 

func (*AtlasProjectByConnectionSecretIndexer) Name() string

func (AtlasProjectByConnectionSecretIndexer) Object added in v2.4.0 

func (AtlasProjectByConnectionSecretIndexer) Object() client.Object

type AtlasProjectByTeamIndexer added in v2.4.0 

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

func NewAtlasProjectByTeamIndexer added in v2.4.0 

func NewAtlasProjectByTeamIndexer(logger *zap.Logger) *AtlasProjectByTeamIndexer

func (*AtlasProjectByTeamIndexer) Keys added in v2.4.0 

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

func (*AtlasProjectByTeamIndexer) Name added in v2.4.0 

func (*AtlasProjectByTeamIndexer) Name() string

func (*AtlasProjectByTeamIndexer) Object added in v2.4.0 

func (*AtlasProjectByTeamIndexer) Object() client.Object

type AtlasStreamConnectionBySecretIndexer added in v2.3.1 

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

func NewAtlasStreamConnectionBySecretIndexer added in v2.3.1 

func NewAtlasStreamConnectionBySecretIndexer(logger *zap.Logger) *AtlasStreamConnectionBySecretIndexer

func (*AtlasStreamConnectionBySecretIndexer) Keys added in v2.3.1 

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

func (*AtlasStreamConnectionBySecretIndexer) Name added in v2.3.1 

func (*AtlasStreamConnectionBySecretIndexer) Name() string

func (*AtlasStreamConnectionBySecretIndexer) Object added in v2.3.1 

func (*AtlasStreamConnectionBySecretIndexer) Object() client.Object

type AtlasStreamInstanceByConnectionIndexer added in v2.3.1 

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

func NewAtlasStreamInstanceByConnectionIndexer added in v2.3.1 

func NewAtlasStreamInstanceByConnectionIndexer(logger *zap.Logger) *AtlasStreamInstanceByConnectionIndexer

func (*AtlasStreamInstanceByConnectionIndexer) Keys added in v2.3.1 

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

func (*AtlasStreamInstanceByConnectionIndexer) Name added in v2.3.1 

func (*AtlasStreamInstanceByConnectionIndexer) Name() string

func (*AtlasStreamInstanceByConnectionIndexer) Object added in v2.3.1 

func (*AtlasStreamInstanceByConnectionIndexer) Object() client.Object

type AtlasStreamInstanceByProjectIndexer added in v2.3.1 

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

func NewAtlasStreamInstanceByProjectIndexer added in v2.3.1 

func NewAtlasStreamInstanceByProjectIndexer(logger *zap.Logger) *AtlasStreamInstanceByProjectIndexer

func (*AtlasStreamInstanceByProjectIndexer) Keys added in v2.3.1 

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

func (*AtlasStreamInstanceByProjectIndexer) Name added in v2.3.1 

func (*AtlasStreamInstanceByProjectIndexer) Name() string

func (*AtlasStreamInstanceByProjectIndexer) Object added in v2.3.1 

func (*AtlasStreamInstanceByProjectIndexer) Object() client.Object

type Indexer added in v2.3.1 

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

type LocalCredentialIndexer added in v2.5.0 

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

func NewAtlasCustomRoleByCredentialIndexer added in v2.6.0 

func NewAtlasCustomRoleByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasDatabaseUserByCredentialIndexer added in v2.5.0 

func NewAtlasDatabaseUserByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasDeploymentByCredentialIndexer added in v2.5.0 

func NewAtlasDeploymentByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewAtlasPrivateEndpointByCredentialIndexer added in v2.6.0 

func NewAtlasPrivateEndpointByCredentialIndexer(logger *zap.Logger) *LocalCredentialIndexer

func NewLocalCredentialsIndexer added in v2.5.0 

func NewLocalCredentialsIndexer(name string, obj client.Object, logger *zap.Logger) *LocalCredentialIndexer

func (*LocalCredentialIndexer) Keys added in v2.5.0 

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

func (*LocalCredentialIndexer) Name added in v2.5.0 

func (lc *LocalCredentialIndexer) Name() string

func (*LocalCredentialIndexer) Object added in v2.5.0 

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.
JackTT - Gopher 🇻🇳