Skip to content

Commit 0aa7afb

Browse files
author
Luiz Pegoraro
committed
fix(agent): add run configuration and fix version change on otlpreceiver for pktvisor.
1 parent e0a88c6 commit 0aa7afb

File tree

2 files changed

+9
-11
lines changed

2 files changed

+9
-11
lines changed

.idea/runConfigurations/orb_agent.xml renamed to .idea/runConfigurations/orb_agent_visor.xml

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

agent/backend/pktvisor/scrape.go

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,8 @@ import (
88
"context"
99
"encoding/json"
1010
"fmt"
11-
"go.opentelemetry.io/collector/config/confighttp"
11+
"go.opentelemetry.io/collector/config/configgrpc"
12+
"go.opentelemetry.io/collector/config/confignet"
1213
"net/http"
1314
"strconv"
1415
"time"
@@ -152,9 +153,10 @@ func (p *pktvisorBackend) receiveOtlp() {
152153
pFactory := otlpreceiver.NewFactory()
153154
cfg := pFactory.CreateDefaultConfig()
154155
cfg.(*otlpreceiver.Config).Protocols = otlpreceiver.Protocols{
155-
HTTP: &otlpreceiver.HTTPConfig{
156-
HTTPServerSettings: &confighttp.HTTPServerSettings{
157-
Endpoint: p.otelReceiverHost + ":" + strconv.Itoa(p.otelReceiverPort),
156+
GRPC: &configgrpc.GRPCServerSettings{
157+
NetAddr: confignet.NetAddr{
158+
Endpoint: p.otelReceiverHost + ":" + strconv.Itoa(p.otelReceiverPort),
159+
Transport: "tcp",
158160
},
159161
},
160162
}
@@ -166,11 +168,7 @@ func (p *pktvisorBackend) receiveOtlp() {
166168
},
167169
BuildInfo: component.NewDefaultBuildInfo(),
168170
}
169-
//p.logger.Info("Started receiver for OTLP in orb-agent", zap.Any("exect", exeCtx),
170-
// zap.Any("set", set),
171-
// zap.Any("cfg", cfg),
172-
// zap.Any("exporter", p.exporter),
173-
// zap.Any("receiver", p.receiver))
171+
174172
p.receiver, err = pFactory.CreateMetricsReceiver(exeCtx, set, cfg, p.exporter)
175173
if err != nil {
176174
p.logger.Error("failed to create a receiver", zap.Error(err))

0 commit comments

Comments
 (0)