scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-04 04:08:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

kubelet: Migrate CAdvisor to contextual logging

Browse Source
This commit is contained in:
Ed Bartosh
2024-10-30 16:34:15 +02:00
parent cb31e42b85
commit e5cb071c2e
15 changed files with 82 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hack/golangci-hints.yaml
View File

@@ -167,6 +167,7 @@ linters-settings: # please keep this alphabetized
contextual k8s.io/kubernetes/pkg/kubelet/pleg/.* contextual k8s.io/kubernetes/pkg/kubelet/pleg/.*
contextual k8s.io/kubernetes/pkg/kubelet/clustertrustbundle/.* contextual k8s.io/kubernetes/pkg/kubelet/clustertrustbundle/.*
contextual k8s.io/kubernetes/pkg/kubelet/token/.* contextual k8s.io/kubernetes/pkg/kubelet/token/.*
contextual k8s.io/kubernetes/pkg/kubelet/cadvisor/.*
# As long as contextual logging is alpha or beta, all WithName, WithValues, # As long as contextual logging is alpha or beta, all WithName, WithValues,
# NewContext calls have to go through klog. Once it is GA, we can lift # NewContext calls have to go through klog. Once it is GA, we can lift

1
hack/golangci-strict.yaml
View File

@@ -213,6 +213,7 @@ linters-settings: # please keep this alphabetized
contextual k8s.io/kubernetes/pkg/kubelet/pleg/.* contextual k8s.io/kubernetes/pkg/kubelet/pleg/.*
contextual k8s.io/kubernetes/pkg/kubelet/clustertrustbundle/.* contextual k8s.io/kubernetes/pkg/kubelet/clustertrustbundle/.*
contextual k8s.io/kubernetes/pkg/kubelet/token/.* contextual k8s.io/kubernetes/pkg/kubelet/token/.*
contextual k8s.io/kubernetes/pkg/kubelet/cadvisor/.*
# As long as contextual logging is alpha or beta, all WithName, WithValues, # As long as contextual logging is alpha or beta, all WithName, WithValues,
# NewContext calls have to go through klog. Once it is GA, we can lift # NewContext calls have to go through klog. Once it is GA, we can lift

1
hack/golangci.yaml
View File

@@ -215,6 +215,7 @@ linters-settings: # please keep this alphabetized
contextual k8s.io/kubernetes/pkg/kubelet/pleg/.* contextual k8s.io/kubernetes/pkg/kubelet/pleg/.*
contextual k8s.io/kubernetes/pkg/kubelet/clustertrustbundle/.* contextual k8s.io/kubernetes/pkg/kubelet/clustertrustbundle/.*
contextual k8s.io/kubernetes/pkg/kubelet/token/.* contextual k8s.io/kubernetes/pkg/kubelet/token/.*
contextual k8s.io/kubernetes/pkg/kubelet/cadvisor/.*
# As long as contextual logging is alpha or beta, all WithName, WithValues, # As long as contextual logging is alpha or beta, all WithName, WithValues,
# NewContext calls have to go through klog. Once it is GA, we can lift # NewContext calls have to go through klog. Once it is GA, we can lift

1
hack/logcheck.conf
View File

@@ -51,6 +51,7 @@ contextual k8s.io/kubernetes/pkg/kubelet/cm/dra/.*
contextual k8s.io/kubernetes/pkg/kubelet/pleg/.* contextual k8s.io/kubernetes/pkg/kubelet/pleg/.*
contextual k8s.io/kubernetes/pkg/kubelet/clustertrustbundle/.* contextual k8s.io/kubernetes/pkg/kubelet/clustertrustbundle/.*
contextual k8s.io/kubernetes/pkg/kubelet/token/.* contextual k8s.io/kubernetes/pkg/kubelet/token/.*
contextual k8s.io/kubernetes/pkg/kubelet/cadvisor/.*
# As long as contextual logging is alpha or beta, all WithName, WithValues, # As long as contextual logging is alpha or beta, all WithName, WithValues,
# NewContext calls have to go through klog. Once it is GA, we can lift # NewContext calls have to go through klog. Once it is GA, we can lift

16
pkg/kubelet/cadvisor/cadvisor_linux.go
View File

