customresource

func ApplyLastConfigApplied ¶

func ApplyLastConfigApplied(ctx context.Context, resource api.AtlasCustomResource, k8sClient client.Client) error

func HaveFinalizer ¶

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

func IsOwner ¶

func IsOwner(resource api.AtlasCustomResource, protectionFlag bool, operatorChecker OperatorChecker, atlasChecker AtlasChecker) (bool, error)

func IsResourceManagedByOperator ¶

func IsResourceManagedByOperator(resource api.AtlasCustomResource) (bool, error)

func IsResourcePolicyKeep ¶ added in v2.1.0

func IsResourcePolicyKeep(resource api.AtlasCustomResource) bool

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

func IsResourcePolicyKeepOrDefault ¶ added in v2.1.0

func IsResourcePolicyKeepOrDefault(resource api.AtlasCustomResource, protectionFlag bool) bool

func ManageFinalizer ¶

func ManageFinalizer(
	ctx context.Context,
	c client.Client,
	resource api.AtlasCustomResource,
	op FinalizerOperator,
) error

func MarkReconciliationStarted ¶

func MarkReconciliationStarted(client client.Client, resource api.AtlasCustomResource, log *zap.SugaredLogger, context context.Context) *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(ctx context.Context, client client.Client, request reconcile.Request, resource api.AtlasCustomResource, log *zap.SugaredLogger) workflow.Result

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

func ReconciliationShouldBeSkipped ¶

func ReconciliationShouldBeSkipped(resource api.AtlasCustomResource) bool

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

func ResourceVersionIsValid ¶

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

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

func SetAnnotation ¶

func SetAnnotation(resource api.AtlasCustomResource, key, value string)

SetAnnotation sets an annotation in resource while respecting the rest of annotations.

func SetFinalizer ¶

func SetFinalizer(resource api.AtlasCustomResource, finalizer string)

SetFinalizer Add the given finalizer to the list of resource finalizer

func UnsetFinalizer ¶

func UnsetFinalizer(resource api.AtlasCustomResource, finalizer string)

UnsetFinalizer remove the given finalizer from the list of resource finalizer

func ValidateResourceVersion ¶

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