github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-31 15:25:57 +00:00
Code Issues Projects Releases Wiki Activity

Control logs verbosity in resource gatherer

Browse Source
This commit is contained in:
Shyam Jeedigunta 2017-11-17 12:58:13 +01:00
parent ad750b60b2
commit fce28995e1
3 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
test/e2e/framework/framework.go
View File

@ -207,6 +207,7 @@ func (f *Framework) BeforeEach() {
MasterOnly: TestContext.GatherKubeSystemResourceUsageData == "master", MasterOnly: TestContext.GatherKubeSystemResourceUsageData == "master",
ResourceDataGatheringPeriod: 60 * time.Second, ResourceDataGatheringPeriod: 60 * time.Second,
ProbeDuration: 15 * time.Second, ProbeDuration: 15 * time.Second,
PrintVerboseLogs: false,
}, nil) }, nil)
if err != nil { if err != nil {
Logf("Error while creating NewResourceUsageGatherer: %v", err) Logf("Error while creating NewResourceUsageGatherer: %v", err)

8
test/e2e/framework/resource_usage_gatherer.go
View File

@ -137,6 +137,7 @@ type resourceGatherWorker struct {
inKubemark bool inKubemark bool
resourceDataGatheringPeriod time.Duration resourceDataGatheringPeriod time.Duration
probeDuration time.Duration probeDuration time.Duration
printVerboseLogs bool
} }
func (w *resourceGatherWorker) singleProbe() { func (w *resourceGatherWorker) singleProbe() {
@ -161,7 +162,9 @@ func (w *resourceGatherWorker) singleProbe() {
} }
for k, v := range nodeUsage { for k, v := range nodeUsage {
data[k] = v data[k] = v
Logf("Get container %v usage on node %v. CPUUsageInCores: %v, MemoryUsageInBytes: %v, MemoryWorkingSetInBytes: %v", k, w.nodeName, v.CPUUsageInCores, v.MemoryUsageInBytes, v.MemoryWorkingSetInBytes) if w.printVerboseLogs {
Logf("Get container %v usage on node %v. CPUUsageInCores: %v, MemoryUsageInBytes: %v, MemoryWorkingSetInBytes: %v", k, w.nodeName, v.CPUUsageInCores, v.MemoryUsageInBytes, v.MemoryWorkingSetInBytes)
}
} }
} }
w.dataSeries = append(w.dataSeries, data) w.dataSeries = append(w.dataSeries, data)
@ -202,6 +205,7 @@ type ResourceGathererOptions struct {
MasterOnly bool MasterOnly bool
ResourceDataGatheringPeriod time.Duration ResourceDataGatheringPeriod time.Duration
ProbeDuration time.Duration ProbeDuration time.Duration
PrintVerboseLogs bool
} }
func NewResourceUsageGatherer(c clientset.Interface, options ResourceGathererOptions, pods *v1.PodList) (*containerResourceGatherer, error) { func NewResourceUsageGatherer(c clientset.Interface, options ResourceGathererOptions, pods *v1.PodList) (*containerResourceGatherer, error) {
@ -221,6 +225,7 @@ func NewResourceUsageGatherer(c clientset.Interface, options ResourceGathererOpt
finished: false, finished: false,
resourceDataGatheringPeriod: options.ResourceDataGatheringPeriod, resourceDataGatheringPeriod: options.ResourceDataGatheringPeriod,
probeDuration: options.ProbeDuration, probeDuration: options.ProbeDuration,
printVerboseLogs: options.PrintVerboseLogs,
}) })
} else { } else {
// Tracks kube-system pods if no valid PodList is passed in. // Tracks kube-system pods if no valid PodList is passed in.
@ -259,6 +264,7 @@ func NewResourceUsageGatherer(c clientset.Interface, options ResourceGathererOpt
inKubemark: false, inKubemark: false,
resourceDataGatheringPeriod: options.ResourceDataGatheringPeriod, resourceDataGatheringPeriod: options.ResourceDataGatheringPeriod,
probeDuration: options.ProbeDuration, probeDuration: options.ProbeDuration,
printVerboseLogs: options.PrintVerboseLogs,
}) })
if options.MasterOnly { if options.MasterOnly {
break break

2
test/e2e/scheduling/nvidia-gpus.go
View File

@ -184,7 +184,7 @@ func testNvidiaGPUsOnCOS(f *framework.Framework) {
pods, err := framework.WaitForControlledPods(f.ClientSet, ds.Namespace, ds.Name, extensionsinternal.Kind("DaemonSet")) pods, err := framework.WaitForControlledPods(f.ClientSet, ds.Namespace, ds.Name, extensionsinternal.Kind("DaemonSet"))
framework.ExpectNoError(err, "getting pods controlled by the daemonset") framework.ExpectNoError(err, "getting pods controlled by the daemonset")
framework.Logf("Starting ResourceUsageGather for the created DaemonSet pods.") framework.Logf("Starting ResourceUsageGather for the created DaemonSet pods.")
rsgather, err := framework.NewResourceUsageGatherer(f.ClientSet, framework.ResourceGathererOptions{false, false, 2 * time.Second, 2 * time.Second}, pods) rsgather, err := framework.NewResourceUsageGatherer(f.ClientSet, framework.ResourceGathererOptions{false, false, 2 * time.Second, 2 * time.Second, true}, pods)
framework.ExpectNoError(err, "creating ResourceUsageGather for the daemonset pods") framework.ExpectNoError(err, "creating ResourceUsageGather for the daemonset pods")
go rsgather.StartGatheringData() go rsgather.StartGatheringData()