Update generated

This commit is contained in:
jennybuckley 2019-07-17 14:59:50 -07:00 committed by Jennifer Buckley
parent 229894c730
commit 018a3db25e
11 changed files with 90 additions and 69 deletions

4
go.sum
View File

@ -484,8 +484,8 @@ modernc.org/strutil v1.0.0/go.mod h1:lstksw84oURvj9y3tn8lGvRxyRC1S2+g5uuIzNfIOBs
modernc.org/xc v1.0.0/go.mod h1:mRNCo0bvLjGhHO9WsyuKVU4q0ceiDDDoEeWDJHrNx8I= modernc.org/xc v1.0.0/go.mod h1:mRNCo0bvLjGhHO9WsyuKVU4q0ceiDDDoEeWDJHrNx8I=
sigs.k8s.io/kustomize v2.0.3+incompatible h1:JUufWFNlI44MdtnjUqVnvh29rR37PQFzPbLXqhyOyX0= sigs.k8s.io/kustomize v2.0.3+incompatible h1:JUufWFNlI44MdtnjUqVnvh29rR37PQFzPbLXqhyOyX0=
sigs.k8s.io/kustomize v2.0.3+incompatible/go.mod h1:MkjgH3RdOWrievjo6c9T245dYlB5QeXV4WCbnt/PEpU= sigs.k8s.io/kustomize v2.0.3+incompatible/go.mod h1:MkjgH3RdOWrievjo6c9T245dYlB5QeXV4WCbnt/PEpU=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ= sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143 h1:9df9ZMJ21XLKSCuwZyI+qfbnQl/hDmrM7wjBK85iv8g=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI= sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs= sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs=
sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o= sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=
vbom.ml/util v0.0.0-20160121211510-db5cfe13f5cc h1:MksmcCZQWAQJCTA5T0jgI/0sJ51AVm4Z41MrmfczEoc= vbom.ml/util v0.0.0-20160121211510-db5cfe13f5cc h1:MksmcCZQWAQJCTA5T0jgI/0sJ51AVm4Z41MrmfczEoc=

View File

@ -310,5 +310,7 @@ modernc.org/strutil v1.0.0/go.mod h1:lstksw84oURvj9y3tn8lGvRxyRC1S2+g5uuIzNfIOBs
modernc.org/xc v1.0.0/go.mod h1:mRNCo0bvLjGhHO9WsyuKVU4q0ceiDDDoEeWDJHrNx8I= modernc.org/xc v1.0.0/go.mod h1:mRNCo0bvLjGhHO9WsyuKVU4q0ceiDDDoEeWDJHrNx8I=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143 h1:9df9ZMJ21XLKSCuwZyI+qfbnQl/hDmrM7wjBK85iv8g=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs= sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs=
sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o= sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=

View File

@ -59,7 +59,7 @@ require (
k8s.io/klog v0.3.1 k8s.io/klog v0.3.1
k8s.io/kube-openapi v0.0.0-20190709113604-33be087ad058 k8s.io/kube-openapi v0.0.0-20190709113604-33be087ad058
k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143
sigs.k8s.io/yaml v1.1.0 sigs.k8s.io/yaml v1.1.0
) )

View File

@ -229,5 +229,7 @@ k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a h1:2jUDc9gJja832Ftp+QbDV0tVhQHMI
k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a/go.mod h1:sZAwmy6armz5eXlNoLmJcl4F1QuKu7sr+mFQ0byX7Ew= k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a/go.mod h1:sZAwmy6armz5eXlNoLmJcl4F1QuKu7sr+mFQ0byX7Ew=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143 h1:9df9ZMJ21XLKSCuwZyI+qfbnQl/hDmrM7wjBK85iv8g=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs= sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs=
sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o= sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=

View File

