File tree Expand file tree Collapse file tree 3 files changed +5
-4
lines changed Expand file tree Collapse file tree 3 files changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -62,7 +62,7 @@ func (m *InformersMap) Start(stop <-chan struct{}) error {
62
62
return nil
63
63
}
64
64
65
- // WaitForCacheSync waits until all the caches have been synced
65
+ // WaitForCacheSync waits until all the caches have been synced.
66
66
func (m * InformersMap ) WaitForCacheSync (stop <- chan struct {}) bool {
67
67
syncedFuncs := append ([]cache.InformerSynced (nil ), m .structured .HasSyncedFuncs ()... )
68
68
syncedFuncs = append (syncedFuncs , m .unstructured .HasSyncedFuncs ()... )
Original file line number Diff line number Diff line change @@ -238,7 +238,7 @@ func (ip *specificInformersMap) newListWatch(gvk schema.GroupVersionKind) (*cach
238
238
}, nil
239
239
}
240
240
241
- // createUnstructuredClient is a ClientCreatorFunc for use with structured
241
+ // createStructuredClient is a ClientCreatorFunc for use with structured
242
242
// objects (i.e. not Unstructured/UnstructuredList).
243
243
func createStructuredClient (gvk schema.GroupVersionKind ,
244
244
codecs serializer.CodecFactory ,
Original file line number Diff line number Diff line change @@ -45,12 +45,13 @@ type clientCache struct {
45
45
// codecs are used to create a REST client for a gvk
46
46
codecs serializer.CodecFactory
47
47
48
+ muByType sync.RWMutex
48
49
// resourceByType caches type metadata
49
50
resourceByType map [reflect.Type ]* resourceMeta
51
+
52
+ muByGVK sync.RWMutex
50
53
// resourceByGVK caches type metadata for unstructured
51
54
unstructuredResourceByGVK map [schema.GroupVersionKind ]* resourceMeta
52
- muByType sync.RWMutex
53
- muByGVK sync.RWMutex
54
55
}
55
56
56
57
// newResource maps obj to a Kubernetes Resource and constructs a client for that Resource.
You can’t perform that action at this time.
0 commit comments