d8dfun/virtual-kubelet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Fix linting errors in node/podcontroller.go

Browse Source
This commit is contained in:
Sargun Dhillon
2019-09-03 10:10:35 -07:00
parent ee31118596
commit 7accddcaf4
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
node/podcontroller.go
View File

@@ -262,20 +262,20 @@ func (pc *PodController) Ready() <-chan struct{} {
} }
// runWorker is a long-running function that will continually call the processNextWorkItem function in order to read and process an item on the work queue. // runWorker is a long-running function that will continually call the processNextWorkItem function in order to read and process an item on the work queue.
func (pc *PodController) runWorker(ctx context.Context, workerId string, q workqueue.RateLimitingInterface) { func (pc *PodController) runWorker(ctx context.Context, workerID string, q workqueue.RateLimitingInterface) {
for pc.processNextWorkItem(ctx, workerId, q) { for pc.processNextWorkItem(ctx, workerID, q) {
} }
} }
// processNextWorkItem will read a single work item off the work queue and attempt to process it,by calling the syncHandler. // processNextWorkItem will read a single work item off the work queue and attempt to process it,by calling the syncHandler.
func (pc *PodController) processNextWorkItem(ctx context.Context, workerId string, q workqueue.RateLimitingInterface) bool { func (pc *PodController) processNextWorkItem(ctx context.Context, workerID string, q workqueue.RateLimitingInterface) bool {
// We create a span only after popping from the queue so that we can get an adequate picture of how long it took to process the item. // We create a span only after popping from the queue so that we can get an adequate picture of how long it took to process the item.
ctx, span := trace.StartSpan(ctx, "processNextWorkItem") ctx, span := trace.StartSpan(ctx, "processNextWorkItem")
defer span.End() defer span.End()
// Add the ID of the current worker as an attribute to the current span. // Add the ID of the current worker as an attribute to the current span.
ctx = span.WithField(ctx, "workerId", workerId) ctx = span.WithField(ctx, "workerId", workerID)
return handleQueueItem(ctx, q, pc.syncHandler) return handleQueueItem(ctx, q, pc.syncHandler)
} }