Merge pull request #136925 from michaelasp/pipeFeatureGate

Pipe feature gate of unlockWhileProcessing

Kubernetes-commit: 7b999810bf37c025ba146e3e1feae80b44eac6d6
This commit is contained in:
Kubernetes Publisher
2026-02-11 08:38:01 +05:30

View File

@@ -852,6 +852,7 @@ func newQueueFIFO(logger klog.Logger, objectType any, clientState Store, transfo
// store to an atomic fifo.
if clientgofeaturegate.FeatureGates().Enabled(clientgofeaturegate.AtomicFIFO) {
options.AtomicEvents = true
options.UnlockWhileProcessing = clientgofeaturegate.FeatureGates().Enabled(clientgofeaturegate.UnlockWhileProcessingFIFO)
} else {
options.KnownObjects = clientState
}