Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 56 for cadvisorapiv2 (0.28 sec)

  1. pkg/kubelet/stats/host_stats_provider.go

    	getPodLogStats(podNamespace, podName string, podUID types.UID, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error)
    	// getPodContainerLogStats gets stats associated with container log usage
    	getPodContainerLogStats(podNamespace, podName string, podUID types.UID, containerName string, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error)
    	// getPodEtcHostsStats gets stats associated with pod etc-hosts usage
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 17:55:59 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. pkg/kubelet/stats/cadvisor_stats_provider.go

    func filterTerminatedContainerInfoAndAssembleByPodCgroupKey(containerInfo map[string]cadvisorapiv2.ContainerInfo) (map[string]cadvisorapiv2.ContainerInfo, map[string]cadvisorapiv2.ContainerInfo) {
    	cinfoMap := make(map[containerID][]containerInfoWithCgroup)
    	cinfosByPodCgroupKey := make(map[string]cadvisorapiv2.ContainerInfo)
    	for key, cinfo := range containerInfo {
    		var podCgroupKey string
    		if cm.IsSystemdStyleName(key) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 16 13:34:22 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  3. pkg/kubelet/stats/cri_stats_provider_others.go

    func (p *criStatsProvider) addCRIPodContainerStats(criSandboxStat *runtimeapi.PodSandboxStats,
    	ps *statsapi.PodStats, fsIDtoInfo map[runtimeapi.FilesystemIdentifier]*cadvisorapiv2.FsInfo,
    	containerMap map[string]*runtimeapi.Container,
    	podSandbox *runtimeapi.PodSandbox,
    	rootFsInfo *cadvisorapiv2.FsInfo, updateCPUNanoCoreUsage bool) error {
    	return nil
    }
    
    func addCRIPodNetworkStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 11:09:04 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  4. pkg/kubelet/stats/host_stats_provider_fake.go

    }
    
    func (f *fakeHostStatsProvider) getPodEtcHostsStats(podUID types.UID, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error) {
    	return nil, fmt.Errorf("not implemented")
    }
    
    func fakeMetricsProvidersToStats(metricsProviders []volume.MetricsProvider, rootFsInfo *cadvisorapiv2.FsInfo) (*statsapi.FsStats, error) {
    	result := rootFsInfoToFsStats(rootFsInfo)
    	for i, metricsProvider := range metricsProviders {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 17:57:17 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/cadvisor_stats_provider_test.go

    			t.Errorf("No container defined with name %v", name)
    		}
    		info.Spec.Memory = cadvisorapiv2.MemorySpec{}
    		info.Spec.Cpu = cadvisorapiv2.CpuSpec{}
    		info.Spec.HasMemory = false
    		info.Spec.HasCpu = false
    		info.Spec.HasNetwork = false
    		infos[name] = info
    	}
    
    	options := cadvisorapiv2.RequestOptions{
    		IdType:    cadvisorapiv2.TypeName,
    		Count:     2,
    		Recursive: true,
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. pkg/kubelet/stats/cri_stats_provider_windows.go

    func (p *criStatsProvider) addCRIPodContainerStats(criSandboxStat *runtimeapi.PodSandboxStats,
    	ps *statsapi.PodStats, fsIDtoInfo map[runtimeapi.FilesystemIdentifier]*cadvisorapiv2.FsInfo,
    	containerMap map[string]*runtimeapi.Container,
    	podSandbox *runtimeapi.PodSandbox,
    	rootFsInfo *cadvisorapiv2.FsInfo,
    	updateCPUNanoCoreUsage bool) error {
    	for _, criContainerStat := range criSandboxStat.GetWindows().GetContainers() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 18 07:03:11 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  7. pkg/kubelet/stats/cri_stats_provider_linux.go

    	ps *statsapi.PodStats, fsIDtoInfo map[runtimeapi.FilesystemIdentifier]*cadvisorapiv2.FsInfo,
    	containerMap map[string]*runtimeapi.Container,
    	podSandbox *runtimeapi.PodSandbox,
    	rootFsInfo *cadvisorapiv2.FsInfo, updateCPUNanoCoreUsage bool) error {
    	for _, criContainerStat := range criSandboxStat.Linux.Containers {
    		container, found := containerMap[criContainerStat.Attributes.Id]
    		if !found {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 11:09:04 UTC 2023
    - 4K bytes
    - Viewed (0)
  8. pkg/kubelet/stats/host_stats_provider_test.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package stats
    
    import (
    	"reflect"
    	"testing"
    
    	cadvisorapiv2 "github.com/google/cadvisor/info/v2"
    
    	kubecontainertest "k8s.io/kubernetes/pkg/kubelet/container/testing"
    
    	"k8s.io/apimachinery/pkg/types"
    	statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 10 11:26:59 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  9. pkg/kubelet/stats/cri_stats_provider.go

    	}
    	if memory != nil {
    		cs.Memory = memory
    	}
    }
    
    func getCRICadvisorStats(infos map[string]cadvisorapiv2.ContainerInfo) (map[string]cadvisorapiv2.ContainerInfo, map[string]cadvisorapiv2.ContainerInfo) {
    	stats := make(map[string]cadvisorapiv2.ContainerInfo)
    	filteredInfos, cinfosByPodCgroupKey := filterTerminatedContainerInfoAndAssembleByPodCgroupKey(infos)
    	for key, info := range filteredInfos {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  10. pkg/kubelet/runonce_test.go

    	cadvisor := cadvisortest.NewMockInterface(mockCtrl)
    	cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).AnyTimes()
    	cadvisor.EXPECT().ImagesFsInfo().Return(cadvisorapiv2.FsInfo{
    		Usage:     400,
    		Capacity:  1000,
    		Available: 600,
    	}, nil).AnyTimes()
    	cadvisor.EXPECT().RootFsInfo().Return(cadvisorapiv2.FsInfo{
    		Usage:    9,
    		Capacity: 10,
    	}, nil).AnyTimes()
    	fakeSecretManager := secret.NewFakeManager()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top