Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 169 for fieldmanager_b (0.19 sec)

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

    	}
    
    	// Agent A applies initial configuration
    	if err := f.Apply(newObj.DeepCopyObject(), "fieldmanager_z", false); err != nil {
    		t.Fatalf("failed to apply object: %v", err)
    	}
    
    	// Agent B applies additive configuration
    	if err := f.Apply(appliedObj, "fieldmanager_b", false); err != nil {
    		t.Fatalf("failed to apply object %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 16 20:03:48 UTC 2023
    - 32.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/fieldmanager.go

    // FieldManager updates the managed fields and merges applied
    // configurations.
    type FieldManager struct {
    	fieldManager Manager
    	subresource  string
    }
    
    // NewFieldManager creates a new FieldManager that decodes, manages, then re-encodes managedFields
    // on update and apply requests.
    func NewFieldManager(f Manager, subresource string) *FieldManager {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 16 20:03:48 UTC 2023
    - 7.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/managedfields/fieldmanager.go

    	"k8s.io/apimachinery/pkg/util/managedfields/internal"
    	"sigs.k8s.io/structured-merge-diff/v4/fieldpath"
    )
    
    // FieldManager updates the managed fields and merges applied
    // configurations.
    type FieldManager = internal.FieldManager
    
    // NewDefaultFieldManager creates a new FieldManager that merges apply requests
    // and update managed fields for other types of requests.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/skipnonapplied.go

    }
    
    // NewProbabilisticSkipNonAppliedManager creates a new wrapped FieldManager that starts tracking managers after the first apply,
    // or starts tracking on create with p probability.
    func NewProbabilisticSkipNonAppliedManager(fieldManager Manager, objectCreater runtime.ObjectCreater, p float32) Manager {
    	return &skipNonAppliedManager{
    		fieldManager:           fieldManager,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 16 20:03:48 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/util/managedfields/extract.go

    // into applyConfiguration. If no managed fields are found for the given fieldManager,
    // no error is returned, but applyConfiguration is left unpopulated. It is possible
    // that no managed fields were found for the fieldManager because other field managers
    // have taken ownership of all the fields previously owned by the fieldManager. It is
    // also possible the fieldManager never owned fields.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 12 03:17:15 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/versioncheck.go

    )
    
    type versionCheckManager struct {
    	fieldManager Manager
    	gvk          schema.GroupVersionKind
    }
    
    var _ Manager = &versionCheckManager{}
    
    // NewVersionCheckManager creates a manager that makes sure that the
    // applied object is in the proper version.
    func NewVersionCheckManager(fieldManager Manager, gvk schema.GroupVersionKind) Manager {
    	return &versionCheckManager{fieldManager: fieldManager, gvk: gvk}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 16 20:03:48 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/lastappliedmanager_test.go

    			),
    		},
    		{
    			fieldManager: "kubectl",
    			original: []byte(`
    apiVersion: apps/v1
    kind: Deployment
    metadata:
      name: my-deployment
    spec:
      replicas: 3
    `),
    			applied: []byte(`
    apiVersion: apps/v1
    kind: Deployment
    metadata:
      name: my-deployment
    spec:
      replicas: 100 # update replicas
    `),
    		},
    		{
    			fieldManager: "kubectl",
    			lastApplied: []byte(`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 20K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/lastappliedupdater.go

    )
    
    type lastAppliedUpdater struct {
    	fieldManager Manager
    }
    
    var _ Manager = &lastAppliedUpdater{}
    
    // NewLastAppliedUpdater sets the client-side apply annotation up to date with
    // server-side apply managed fields
    func NewLastAppliedUpdater(fieldManager Manager) Manager {
    	return &lastAppliedUpdater{
    		fieldManager: fieldManager,
    	}
    }
    
    // Update implements Manager.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/capmanagers.go

    func NewCapManagersManager(fieldManager Manager, maxUpdateManagers int) Manager {
    	return &capManagersManager{
    		fieldManager:          fieldManager,
    		maxUpdateManagers:     maxUpdateManagers,
    		oldUpdatesManagerName: "ancient-changes",
    	}
    }
    
    // Update implements Manager.
    func (f *capManagersManager) Update(liveObj, newObj runtime.Object, managed Managed, manager string) (runtime.Object, Managed, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/util/managedfields/extract_test.go

    			err = ExtractInto(tc.obj, tc.objType, tc.fieldManager, &out, tc.subresource)
    			if err != nil {
    				t.Fatalf("Unexpected extract error: %v", err)
    			}
    			if !equality.Semantic.DeepEqual(out, tc.expectedOut) {
    				t.Fatalf("Expected output did not match actual output: %s", cmp.Diff(out, tc.expectedOut))
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 22 22:32:45 UTC 2021
    - 8.3K bytes
    - Viewed (0)
Back to top