- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for ContainerInfoV2 (0.17 sec)
-
pkg/kubelet/cadvisor/testing/cadvisor_mock.go
} // ContainerInfoV2 mocks base method. func (m *MockInterface) ContainerInfoV2(name string, options v2.RequestOptions) (map[string]v2.ContainerInfo, error) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "ContainerInfoV2", name, options) ret0, _ := ret[0].(map[string]v2.ContainerInfo) ret1, _ := ret[1].(error) return ret0, ret1 } // ContainerInfoV2 indicates an expected call of ContainerInfoV2.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/kubelet/cadvisor/testing/cadvisor_fake.go
) var _ cadvisor.Interface = new(Fake) // Start is a fake implementation of Interface.Start. func (c *Fake) Start() error { return nil } // ContainerInfoV2 is a fake implementation of Interface.ContainerInfoV2. func (c *Fake) ContainerInfoV2(name string, options cadvisorapiv2.RequestOptions) (map[string]cadvisorapiv2.ContainerInfo, error) { return map[string]cadvisorapiv2.ContainerInfo{}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 22:07:20 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/kubelet/cadvisor/cadvisor_windows.go
rootPath: rootPath, winStatsClient: client, }, err } func (cu *cadvisorClient) Start() error { return nil } // ContainerInfoV2 is only expected to be used for the root container. Returns info for all containers in the node. func (cu *cadvisorClient) ContainerInfoV2(name string, options cadvisorapiv2.RequestOptions) (map[string]cadvisorapiv2.ContainerInfo, error) { return cu.winStatsClient.WinContainerInfos() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 22:07:20 UTC 2023 - 2.5K bytes - Viewed (0) -
pkg/kubelet/cadvisor/cadvisor_unsupported.go
} var errUnsupported = errors.New("cAdvisor is unsupported in this build") func (cu *cadvisorUnsupported) Start() error { return errUnsupported } func (cu *cadvisorUnsupported) ContainerInfoV2(name string, options cadvisorapiv2.RequestOptions) (map[string]cadvisorapiv2.ContainerInfo, error) { return nil, errUnsupported }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 22:07:20 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/kubelet/cadvisor/types.go
cadvisorapiv2 "github.com/google/cadvisor/info/v2" ) // Interface is an abstract interface for testability. It abstracts the interface to cAdvisor. type Interface interface { Start() error ContainerInfoV2(name string, options cadvisorapiv2.RequestOptions) (map[string]cadvisorapiv2.ContainerInfo, error) GetRequestedContainersInfo(containerName string, options cadvisorapiv2.RequestOptions) (map[string]*cadvisorapi.ContainerInfo, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 22:07:20 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/kubelet/stats/provider_test.go
containerInfo = getTestContainerInfo(containerInfoSeed, "test-pod", "test-ns", "test-container") containerInfoMap = map[string]cadvisorapiv2.ContainerInfo{cgroupName: containerInfo} ) mockCadvisor.EXPECT().ContainerInfoV2(cgroupName, options).Return(containerInfoMap, nil) provider := newStatsProvider(mockCadvisor, mockPodManager, mockRuntimeCache, fakeContainerStatsProvider{}) cs, ns, err := provider.GetCgroupStats(cgroupName, updateStats)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20K bytes - Viewed (0) -
pkg/kubelet/cadvisor/cadvisor_linux.go
rootPath: rootPath, Manager: m, }, nil } func (cc *cadvisorClient) Start() error { return cc.Manager.Start() } func (cc *cadvisorClient) ContainerInfoV2(name string, options cadvisorapiv2.RequestOptions) (map[string]cadvisorapiv2.ContainerInfo, error) { return cc.GetContainerInfoV2(name, options) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 22:07:20 UTC 2023 - 5.5K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider_test.go
Count: 2, Recursive: true, } mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockCadvisor := cadvisortest.NewMockInterface(mockCtrl) mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(infos, nil) mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil) mockCadvisor.EXPECT().ImagesFsInfo().Return(imagefs, nil) mockRuntime := containertest.NewMockRuntime(mockCtrl)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 30.2K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider.go
return true } return cstat.CpuInst.Usage.Total == 0 && cstat.Memory.RSS == 0 } func getCadvisorContainerInfo(ca cadvisor.Interface) (map[string]cadvisorapiv2.ContainerInfo, error) { infos, err := ca.ContainerInfoV2("/", cadvisorapiv2.RequestOptions{ IdType: cadvisorapiv2.TypeName, Count: 2, // 2 samples are needed to compute "instantaneous" CPU Recursive: true, }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 16 13:34:22 UTC 2023 - 18.9K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
} options := cadvisorapiv2.RequestOptions{ IdType: cadvisorapiv2.TypeName, Count: 2, Recursive: true, } mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(infos, nil) mockCadvisor.EXPECT().RootFsInfo().Return(rootFsInfo, nil) mockCadvisor.EXPECT().GetDirFsInfo(imageFsMountpoint).Return(imageFsInfo, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0)