Skip to content

Commit ce3ce9a

Browse files
authored
Merge pull request kubernetes#77023 from obitech/fix_golint_issues_in_kubelet_packages_oom
Fix golint issues in pkg/kubelet/oom
2 parents 37281a4 + ccfb637 commit ce3ce9a

File tree

6 files changed

+21
-23
lines changed

6 files changed

+21
-23
lines changed

hack/.golint_failures

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,6 @@ pkg/kubelet/dockershim/network/testing
171171
pkg/kubelet/events
172172
pkg/kubelet/lifecycle
173173
pkg/kubelet/metrics
174-
pkg/kubelet/oom
175174
pkg/kubelet/pod/testing
176175
pkg/kubelet/preemption
177176
pkg/kubelet/prober

pkg/kubelet/kubelet.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ import (
3232
"time"
3333

3434
cadvisorapi "github.com/google/cadvisor/info/v1"
35-
"k8s.io/api/core/v1"
35+
v1 "k8s.io/api/core/v1"
3636
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
3737
"k8s.io/apimachinery/pkg/fields"
3838
"k8s.io/apimachinery/pkg/labels"
@@ -465,7 +465,7 @@ func NewMainKubelet(kubeCfg *kubeletconfiginternal.KubeletConfiguration,
465465

466466
containerRefManager := kubecontainer.NewRefManager()
467467

468-
oomWatcher := oomwatcher.NewOOMWatcher(kubeDeps.Recorder)
468+
oomWatcher := oomwatcher.NewWatcher(kubeDeps.Recorder)
469469

470470
clusterDNS := make([]net.IP, 0, len(kubeCfg.ClusterDNS))
471471
for _, ipEntry := range kubeCfg.ClusterDNS {
@@ -1079,7 +1079,7 @@ type Kubelet struct {
10791079
os kubecontainer.OSInterface
10801080

10811081
// Watcher of out of memory events.
1082-
oomWatcher oomwatcher.OOMWatcher
1082+
oomWatcher oomwatcher.Watcher
10831083

10841084
// Monitor resource usage
10851085
resourceAnalyzer serverstats.ResourceAnalyzer

pkg/kubelet/oom/oom_watcher_linux.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ limitations under the License.
1919
package oom
2020

2121
import (
22-
"k8s.io/api/core/v1"
22+
v1 "k8s.io/api/core/v1"
2323
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
2424
"k8s.io/apimachinery/pkg/util/runtime"
2525
"k8s.io/client-go/tools/record"
@@ -28,23 +28,23 @@ import (
2828
"github.com/google/cadvisor/utils/oomparser"
2929
)
3030

31-
type realOOMWatcher struct {
31+
type realWatcher struct {
3232
recorder record.EventRecorder
3333
}
3434

35-
var _ OOMWatcher = &realOOMWatcher{}
35+
var _ Watcher = &realWatcher{}
3636

37-
// NewOOMWatcher creates and initializes a OOMWatcher based on parameters.
38-
func NewOOMWatcher(recorder record.EventRecorder) OOMWatcher {
39-
return &realOOMWatcher{
37+
// NewWatcher creates and initializes a OOMWatcher based on parameters.
38+
func NewWatcher(recorder record.EventRecorder) Watcher {
39+
return &realWatcher{
4040
recorder: recorder,
4141
}
4242
}
4343

4444
const systemOOMEvent = "SystemOOM"
4545

46-
// Watches for system oom's and records an event for every system oom encountered.
47-
func (ow *realOOMWatcher) Start(ref *v1.ObjectReference) error {
46+
// Start watches for system oom's and records an event for every system oom encountered.
47+
func (ow *realWatcher) Start(ref *v1.ObjectReference) error {
4848
oomLog, err := oomparser.New()
4949
if err != nil {
5050
return err

pkg/kubelet/oom/oom_watcher_linux_test.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,14 +21,15 @@ import (
2121

2222
"github.com/stretchr/testify/assert"
2323

24-
"k8s.io/api/core/v1"
24+
v1 "k8s.io/api/core/v1"
2525
"k8s.io/client-go/tools/record"
2626
)
2727

28+
// TestBasic verifies that the OOMWatch works without error.
2829
func TestBasic(t *testing.T) {
2930
fakeRecorder := &record.FakeRecorder{}
3031
node := &v1.ObjectReference{}
31-
oomWatcher := NewOOMWatcher(fakeRecorder)
32+
oomWatcher := NewWatcher(fakeRecorder)
3233
assert.NoError(t, oomWatcher.Start(node))
3334

3435
// TODO: Improve this test once cadvisor exports events.EventChannel as an interface

pkg/kubelet/oom/oom_watcher_unsupported.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,16 +19,16 @@ limitations under the License.
1919
package oom
2020

2121
import (
22-
"k8s.io/api/core/v1"
22+
v1 "k8s.io/api/core/v1"
2323
"k8s.io/client-go/tools/record"
2424
)
2525

2626
type oomWatcherUnsupported struct{}
2727

28-
var _ OOMWatcher = new(oomWatcherUnsupported)
28+
var _ Watcher = new(oomWatcherUnsupported)
2929

30-
// NewOOMWatcher creates a fake one here
31-
func NewOOMWatcher(_ record.EventRecorder) OOMWatcher {
30+
// NewWatcher creates a fake one here
31+
func NewWatcher(_ record.EventRecorder) Watcher {
3232
return &oomWatcherUnsupported{}
3333
}
3434

pkg/kubelet/oom/types.go

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -16,11 +16,9 @@ limitations under the License.
1616

1717
package oom
1818

19-
import (
20-
"k8s.io/api/core/v1"
21-
)
19+
import v1 "k8s.io/api/core/v1"
2220

23-
// OOMWatcher defines the interface of OOM watchers.
24-
type OOMWatcher interface {
21+
// Watcher defines the interface of OOM watchers.
22+
type Watcher interface {
2523
Start(ref *v1.ObjectReference) error
2624
}

0 commit comments

Comments
 (0)