Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewConflictError (0.36 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/conflict.go

    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"sigs.k8s.io/structured-merge-diff/v4/fieldpath"
    	"sigs.k8s.io/structured-merge-diff/v4/merge"
    )
    
    // NewConflictError returns an error including details on the requests apply conflicts
    func NewConflictError(conflicts merge.Conflicts) *errors.StatusError {
    	causes := []metav1.StatusCause{}
    	for _, conflict := range conflicts {
    		causes = append(causes, metav1.StatusCause{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/conflict_test.go

    	"k8s.io/apimachinery/pkg/util/managedfields/internal"
    	"sigs.k8s.io/structured-merge-diff/v4/fieldpath"
    	"sigs.k8s.io/structured-merge-diff/v4/merge"
    )
    
    // TestNewConflictError tests that NewConflictError creates the correct StatusError for a given smd Conflicts
    func TestNewConflictError(t *testing.T) {
    	testCases := []struct {
    		conflict merge.Conflicts
    		expected *errors.StatusError
    	}{
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/fieldmanager.go

    	}
    
    	object, managed, err = f.fieldManager.Apply(liveObj, appliedObj, managed, manager, force)
    	if err != nil {
    		if conflicts, ok := err.(merge.Conflicts); ok {
    			return nil, NewConflictError(conflicts)
    		}
    		return nil, err
    	}
    
    	if err = EncodeObjectManagedFields(object, managed); err != nil {
    		return nil, fmt.Errorf("failed to encode managed fields: %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 16 20:03:48 UTC 2023
    - 7.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/lastappliedmanager_test.go

    						Manager: fmt.Sprintf(`{"manager":"test_client_side_apply","operation":"Update","apiVersion":"%s"}`, f.APIVersion()),
    						Path:    p,
    					})
    				})
    				expectedConflictErr := internal.NewConflictError(expectedConflicts)
    				if !reflect.DeepEqual(expectedConflictErr, err) {
    					t.Errorf("expected to get\n%+v\nbut got\n%+v", expectedConflictErr, err)
    				}
    
    				// Yet force should resolve all conflicts
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 20K bytes
    - Viewed (0)
Back to top