mirror of
https://github.com/kubernetes-sigs/prometheus-adapter.git
synced 2026-04-06 09:47:54 +00:00
Merge pull request #148 from brancz/empty-err
Fix empty pod or node list resulting in an error
This commit is contained in:
commit
6f6f1ba788
1 changed files with 4 additions and 2 deletions
|
|
@ -118,9 +118,10 @@ type nsQueryResults struct {
|
|||
err error
|
||||
}
|
||||
|
||||
// GetContainerMetrics implements the provider.MetricsProvider interface. It may return nil, nil, nil.
|
||||
func (p *resourceProvider) GetContainerMetrics(pods ...apitypes.NamespacedName) ([]provider.TimeInfo, [][]metrics.ContainerMetrics, error) {
|
||||
if len(pods) == 0 {
|
||||
return nil, nil, fmt.Errorf("no pods to fetch metrics for")
|
||||
return nil, nil, nil
|
||||
}
|
||||
|
||||
// TODO(directxman12): figure out how well this scales if we go to list 1000+ pods
|
||||
|
|
@ -238,9 +239,10 @@ func (p *resourceProvider) assignForPod(pod apitypes.NamespacedName, resultsByNs
|
|||
*resMetrics = containerMetricsList
|
||||
}
|
||||
|
||||
// GetNodeMetrics implements the provider.MetricsProvider interface. It may return nil, nil, nil.
|
||||
func (p *resourceProvider) GetNodeMetrics(nodes ...string) ([]provider.TimeInfo, []corev1.ResourceList, error) {
|
||||
if len(nodes) == 0 {
|
||||
return nil, nil, fmt.Errorf("no nodes to fetch metrics for")
|
||||
return nil, nil, nil
|
||||
}
|
||||
|
||||
now := pmodel.Now()
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue