Method executeCreateOperation

pkg/kube/object_patch/patch.go:83–150

(op *createOperation)

}

func (o *ObjectPatcher) executeCreateOperation(op *createOperation) error {
	if op.object == nil {
		return fmt.Errorf("cannot create empty object")
	}

	// Convert object from any.
	object, err := toUnstructured(op.object)
	if err != nil {
		return err
	}

	apiVersion := object.GetAPIVersion()
	kind := object.GetKind()

	wrapErr := func(e error) error {
		objectID := fmt.Sprintf("%s/%s/%s/%s", apiVersion, kind, object.GetNamespace(), object.GetName())
		return gerror.WithMessage(e, objectID)
	}

	gvk, err := o.kubeClient.GroupVersionResource(apiVersion, kind)
	if err != nil {
		return wrapErr(err)
	}

	log.Debug("Started Create API call")
	_, err = o.kubeClient.Dynamic().
		Resource(gvk).
		Namespace(object.GetNamespace()).
		Create(context.TODO(), object, pkg.DefaultCreateOptions(), generateSubresources(op.subresource)...)
	log.Debug("Finished Create API call")

	objectExists := errors.IsAlreadyExists(err)

	if objectExists && op.ignoreIfExists {
		log.Debug("resource already exists, exiting without error")
		return nil
	}

	if objectExists && op.updateIfExists {
		log.Debug("Object already exists, attempting to Update it with optimistic lock")

		return retry.RetryOnConflict(retry.DefaultBackoff, func() error {
			log.Debug("Started Get API call")
			existingObj, err := o.kubeClient.Dynamic().
				Resource(gvk).
				Namespace(object.GetNamespace()).
				Get(context.TODO(), object.GetName(), metav1.GetOptions{}, generateSubresources(op.subresource)...)
			log.Debug("Finished Get API call")
			if err != nil {
				return wrapErr(err)
			}

			objCopy := object.DeepCopy()
			objCopy.SetResourceVersion(existingObj.GetResourceVersion())

			log.Debug("Started Update API call")
			_, err = o.kubeClient.Dynamic().
				Resource(gvk).