Skip to content

Commit 9235a09

Browse files
filipcirtogk8s-infra-cherrypick-robot
authored andcommitted
feedback improvements
1 parent 9b1be0b commit 9235a09

File tree

3 files changed

+11
-26
lines changed

3 files changed

+11
-26
lines changed

pkg/client/client.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -151,8 +151,7 @@ func newClient(config *rest.Config, options Options) (*client, error) {
151151
mapper: options.Mapper,
152152
codecs: serializer.NewCodecFactory(options.Scheme),
153153

154-
structuredResourceByType: make(map[cacheKey]*resourceMeta),
155-
unstructuredResourceByType: make(map[cacheKey]*resourceMeta),
154+
resourceByType: make(map[cacheKey]*resourceMeta),
156155
}
157156

158157
rawMetaClient, err := metadata.NewForConfigAndClient(metadata.ConfigFor(config), options.HTTPClient)

pkg/client/client_rest_resources.go

Lines changed: 4 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -48,11 +48,8 @@ type clientRestResources struct {
4848
// codecs are used to create a REST client for a gvk
4949
codecs serializer.CodecFactory
5050

51-
// structuredResourceByType stores structured type metadata
52-
structuredResourceByType map[cacheKey]*resourceMeta
53-
54-
// unstructuredResourceByType stores unstructured type metadata
55-
unstructuredResourceByType map[cacheKey]*resourceMeta
51+
// resourceByType stores type metadata
52+
resourceByType map[cacheKey]*resourceMeta
5653

5754
mu sync.RWMutex
5855
}
@@ -127,12 +124,7 @@ func (c *clientRestResources) getResource(obj any) (*resourceMeta, error) {
127124

128125
cacheKey := cacheKey{gvk: gvk, forceDisableProtoBuf: forceDisableProtoBuf}
129126

130-
resourceByType := c.structuredResourceByType
131-
if isUnstructured {
132-
resourceByType = c.unstructuredResourceByType
133-
}
134-
135-
r, known := resourceByType[cacheKey]
127+
r, known := c.resourceByType[cacheKey]
136128

137129
c.mu.RUnlock()
138130

@@ -152,7 +144,7 @@ func (c *clientRestResources) getResource(obj any) (*resourceMeta, error) {
152144
if err != nil {
153145
return nil, err
154146
}
155-
resourceByType[cacheKey] = r
147+
c.resourceByType[cacheKey] = r
156148
return r, err
157149
}
158150

pkg/client/client_test.go

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -960,10 +960,6 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
960960
"some-key": []byte("some-value"),
961961
}
962962
secretObject := &corev1.Secret{
963-
TypeMeta: metav1.TypeMeta{
964-
Kind: "Secret",
965-
APIVersion: "v1",
966-
},
967963
ObjectMeta: metav1.ObjectMeta{
968964
Name: "secret-one",
969965
Namespace: "default",
@@ -973,8 +969,6 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
973969

974970
secretApplyConfiguration := corev1applyconfigurations.
975971
Secret("secret-two", "default").
976-
WithAPIVersion("v1").
977-
WithKind("Secret").
978972
WithData(data)
979973

980974
err = cl.Create(ctx, secretObject)
@@ -983,11 +977,11 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
983977
err = cl.Apply(ctx, secretApplyConfiguration, &client.ApplyOptions{FieldManager: "test-manager"})
984978
Expect(err).NotTo(HaveOccurred())
985979

986-
cm, err := clientset.CoreV1().Secrets(ptr.Deref(secretApplyConfiguration.GetNamespace(), "")).Get(ctx, ptr.Deref(secretApplyConfiguration.GetName(), ""), metav1.GetOptions{})
980+
secret, err := clientset.CoreV1().Secrets(ptr.Deref(secretApplyConfiguration.GetNamespace(), "")).Get(ctx, ptr.Deref(secretApplyConfiguration.GetName(), ""), metav1.GetOptions{})
987981
Expect(err).NotTo(HaveOccurred())
988982

989-
Expect(cm.Data).To(BeComparableTo(data))
990-
Expect(cm.Data).To(BeComparableTo(secretApplyConfiguration.Data))
983+
Expect(secret.Data).To(BeComparableTo(data))
984+
Expect(secret.Data).To(BeComparableTo(secretApplyConfiguration.Data))
991985

992986
data = map[string][]byte{
993987
"some-key": []byte("some-new-value"),
@@ -997,11 +991,11 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
997991
err = cl.Apply(ctx, secretApplyConfiguration, &client.ApplyOptions{FieldManager: "test-manager"})
998992
Expect(err).NotTo(HaveOccurred())
999993

1000-
cm, err = clientset.CoreV1().Secrets(ptr.Deref(secretApplyConfiguration.GetNamespace(), "")).Get(ctx, ptr.Deref(secretApplyConfiguration.GetName(), ""), metav1.GetOptions{})
994+
secret, err = clientset.CoreV1().Secrets(ptr.Deref(secretApplyConfiguration.GetNamespace(), "")).Get(ctx, ptr.Deref(secretApplyConfiguration.GetName(), ""), metav1.GetOptions{})
1001995
Expect(err).NotTo(HaveOccurred())
1002996

1003-
Expect(cm.Data).To(BeComparableTo(data))
1004-
Expect(cm.Data).To(BeComparableTo(secretApplyConfiguration.Data))
997+
Expect(secret.Data).To(BeComparableTo(data))
998+
Expect(secret.Data).To(BeComparableTo(secretApplyConfiguration.Data))
1005999
})
10061000
})
10071001
})

0 commit comments

Comments
 (0)