@@ -20,6 +20,7 @@ limitations under the License.
package cadvisor package cadvisor
import ( import (
"context"
"flag" "flag"
"fmt" "fmt"
"net/http" "net/http"
@@ -71,7 +72,8 @@ func init() {
f.DefValue = defaultValue f.DefValue = defaultValue
f.Value.Set(defaultValue) f.Value.Set(defaultValue)
} else { } else {
klog.ErrorS(nil, "Expected cAdvisor flag not found", "flag", name) ctx := context.Background()
klog.FromContext(ctx).Error(nil, "Expected cAdvisor flag not found", "flag", name)
} }
} }
} }
@@ -140,19 +142,19 @@ func (cc *cadvisorClient) MachineInfo() (*cadvisorapi.MachineInfo, error) {
return cc.GetMachineInfo() return cc.GetMachineInfo()
} }
func (cc *cadvisorClient) ImagesFsInfo() (cadvisorapiv2.FsInfo, error) { func (cc *cadvisorClient) ImagesFsInfo(ctx context.Context) (cadvisorapiv2.FsInfo, error) {
label, err := cc.imageFsInfoProvider.ImageFsInfoLabel() label, err := cc.imageFsInfoProvider.ImageFsInfoLabel()
if err != nil { if err != nil {
return cadvisorapiv2.FsInfo{}, err return cadvisorapiv2.FsInfo{}, err
} }
return cc.getFsInfo(label) return cc.getFsInfo(ctx, label)
} }
func (cc *cadvisorClient) RootFsInfo() (cadvisorapiv2.FsInfo, error) { func (cc *cadvisorClient) RootFsInfo() (cadvisorapiv2.FsInfo, error) {
return cc.GetDirFsInfo(cc.rootPath) return cc.GetDirFsInfo(cc.rootPath)
} }
func (cc *cadvisorClient) getFsInfo(label string) (cadvisorapiv2.FsInfo, error) { func (cc *cadvisorClient) getFsInfo(ctx context.Context, label string) (cadvisorapiv2.FsInfo, error) {
res, err := cc.GetFsInfo(label) res, err := cc.GetFsInfo(label)
if err != nil { if err != nil {
return cadvisorapiv2.FsInfo{}, err return cadvisorapiv2.FsInfo{}, err
@@ -162,16 +164,16 @@ func (cc *cadvisorClient) getFsInfo(label string) (cadvisorapiv2.FsInfo, error)
} }
// TODO(vmarmol): Handle this better when a label has more than one image filesystem. // TODO(vmarmol): Handle this better when a label has more than one image filesystem.
if len(res) > 1 { if len(res) > 1 {
klog.InfoS("More than one filesystem labeled. Only using the first one", "label", label, "fileSystem", res) klog.FromContext(ctx).Info("More than one filesystem labeled. Only using the first one", "label", label, "fileSystem", res)
} }
return res[0], nil return res[0], nil
} }
func (cc *cadvisorClient) ContainerFsInfo() (cadvisorapiv2.FsInfo, error) { func (cc *cadvisorClient) ContainerFsInfo(ctx context.Context) (cadvisorapiv2.FsInfo, error) {
label, err := cc.imageFsInfoProvider.ContainerFsInfoLabel() label, err := cc.imageFsInfoProvider.ContainerFsInfoLabel()
if err != nil { if err != nil {
return cadvisorapiv2.FsInfo{}, err return cadvisorapiv2.FsInfo{}, err
} }
return cc.getFsInfo(label) return cc.getFsInfo(ctx, label)
} }

5
pkg/kubelet/cadvisor/cadvisor_unsupported.go
View File

@@ -20,6 +20,7 @@ limitations under the License.
package cadvisor package cadvisor
import ( import (
"context"
"errors" "errors"
cadvisorapi "github.com/google/cadvisor/info/v1" cadvisorapi "github.com/google/cadvisor/info/v1"
@@ -58,7 +59,7 @@ func (cu *cadvisorUnsupported) VersionInfo() (*cadvisorapi.VersionInfo, error) {
return nil, errUnsupported return nil, errUnsupported
} }
func (cu *cadvisorUnsupported) ImagesFsInfo() (cadvisorapiv2.FsInfo, error) { func (cu *cadvisorUnsupported) ImagesFsInfo(context.Context) (cadvisorapiv2.FsInfo, error) {
return cadvisorapiv2.FsInfo{}, errUnsupported return cadvisorapiv2.FsInfo{}, errUnsupported
} }
@@ -66,7 +67,7 @@ func (cu *cadvisorUnsupported) RootFsInfo() (cadvisorapiv2.FsInfo, error) {
return cadvisorapiv2.FsInfo{}, errUnsupported return cadvisorapiv2.FsInfo{}, errUnsupported
} }
func (cu *cadvisorUnsupported) ContainerFsInfo() (cadvisorapiv2.FsInfo, error) { func (cu *cadvisorUnsupported) ContainerFsInfo(context.Context) (cadvisorapiv2.FsInfo, error) {
return cadvisorapiv2.FsInfo{}, errUnsupported return cadvisorapiv2.FsInfo{}, errUnsupported
} }

