From 9d9aeb56784381737ba5eca71628d111e634bdab Mon Sep 17 00:00:00 2001 From: Annanay Date: Tue, 5 Mar 2019 00:00:39 +0530 Subject: [PATCH] Rebased Signed-off-by: Annanay --- cmd/agent/app/builder.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cmd/agent/app/builder.go b/cmd/agent/app/builder.go index f463eff6a47..6c9a32d5b32 100644 --- a/cmd/agent/app/builder.go +++ b/cmd/agent/app/builder.go @@ -229,14 +229,14 @@ func CreateCollectorProxy( len(tchanRep.CollectorHostPorts) > 0 && len(grpcRepOpts.CollectorHostPort) == 0 { logger.Warn("Using deprecated configuration", zap.String("option", "--collector-host.port")) - return tchannel.NewCollectorProxy(tchanRep, mFactory, logger) + return tchannel.NewCollectorProxy(tchanRep, opts.AgentTags, mFactory, logger) } switch opts.ReporterType { case reporter.GRPC: grpclog.SetLoggerV2(grpclog.NewLoggerV2(ioutil.Discard, os.Stderr, os.Stderr)) - return grpc.NewCollectorProxy(grpcRepOpts, mFactory, logger) + return grpc.NewCollectorProxy(grpcRepOpts, opts.AgentTags, mFactory, logger) case reporter.TCHANNEL: - return tchannel.NewCollectorProxy(tchanRep, mFactory, logger) + return tchannel.NewCollectorProxy(tchanRep, opts.AgentTags, mFactory, logger) default: return nil, errors.New(fmt.Sprintf("unknown reporter type %s", string(opts.ReporterType))) }