From 1ae4fddcc9f5fe1a15af9f88f9fd95ae86d9de2b Mon Sep 17 00:00:00 2001 From: Jerry Leung Date: Fri, 24 May 2024 19:26:15 -0700 Subject: [PATCH] Added extensions --- collector/receiver/telemetryapireceiver/receiver.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/collector/receiver/telemetryapireceiver/receiver.go b/collector/receiver/telemetryapireceiver/receiver.go index 00b9cb050b..4b8d3a97c2 100644 --- a/collector/receiver/telemetryapireceiver/receiver.go +++ b/collector/receiver/telemetryapireceiver/receiver.go @@ -69,7 +69,7 @@ func (r *telemetryAPIReceiver) Start(ctx context.Context, host component.Host) e }() telemetryClient := telemetryapi.NewClient(r.logger) - _, err := telemetryClient.Subscribe(ctx, []telemetryapi.EventType{telemetryapi.Platform, telemetryapi.Function}, r.extensionID, fmt.Sprintf("http://%s/", address)) + _, err := telemetryClient.Subscribe(ctx, []telemetryapi.EventType{telemetryapi.Platform, telemetryapi.Function, telemetryapi.Extension}, r.extensionID, fmt.Sprintf("http://%s/", address)) if err != nil { r.logger.Info("Listening for requests", zap.String("address", address), zap.String("extensionID", r.extensionID)) return err