6
pkg/kubelet/cadvisor/cadvisor_windows.go
View File

@@ -20,6 +20,8 @@ limitations under the License.
package cadvisor package cadvisor
import ( import (
"context"
cadvisorapi "github.com/google/cadvisor/info/v1" cadvisorapi "github.com/google/cadvisor/info/v1"
cadvisorapiv2 "github.com/google/cadvisor/info/v2" cadvisorapiv2 "github.com/google/cadvisor/info/v2"
"k8s.io/kubernetes/pkg/kubelet/winstats" "k8s.io/kubernetes/pkg/kubelet/winstats"
@@ -62,11 +64,11 @@ func (cu *cadvisorClient) VersionInfo() (*cadvisorapi.VersionInfo, error) {
return cu.winStatsClient.WinVersionInfo() return cu.winStatsClient.WinVersionInfo()
} }
func (cu *cadvisorClient) ImagesFsInfo() (cadvisorapiv2.FsInfo, error) { func (cu *cadvisorClient) ImagesFsInfo(context.Context) (cadvisorapiv2.FsInfo, error) {
return cadvisorapiv2.FsInfo{}, nil return cadvisorapiv2.FsInfo{}, nil
} }
func (cu *cadvisorClient) ContainerFsInfo() (cadvisorapiv2.FsInfo, error) { func (cu *cadvisorClient) ContainerFsInfo(context.Context) (cadvisorapiv2.FsInfo, error) {
return cadvisorapiv2.FsInfo{}, nil return cadvisorapiv2.FsInfo{}, nil
} }

6
pkg/kubelet/cadvisor/testing/cadvisor_fake.go
View File

@@ -17,6 +17,8 @@ limitations under the License.
package testing package testing
import ( import (
"context"
cadvisorapi "github.com/google/cadvisor/info/v1" cadvisorapi "github.com/google/cadvisor/info/v1"
cadvisorapiv2 "github.com/google/cadvisor/info/v2" cadvisorapiv2 "github.com/google/cadvisor/info/v2"
"k8s.io/kubernetes/pkg/kubelet/cadvisor" "k8s.io/kubernetes/pkg/kubelet/cadvisor"
@@ -76,7 +78,7 @@ func (c *Fake) VersionInfo() (*cadvisorapi.VersionInfo, error) {
} }
// ImagesFsInfo is a fake implementation of Interface.ImagesFsInfo. // ImagesFsInfo is a fake implementation of Interface.ImagesFsInfo.
func (c *Fake) ImagesFsInfo() (cadvisorapiv2.FsInfo, error) { func (c *Fake) ImagesFsInfo(context.Context) (cadvisorapiv2.FsInfo, error) {
return cadvisorapiv2.FsInfo{}, nil return cadvisorapiv2.FsInfo{}, nil
} }
@@ -86,7 +88,7 @@ func (c *Fake) RootFsInfo() (cadvisorapiv2.FsInfo, error) {
} }
// ContainerFsInfo is a fake implementation of Interface.ContainerFsInfo. // ContainerFsInfo is a fake implementation of Interface.ContainerFsInfo.
func (c *Fake) ContainerFsInfo() (cadvisorapiv2.FsInfo, error) { func (c *Fake) ContainerFsInfo(context.Context) (cadvisorapiv2.FsInfo, error) {
return cadvisorapiv2.FsInfo{}, nil return cadvisorapiv2.FsInfo{}, nil
} }

60
pkg/kubelet/cadvisor/testing/cadvisor_mock.go
View File

@@ -19,6 +19,8 @@ limitations under the License.
package testing package testing
import ( import (
context "context"
v1 "github.com/google/cadvisor/info/v1" v1 "github.com/google/cadvisor/info/v1"
mock "github.com/stretchr/testify/mock" mock "github.com/stretchr/testify/mock"
@@ -38,9 +40,9 @@ func (_m *MockInterface) EXPECT() *MockInterface_Expecter {
return &MockInterface_Expecter{mock: &_m.Mock} return &MockInterface_Expecter{mock: &_m.Mock}
} }
// ContainerFsInfo provides a mock function with given fields: // ContainerFsInfo provides a mock function with given fields: _a0
func (_m *MockInterface) ContainerFsInfo() (v2.FsInfo, error) { func (_m *MockInterface) ContainerFsInfo(_a0 context.Context) (v2.FsInfo, error) {
ret := _m.Called() ret := _m.Called(_a0)
if len(ret) == 0 { if len(ret) == 0 {
panic("no return value specified for ContainerFsInfo") panic("no return value specified for ContainerFsInfo")
@@ -48,17 +50,17 @@ func (_m *MockInterface) ContainerFsInfo() (v2.FsInfo, error) {
var r0 v2.FsInfo var r0 v2.FsInfo
var r1 error var r1 error
if rf, ok := ret.Get(0).(func() (v2.FsInfo, error)); ok { if rf, ok := ret.Get(0).(func(context.Context) (v2.FsInfo, error)); ok {
return rf() return rf(_a0)
} }
if rf, ok := ret.Get(0).(func() v2.FsInfo); ok { if rf, ok := ret.Get(0).(func(context.Context) v2.FsInfo); ok {
r0 = rf() r0 = rf(_a0)
} else { } else {
r0 = ret.Get(0).(v2.FsInfo) r0 = ret.Get(0).(v2.FsInfo)
} }
if rf, ok := ret.Get(1).(func() error); ok { if rf, ok := ret.Get(1).(func(context.Context) error); ok {
r1 = rf() r1 = rf(_a0)
} else { } else {
r1 = ret.Error(1) r1 = ret.Error(1)
} }
@@ -72,13 +74,14 @@ type MockInterface_ContainerFsInfo_Call struct {
} }
// ContainerFsInfo is a helper method to define mock.On call // ContainerFsInfo is a helper method to define mock.On call
func (_e *MockInterface_Expecter) ContainerFsInfo() *MockInterface_ContainerFsInfo_Call { // - _a0 context.Context
return &MockInterface_ContainerFsInfo_Call{Call: _e.mock.On("ContainerFsInfo")} func (_e *MockInterface_Expecter) ContainerFsInfo(_a0 interface{}) *MockInterface_ContainerFsInfo_Call {
return &MockInterface_ContainerFsInfo_Call{Call: _e.mock.On("ContainerFsInfo", _a0)}
} }
func (_c *MockInterface_ContainerFsInfo_Call) Run(run func()) *MockInterface_ContainerFsInfo_Call { func (_c *MockInterface_ContainerFsInfo_Call) Run(run func(_a0 context.Context)) *MockInterface_ContainerFsInfo_Call {
_c.Call.Run(func(args mock.Arguments) { _c.Call.Run(func(args mock.Arguments) {
run() run(args[0].(context.Context))
}) })
return _c return _c
} }
@@ -88,7 +91,7 @@ func (_c *MockInterface_ContainerFsInfo_Call) Return(_a0 v2.FsInfo, _a1 error) *
return _c return _c
} }
func (_c *MockInterface_ContainerFsInfo_Call) RunAndReturn(run func() (v2.FsInfo, error)) *MockInterface_ContainerFsInfo_Call { func (_c *MockInterface_ContainerFsInfo_Call) RunAndReturn(run func(context.Context) (v2.FsInfo, error)) *MockInterface_ContainerFsInfo_Call {
_c.Call.Return(run) _c.Call.Return(run)
return _c return _c
} }
@@ -267,9 +270,9 @@ func (_c *MockInterface_GetRequestedContainersInfo_Call) RunAndReturn(run func(s
return _c return _c
} }
// ImagesFsInfo provides a mock function with given fields: // ImagesFsInfo provides a mock function with given fields: _a0
func (_m *MockInterface) ImagesFsInfo() (v2.FsInfo, error) { func (_m *MockInterface) ImagesFsInfo(_a0 context.Context) (v2.FsInfo, error) {
ret := _m.Called() ret := _m.Called(_a0)
if len(ret) == 0 { if len(ret) == 0 {
panic("no return value specified for ImagesFsInfo") panic("no return value specified for ImagesFsInfo")
@@ -277,17 +280,17 @@ func (_m *MockInterface) ImagesFsInfo() (v2.FsInfo, error) {
var r0 v2.FsInfo var r0 v2.FsInfo
var r1 error var r1 error
if rf, ok := ret.Get(0).(func() (v2.FsInfo, error)); ok { if rf, ok := ret.Get(0).(func(context.Context) (v2.FsInfo, error)); ok {
return rf() return rf(_a0)
} }
if rf, ok := ret.Get(0).(func() v2.FsInfo); ok { if rf, ok := ret.Get(0).(func(context.Context) v2.FsInfo); ok {
r0 = rf() r0 = rf(_a0)
} else { } else {
r0 = ret.Get(0).(v2.FsInfo) r0 = ret.Get(0).(v2.FsInfo)
} }
if rf, ok := ret.Get(1).(func() error); ok { if rf, ok := ret.Get(1).(func(context.Context) error); ok {
r1 = rf() r1 = rf(_a0)
} else { } else {
r1 = ret.Error(1) r1 = ret.Error(1)
} }
@@ -301,13 +304,14 @@ type MockInterface_ImagesFsInfo_Call struct {
} }
// ImagesFsInfo is a helper method to define mock.On call // ImagesFsInfo is a helper method to define mock.On call
func (_e *MockInterface_Expecter) ImagesFsInfo() *MockInterface_ImagesFsInfo_Call { // - _a0 context.Context
return &MockInterface_ImagesFsInfo_Call{Call: _e.mock.On("ImagesFsInfo")} func (_e *MockInterface_Expecter) ImagesFsInfo(_a0 interface{}) *MockInterface_ImagesFsInfo_Call {
return &MockInterface_ImagesFsInfo_Call{Call: _e.mock.On("ImagesFsInfo", _a0)}
} }
func (_c *MockInterface_ImagesFsInfo_Call) Run(run func()) *MockInterface_ImagesFsInfo_Call { func (_c *MockInterface_ImagesFsInfo_Call) Run(run func(_a0 context.Context)) *MockInterface_ImagesFsInfo_Call {
_c.Call.Run(func(args mock.Arguments) { _c.Call.Run(func(args mock.Arguments) {
run() run(args[0].(context.Context))
}) })
return _c return _c
} }
@@ -317,7 +321,7 @@ func (_c *MockInterface_ImagesFsInfo_Call) Return(_a0 v2.FsInfo, _a1 error) *Moc
return _c return _c
} }
func (_c *MockInterface_ImagesFsInfo_Call) RunAndReturn(run func() (v2.FsInfo, error)) *MockInterface_ImagesFsInfo_Call { func (_c *MockInterface_ImagesFsInfo_Call) RunAndReturn(run func(context.Context) (v2.FsInfo, error)) *MockInterface_ImagesFsInfo_Call {
_c.Call.Return(run) _c.Call.Return(run)
return _c return _c
} }

6
pkg/kubelet/cadvisor/types.go
View File

@@ -18,6 +18,8 @@ limitations under the License.
package cadvisor package cadvisor
import ( import (
"context"
cadvisorapi "github.com/google/cadvisor/info/v1" cadvisorapi "github.com/google/cadvisor/info/v1"
cadvisorapiv2 "github.com/google/cadvisor/info/v2" cadvisorapiv2 "github.com/google/cadvisor/info/v2"
) )
@@ -32,14 +34,14 @@ type Interface interface {
VersionInfo() (*cadvisorapi.VersionInfo, error) VersionInfo() (*cadvisorapi.VersionInfo, error)
// Returns usage information about the filesystem holding container images. // Returns usage information about the filesystem holding container images.
ImagesFsInfo() (cadvisorapiv2.FsInfo, error) ImagesFsInfo(context.Context) (cadvisorapiv2.FsInfo, error)
// Returns usage information about the root filesystem. // Returns usage information about the root filesystem.
RootFsInfo() (cadvisorapiv2.FsInfo, error) RootFsInfo() (cadvisorapiv2.FsInfo, error)
// Returns usage information about the writeable layer. // Returns usage information about the writeable layer.
// KEP 4191 can separate the image filesystem // KEP 4191 can separate the image filesystem
ContainerFsInfo() (cadvisorapiv2.FsInfo, error) ContainerFsInfo(context.Context) (cadvisorapiv2.FsInfo, error)
// Get filesystem information for the filesystem that contains the given file. // Get filesystem information for the filesystem that contains the given file.
GetDirFsInfo(path string) (cadvisorapiv2.FsInfo, error) GetDirFsInfo(path string) (cadvisorapiv2.FsInfo, error)

5
pkg/kubelet/kubelet_test.go
View File

@@ -60,7 +60,6 @@ import (
remote "k8s.io/cri-client/pkg" remote "k8s.io/cri-client/pkg"
fakeremote "k8s.io/cri-client/pkg/fake" fakeremote "k8s.io/cri-client/pkg/fake"
"k8s.io/klog/v2" "k8s.io/klog/v2"
"k8s.io/klog/v2/ktesting"
"k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/features"
kubeletconfiginternal "k8s.io/kubernetes/pkg/kubelet/apis/config" kubeletconfiginternal "k8s.io/kubernetes/pkg/kubelet/apis/config"
cadvisortest "k8s.io/kubernetes/pkg/kubelet/cadvisor/testing" cadvisortest "k8s.io/kubernetes/pkg/kubelet/cadvisor/testing"
@@ -104,6 +103,7 @@ import (
"k8s.io/kubernetes/pkg/volume/util" "k8s.io/kubernetes/pkg/volume/util"
"k8s.io/kubernetes/pkg/volume/util/hostutil" "k8s.io/kubernetes/pkg/volume/util/hostutil"
"k8s.io/kubernetes/pkg/volume/util/subpath" "k8s.io/kubernetes/pkg/volume/util/subpath"
"k8s.io/kubernetes/test/utils/ktesting"
"k8s.io/utils/clock" "k8s.io/utils/clock"
testingclock "k8s.io/utils/clock/testing" testingclock "k8s.io/utils/clock/testing"
"k8s.io/utils/ptr" "k8s.io/utils/ptr"
@@ -3052,6 +3052,7 @@ func createRemoteRuntimeService(endpoint string, t *testing.T, tp oteltrace.Trac
} }
func TestNewMainKubeletStandAlone(t *testing.T) { func TestNewMainKubeletStandAlone(t *testing.T) {
tCtx := ktesting.Init(t)
tempDir, err := os.MkdirTemp("", "logs") tempDir, err := os.MkdirTemp("", "logs")
ContainerLogsDir = tempDir ContainerLogsDir = tempDir
assert.NoError(t, err) assert.NoError(t, err)
@@ -3067,7 +3068,7 @@ func TestNewMainKubeletStandAlone(t *testing.T) {
tp := noopoteltrace.NewTracerProvider() tp := noopoteltrace.NewTracerProvider()
cadvisor := cadvisortest.NewMockInterface(t) cadvisor := cadvisortest.NewMockInterface(t)
cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).Maybe() cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).Maybe()
cadvisor.EXPECT().ImagesFsInfo().Return(cadvisorapiv2.FsInfo{ cadvisor.EXPECT().ImagesFsInfo(tCtx).Return(cadvisorapiv2.FsInfo{
Usage: 400, Usage: 400,
Capacity: 1000, Capacity: 1000,
Available: 600, Available: 600,

2
pkg/kubelet/runonce_test.go
View File

@@ -59,7 +59,7 @@ func TestRunOnce(t *testing.T) {
cadvisor := cadvisortest.NewMockInterface(t) cadvisor := cadvisortest.NewMockInterface(t)
cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).Maybe() cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).Maybe()
cadvisor.EXPECT().ImagesFsInfo().Return(cadvisorapiv2.FsInfo{ cadvisor.EXPECT().ImagesFsInfo(ctx).Return(cadvisorapiv2.FsInfo{
Usage: 400, Usage: 400,
Capacity: 1000, Capacity: 1000,
Available: 600, Available: 600,

12
pkg/kubelet/stats/cadvisor_stats_provider.go
View File

@@ -77,7 +77,7 @@ func newCadvisorStatsProvider(
} }
// ListPodStats returns the stats of all the pod-managed containers. // ListPodStats returns the stats of all the pod-managed containers.
func (p *cadvisorStatsProvider) ListPodStats(_ context.Context) ([]statsapi.PodStats, error) { func (p *cadvisorStatsProvider) ListPodStats(ctx context.Context) ([]statsapi.PodStats, error) {
// Gets node root filesystem information and image filesystem stats, which // Gets node root filesystem information and image filesystem stats, which
// will be used to populate the available and capacity bytes/inodes in // will be used to populate the available and capacity bytes/inodes in
// container stats. // container stats.
@@ -85,7 +85,7 @@ func (p *cadvisorStatsProvider) ListPodStats(_ context.Context) ([]statsapi.PodS
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to get rootFs info: %v", err) return nil, fmt.Errorf("failed to get rootFs info: %v", err)
} }
imageFsInfo, err := p.cadvisor.ImagesFsInfo() imageFsInfo, err := p.cadvisor.ImagesFsInfo(ctx)
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to get imageFs info: %v", err) return nil, fmt.Errorf("failed to get imageFs info: %v", err)
} }
@@ -241,7 +241,7 @@ func (p *cadvisorStatsProvider) ListPodCPUAndMemoryStats(_ context.Context) ([]s
// ImageFsStats returns the stats of the filesystem for storing images. // ImageFsStats returns the stats of the filesystem for storing images.
func (p *cadvisorStatsProvider) ImageFsStats(ctx context.Context) (imageFsRet *statsapi.FsStats, containerFsRet *statsapi.FsStats, errCall error) { func (p *cadvisorStatsProvider) ImageFsStats(ctx context.Context) (imageFsRet *statsapi.FsStats, containerFsRet *statsapi.FsStats, errCall error) {
imageFsInfo, err := p.cadvisor.ImagesFsInfo() imageFsInfo, err := p.cadvisor.ImagesFsInfo(ctx)
if err != nil { if err != nil {
return nil, nil, fmt.Errorf("failed to get imageFs info: %v", err) return nil, nil, fmt.Errorf("failed to get imageFs info: %v", err)
} }
@@ -308,7 +308,7 @@ func (p *cadvisorStatsProvider) ImageFsStats(ctx context.Context) (imageFsRet *s
return fsStats, fsStats, nil return fsStats, fsStats, nil
} }
containerFsInfo, err := p.cadvisor.ContainerFsInfo() containerFsInfo, err := p.cadvisor.ContainerFsInfo(ctx)
if err != nil { if err != nil {
return nil, nil, fmt.Errorf("failed to get container fs info: %w", err) return nil, nil, fmt.Errorf("failed to get container fs info: %w", err)
} }
@@ -344,8 +344,8 @@ func (p *cadvisorStatsProvider) ImageFsStats(ctx context.Context) (imageFsRet *s
// ImageFsDevice returns name of the device where the image filesystem locates, // ImageFsDevice returns name of the device where the image filesystem locates,
// e.g. /dev/sda1. // e.g. /dev/sda1.
func (p *cadvisorStatsProvider) ImageFsDevice(_ context.Context) (string, error) { func (p *cadvisorStatsProvider) ImageFsDevice(ctx context.Context) (string, error) {
imageFsInfo, err := p.cadvisor.ImagesFsInfo() imageFsInfo, err := p.cadvisor.ImagesFsInfo(ctx)
if err != nil { if err != nil {
return "", err return "", err
} }

20
pkg/kubelet/stats/cadvisor_stats_provider_test.go
View File

@@ -248,7 +248,7 @@ func TestCadvisorListPodStats(t *testing.T) {
mockCadvisor := cadvisortest.NewMockInterface(t) mockCadvisor := cadvisortest.NewMockInterface(t)
mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(infos, nil) mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(infos, nil)
mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil) mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil)
mockCadvisor.EXPECT().ImagesFsInfo().Return(imagefs, nil) mockCadvisor.EXPECT().ImagesFsInfo(ctx).Return(imagefs, nil)
mockRuntime := containertest.NewMockRuntime(t) mockRuntime := containertest.NewMockRuntime(t)
@@ -531,7 +531,7 @@ func TestCadvisorImagesFsStatsKubeletSeparateDiskOff(t *testing.T) {
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, false) featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, false)
mockCadvisor.EXPECT().ImagesFsInfo().Return(imageFsInfo, nil) mockCadvisor.EXPECT().ImagesFsInfo(ctx).Return(imageFsInfo, nil)
mockRuntime.EXPECT().ImageStats(ctx).Return(imageStats, nil) mockRuntime.EXPECT().ImageStats(ctx).Return(imageStats, nil)
provider := newCadvisorStatsProvider(mockCadvisor, &fakeResourceAnalyzer{}, mockRuntime, nil, NewFakeHostStatsProvider()) provider := newCadvisorStatsProvider(mockCadvisor, &fakeResourceAnalyzer{}, mockRuntime, nil, NewFakeHostStatsProvider())
@@ -609,10 +609,10 @@ func TestImageFsStatsCustomResponse(t *testing.T) {
mockRuntime := containertest.NewMockRuntime(t) mockRuntime := containertest.NewMockRuntime(t)
res := getTestFsInfo(1000) res := getTestFsInfo(1000)
mockCadvisor.EXPECT().ImagesFsInfo().Return(res, nil) mockCadvisor.EXPECT().ImagesFsInfo(ctx).Return(res, nil)
mockRuntime.EXPECT().ImageFsInfo(ctx).Return(tc.response, nil) mockRuntime.EXPECT().ImageFsInfo(ctx).Return(tc.response, nil)
if tc.callContainerFsInfo { if tc.callContainerFsInfo {
mockCadvisor.EXPECT().ContainerFsInfo().Return(res, nil) mockCadvisor.EXPECT().ContainerFsInfo(ctx).Return(res, nil)
} }
provider := newCadvisorStatsProvider(mockCadvisor, &fakeResourceAnalyzer{}, mockRuntime, nil, NewFakeHostStatsProvider()) provider := newCadvisorStatsProvider(mockCadvisor, &fakeResourceAnalyzer{}, mockRuntime, nil, NewFakeHostStatsProvider())
@@ -649,7 +649,7 @@ func TestCadvisorImagesFsStats(t *testing.T) {
} }
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, true) featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, true)
mockCadvisor.EXPECT().ImagesFsInfo().Return(imageFsInfo, nil) mockCadvisor.EXPECT().ImagesFsInfo(ctx).Return(imageFsInfo, nil)
mockRuntime.EXPECT().ImageFsInfo(ctx).Return(imageFsInfoResponse, nil) mockRuntime.EXPECT().ImageFsInfo(ctx).Return(imageFsInfoResponse, nil)
provider := newCadvisorStatsProvider(mockCadvisor, &fakeResourceAnalyzer{}, mockRuntime, nil, NewFakeHostStatsProvider()) provider := newCadvisorStatsProvider(mockCadvisor, &fakeResourceAnalyzer{}, mockRuntime, nil, NewFakeHostStatsProvider())
@@ -701,8 +701,8 @@ func TestCadvisorSplitImagesFsStats(t *testing.T) {
ContainerFilesystems: []*runtimeapi.FilesystemUsage{containerFsInfoCRI}, ContainerFilesystems: []*runtimeapi.FilesystemUsage{containerFsInfoCRI},
} }
mockCadvisor.EXPECT().ImagesFsInfo().Return(imageFsInfo, nil) mockCadvisor.EXPECT().ImagesFsInfo(ctx).Return(imageFsInfo, nil)
mockCadvisor.EXPECT().ContainerFsInfo().Return(containerFsInfo, nil) mockCadvisor.EXPECT().ContainerFsInfo(ctx).Return(containerFsInfo, nil)
mockRuntime.EXPECT().ImageFsInfo(ctx).Return(imageFsInfoResponse, nil) mockRuntime.EXPECT().ImageFsInfo(ctx).Return(imageFsInfoResponse, nil)
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, true) featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, true)
@@ -754,8 +754,8 @@ func TestCadvisorSameDiskDifferentLocations(t *testing.T) {
ContainerFilesystems: []*runtimeapi.FilesystemUsage{containerFsInfoCRI}, ContainerFilesystems: []*runtimeapi.FilesystemUsage{containerFsInfoCRI},
} }
mockCadvisor.EXPECT().ImagesFsInfo().Return(imageFsInfo, nil) mockCadvisor.EXPECT().ImagesFsInfo(ctx).Return(imageFsInfo, nil)
mockCadvisor.EXPECT().ContainerFsInfo().Return(containerFsInfo, nil) mockCadvisor.EXPECT().ContainerFsInfo(ctx).Return(containerFsInfo, nil)
mockRuntime.EXPECT().ImageFsInfo(ctx).Return(imageFsInfoResponse, nil) mockRuntime.EXPECT().ImageFsInfo(ctx).Return(imageFsInfoResponse, nil)
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, true) featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.KubeletSeparateDiskGC, true)
@@ -858,7 +858,7 @@ func TestCadvisorListPodStatsWhenContainerLogFound(t *testing.T) {
mockCadvisor := cadvisortest.NewMockInterface(t) mockCadvisor := cadvisortest.NewMockInterface(t)
mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(infos, nil) mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(infos, nil)
mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil) mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil)
mockCadvisor.EXPECT().ImagesFsInfo().Return(imagefs, nil) mockCadvisor.EXPECT().ImagesFsInfo(ctx).Return(imagefs, nil)
mockRuntime := containertest.NewMockRuntime(t) mockRuntime := containertest.NewMockRuntime(t)
mockRuntime.EXPECT().ImageStats(ctx).Return(&kubecontainer.ImageStats{TotalStorageBytes: 123}, nil).Maybe() mockRuntime.EXPECT().ImageStats(ctx).Return(&kubecontainer.ImageStats{TotalStorageBytes: 123}, nil).Maybe()

4
pkg/kubelet/stats/provider.go
View File

@@ -200,11 +200,11 @@ func (p *Provider) HasDedicatedImageFs(ctx context.Context) (bool, error) {
// HasDedicatedImageFs returns true if a dedicated image filesystem exists for storing images. // HasDedicatedImageFs returns true if a dedicated image filesystem exists for storing images.
// KEP Issue Number 4191: Enhanced this to allow for the containers to be separate from images. // KEP Issue Number 4191: Enhanced this to allow for the containers to be separate from images.
func (p *Provider) HasDedicatedContainerFs(ctx context.Context) (bool, error) { func (p *Provider) HasDedicatedContainerFs(ctx context.Context) (bool, error) {
imageFs, err := p.cadvisor.ImagesFsInfo() imageFs, err := p.cadvisor.ImagesFsInfo(ctx)
if err != nil { if err != nil {
return false, err return false, err
} }
containerFs, err := p.cadvisor.ContainerFsInfo() containerFs, err := p.cadvisor.ContainerFsInfo(ctx)
if err != nil { if err != nil {
return false, err return false, err
} }