- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for cadvisorapiv2 (0.29 sec)
-
pkg/kubelet/stats/provider_test.go
e.Format = cadvisorapiv1.IntType case 1: e.Format = cadvisorapiv1.FloatType } c.Fuzz(&e.Units) }) var ret []cadvisorapiv1.MetricSpec f.Fuzz(&ret) return ret } func generateCustomMetrics(spec []cadvisorapiv1.MetricSpec) map[string][]cadvisorapiv1.MetricVal { ret := map[string][]cadvisorapiv1.MetricVal{} for _, metricSpec := range spec { f := fuzz.New().NilChance(0).Funcs(
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/stats/helper.go
func getCgroupInfo(cadvisor cadvisor.Interface, containerName string, updateStats bool) (*cadvisorapiv2.ContainerInfo, error) { var maxAge *time.Duration if updateStats { age := 0 * time.Second maxAge = &age } infoMap, err := cadvisor.ContainerInfoV2(containerName, cadvisorapiv2.RequestOptions{ IdType: cadvisorapiv2.TypeName, Count: 2, // 2 samples are needed to compute "instantaneous" CPU Recursive: false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 23:40:02 UTC 2023 - 14.8K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
pkg/kubelet/stats/cri_stats_provider_windows_test.go
See the License for the specific language governing permissions and limitations under the License. */ package stats import ( "reflect" "testing" "time" "github.com/Microsoft/hcsshim" cadvisorapiv2 "github.com/google/cadvisor/info/v2" "github.com/stretchr/testify/assert" "k8s.io/apimachinery/pkg/api/resource" v1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 17 00:02:10 UTC 2024 - 13.8K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/numa_info_test.go
*/ package topologymanager import ( "fmt" "reflect" "strings" "testing" cadvisorapi "github.com/google/cadvisor/info/v1" "k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask" ) func TestNUMAInfo(t *testing.T) { tcases := []struct { name string topology []cadvisorapi.Node expectedNUMAInfo *NUMAInfo expectedErr error opts PolicyOptions }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:14 UTC 2022 - 11.6K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/topology/topology_test.go
}, { name: "DualSocketNoHT", machineInfo: cadvisorapi.MachineInfo{ NumCores: 4, NumSockets: 2, Topology: []cadvisorapi.Node{ {Id: 0, Cores: []cadvisorapi.Core{ {SocketID: 0, Id: 0, Threads: []int{0}}, {SocketID: 0, Id: 2, Threads: []int{2}}, }, }, {Id: 1, Cores: []cadvisorapi.Core{ {SocketID: 1, Id: 1, Threads: []int{1}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 31.7K bytes - Viewed (0) -
pkg/kubelet/winstats/network_stats.go
packetsOutboundDiscardedCounter: packetsOutboundDiscardedCounter, packetsOutboundErrorsCounter: packetsOutboundErrorsCounter, adapterStats: map[string]cadvisorapi.InterfaceStats{}, }, nil } func (n *networkCounter) getData() ([]cadvisorapi.InterfaceStats, error) { packetsReceivedPerSecondData, err := n.packetsReceivedPerSecondCounter.getDataList() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 10.2K bytes - Viewed (0)