github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-06-29 00:17:46 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #82325 from RainbowMango/pr_cleanupup_staticcheck_for_client_cache

Browse Source 
Cleanup staticcheck for package cache

Kubernetes-commit: 41b3e60f0e4032eec2caf38348d82641395f7af6
This commit is contained in:
Kubernetes Publisher 2019-09-17 00:50:24 -07:00
commit ecd4f6fb8c
3 changed files with 0 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tools/cache/delta_fifo.go vendored
View File

@ -539,13 +539,6 @@ func (f *DeltaFIFO) Resync() error {
return nil return nil
} }
func (f *DeltaFIFO) syncKey(key string) error {
f.lock.Lock()
defer f.lock.Unlock()
return f.syncKeyLocked(key)
}
func (f *DeltaFIFO) syncKeyLocked(key string) error { func (f *DeltaFIFO) syncKeyLocked(key string) error {
obj, exists, err := f.knownObjects.GetByKey(key) obj, exists, err := f.knownObjects.GetByKey(key)
if err != nil { if err != nil {

5
tools/cache/reflector.go vendored
View File

@ -45,8 +45,6 @@ import (
type Reflector struct { type Reflector struct {
// name identifies this reflector. By default it will be a file:line if possible. // name identifies this reflector. By default it will be a file:line if possible.
name string name string
// metrics tracks basic metric information about the reflector
metrics *reflectorMetrics
// The type of object we expect to place in the store. // The type of object we expect to place in the store.
expectedType reflect.Type expectedType reflect.Type
@ -129,9 +127,6 @@ var (
// nothing will ever be sent down this channel // nothing will ever be sent down this channel
neverExitWatch <-chan time.Time = make(chan time.Time) neverExitWatch <-chan time.Time = make(chan time.Time)
// Used to indicate that watching stopped so that a resync could happen.
errorResyncRequested = errors.New("resync channel fired")
// Used to indicate that watching stopped because of a signal from the stop // Used to indicate that watching stopped because of a signal from the stop
// channel passed in from a client of the reflector. // channel passed in from a client of the reflector.
errorStopRequested = errors.New("Stop requested") errorStopRequested = errors.New("Stop requested")

13
tools/cache/reflector_metrics.go vendored
View File

@ -47,19 +47,6 @@ func (noopMetric) Dec() {}
func (noopMetric) Observe(float64) {} func (noopMetric) Observe(float64) {}
func (noopMetric) Set(float64) {} func (noopMetric) Set(float64) {}
type reflectorMetrics struct {
numberOfLists CounterMetric
listDuration SummaryMetric
numberOfItemsInList SummaryMetric
numberOfWatches CounterMetric
numberOfShortWatches CounterMetric
watchDuration SummaryMetric
numberOfItemsInWatch SummaryMetric
lastResourceVersion GaugeMetric
}
// MetricsProvider generates various metrics used by the reflector. // MetricsProvider generates various metrics used by the reflector.
type MetricsProvider interface { type MetricsProvider interface {
NewListsMetric(name string) CounterMetric NewListsMetric(name string) CounterMetric