- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for cadvisorapi (0.3 sec)
-
pkg/kubelet/cm/devicemanager/manager.go
limitations under the License. */ package devicemanager import ( "context" "fmt" "os" "path/filepath" "runtime" "sort" "sync" "time" cadvisorapi "github.com/google/cadvisor/info/v1" "k8s.io/klog/v2" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/resource" errorsutil "k8s.io/apimachinery/pkg/util/errors" "k8s.io/apimachinery/pkg/util/sets"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
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/kubelet_getters.go
func (kl *Kubelet) GetRequestedContainersInfo(containerName string, options cadvisorv2.RequestOptions) (map[string]*cadvisorapiv1.ContainerInfo, error) { return kl.cadvisor.GetRequestedContainersInfo(containerName, options) } // GetVersionInfo returns information about the version of cAdvisor in use. func (kl *Kubelet) GetVersionInfo() (*cadvisorapiv1.VersionInfo, error) { return kl.cadvisor.VersionInfo() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters.go
limitations under the License. */ package nodestatus import ( "context" "fmt" "math" "net" goruntime "runtime" "strings" "time" cadvisorapiv1 "github.com/google/cadvisor/info/v1" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/resource" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/util/errors"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0)