Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for ContainerInfoV2 (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top