Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
 - func DeleteAllPrivateEndpoints(ctx *workflow.Context, atlasProject *akov2.AtlasProject) workflow.Result
 - func DeleteOwnedNetworkPeers(ctx context.Context, project *akov2.AtlasProject, ...) workflow.Result
 - func GetAllExistedNetworkPeer(ctx context.Context, peerService admin.NetworkPeeringApi, groupID string) ([]admin.BaseNetworkPeeringConnectionSettings, error)
 - func IsEncryptionSpecEmpty(spec *akov2.EncryptionAtRest) bool
 - func SyncNetworkPeer(workflowCtx *workflow.Context, groupID string, ...) (workflow.Result, api.ConditionType)
 - func UpdateStatuses(context context.Context, containerService admin.NetworkPeeringApi, ...) ([]status.AtlasNetworkPeer, error)
 - type AtlasProjectReconciler
 - type AtlasProjectServices
 - type CloudProviderIntegrationIdentifiable
 - type CustomRolesOperations
 - type TeamDataContainer
 
Constants ¶
      View Source
      
  
    const ( StatusFailed = "FAILED" StatusReady = "AVAILABLE" StatusDeleting = "DELETING" StatusTerminating = "TERMINATING" )
      View Source
      
  
const (
	ObjectIDRegex = "^([a-f0-9]{24})$"
)
    Variables ¶
This section is empty.
Functions ¶
func DeleteOwnedNetworkPeers ¶ added in v2.7.1
func DeleteOwnedNetworkPeers(ctx context.Context, project *akov2.AtlasProject, service admin.NetworkPeeringApi, logger *zap.SugaredLogger) workflow.Result
func GetAllExistedNetworkPeer ¶
func GetAllExistedNetworkPeer(ctx context.Context, peerService admin.NetworkPeeringApi, groupID string) ([]admin.BaseNetworkPeeringConnectionSettings, error)
func IsEncryptionSpecEmpty ¶
func IsEncryptionSpecEmpty(spec *akov2.EncryptionAtRest) bool
func SyncNetworkPeer ¶
func SyncNetworkPeer(workflowCtx *workflow.Context, groupID string, peerStatuses []status.AtlasNetworkPeer, peerSpecs []akov2.NetworkPeer, lastAppliedPeers []akov2.NetworkPeer) (workflow.Result, api.ConditionType)
func UpdateStatuses ¶
func UpdateStatuses(context context.Context, containerService admin.NetworkPeeringApi, peerStatuses []status.AtlasNetworkPeer, peersToUpdate []admin.BaseNetworkPeeringConnectionSettings, groupID string, logger *zap.SugaredLogger) ([]status.AtlasNetworkPeer, error)
Types ¶
type AtlasProjectReconciler ¶
type AtlasProjectReconciler struct {
	Client                      client.Client
	Log                         *zap.SugaredLogger
	Scheme                      *runtime.Scheme
	GlobalPredicates            []predicate.Predicate
	EventRecorder               record.EventRecorder
	AtlasProvider               atlas.Provider
	ObjectDeletionProtection    bool
	SubObjectDeletionProtection bool
	GlobalSecretRef             client.ObjectKey
}
    AtlasProjectReconciler reconciles a AtlasProject object
func (*AtlasProjectReconciler) For ¶ added in v2.7.1
func (r *AtlasProjectReconciler) For() (client.Object, builder.Predicates)
func (*AtlasProjectReconciler) SetupWithManager ¶
func (r *AtlasProjectReconciler) SetupWithManager(mgr ctrl.Manager, skipNameValidation bool) error
type AtlasProjectServices ¶ added in v2.7.0
type AtlasProjectServices struct {
	// contains filtered or unexported fields
}
    type CloudProviderIntegrationIdentifiable ¶
type CloudProviderIntegrationIdentifiable akov2.CloudProviderIntegration
type CustomRolesOperations ¶
type CustomRolesOperations struct {
	Create map[string]customroles.CustomRole
	Update map[string]customroles.CustomRole
}
    
      
      Source Files
      ¶
    
- alert_configurations.go
 - atlasproject_controller.go
 - auditing.go
 - backupcompliancepolicy.go
 - cloud_provider_integration.go
 - custom_roles.go
 - encryption_at_rest.go
 - integrations.go
 - ipaccess_list.go
 - maintenancewindow.go
 - network_peering.go
 - private_endpoint.go
 - project.go
 - project_settings.go
 - team_reconciler.go
 - teams.go
 - x509_auth.go
 
 Click to show internal directories. 
   Click to hide internal directories.