atlasdeployment

package

v2.2.2-rc4 Latest Latest Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 37 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/mongodb/mongodb-atlas-kubernetes

Links

Open Source Insights

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

Constants ¶

View Source

const (
	Unset atlasClusterType = iota
	Advanced
	Serverless
)

View Source

const (
	SPEStatusDeleting  = "DELETING"
	SPEStatusReserved  = "RESERVED"
	SPEStatusAvailable = "AVAILABLE"
)

Status transitions: RESERVATION_REQUESTED -> RESERVED -> INITIATING -> AVAILABLE -> DELETING I assume FAILED state can be reach from any other state transition

View Source

const FreeTier = "M0"

Variables ¶

This section is empty.

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 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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL