Merge pull request #30972 from TerryHowe/kube-client-update-mutex

fix: kube client create mutex
pull/30973/head
Matt Farina 3 months ago committed by GitHub
commit 0a8194c9a3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

@ -585,10 +585,14 @@ func batchPerform(infos ResourceList, fn func(*resource.Info) error, errs chan<-
} }
} }
var createMutex sync.Mutex
func createResource(info *resource.Info) error { func createResource(info *resource.Info) error {
return retry.RetryOnConflict( return retry.RetryOnConflict(
retry.DefaultRetry, retry.DefaultRetry,
func() error { func() error {
createMutex.Lock()
defer createMutex.Unlock()
obj, err := resource.NewHelper(info.Client, info.Mapping).WithFieldManager(getManagedFieldsManager()).Create(info.Namespace, true, info.Object) obj, err := resource.NewHelper(info.Client, info.Mapping).WithFieldManager(getManagedFieldsManager()).Create(info.Namespace, true, info.Object)
if err != nil { if err != nil {
return err return err

Loading…
Cancel
Save