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 SetNewStatuses(customContext *workflow.Context, ...)
• 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
  • func (r *AtlasProjectReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasProjectReconciler) SetupWithManager(mgr ctrl.Manager) error
• type CustomRolesOperations
• type IPAccessListStatus
  • func GetIPAccessListStatus(client mongodbatlas.Client, accessList mongodbatlas.ProjectIPAccessList) (IPAccessListStatus, error)
• type IPAccessListStatusType
• 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 SetNewStatuses

func SetNewStatuses(customContext *workflow.Context, specToStatus map[v1.CloudProviderAccessRole]status.CloudProviderAccessRole)

func SyncNetworkPeer

func SyncNetworkPeer(context context.Context, ctx *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 CustomRolesOperations

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

type IPAccessListStatus

type IPAccessListStatus struct {
	Status string `json:"STATUS"`
}

func GetIPAccessListStatus

func GetIPAccessListStatus(client mongodbatlas.Client, accessList mongodbatlas.ProjectIPAccessList) (IPAccessListStatus, error)

GetIPAccessListStatus returns the status of an individual project ip access list. The documentation can be found here https://docs.atlas.mongodb.com/reference/api/ip-access-list/get-one-access-list-entry-status/

type IPAccessListStatusType

type IPAccessListStatusType string

const (
	IPAccessListActive  IPAccessListStatusType = "ACTIVE"
	IPAccessListFailed  IPAccessListStatusType = "FAILED"
	IPAccessListPending IPAccessListStatusType = "PENDING"
)

type TeamDataContainer

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