Documentation ¶
Index ¶
- Constants
- func AreIntegrationsEqual(atlas, specAsAtlas *aliasThirdPartyIntegration) bool
- func AtlasInSync(atlas *mongodbatlas.EncryptionAtRest, spec *mdbv1.EncryptionAtRest) (bool, error)
- func DeleteAllNetworkPeers(ctx context.Context, groupID string, service mongodbatlas.PeersService, ...) workflow.Result
- func DeleteAllPrivateEndpoints(ctx *workflow.Context, projectID string) workflow.Result
- func GetAllExistedNetworkPeer(ctx context.Context, peerService mongodbatlas.PeersService, groupID string) ([]mongodbatlas.Peer, error)
- func IsEncryptionAtlasEmpty(atlas *mongodbatlas.EncryptionAtRest) bool
- func IsEncryptionSpecEmpty(spec *mdbv1.EncryptionAtRest) bool
- func SyncNetworkPeer(context context.Context, ctx *workflow.Context, groupID string, ...) (workflow.Result, status.ConditionType)
- func UpdateStatuses(context context.Context, containerService mongodbatlas.ContainersService, ...) ([]status.AtlasNetworkPeer, error)
- type AtlasProjectReconciler
- type CloudProviderAccessIdentifiable
- 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 AreIntegrationsEqual ¶ added in v1.4.0
func AreIntegrationsEqual(atlas, specAsAtlas *aliasThirdPartyIntegration) bool
func AtlasInSync ¶ added in v1.3.0
func AtlasInSync(atlas *mongodbatlas.EncryptionAtRest, spec *mdbv1.EncryptionAtRest) (bool, error)
func DeleteAllNetworkPeers ¶ added in v1.3.0
func DeleteAllNetworkPeers(ctx context.Context, groupID string, service mongodbatlas.PeersService, logger *zap.SugaredLogger) workflow.Result
func DeleteAllPrivateEndpoints ¶ added in v0.7.0
func GetAllExistedNetworkPeer ¶ added in v1.6.0
func GetAllExistedNetworkPeer(ctx context.Context, peerService mongodbatlas.PeersService, groupID string) ([]mongodbatlas.Peer, error)
func IsEncryptionAtlasEmpty ¶ added in v1.3.0
func IsEncryptionAtlasEmpty(atlas *mongodbatlas.EncryptionAtRest) bool
func IsEncryptionSpecEmpty ¶ added in v1.3.0
func IsEncryptionSpecEmpty(spec *mdbv1.EncryptionAtRest) bool
func SyncNetworkPeer ¶ added in v1.3.0
func SyncNetworkPeer(context context.Context, ctx *workflow.Context, groupID string, peerStatuses []status.AtlasNetworkPeer, peerSpecs []mdbv1.NetworkPeer) (workflow.Result, status.ConditionType)
func UpdateStatuses ¶ added in v1.3.0
func UpdateStatuses(context context.Context, containerService mongodbatlas.ContainersService, peerStatuses []status.AtlasNetworkPeer, peersToUpdate []mongodbatlas.Peer, groupID string, logger *zap.SugaredLogger) ([]status.AtlasNetworkPeer, error)
Types ¶
type AtlasProjectReconciler ¶
type AtlasProjectReconciler struct { Client client.Client watch.ResourceWatcher Log *zap.SugaredLogger Scheme *runtime.Scheme AtlasDomain string GlobalAPISecret client.ObjectKey GlobalPredicates []predicate.Predicate EventRecorder record.EventRecorder ObjectDeletionProtection bool SubObjectDeletionProtection bool }
AtlasProjectReconciler reconciles a AtlasProject object
func (*AtlasProjectReconciler) SetupWithManager ¶
func (r *AtlasProjectReconciler) SetupWithManager(mgr ctrl.Manager) error
type CloudProviderAccessIdentifiable ¶ added in v1.8.2
type CloudProviderAccessIdentifiable v1.CloudProviderAccessRole
func (CloudProviderAccessIdentifiable) Identifier ¶ added in v1.8.2
func (cpa CloudProviderAccessIdentifiable) Identifier() interface{}
type CustomRolesOperations ¶ added in v1.4.1
type CustomRolesOperations struct { Create map[string]v1.CustomRole Update map[string]v1.CustomRole Delete map[string]v1.CustomRole }
Source Files ¶
Click to show internal directories.
Click to hide internal directories.