atlasdeployment

Documentation

Index

• Constants
• func AdvancedDeploymentFromAtlas(advancedDeployment mongodbatlas.AdvancedCluster) (mdbv1.AdvancedDeploymentSpec, error)
• func AdvancedDeploymentsEqual(log *zap.SugaredLogger, deploymentAtlas mdbv1.AdvancedDeploymentSpec, ...) bool
• func CompareInstanceSizes(is1 InstanceSize, is2 InstanceSize) int
• func DeploymentsEqual(log *zap.SugaredLogger, deploymentAtlas mongodbatlas.Cluster, ...) bool
• func GetAllDeploymentNames(client mongodbatlas.Client, projectID string) ([]string, error)
• func IsClusterSupportServerlessPE(deploymentSpec *mdbv1.ServerlessSpec) (provider.ProviderName, workflow.Result)
• func MergedAdvancedDeployment(atlasDeploymentAsAtlas mongodbatlas.AdvancedCluster, ...) (mergedDeployment mdbv1.AdvancedDeploymentSpec, ...)
• func MergedDeployment(atlasDeployment mongodbatlas.Cluster, spec mdbv1.AtlasDeploymentSpec) (result mongodbatlas.Cluster, err error)
• type AtlasDeploymentReconciler
  • func (r *AtlasDeploymentReconciler) Delete(e event.DeleteEvent) error
  • func (r *AtlasDeploymentReconciler) Reconcile(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type InstanceSize
  • func NewFromInstanceSizeName(instanceSizeName string) (InstanceSize, error)
• type SPEDiff

Constants

const (
	SPEStatusDeleting = "DELETING"

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

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

Functions

func AdvancedDeploymentFromAtlas

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

func AdvancedDeploymentsEqual

func AdvancedDeploymentsEqual(log *zap.SugaredLogger, deploymentAtlas mdbv1.AdvancedDeploymentSpec, deploymentOperator mdbv1.AdvancedDeploymentSpec) bool

AdvancedDeploymentsEqual compares two Atlas Advanced Deployments

func CompareInstanceSizes

func CompareInstanceSizes(is1 InstanceSize, is2 InstanceSize) int

func DeploymentsEqual

func DeploymentsEqual(log *zap.SugaredLogger, deploymentAtlas mongodbatlas.Cluster, deploymentOperator mongodbatlas.Cluster) bool

DeploymentsEqual compares two Atlas Deployments

func GetAllDeploymentNames

func GetAllDeploymentNames(client mongodbatlas.Client, projectID string) ([]string, error)

GetAllDeploymentNames returns all deployment names including regular and advanced deployment.

func IsClusterSupportServerlessPE

func IsClusterSupportServerlessPE(deploymentSpec *mdbv1.ServerlessSpec) (provider.ProviderName, workflow.Result)

func MergedAdvancedDeployment

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

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

func MergedDeployment

func MergedDeployment(atlasDeployment mongodbatlas.Cluster, spec mdbv1.AtlasDeploymentSpec) (result mongodbatlas.Cluster, err error)

MergedDeployment will return the result of merging AtlasDeploymentSpec with Atlas Deployment

Types

type AtlasDeploymentReconciler

type AtlasDeploymentReconciler struct {
	watch.ResourceWatcher
	Client           client.Client
	Log              *zap.SugaredLogger
	Scheme           *runtime.Scheme
	AtlasDomain      string
	GlobalAPISecret  client.ObjectKey
	GlobalPredicates []predicate.Predicate
	EventRecorder    record.EventRecorder
}

AtlasDeploymentReconciler reconciles an AtlasDeployment object

func (*AtlasDeploymentReconciler) Delete

func (r *AtlasDeploymentReconciler) Delete(e event.DeleteEvent) error

Delete implements a handler for the Delete event.

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 InstanceSize

type InstanceSize struct {
	Family string
	Size   int
	IsNVME bool
}

func NewFromInstanceSizeName

func NewFromInstanceSizeName(instanceSizeName string) (InstanceSize, error)

type SPEDiff

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