-
Notifications
You must be signed in to change notification settings - Fork 907
/
object.go
104 lines (83 loc) · 2.41 KB
/
object.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
/*
Copyright 2024 The Crossplane Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package claim
import (
"strings"
"dario.cat/mergo"
"github.com/crossplane/crossplane-runtime/pkg/errors"
)
const (
errUnsupportedDstObject = "destination object was not valid object"
errUnsupportedSrcObject = "source object was not valid object"
)
func withoutReservedK8sEntries(a map[string]string) map[string]string {
for k := range a {
s := strings.Split(k, "/")
if strings.HasSuffix(s[0], "kubernetes.io") || strings.HasSuffix(s[0], "k8s.io") {
delete(a, k)
}
}
return a
}
func withoutKeys(in map[string]any, keys ...string) map[string]any {
filter := map[string]bool{}
for _, k := range keys {
filter[k] = true
}
out := map[string]any{}
for k, v := range in {
if filter[k] {
continue
}
out[k] = v
}
return out
}
type mergeConfig struct {
mergeOptions []func(*mergo.Config)
srcfilter []string
}
// withMergeOptions allows custom mergo.Config options.
func withMergeOptions(opts ...func(*mergo.Config)) func(*mergeConfig) {
return func(config *mergeConfig) {
config.mergeOptions = opts
}
}
// withSrcFilter filters supplied keys from src map before merging.
func withSrcFilter(keys ...string) func(*mergeConfig) {
return func(config *mergeConfig) {
config.srcfilter = keys
}
}
// merge a src map into dst map.
func merge(dst, src any, opts ...func(*mergeConfig)) error {
if dst == nil || src == nil {
// Nothing available to merge if dst or src are nil.
// This can occur early on in reconciliation when the
// status subresource has not been set yet.
return nil
}
config := &mergeConfig{}
for _, opt := range opts {
opt(config)
}
dstMap, ok := dst.(map[string]any)
if !ok {
return errors.New(errUnsupportedDstObject)
}
srcMap, ok := src.(map[string]any)
if !ok {
return errors.New(errUnsupportedSrcObject)
}
return mergo.Merge(&dstMap, withoutKeys(srcMap, config.srcfilter...), config.mergeOptions...)
}