atlasproject

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(workflowCtx *workflow.Context, groupID string, ...) (workflow.Result, status.ConditionType)
• func UpdateStatuses(context context.Context, containerService mongodbatlas.ContainersService, ...) ([]status.AtlasNetworkPeer, error)
• type AtlasProjectReconciler
  • func (r *AtlasProjectReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasProjectReconciler) SetupWithManager(mgr ctrl.Manager) error
• type CloudProviderAccessIdentifiable
  • func (cpa CloudProviderAccessIdentifiable) Identifier() interface{}
• type CustomRolesOperations
• type TeamDataContainer

Constants

const (
	StatusFailed      = "FAILED"
	StatusReady       = "AVAILABLE"
	StatusDeleting    = "DELETING"
	StatusTerminating = "TERMINATING"
)

const (
	ObjectIDRegex = "^([a-f0-9]{24})$"
)

Functions

func AreIntegrationsEqual

func AreIntegrationsEqual(atlas, specAsAtlas *aliasThirdPartyIntegration) bool

func AtlasInSync

func AtlasInSync(atlas *mongodbatlas.EncryptionAtRest, spec *mdbv1.EncryptionAtRest) (bool, error)

func DeleteAllNetworkPeers

func DeleteAllNetworkPeers(ctx context.Context, groupID string, service mongodbatlas.PeersService, logger *zap.SugaredLogger) workflow.Result

func DeleteAllPrivateEndpoints

func DeleteAllPrivateEndpoints(ctx *workflow.Context, projectID string) workflow.Result

func GetAllExistedNetworkPeer

func GetAllExistedNetworkPeer(ctx context.Context, peerService mongodbatlas.PeersService, groupID string) ([]mongodbatlas.Peer, error)

func IsEncryptionAtlasEmpty

func IsEncryptionAtlasEmpty(atlas *mongodbatlas.EncryptionAtRest) bool

func IsEncryptionSpecEmpty

func IsEncryptionSpecEmpty(spec *mdbv1.EncryptionAtRest) bool

func SyncNetworkPeer

func SyncNetworkPeer(workflowCtx *workflow.Context, groupID string, peerStatuses []status.AtlasNetworkPeer, peerSpecs []mdbv1.NetworkPeer) (workflow.Result, status.ConditionType)

func UpdateStatuses

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) Reconcile

func (r *AtlasProjectReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*AtlasProjectReconciler) SetupWithManager

func (r *AtlasProjectReconciler) SetupWithManager(mgr ctrl.Manager) error

type CloudProviderAccessIdentifiable

type CloudProviderAccessIdentifiable v1.CloudProviderAccessRole

func (CloudProviderAccessIdentifiable) Identifier

func (cpa CloudProviderAccessIdentifiable) Identifier() interface{}

type CustomRolesOperations

type CustomRolesOperations struct {
	Create map[string]v1.CustomRole
	Update map[string]v1.CustomRole
	Delete map[string]v1.CustomRole
}

type TeamDataContainer

type TeamDataContainer struct {
	ProjectTeam *v1.Team
	Team        *v1.AtlasTeam
	Context     *workflow.Context
}