- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 117 for fieldmanager_b (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/managedfieldsupdater.go
// done. func NewManagedFieldsUpdater(fieldManager Manager) Manager { return &managedFieldsUpdater{ fieldManager: fieldManager, } } // Update implements Manager. func (f *managedFieldsUpdater) Update(liveObj, newObj runtime.Object, managed Managed, manager string) (runtime.Object, Managed, error) { self := "current-operation" object, managed, err := f.fieldManager.Update(liveObj, newObj, managed, self) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/validation/validation.go
} } else { if options.FieldManager == "" { // This field is defaulted to "kubectl" by kubectl, but HAS TO be explicitly set by controllers. allErrs = append(allErrs, field.Required(field.NewPath("fieldManager"), "is required for apply patch")) } } allErrs = append(allErrs, ValidateFieldManager(options.FieldManager, field.NewPath("fieldManager"))...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 01:52:02 UTC 2022 - 13.5K bytes - Viewed (0)