Skip to content

Commit 4e755a1

Browse files
committed
feedback improvements
1 parent a285a4f commit 4e755a1

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
@@ -962,10 +962,6 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
962962
"some-key": []byte("some-value"),
963963
}
964964
secretObject := &corev1.Secret{
965-
TypeMeta: metav1.TypeMeta{
966-
Kind: "Secret",
967-
APIVersion: "v1",
968-
},
969965
ObjectMeta: metav1.ObjectMeta{
970966
Name: "secret-one",
971967
Namespace: "default",
@@ -975,8 +971,6 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
975971

976972
secretApplyConfiguration := corev1applyconfigurations.
977973
Secret("secret-two", "default").
978-
WithAPIVersion("v1").
979-
WithKind("Secret").
980974
WithData(data)
981975

982976
err = cl.Create(ctx, secretObject)
@@ -985,11 +979,11 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
985979
err = cl.Apply(ctx, secretApplyConfiguration, &client.ApplyOptions{FieldManager: "test-manager"})
986980
Expect(err).NotTo(HaveOccurred())
987981

988-
cm, err := clientset.CoreV1().Secrets(ptr.Deref(secretApplyConfiguration.GetNamespace(), "")).Get(ctx, ptr.Deref(secretApplyConfiguration.GetName(), ""), metav1.GetOptions{})
982+
secret, err := clientset.CoreV1().Secrets(ptr.Deref(secretApplyConfiguration.GetNamespace(), "")).Get(ctx, ptr.Deref(secretApplyConfiguration.GetName(), ""), metav1.GetOptions{})
989983
Expect(err).NotTo(HaveOccurred())
990984

991-
Expect(cm.Data).To(BeComparableTo(data))
992-
Expect(cm.Data).To(BeComparableTo(secretApplyConfiguration.Data))
985+
Expect(secret.Data).To(BeComparableTo(data))
986+
Expect(secret.Data).To(BeComparableTo(secretApplyConfiguration.Data))
993987

994988
data = map[string][]byte{
995989
"some-key": []byte("some-new-value"),
@@ -999,11 +993,11 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
999993
err = cl.Apply(ctx, secretApplyConfiguration, &client.ApplyOptions{FieldManager: "test-manager"})
1000994
Expect(err).NotTo(HaveOccurred())
1001995

1002-
cm, err = clientset.CoreV1().Secrets(ptr.Deref(secretApplyConfiguration.GetNamespace(), "")).Get(ctx, ptr.Deref(secretApplyConfiguration.GetName(), ""), metav1.GetOptions{})
996+
secret, err = clientset.CoreV1().Secrets(ptr.Deref(secretApplyConfiguration.GetNamespace(), "")).Get(ctx, ptr.Deref(secretApplyConfiguration.GetName(), ""), metav1.GetOptions{})
1003997
Expect(err).NotTo(HaveOccurred())
1004998

1005-
Expect(cm.Data).To(BeComparableTo(data))
1006-
Expect(cm.Data).To(BeComparableTo(secretApplyConfiguration.Data))
999+
Expect(secret.Data).To(BeComparableTo(data))
1000+
Expect(secret.Data).To(BeComparableTo(secretApplyConfiguration.Data))
10071001
})
10081002
})
10091003
})

0 commit comments

Comments
 (0)