github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-07-22 02:43:14 +00:00
Code Issues Projects Releases Wiki Activity

fix golint failures for staging/src/k8s.io/client-go/examples/workqueue

Browse Source 
Kubernetes-commit: d3db1ec12d1156fbdefacb15b5c5c6d31523a163
This commit is contained in:
yttan 2020-09-08 15:01:45 +08:00 committed by Kubernetes Publisher
parent 42c4a6e381
commit 3f4798d9ac
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/workqueue/main.go
View File

@ -34,12 +34,14 @@ import (
"k8s.io/client-go/util/workqueue"
)
// Controller demonstrates how to implement a controller with client-go.
type Controller struct {
indexer cache.Indexer
queue workqueue.RateLimitingInterface
informer cache.Controller
}
// NewController creates a new Controller.
func NewController(queue workqueue.RateLimitingInterface, indexer cache.Indexer, informer cache.Controller) *Controller {
return &Controller{
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)
}
// Run begins watching and syncing.
func (c *Controller) Run(threadiness int, stopCh chan struct{}) {
defer runtime.HandleCrash()