From dc64847f4c6417f64d386eae1facf33e3102a378 Mon Sep 17 00:00:00 2001 From: Koenraad Verheyden Date: Mon, 12 Jul 2021 20:34:02 +0200 Subject: [PATCH] Remove redundant type assertion (golangci-lint) --- modules/distributor/receiver/shim.go | 16 +++------------- 1 file changed, 3 insertions(+), 13 deletions(-) diff --git a/modules/distributor/receiver/shim.go b/modules/distributor/receiver/shim.go index b02470dc29b..68c0a058391 100644 --- a/modules/distributor/receiver/shim.go +++ b/modules/distributor/receiver/shim.go @@ -102,22 +102,12 @@ func New(receiverCfg map[string]interface{}, pusher tempopb.PusherServer, multit return nil, fmt.Errorf("receiver factory not found for type: %s", cfg.Type()) } - if factory, ok := factoryBase.(component.ReceiverFactory); ok { - receiver, err := factory.CreateTracesReceiver(ctx, params, cfg, shim) - if err != nil { - return nil, err - } - - shim.receivers = append(shim.receivers, receiver) - continue - } - - /*factory := factoryBase.(component.ReceiverFactoryOld) - receiver, err := factory.CreateTraceReceiver(ctx, zapLogger, cfg, converter.NewOCToInternalTraceConverter(shim)) + receiver, err := factoryBase.CreateTracesReceiver(ctx, params, cfg, shim) if err != nil { return nil, err } - shim.receivers = append(shim.receivers, receiver)*/ + + shim.receivers = append(shim.receivers, receiver) } shim.Service = services.NewIdleService(shim.starting, shim.stopping)