github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 05:27:21 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #94605 from yttan/lint

Browse Source 
fix golint failures for staging/src/k8s.io/client-go/examples/workqueue
This commit is contained in:
Kubernetes Prow Robot 2020-09-08 21:35:52 -07:00 committed by GitHub
commit 1c6057b59c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hack/.golint_failures
View File

@ -381,7 +381,6 @@ staging/src/k8s.io/client-go/discovery
staging/src/k8s.io/client-go/discovery/fake staging/src/k8s.io/client-go/discovery/fake
staging/src/k8s.io/client-go/dynamic staging/src/k8s.io/client-go/dynamic
staging/src/k8s.io/client-go/dynamic/fake staging/src/k8s.io/client-go/dynamic/fake
staging/src/k8s.io/client-go/examples/workqueue
staging/src/k8s.io/client-go/kubernetes/typed/certificates/v1beta1 staging/src/k8s.io/client-go/kubernetes/typed/certificates/v1beta1
staging/src/k8s.io/client-go/kubernetes/typed/certificates/v1beta1/fake staging/src/k8s.io/client-go/kubernetes/typed/certificates/v1beta1/fake
staging/src/k8s.io/client-go/kubernetes/typed/core/v1 staging/src/k8s.io/client-go/kubernetes/typed/core/v1

3
staging/src/k8s.io/client-go/examples/workqueue/main.go
View File

@ -34,12 +34,14 @@ import (
"k8s.io/client-go/util/workqueue" "k8s.io/client-go/util/workqueue"
) )
// Controller demonstrates how to implement a controller with client-go.
type Controller struct { type Controller struct {
indexer cache.Indexer indexer cache.Indexer
queue workqueue.RateLimitingInterface queue workqueue.RateLimitingInterface
informer cache.Controller informer cache.Controller
} }
// NewController creates a new Controller.
func NewController(queue workqueue.RateLimitingInterface, indexer cache.Indexer, informer cache.Controller) *Controller { func NewController(queue workqueue.RateLimitingInterface, indexer cache.Indexer, informer cache.Controller) *Controller {
return &Controller{ return &Controller{
informer: informer, informer: informer,
@ -113,6 +115,7 @@ func (c *Controller) handleErr(err error, key interface{}) {
klog.Infof("Dropping pod %q out of the queue: %v", key, err) klog.Infof("Dropping pod %q out of the queue: %v", key, err)
} }
// Run begins watching and syncing.
func (c *Controller) Run(threadiness int, stopCh chan struct{}) { func (c *Controller) Run(threadiness int, stopCh chan struct{}) {
defer runtime.HandleCrash() defer runtime.HandleCrash()