Method Execute

pkg/utils/fencing.go:180–206

Execute executes the instructions given with the fluent builder, returns any error encountered

(ctx context.Context, key types.NamespacedName, obj client.Object)

// Execute executes the instructions given with the fluent builder, returns any error encountered
func (fb *FencingMetadataExecutor) Execute(ctx context.Context, key types.NamespacedName, obj client.Object) error {
	if len(fb.instanceNames) == 0 {
		return errors.New("chose an operation to execute")
	}
	if len(fb.instanceNames) > 1 && slices.Contains(fb.instanceNames, FenceAllInstances) {
		return errors.New("the fence-all-instances token (*) cannot be used along other instances")
	}

	if err := fb.cli.Get(ctx, key, obj); err != nil {
		return err
	}

	var appliedChange bool
	fencedObject := obj.DeepCopyObject().(client.Object)
	for _, name := range fb.instanceNames {
		changed, err := fb.fenceFunc(name, fencedObject)
		if err != nil {
			return err
		}
		appliedChange = appliedChange || changed
	}
	if !appliedChange {
		return nil
	}

	return fb.cli.Patch(ctx, fencedObject, client.MergeFrom(obj))
}