Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
K
k3s
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Registry
Registry
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Jacklull
k3s
Commits
9e35d3d7
Commit
9e35d3d7
authored
Apr 24, 2019
by
obitech
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Fix golint issues in pkg/kubelet/oom
parent
1039feea
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
22 additions
and
23 deletions
+22
-23
.golint_failures
hack/.golint_failures
+1
-1
kubelet.go
pkg/kubelet/kubelet.go
+3
-3
oom_watcher_linux.go
pkg/kubelet/oom/oom_watcher_linux.go
+8
-8
oom_watcher_linux_test.go
pkg/kubelet/oom/oom_watcher_linux_test.go
+3
-2
oom_watcher_unsupported.go
pkg/kubelet/oom/oom_watcher_unsupported.go
+4
-4
types.go
pkg/kubelet/oom/types.go
+3
-5
No files found.
hack/.golint_failures
View file @
9e35d3d7
...
...
@@ -181,7 +181,7 @@ pkg/kubelet/dockershim/network/testing
pkg/kubelet/events
pkg/kubelet/lifecycle
pkg/kubelet/metrics
pkg/kubelet/
oom
pkg/kubelet/
pod
pkg/kubelet/pod/testing
pkg/kubelet/preemption
pkg/kubelet/prober
...
...
pkg/kubelet/kubelet.go
View file @
9e35d3d7
...
...
@@ -32,7 +32,7 @@ import (
"time"
cadvisorapi
"github.com/google/cadvisor/info/v1"
"k8s.io/api/core/v1"
v1
"k8s.io/api/core/v1"
metav1
"k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/fields"
"k8s.io/apimachinery/pkg/labels"
...
...
@@ -465,7 +465,7 @@ func NewMainKubelet(kubeCfg *kubeletconfiginternal.KubeletConfiguration,
containerRefManager
:=
kubecontainer
.
NewRefManager
()
oomWatcher
:=
oomwatcher
.
New
OOM
Watcher
(
kubeDeps
.
Recorder
)
oomWatcher
:=
oomwatcher
.
NewWatcher
(
kubeDeps
.
Recorder
)
clusterDNS
:=
make
([]
net
.
IP
,
0
,
len
(
kubeCfg
.
ClusterDNS
))
for
_
,
ipEntry
:=
range
kubeCfg
.
ClusterDNS
{
...
...
@@ -1079,7 +1079,7 @@ type Kubelet struct {
os
kubecontainer
.
OSInterface
// Watcher of out of memory events.
oomWatcher
oomwatcher
.
OOM
Watcher
oomWatcher
oomwatcher
.
Watcher
// Monitor resource usage
resourceAnalyzer
serverstats
.
ResourceAnalyzer
...
...
pkg/kubelet/oom/oom_watcher_linux.go
View file @
9e35d3d7
...
...
@@ -19,7 +19,7 @@ limitations under the License.
package
oom
import
(
"k8s.io/api/core/v1"
v1
"k8s.io/api/core/v1"
metav1
"k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/util/runtime"
"k8s.io/client-go/tools/record"
...
...
@@ -28,23 +28,23 @@ import (
"github.com/google/cadvisor/utils/oomparser"
)
type
real
OOM
Watcher
struct
{
type
realWatcher
struct
{
recorder
record
.
EventRecorder
}
var
_
OOMWatcher
=
&
realOOM
Watcher
{}
var
_
Watcher
=
&
real
Watcher
{}
// New
OOM
Watcher creates and initializes a OOMWatcher based on parameters.
func
New
OOMWatcher
(
recorder
record
.
EventRecorder
)
OOM
Watcher
{
return
&
real
OOM
Watcher
{
// NewWatcher creates and initializes a OOMWatcher based on parameters.
func
New
Watcher
(
recorder
record
.
EventRecorder
)
Watcher
{
return
&
realWatcher
{
recorder
:
recorder
,
}
}
const
systemOOMEvent
=
"SystemOOM"
//
W
atches for system oom's and records an event for every system oom encountered.
func
(
ow
*
real
OOM
Watcher
)
Start
(
ref
*
v1
.
ObjectReference
)
error
{
//
Start w
atches for system oom's and records an event for every system oom encountered.
func
(
ow
*
realWatcher
)
Start
(
ref
*
v1
.
ObjectReference
)
error
{
oomLog
,
err
:=
oomparser
.
New
()
if
err
!=
nil
{
return
err
...
...
pkg/kubelet/oom/oom_watcher_linux_test.go
View file @
9e35d3d7
...
...
@@ -21,14 +21,15 @@ import (
"github.com/stretchr/testify/assert"
"k8s.io/api/core/v1"
v1
"k8s.io/api/core/v1"
"k8s.io/client-go/tools/record"
)
// TestBasic verifies that the OOMWatch works without error.
func
TestBasic
(
t
*
testing
.
T
)
{
fakeRecorder
:=
&
record
.
FakeRecorder
{}
node
:=
&
v1
.
ObjectReference
{}
oomWatcher
:=
New
OOM
Watcher
(
fakeRecorder
)
oomWatcher
:=
NewWatcher
(
fakeRecorder
)
assert
.
NoError
(
t
,
oomWatcher
.
Start
(
node
))
// TODO: Improve this test once cadvisor exports events.EventChannel as an interface
...
...
pkg/kubelet/oom/oom_watcher_unsupported.go
View file @
9e35d3d7
...
...
@@ -19,16 +19,16 @@ limitations under the License.
package
oom
import
(
"k8s.io/api/core/v1"
v1
"k8s.io/api/core/v1"
"k8s.io/client-go/tools/record"
)
type
oomWatcherUnsupported
struct
{}
var
_
OOM
Watcher
=
new
(
oomWatcherUnsupported
)
var
_
Watcher
=
new
(
oomWatcherUnsupported
)
// New
OOM
Watcher creates a fake one here
func
New
OOMWatcher
(
_
record
.
EventRecorder
)
OOM
Watcher
{
// NewWatcher creates a fake one here
func
New
Watcher
(
_
record
.
EventRecorder
)
Watcher
{
return
&
oomWatcherUnsupported
{}
}
...
...
pkg/kubelet/oom/types.go
View file @
9e35d3d7
...
...
@@ -16,11 +16,9 @@ limitations under the License.
package
oom
import
(
"k8s.io/api/core/v1"
)
import
v1
"k8s.io/api/core/v1"
//
OOM
Watcher defines the interface of OOM watchers.
type
OOM
Watcher
interface
{
// Watcher defines the interface of OOM watchers.
type
Watcher
interface
{
Start
(
ref
*
v1
.
ObjectReference
)
error
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment