@@ -45,7 +45,7 @@ func TestNewTraceProcessor(t *testing.T) {
45
45
require .NoError (t , err )
46
46
}
47
47
48
- func TestBadOption (t * testing.T ) {
48
+ func TestTraceProcessorBadOption (t * testing.T ) {
49
49
opt := func (p * kubernetesprocessor ) error {
50
50
return fmt .Errorf ("bad option" )
51
51
}
@@ -60,7 +60,7 @@ func TestBadOption(t *testing.T) {
60
60
assert .Equal (t , err .Error (), "bad option" )
61
61
}
62
62
63
- func TestBadClientProvider (t * testing.T ) {
63
+ func TestTraceProcessorBadClientProvider (t * testing.T ) {
64
64
clientProvider := func (_ * zap.Logger , _ k8sconfig.APIConfig , _ kube.ExtractionRules , _ kube.Filters , _ kube.APIClientsetProvider , _ kube.InformerProvider ) (kube.Client , error ) {
65
65
return nil , fmt .Errorf ("bad client error" )
66
66
}
@@ -368,6 +368,36 @@ func TestNewMetricsProcessor(t *testing.T) {
368
368
require .NoError (t , err )
369
369
}
370
370
371
+ func TestMetricsProcessorBadOption (t * testing.T ) {
372
+ opt := func (p * kubernetesprocessor ) error {
373
+ return fmt .Errorf ("bad option" )
374
+ }
375
+ p , err := NewMetricsProcessor (
376
+ zap .NewNop (),
377
+ exportertest .NewNopMetricsExporter (),
378
+ newFakeClient ,
379
+ opt ,
380
+ )
381
+ assert .Nil (t , p )
382
+ assert .Error (t , err )
383
+ assert .Equal (t , err .Error (), "bad option" )
384
+ }
385
+
386
+ func TestMetricsProcessorBadClientProvider (t * testing.T ) {
387
+ clientProvider := func (_ * zap.Logger , _ k8sconfig.APIConfig , _ kube.ExtractionRules , _ kube.Filters , _ kube.APIClientsetProvider , _ kube.InformerProvider ) (kube.Client , error ) {
388
+ return nil , fmt .Errorf ("bad client error" )
389
+ }
390
+ p , err := NewMetricsProcessor (
391
+ zap .NewNop (),
392
+ exportertest .NewNopMetricsExporter (),
393
+ clientProvider ,
394
+ )
395
+
396
+ assert .Nil (t , p )
397
+ assert .Error (t , err )
398
+ assert .Equal (t , err .Error (), "bad client error" )
399
+ }
400
+
371
401
func TestMetricsProcessorNoAttrs (t * testing.T ) {
372
402
next := & testMetricsConsumer {}
373
403
p , err := NewMetricsProcessor (
0 commit comments