customresource

Documentation

Index

• Constants
• func HaveFinalizer(resource mdbv1.AtlasCustomResource, finalizer string) bool
• func MarkReconciliationStarted(client client.Client, resource mdbv1.AtlasCustomResource, ...) *workflow.Context
• func PrepareResource(client client.Client, request reconcile.Request, ...) workflow.Result
• func ReconciliationShouldBeSkipped(resource mdbv1.AtlasCustomResource) bool
• func ResourceShouldBeLeftInAtlas(resource mdbv1.AtlasCustomResource) bool
• func ResourceVersionIsValid(resource mdbv1.AtlasCustomResource) (bool, error)
• func SetFinalizer(resource mdbv1.AtlasCustomResource, finalizer string)
• func UnsetFinalizer(resource mdbv1.AtlasCustomResource, finalizer string)
• func ValidateResourceVersion(ctx *workflow.Context, resource mdbv1.AtlasCustomResource, ...) workflow.Result

Constants

const (
	ResourcePolicyAnnotation       = "mongodb.com/atlas-resource-policy"
	ReconciliationPolicyAnnotation = "mongodb.com/atlas-reconciliation-policy"
	ResourceVersion                = "app.kubernetes.io/version"
	ResourceVersionOverride        = "mongodb.com/atlas-resource-version-policy"

	ResourcePolicyKeep       = "keep"
	ReconciliationPolicySkip = "skip"
	ResourceVersionAllow     = "allow"
)

const FinalizerLabel = "mongodbatlas/finalizer"

Functions

func HaveFinalizer

func HaveFinalizer(resource mdbv1.AtlasCustomResource, finalizer string) bool

func MarkReconciliationStarted

func MarkReconciliationStarted(client client.Client, resource mdbv1.AtlasCustomResource, log *zap.SugaredLogger) *workflow.Context

MarkReconciliationStarted updates the status of the Atlas Resource to indicate that the Operator has started working on it. Internally this will also update the 'observedGeneration' field that notify clients that the resource is being worked on

func PrepareResource

func PrepareResource(client client.Client, request reconcile.Request, resource mdbv1.AtlasCustomResource, log *zap.SugaredLogger) workflow.Result

PrepareResource queries the Custom Resource 'request.NamespacedName' and populates the 'resource' pointer.

func ReconciliationShouldBeSkipped

func ReconciliationShouldBeSkipped(resource mdbv1.AtlasCustomResource) bool

ReconciliationShouldBeSkipped returns 'true' if reconciliation should be skipped for this resource.

func ResourceShouldBeLeftInAtlas

func ResourceShouldBeLeftInAtlas(resource mdbv1.AtlasCustomResource) bool

ResourceShouldBeLeftInAtlas returns 'true' if the resource should not be removed from Atlas on K8s resource removal.

func ResourceVersionIsValid

func ResourceVersionIsValid(resource mdbv1.AtlasCustomResource) (bool, error)

ResourceVersionIsValid returns 'true' if current version of resource is <= current version of the operator.

func SetFinalizer

func SetFinalizer(resource mdbv1.AtlasCustomResource, finalizer string)

SetFinalizer Add the given finalizer to the list of resource finalizer

func UnsetFinalizer

func UnsetFinalizer(resource mdbv1.AtlasCustomResource, finalizer string)

UnsetFinalizer remove the given finalizer from the list of resource finalizer

func ValidateResourceVersion

func ValidateResourceVersion(ctx *workflow.Context, resource mdbv1.AtlasCustomResource, log *zap.SugaredLogger) workflow.Result