[exporter/coralogix] Add profile support for the Coralogix exporter (#38012)

#### Description
Add support for profiles to the Coralogix exporter.

#### Link to tracking issue
Fixes #38011

#### Testing
Added new unit tests.

Signed-off-by: Israel Blancas <[email protected]>

Author: iblancasa

.chloggen/38011-add-profiles-coralogixexporter.yaml

@@ -0,0 +1,29 @@
+# Use this changelog template to create an entry for release notes.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
+component: coralogixexporter
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Add support for profiles to the Coralogix exporter.
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [38011]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext: |
+  This change adds support for profiles to the Coralogix exporter.
+  It allows users to export profiles to Coralogix.
+
+# If your change doesn't affect end users or the exported elements of any package,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+# Optional: The change log or logs in which this entry should be included.
+# e.g. '[user]' or '[user, api]'
+# Include 'user' if the change is relevant to end users.
+# Include 'api' if there is a change to a library API.
+# Default: '[user]'
+change_logs: []

exporter/coralogixexporter/README.md

@@ -3,11 +3,13 @@
 <!-- status autogenerated section -->
 | Status        |           |
 | ------------- |-----------|
-| Stability     | [beta]: traces, metrics, logs   |
+| Stability     | [alpha]: profiles   |
+|               | [beta]: traces, metrics, logs   |
 | Distributions | [contrib] |
 | Issues        | [![Open issues](https://img.shields.io/github/issues-search/open-telemetry/opentelemetry-collector-contrib?query=is%3Aissue%20is%3Aopen%20label%3Aexporter%2Fcoralogix%20&label=open&color=orange&logo=opentelemetry)](https://github.com/open-telemetry/opentelemetry-collector-contrib/issues?q=is%3Aopen+is%3Aissue+label%3Aexporter%2Fcoralogix) [![Closed issues](https://img.shields.io/github/issues-search/open-telemetry/opentelemetry-collector-contrib?query=is%3Aissue%20is%3Aclosed%20label%3Aexporter%2Fcoralogix%20&label=closed&color=blue&logo=opentelemetry)](https://github.com/open-telemetry/opentelemetry-collector-contrib/issues?q=is%3Aclosed+is%3Aissue+label%3Aexporter%2Fcoralogix) |
 | [Code Owners](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/main/CONTRIBUTING.md#becoming-a-code-owner)    | [@povilasv](https://www.github.com/povilasv), [@iblancasa](https://www.github.com/iblancasa), [@douglascamata](https://www.github.com/douglascamata) |
 
+[alpha]: https://github.com/open-telemetry/opentelemetry-collector/blob/main/docs/component-stability.md#alpha
 [beta]: https://github.com/open-telemetry/opentelemetry-collector/blob/main/docs/component-stability.md#beta
 [contrib]: https://github.com/open-telemetry/opentelemetry-collector-releases/tree/main/distributions/otelcol-contrib
 <!-- end autogenerated section -->

exporter/coralogixexporter/config.go

@@ -4,6 +4,7 @@
 package coralogixexporter // import "github.com/open-telemetry/opentelemetry-collector-contrib/exporter/coralogixexporter"
 
 import (
+	"errors"
 	"fmt"
 
 	"go.opentelemetry.io/collector/config/configgrpc"
@@ -43,6 +44,9 @@ type Config struct {
 	// The Coralogix logs ingress endpoint
 	Logs configgrpc.ClientConfig `mapstructure:"logs"`
 
+	// The Coralogix profiles ingress endpoint
+	Profiles configgrpc.ClientConfig `mapstructure:"profiles"`
+
 	// Your Coralogix private key (sensitive) for authentication
 	PrivateKey configopaque.String `mapstructure:"private_key"`
 
@@ -69,14 +73,15 @@ func (c *Config) Validate() error {
 	if isEmpty(c.Domain) &&
 		isEmpty(c.Traces.Endpoint) &&
 		isEmpty(c.Metrics.Endpoint) &&
-		isEmpty(c.Logs.Endpoint) {
-		return fmt.Errorf("`domain` or `traces.endpoint` or `metrics.endpoint` or `logs.endpoint` not specified, please fix the configuration")
+		isEmpty(c.Logs.Endpoint) &&
+		isEmpty(c.Profiles.Endpoint) {
+		return errors.New("`domain` or `traces.endpoint` or `metrics.endpoint` or `logs.endpoint` or `profiles.endpoint` not specified, please fix the configuration")
 	}
 	if c.PrivateKey == "" {
-		return fmt.Errorf("`private_key` not specified, please fix the configuration")
+		return errors.New("`private_key` not specified, please fix the configuration")
 	}
 	if c.AppName == "" {
-		return fmt.Errorf("`application_name` not specified, please fix the configuration")
+		return errors.New("`application_name` not specified, please fix the configuration")
 	}
 
 	// check if headers exists

exporter/coralogixexporter/factory.go

@@ -15,18 +15,21 @@ import (
 	"go.opentelemetry.io/collector/consumer"
 	"go.opentelemetry.io/collector/exporter"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
+	"go.opentelemetry.io/collector/exporter/exporterhelper/xexporterhelper"
+	"go.opentelemetry.io/collector/exporter/xexporter"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/coralogixexporter/internal/metadata"
 )
 
 // NewFactory by Coralogix
 func NewFactory() exporter.Factory {
-	return exporter.NewFactory(
+	return xexporter.NewFactory(
 		metadata.Type,
 		createDefaultConfig,
-		exporter.WithTraces(createTraceExporter, metadata.TracesStability),
-		exporter.WithMetrics(createMetricsExporter, metadata.MetricsStability),
-		exporter.WithLogs(createLogsExporter, metadata.LogsStability),
+		xexporter.WithTraces(createTraceExporter, metadata.TracesStability),
+		xexporter.WithMetrics(createMetricsExporter, metadata.MetricsStability),
+		xexporter.WithLogs(createLogsExporter, metadata.LogsStability),
+		xexporter.WithProfiles(createProfilesExporter, metadata.ProfilesStability),
 	)
 }
 
@@ -130,3 +133,27 @@ func createLogsExporter(
 		exporterhelper.WithShutdown(oce.shutdown),
 	)
 }
+
+func createProfilesExporter(
+	ctx context.Context,
+	set exporter.Settings,
+	cfg component.Config,
+) (xexporter.Profiles, error) {
+	oce, err := newProfilesExporter(cfg, set)
+	if err != nil {
+		return nil, err
+	}
+	oCfg := cfg.(*Config)
+	return xexporterhelper.NewProfilesExporter(
+		ctx,
+		set,
+		cfg,
+		oce.pushProfiles,
+		exporterhelper.WithCapabilities(consumer.Capabilities{MutatesData: true}),
+		exporterhelper.WithTimeout(oCfg.TimeoutSettings),
+		exporterhelper.WithRetry(oCfg.BackOffConfig),
+		exporterhelper.WithQueue(oCfg.QueueSettings),
+		exporterhelper.WithStart(oce.start),
+		exporterhelper.WithShutdown(oce.shutdown),
+	)
+}

exporter/coralogixexporter/go.mod

@@ -17,9 +17,13 @@ require (
 	go.opentelemetry.io/collector/consumer v1.26.1-0.20250219144032-c2af75d88e89
 	go.opentelemetry.io/collector/consumer/consumererror v0.120.1-0.20250219144032-c2af75d88e89
 	go.opentelemetry.io/collector/exporter v0.120.1-0.20250219144032-c2af75d88e89
+	go.opentelemetry.io/collector/exporter/exporterhelper/xexporterhelper v0.120.1-0.20250219144032-c2af75d88e89
 	go.opentelemetry.io/collector/exporter/exportertest v0.120.1-0.20250219144032-c2af75d88e89
+	go.opentelemetry.io/collector/exporter/xexporter v0.120.1-0.20250219144032-c2af75d88e89
 	go.opentelemetry.io/collector/pdata v1.26.1-0.20250219144032-c2af75d88e89
+	go.opentelemetry.io/collector/pdata/pprofile v0.120.1-0.20250219144032-c2af75d88e89
 	go.uber.org/goleak v1.3.0
+	go.uber.org/zap v1.27.0
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20250115164207-1a7da9e5054f
 	google.golang.org/grpc v1.70.0
 )
@@ -50,15 +54,15 @@ require (
 	go.opentelemetry.io/collector/client v1.26.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/config/configauth v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/config/confignet v1.26.1-0.20250219144032-c2af75d88e89 // indirect
+	go.opentelemetry.io/collector/consumer/consumererror/xconsumererror v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/consumer/consumertest v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/consumer/xconsumer v0.120.1-0.20250219144032-c2af75d88e89 // indirect
-	go.opentelemetry.io/collector/exporter/xexporter v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/extension v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/extension/auth v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/extension/xextension v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/featuregate v1.26.1-0.20250219144032-c2af75d88e89 // indirect
-	go.opentelemetry.io/collector/pdata/pprofile v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/pipeline v0.120.1-0.20250219144032-c2af75d88e89 // indirect
+	go.opentelemetry.io/collector/pipeline/xpipeline v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/receiver v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/receiver/receivertest v0.120.1-0.20250219144032-c2af75d88e89 // indirect
 	go.opentelemetry.io/collector/receiver/xreceiver v0.120.1-0.20250219144032-c2af75d88e89 // indirect
@@ -69,7 +73,6 @@ require (
 	go.opentelemetry.io/otel/sdk/metric v1.34.0 // indirect
 	go.opentelemetry.io/otel/trace v1.34.0 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
-	go.uber.org/zap v1.27.0 // indirect
 	golang.org/x/net v0.34.0 // indirect
 	golang.org/x/sys v0.29.0 // indirect
 	golang.org/x/text v0.21.0 // indirect

exporter/coralogixexporter/go.sum

@@ -3,6 +3,7 @@ type: coralogix
 status:
   class: exporter
   stability:
+    alpha: [profiles]
     beta: [traces, metrics, logs]
   distributions: [contrib]
   codeowners:

exporter/coralogixexporter/internal/metadata/generated_status.go

@@ -0,0 +1,116 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+package coralogixexporter // import "github.com/open-telemetry/opentelemetry-collector-contrib/exporter/coralogixexporter"
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"runtime"
+
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/config/configgrpc"
+	"go.opentelemetry.io/collector/config/configopaque"
+	"go.opentelemetry.io/collector/exporter"
+	"go.opentelemetry.io/collector/pdata/pprofile"
+	"go.opentelemetry.io/collector/pdata/pprofile/pprofileotlp"
+	"go.uber.org/zap"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/metadata"
+)
+
+func newProfilesExporter(cfg component.Config, set exporter.Settings) (*profilesExporter, error) {
+	oCfg := cfg.(*Config)
+
+	if isEmpty(oCfg.Domain) && isEmpty(oCfg.Profiles.Endpoint) {
+		return nil, errors.New("coralogix exporter config requires `domain` or `profiles.endpoint` configuration")
+	}
+
+	userAgent := fmt.Sprintf("%s/%s (%s/%s)",
+		set.BuildInfo.Description, set.BuildInfo.Version, runtime.GOOS, runtime.GOARCH)
+
+	return &profilesExporter{
+		config:    oCfg,
+		settings:  set.TelemetrySettings,
+		userAgent: userAgent,
+	}, nil
+}
+
+type profilesExporter struct {
+	// Input configuration.
+	config *Config
+
+	profilesExporter pprofileotlp.GRPCClient
+	clientConn       *grpc.ClientConn
+	callOptions      []grpc.CallOption
+
+	settings component.TelemetrySettings
+
+	// Default user-agent header.
+	userAgent string
+}
+
+func (e *profilesExporter) start(ctx context.Context, host component.Host) (err error) {
+	switch {
+	case !isEmpty(e.config.Profiles.Endpoint):
+		if e.clientConn, err = e.config.Profiles.ToClientConn(ctx, host, e.settings, configgrpc.WithGrpcDialOption(grpc.WithUserAgent(e.userAgent))); err != nil {
+			return err
+		}
+	case !isEmpty(e.config.Domain):
+		if e.clientConn, err = e.config.getDomainGrpcSettings().ToClientConn(ctx, host, e.settings, configgrpc.WithGrpcDialOption(grpc.WithUserAgent(e.userAgent))); err != nil {
+			return err
+		}
+	}
+
+	e.profilesExporter = pprofileotlp.NewGRPCClient(e.clientConn)
+	if e.config.Profiles.Headers == nil {
+		e.config.Profiles.Headers = make(map[string]configopaque.String)
+	}
+	e.config.Profiles.Headers["Authorization"] = configopaque.String("Bearer " + string(e.config.PrivateKey))
+
+	e.callOptions = []grpc.CallOption{
+		grpc.WaitForReady(e.config.Profiles.WaitForReady),
+	}
+
+	return
+}
+
+func (e *profilesExporter) pushProfiles(ctx context.Context, md pprofile.Profiles) error {
+	rss := md.ResourceProfiles()
+	for i := 0; i < rss.Len(); i++ {
+		resourceProfile := rss.At(i)
+		appName, subsystem := e.config.getMetadataFromResource(resourceProfile.Resource())
+		resourceProfile.Resource().Attributes().PutStr(cxAppNameAttrName, appName)
+		resourceProfile.Resource().Attributes().PutStr(cxSubsystemNameAttrName, subsystem)
+	}
+
+	resp, err := e.profilesExporter.Export(e.enhanceContext(ctx), pprofileotlp.NewExportRequestFromProfiles(md), e.callOptions...)
+	if err != nil {
+		return processError(err)
+	}
+
+	partialSuccess := resp.PartialSuccess()
+	if !(partialSuccess.ErrorMessage() == "" && partialSuccess.RejectedProfiles() == 0) {
+		e.settings.Logger.Error("Partial success response from Coralogix",
+			zap.String("message", partialSuccess.ErrorMessage()),
+			zap.Int64("rejected_profiles", partialSuccess.RejectedProfiles()),
+		)
+	}
+	return nil
+}
+
+func (e *profilesExporter) shutdown(context.Context) error {
+	if e.clientConn == nil {
+		return nil
+	}
+	return e.clientConn.Close()
+}
+
+func (e *profilesExporter) enhanceContext(ctx context.Context) context.Context {
+	md := metadata.New(nil)
+	for k, v := range e.config.Profiles.Headers {
+		md.Set(k, string(v))
+	}
+	return metadata.NewOutgoingContext(ctx, md)
+}