atlasdeployment

Documentation

Index

• Constants
• func AdvancedDeploymentFromAtlas(advancedDeployment mongodbatlas.AdvancedCluster) (akov2.AdvancedDeploymentSpec, error)
• func AdvancedDeploymentsEqual(log *zap.SugaredLogger, deploymentOperator *akov2.AdvancedDeploymentSpec, ...) (areEqual bool, diff string)
• func EnsureCustomZoneMapping(service *workflow.Context, groupID string, ...) workflow.Result
• func EnsureManagedNamespaces(service *workflow.Context, groupID string, clusterType string, ...) workflow.Result
• func GetAllDeploymentNames(ctx context.Context, client *mongodbatlas.Client, projectID string) ([]string, error)
• func GetGlobalDeploymentState(ctx context.Context, client mongodbatlas.GlobalClustersService, groupID string, ...) ([]mongodbatlas.ManagedNamespace, map[string]string, error)
• func GetServerlessProvider(deploymentSpec *akov2.ServerlessSpec) provider.ProviderName
• func IsFreeTierAdvancedDeployment(deployment *mongodbatlas.AdvancedCluster) bool
• func MergedAdvancedDeployment(atlasDeploymentAsAtlas mongodbatlas.AdvancedCluster, ...) (mergedDeployment akov2.AdvancedDeploymentSpec, ...)
• type AtlasDeploymentReconciler
  • func (r *AtlasDeploymentReconciler) Reconcile(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NamespaceDiff
• type SPEDiff

Constants

const (
	Unset atlasClusterType = iota
	Advanced
	Serverless
)

const (
	SPEStatusDeleting = "DELETING"

	SPEStatusReserved             = "RESERVED"              //stage 1
	SPEStatusReservationRequested = "RESERVATION_REQUESTED" //stage 1

	SPEStatusAvailable  = "AVAILABLE"  //stage 2
	SPEStatusInitiating = "INITIATING" //stage 2
	SPEStatusFailed     = "FAILED"     //stage 2
)

const FreeTier = "M0"

Functions

func AdvancedDeploymentFromAtlas

func AdvancedDeploymentFromAtlas(advancedDeployment mongodbatlas.AdvancedCluster) (akov2.AdvancedDeploymentSpec, error)

func AdvancedDeploymentsEqual

func AdvancedDeploymentsEqual(log *zap.SugaredLogger, deploymentOperator *akov2.AdvancedDeploymentSpec, deploymentAtlas *akov2.AdvancedDeploymentSpec) (areEqual bool, diff string)

AdvancedDeploymentsEqual compares two Atlas Advanced Deployments

func EnsureCustomZoneMapping

func EnsureCustomZoneMapping(service *workflow.Context, groupID string, customZoneMappings []akov2.CustomZoneMapping, deploymentName string) workflow.Result

func EnsureManagedNamespaces

func EnsureManagedNamespaces(service *workflow.Context, groupID string, clusterType string, managedNamespace []akov2.ManagedNamespace, deploymentName string) workflow.Result

func GetAllDeploymentNames

func GetAllDeploymentNames(ctx context.Context, client *mongodbatlas.Client, projectID string) ([]string, error)

GetAllDeploymentNames returns all deployment names including regular and advanced deployment.

func GetGlobalDeploymentState

func GetGlobalDeploymentState(ctx context.Context, client mongodbatlas.GlobalClustersService, groupID string, deploymentName string) ([]mongodbatlas.ManagedNamespace, map[string]string, error)

func GetServerlessProvider

func GetServerlessProvider(deploymentSpec *akov2.ServerlessSpec) provider.ProviderName

func IsFreeTierAdvancedDeployment

func IsFreeTierAdvancedDeployment(deployment *mongodbatlas.AdvancedCluster) bool

func MergedAdvancedDeployment

func MergedAdvancedDeployment(atlasDeploymentAsAtlas mongodbatlas.AdvancedCluster, specDeployment akov2.AdvancedDeploymentSpec) (mergedDeployment akov2.AdvancedDeploymentSpec, atlasDeployment akov2.AdvancedDeploymentSpec, err error)

MergedAdvancedDeployment will return the result of merging AtlasDeploymentSpec with Atlas Advanced Deployment

Types

type AtlasDeploymentReconciler

type AtlasDeploymentReconciler struct {
	watch.ResourceWatcher
	Client                      client.Client
	Log                         *zap.SugaredLogger
	Scheme                      *runtime.Scheme
	GlobalPredicates            []predicate.Predicate
	EventRecorder               record.EventRecorder
	AtlasProvider               atlas.Provider
	ObjectDeletionProtection    bool
	SubObjectDeletionProtection bool
}

AtlasDeploymentReconciler reconciles an AtlasDeployment object

func (*AtlasDeploymentReconciler) Reconcile

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

func (*AtlasDeploymentReconciler) SetupWithManager

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

type NamespaceDiff

type NamespaceDiff struct {
	ToCreate       []mongodbatlas.ManagedNamespace
	ToDelete       []mongodbatlas.ManagedNamespace
	ToUpdateStatus []mongodbatlas.ManagedNamespace
}

type SPEDiff

type SPEDiff struct {
	PEToCreate        []akov2.ServerlessPrivateEndpoint
	PEToConnect       []mongodbatlas.ServerlessPrivateEndpointConnection
	PEToUpdateStatus  []mongodbatlas.ServerlessPrivateEndpointConnection
	PEToDelete        []string
	DuplicateToCreate []akov2.ServerlessPrivateEndpoint
}