github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

drop deprecated workqueue NewNamed package

Browse Source 
Signed-off-by: liyuerich <yue.li@daocloud.io>
This commit is contained in:
liyuerich
2023-10-16 18:11:17 +08:00
parent 7d880fd489
commit 98dfaed4be
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/controller/nodelifecycle/node_lifecycle_controller.go
View File

@@ -344,7 +344,7 @@ func NewNodeLifecycleController(
secondaryEvictionLimiterQPS: secondaryEvictionLimiterQPS, secondaryEvictionLimiterQPS: secondaryEvictionLimiterQPS,
largeClusterThreshold: largeClusterThreshold, largeClusterThreshold: largeClusterThreshold,
unhealthyZoneThreshold: unhealthyZoneThreshold, unhealthyZoneThreshold: unhealthyZoneThreshold,
nodeUpdateQueue: workqueue.NewNamed("node_lifecycle_controller"), nodeUpdateQueue: workqueue.NewTypedWithConfig[any](workqueue.TypedQueueConfig[any]{Name: "node_lifecycle_controller"}),
podUpdateQueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "node_lifecycle_controller_pods"), podUpdateQueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "node_lifecycle_controller_pods"),
} }

4
pkg/controller/volume/persistentvolume/pv_controller_base.go
View File

@@ -92,8 +92,8 @@ func NewController(ctx context.Context, p ControllerParameters) (*PersistentVolu
clusterName: p.ClusterName, clusterName: p.ClusterName,
createProvisionedPVRetryCount: createProvisionedPVRetryCount, createProvisionedPVRetryCount: createProvisionedPVRetryCount,
createProvisionedPVInterval: createProvisionedPVInterval, createProvisionedPVInterval: createProvisionedPVInterval,
claimQueue: workqueue.NewNamed("claims"), claimQueue: workqueue.NewTypedWithConfig[any](workqueue.TypedQueueConfig[any]{Name: "claims"}),
volumeQueue: workqueue.NewNamed("volumes"), volumeQueue: workqueue.NewTypedWithConfig[any](workqueue.TypedQueueConfig[any]{Name: "volumes"}),
resyncPeriod: p.SyncPeriod, resyncPeriod: p.SyncPeriod,
operationTimestamps: metrics.NewOperationStartTimeCache(), operationTimestamps: metrics.NewOperationStartTimeCache(),
} }

2
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
View File

@@ -122,7 +122,7 @@ func NewQuotaEvaluator(quotaAccessor QuotaAccessor, ignoredResources map[schema.
ignoredResources: ignoredResources, ignoredResources: ignoredResources,
registry: quotaRegistry, registry: quotaRegistry,
queue: workqueue.NewNamed("admission_quota_controller"), queue: workqueue.NewTypedWithConfig[any](workqueue.TypedQueueConfig[any]{Name: "admission_quota_controller"}),
work: map[string][]*admissionWaiter{}, work: map[string][]*admissionWaiter{},
dirtyWork: map[string][]*admissionWaiter{}, dirtyWork: map[string][]*admissionWaiter{},
inProgress: sets.String{}, inProgress: sets.String{},