*Added MS_Fabric output plugin

*Added ADX_commons and EH_Commons tests *Added tests for ADX output
asaharn · Dec 27, 2024 · efb1e7d · efb1e7d
1 parent 179e6b9
commit efb1e7d
Show file tree

Hide file tree

Showing 12 changed files with 1,235 additions and 450 deletions.
diff --git a/plugins/common/adx/adx_commons.go b/plugins/common/adx/adx_commons.go
@@ -36,6 +36,7 @@ type AzureDataExplorer struct {
 	serializer      telegraf.Serializer
 	kustoClient     *kusto.Client
 	metricIngestors map[string]ingest.Ingestor
+	AppName         string
 }
 
 const (
@@ -57,7 +58,7 @@ func (*AzureDataExplorer) SampleConfig() string {
 func (adx *AzureDataExplorer) Connect() error {
 	conn := kusto.NewConnectionStringBuilder(adx.Endpoint).WithDefaultAzureCredential()
 	// Since init is called before connect, we can set the connector details here including the type. This will be used for telemetry and tracing.
-	conn.SetConnectorDetails("Telegraf", internal.ProductToken(), "", "", false, "")
+	conn.SetConnectorDetails("Telegraf", internal.ProductToken(), adx.AppName, "", false, "")
 	client, err := kusto.New(conn)
 	if err != nil {
 		return err
@@ -68,6 +69,10 @@ func (adx *AzureDataExplorer) Connect() error {
 	return nil
 }
 
+func (adx *AzureDataExplorer) SetSerializer(serializer telegraf.Serializer) {
+	adx.serializer = serializer
+}
+
 // Clean up and close the ingestor
 func (adx *AzureDataExplorer) Close() error {
 	var errs []error