| 1234567891011121314151617181920212223242526272829303132333435363738394041424344 |
- package metrics
- import (
- "testing"
- "github.com/opencost/opencost/core/pkg/clustercache"
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
- )
- func TestWhitelist(t *testing.T) {
- sampleServices := []*clustercache.Service{{
- SpecSelector: map[string]string{"servicewhitelistlabel": "foo"},
- }}
- replicaSetLabelSelector := metav1.LabelSelector{
- MatchLabels: map[string]string{"replicasetwhitelistlabel1": "bar"},
- }
- sampleReplicaSets := []*clustercache.ReplicaSet{{
- SpecSelector: &replicaSetLabelSelector,
- }}
- sampleStatefulSets := []*clustercache.StatefulSet{}
- kc := &clustercache.MockClusterCache{ReplicaSets: sampleReplicaSets, StatefulSets: sampleStatefulSets, Services: sampleServices}
- wl := map[string]bool{
- "whitelistedlabel": true,
- }
- mc := MetricsConfig{
- DisabledMetrics: []string{},
- UseLabelsWhitelist: true,
- LabelsWhitelist: wl,
- }
- kplc := KubePodLabelsCollector{
- KubeClusterCache: kc,
- metricsConfig: mc,
- }
- kplc.UpdateWhitelist()
- if !kplc.labelsWhitelist["servicewhitelistlabel"] {
- t.Errorf("Missing expected label %s", "servicewhitelistlabel")
- }
- if !kplc.labelsWhitelist["replicasetwhitelistlabel1"] {
- t.Errorf("Missing expected label %s", "servicewhitelistlabel1")
- }
- }
|