@ -266,5 +266,7 @@ modernc.org/strutil v1.0.0/go.mod h1:lstksw84oURvj9y3tn8lGvRxyRC1S2+g5uuIzNfIOBs
modernc.org/xc v1.0.0/go.mod h1:mRNCo0bvLjGhHO9WsyuKVU4q0ceiDDDoEeWDJHrNx8I= modernc.org/xc v1.0.0/go.mod h1:mRNCo0bvLjGhHO9WsyuKVU4q0ceiDDDoEeWDJHrNx8I=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143 h1:9df9ZMJ21XLKSCuwZyI+qfbnQl/hDmrM7wjBK85iv8g=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs= sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs=
sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o= sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=

View File

@ -209,5 +209,6 @@ k8s.io/kube-openapi v0.0.0-20190709113604-33be087ad058/go.mod h1:nfDlWeOsu3pUf4y
k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a h1:2jUDc9gJja832Ftp+QbDV0tVhQHMISFn01els+2ZAcw= k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a h1:2jUDc9gJja832Ftp+QbDV0tVhQHMISFn01els+2ZAcw=
k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a/go.mod h1:sZAwmy6armz5eXlNoLmJcl4F1QuKu7sr+mFQ0byX7Ew= k8s.io/utils v0.0.0-20190607212802-c55fbcfc754a/go.mod h1:sZAwmy6armz5eXlNoLmJcl4F1QuKu7sr+mFQ0byX7Ew=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs= sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs=
sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o= sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=

View File

@ -263,5 +263,7 @@ modernc.org/strutil v1.0.0/go.mod h1:lstksw84oURvj9y3tn8lGvRxyRC1S2+g5uuIzNfIOBs
modernc.org/xc v1.0.0/go.mod h1:mRNCo0bvLjGhHO9WsyuKVU4q0ceiDDDoEeWDJHrNx8I= modernc.org/xc v1.0.0/go.mod h1:mRNCo0bvLjGhHO9WsyuKVU4q0ceiDDDoEeWDJHrNx8I=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e h1:4Z09Hglb792X0kfOBBJUPFEyvVfQWrYT/l8h5EKA6JQ=
sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI= sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143 h1:9df9ZMJ21XLKSCuwZyI+qfbnQl/hDmrM7wjBK85iv8g=
sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143/go.mod h1:wWxsB5ozmmv/SG7nM11ayaAW51xMvak/t1r0CSlcokI=
sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs= sigs.k8s.io/yaml v1.1.0 h1:4A07+ZFc2wgJwo8YNlQpr1rVlgUDlxXHhPJciaPY5gs=
sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o= sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=

2
vendor/modules.txt vendored
View File

@ -1752,7 +1752,7 @@ sigs.k8s.io/kustomize/pkg/transformers
sigs.k8s.io/kustomize/pkg/transformers/config sigs.k8s.io/kustomize/pkg/transformers/config
sigs.k8s.io/kustomize/pkg/transformers/config/defaultconfig sigs.k8s.io/kustomize/pkg/transformers/config/defaultconfig
sigs.k8s.io/kustomize/pkg/types sigs.k8s.io/kustomize/pkg/types
# sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e => sigs.k8s.io/structured-merge-diff v0.0.0-20190525122527-15d366b2352e # sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143 => sigs.k8s.io/structured-merge-diff v0.0.0-20190628201129-059502f64143
sigs.k8s.io/structured-merge-diff/fieldpath sigs.k8s.io/structured-merge-diff/fieldpath
sigs.k8s.io/structured-merge-diff/merge sigs.k8s.io/structured-merge-diff/merge
sigs.k8s.io/structured-merge-diff/schema sigs.k8s.io/structured-merge-diff/schema

View File

@ -16,16 +16,42 @@ package fieldpath
// APIVersion describes the version of an object or of a fieldset. // APIVersion describes the version of an object or of a fieldset.
type APIVersion string type APIVersion string
type VersionedSet interface {
Set() *Set
APIVersion() APIVersion
Applied() bool
}
// VersionedSet associates a version to a set. // VersionedSet associates a version to a set.
type VersionedSet struct { type versionedSet struct {
*Set set *Set
APIVersion APIVersion apiVersion APIVersion
Applied bool applied bool
}
func NewVersionedSet(set *Set, apiVersion APIVersion, applied bool) VersionedSet {
return versionedSet{
set: set,
apiVersion: apiVersion,
applied: applied,
}
}
func (v versionedSet) Set() *Set {
return v.set
}
func (v versionedSet) APIVersion() APIVersion {
return v.apiVersion
}
func (v versionedSet) Applied() bool {
return v.applied
} }
// ManagedFields is a map from manager to VersionedSet (what they own in // ManagedFields is a map from manager to VersionedSet (what they own in
// what version). // what version).
type ManagedFields map[string]*VersionedSet type ManagedFields map[string]VersionedSet
// Difference returns a symmetric difference between two Managers. If a // Difference returns a symmetric difference between two Managers. If a
// given user's entry has version X in lhs and version Y in rhs, then // given user's entry has version X in lhs and version Y in rhs, then
@ -37,7 +63,7 @@ func (lhs ManagedFields) Difference(rhs ManagedFields) ManagedFields {
for manager, left := range lhs { for manager, left := range lhs {
right, ok := rhs[manager] right, ok := rhs[manager]
if !ok { if !ok {
if !left.Empty() { if !left.Set().Empty() {
diff[manager] = left diff[manager] = left
} }
continue continue
@ -46,17 +72,14 @@ func (lhs ManagedFields) Difference(rhs ManagedFields) ManagedFields {
// If we have sets in both but their version // If we have sets in both but their version
// differs, we don't even diff and keep the // differs, we don't even diff and keep the
// entire thing. // entire thing.
if left.APIVersion != right.APIVersion { if left.APIVersion() != right.APIVersion() {
diff[manager] = right diff[manager] = right
continue continue
} }
newSet := left.Difference(right.Set).Union(right.Difference(left.Set)) newSet := left.Set().Difference(right.Set()).Union(right.Set().Difference(left.Set()))
if !newSet.Empty() { if !newSet.Empty() {
diff[manager] = &VersionedSet{ diff[manager] = NewVersionedSet(newSet, right.APIVersion(), false)
Set: newSet,
APIVersion: right.APIVersion,
}
} }
} }
@ -65,7 +88,7 @@ func (lhs ManagedFields) Difference(rhs ManagedFields) ManagedFields {
// Already done // Already done
continue continue
} }
if !set.Empty() { if !set.Set().Empty() {
diff[manager] = set diff[manager] = set
} }
} }

View File

@ -79,7 +79,7 @@ func ConflictsFromManagers(sets fieldpath.ManagedFields) Conflicts {
conflicts := []Conflict{} conflicts := []Conflict{}
for manager, set := range sets { for manager, set := range sets {
set.Iterate(func(p fieldpath.Path) { set.Set().Iterate(func(p fieldpath.Path) {
conflicts = append(conflicts, Conflict{ conflicts = append(conflicts, Conflict{
Manager: manager, Manager: manager,
Path: p, Path: p,

View File

@ -36,25 +36,23 @@ type Updater struct {
func (s *Updater) update(oldObject, newObject *typed.TypedValue, version fieldpath.APIVersion, managers fieldpath.ManagedFields, workflow string, force bool) (fieldpath.ManagedFields, error) { func (s *Updater) update(oldObject, newObject *typed.TypedValue, version fieldpath.APIVersion, managers fieldpath.ManagedFields, workflow string, force bool) (fieldpath.ManagedFields, error) {
conflicts := fieldpath.ManagedFields{} conflicts := fieldpath.ManagedFields{}
removed := fieldpath.ManagedFields{} removed := fieldpath.ManagedFields{}
type Versioned struct { compare, err := oldObject.Compare(newObject)
oldObject *typed.TypedValue if err != nil {
newObject *typed.TypedValue return nil, fmt.Errorf("failed to compare objects: %v", err)
} }
versions := map[fieldpath.APIVersion]Versioned{
version: { versions := map[fieldpath.APIVersion]*typed.Comparison{
oldObject: oldObject, version: compare,
newObject: newObject,
},
} }
for manager, managerSet := range managers { for manager, managerSet := range managers {
if manager == workflow { if manager == workflow {
continue continue
} }
versioned, ok := versions[managerSet.APIVersion] compare, ok := versions[managerSet.APIVersion()]
if !ok { if !ok {
var err error var err error
versioned.oldObject, err = s.Converter.Convert(oldObject, managerSet.APIVersion) versionedOldObject, err := s.Converter.Convert(oldObject, managerSet.APIVersion())
if err != nil { if err != nil {
if s.Converter.IsMissingVersionError(err) { if s.Converter.IsMissingVersionError(err) {
delete(managers, manager) delete(managers, manager)
@ -62,7 +60,7 @@ func (s *Updater) update(oldObject, newObject *typed.TypedValue, version fieldpa
} }
return nil, fmt.Errorf("failed to convert old object: %v", err) return nil, fmt.Errorf("failed to convert old object: %v", err)
} }
versioned.newObject, err = s.Converter.Convert(newObject, managerSet.APIVersion) versionedNewObject, err := s.Converter.Convert(newObject, managerSet.APIVersion())
if err != nil { if err != nil {
if s.Converter.IsMissingVersionError(err) { if s.Converter.IsMissingVersionError(err) {
delete(managers, manager) delete(managers, manager)
@ -70,26 +68,20 @@ func (s *Updater) update(oldObject, newObject *typed.TypedValue, version fieldpa
} }
return nil, fmt.Errorf("failed to convert new object: %v", err) return nil, fmt.Errorf("failed to convert new object: %v", err)
} }
versions[managerSet.APIVersion] = versioned compare, err = versionedOldObject.Compare(versionedNewObject)
} if err != nil {
compare, err := versioned.oldObject.Compare(versioned.newObject) return nil, fmt.Errorf("failed to compare objects: %v", err)
if err != nil { }
return nil, fmt.Errorf("failed to compare objects: %v", err) versions[managerSet.APIVersion()] = compare
} }
conflictSet := managerSet.Intersection(compare.Modified.Union(compare.Added)) conflictSet := managerSet.Set().Intersection(compare.Modified.Union(compare.Added))
if !conflictSet.Empty() { if !conflictSet.Empty() {
conflicts[manager] = &fieldpath.VersionedSet{ conflicts[manager] = fieldpath.NewVersionedSet(conflictSet, managerSet.APIVersion(), false)
Set: conflictSet,
APIVersion: managerSet.APIVersion,
}
} }
if !compare.Removed.Empty() { if !compare.Removed.Empty() {
removed[manager] = &fieldpath.VersionedSet{ removed[manager] = fieldpath.NewVersionedSet(compare.Removed, managerSet.APIVersion(), false)
Set: compare.Removed,
APIVersion: managerSet.APIVersion,
}
} }
} }
@ -98,15 +90,15 @@ func (s *Updater) update(oldObject, newObject *typed.TypedValue, version fieldpa
} }
for manager, conflictSet := range conflicts { for manager, conflictSet := range conflicts {
managers[manager].Set = managers[manager].Set.Difference(conflictSet.Set) managers[manager] = fieldpath.NewVersionedSet(managers[manager].Set().Difference(conflictSet.Set()), managers[manager].APIVersion(), managers[manager].Applied())
} }
for manager, removedSet := range removed { for manager, removedSet := range removed {
managers[manager].Set = managers[manager].Set.Difference(removedSet.Set) managers[manager] = fieldpath.NewVersionedSet(managers[manager].Set().Difference(removedSet.Set()), managers[manager].APIVersion(), managers[manager].Applied())
} }
for manager := range managers { for manager := range managers {
if managers[manager].Set.Empty() { if managers[manager].Set().Empty() {
delete(managers, manager) delete(managers, manager)
} }
} }
@ -134,13 +126,14 @@ func (s *Updater) Update(liveObject, newObject *typed.TypedValue, version fieldp
return nil, fieldpath.ManagedFields{}, fmt.Errorf("failed to compare live and new objects: %v", err) return nil, fieldpath.ManagedFields{}, fmt.Errorf("failed to compare live and new objects: %v", err)
} }
if _, ok := managers[manager]; !ok { if _, ok := managers[manager]; !ok {
managers[manager] = &fieldpath.VersionedSet{ managers[manager] = fieldpath.NewVersionedSet(fieldpath.NewSet(), version, false)
Set: fieldpath.NewSet(),
}
} }
managers[manager].Set = managers[manager].Set.Union(compare.Modified).Union(compare.Added).Difference(compare.Removed) managers[manager] = fieldpath.NewVersionedSet(
managers[manager].APIVersion = version managers[manager].Set().Union(compare.Modified).Union(compare.Added).Difference(compare.Removed),
if managers[manager].Set.Empty() { version,
false,
)
if managers[manager].Set().Empty() {
delete(managers, manager) delete(managers, manager)
} }
return newObject, managers, nil return newObject, managers, nil
@ -168,11 +161,7 @@ func (s *Updater) Apply(liveObject, configObject *typed.TypedValue, version fiel
if err != nil { if err != nil {
return nil, fieldpath.ManagedFields{}, fmt.Errorf("failed to get field set: %v", err) return nil, fieldpath.ManagedFields{}, fmt.Errorf("failed to get field set: %v", err)
} }
managers[manager] = &fieldpath.VersionedSet{ managers[manager] = fieldpath.NewVersionedSet(set, version, true)
Set: set,
APIVersion: version,
Applied: true,
}
newObject, err = s.prune(newObject, managers, manager, lastSet) newObject, err = s.prune(newObject, managers, manager, lastSet)
if err != nil { if err != nil {
return nil, fieldpath.ManagedFields{}, fmt.Errorf("failed to prune fields: %v", err) return nil, fieldpath.ManagedFields{}, fmt.Errorf("failed to prune fields: %v", err)
@ -196,18 +185,18 @@ func shallowCopyManagers(managers fieldpath.ManagedFields) fieldpath.ManagedFiel
// * applyingManager applied it last time // * applyingManager applied it last time
// * applyingManager didn't apply it this time // * applyingManager didn't apply it this time
// * no other applier claims to manage it // * no other applier claims to manage it
func (s *Updater) prune(merged *typed.TypedValue, managers fieldpath.ManagedFields, applyingManager string, lastSet *fieldpath.VersionedSet) (*typed.TypedValue, error) { func (s *Updater) prune(merged *typed.TypedValue, managers fieldpath.ManagedFields, applyingManager string, lastSet fieldpath.VersionedSet) (*typed.TypedValue, error) {
if lastSet == nil || lastSet.Set.Empty() { if lastSet == nil || lastSet.Set().Empty() {
return merged, nil return merged, nil
} }
convertedMerged, err := s.Converter.Convert(merged, lastSet.APIVersion) convertedMerged, err := s.Converter.Convert(merged, lastSet.APIVersion())
if err != nil { if err != nil {
if s.Converter.IsMissingVersionError(err) { if s.Converter.IsMissingVersionError(err) {
return merged, nil return merged, nil
} }
return nil, fmt.Errorf("failed to convert merged object to last applied version: %v", err) return nil, fmt.Errorf("failed to convert merged object to last applied version: %v", err)
} }
pruned := convertedMerged.RemoveItems(lastSet.Set) pruned := convertedMerged.RemoveItems(lastSet.Set())
pruned, err = s.addBackOwnedItems(convertedMerged, pruned, managers, applyingManager) pruned, err = s.addBackOwnedItems(convertedMerged, pruned, managers, applyingManager)
if err != nil { if err != nil {
return nil, fmt.Errorf("failed add back owned items: %v", err) return nil, fmt.Errorf("failed add back owned items: %v", err)
@ -216,7 +205,7 @@ func (s *Updater) prune(merged *typed.TypedValue, managers fieldpath.ManagedFiel
if err != nil { if err != nil {
return nil, fmt.Errorf("failed add back dangling items: %v", err) return nil, fmt.Errorf("failed add back dangling items: %v", err)
} }
return s.Converter.Convert(pruned, managers[applyingManager].APIVersion) return s.Converter.Convert(pruned, managers[applyingManager].APIVersion())
} }
// addBackOwnedItems adds back any list and map items that were removed by prune, // addBackOwnedItems adds back any list and map items that were removed by prune,
@ -225,11 +214,11 @@ func (s *Updater) addBackOwnedItems(merged, pruned *typed.TypedValue, managedFie
var err error var err error
managedAtVersion := map[fieldpath.APIVersion]*fieldpath.Set{} managedAtVersion := map[fieldpath.APIVersion]*fieldpath.Set{}
for _, managerSet := range managedFields { for _, managerSet := range managedFields {
if managerSet.Applied { if managerSet.Applied() {
if _, ok := managedAtVersion[managerSet.APIVersion]; !ok { if _, ok := managedAtVersion[managerSet.APIVersion()]; !ok {
managedAtVersion[managerSet.APIVersion] = fieldpath.NewSet() managedAtVersion[managerSet.APIVersion()] = fieldpath.NewSet()
} }
managedAtVersion[managerSet.APIVersion] = managedAtVersion[managerSet.APIVersion].Union(managerSet.Set) managedAtVersion[managerSet.APIVersion()] = managedAtVersion[managerSet.APIVersion()].Union(managerSet.Set())
} }
} }
for version, managed := range managedAtVersion { for version, managed := range managedAtVersion {
@ -263,8 +252,8 @@ func (s *Updater) addBackOwnedItems(merged, pruned *typed.TypedValue, managedFie
// addBackDanglingItems makes sure that the only items removed by prune are items that were // addBackDanglingItems makes sure that the only items removed by prune are items that were
// previously owned by the currently applying manager. This will add back unowned items and items // previously owned by the currently applying manager. This will add back unowned items and items
// which are owned by Updaters that shouldn't be removed. // which are owned by Updaters that shouldn't be removed.
func (s *Updater) addBackDanglingItems(merged, pruned *typed.TypedValue, lastSet *fieldpath.VersionedSet) (*typed.TypedValue, error) { func (s *Updater) addBackDanglingItems(merged, pruned *typed.TypedValue, lastSet fieldpath.VersionedSet) (*typed.TypedValue, error) {
convertedPruned, err := s.Converter.Convert(pruned, lastSet.APIVersion) convertedPruned, err := s.Converter.Convert(pruned, lastSet.APIVersion())
if err != nil { if err != nil {
if s.Converter.IsMissingVersionError(err) { if s.Converter.IsMissingVersionError(err) {
return merged, nil return merged, nil
@ -279,5 +268,5 @@ func (s *Updater) addBackDanglingItems(merged, pruned *typed.TypedValue, lastSet
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to create field set from merged object in last applied version: %v", err) return nil, fmt.Errorf("failed to create field set from merged object in last applied version: %v", err)
} }
return merged.RemoveItems(mergedSet.Difference(prunedSet).Intersection(lastSet.Set)), nil return merged.RemoveItems(mergedSet.Difference(prunedSet).Intersection(lastSet.Set())), nil
} }