feat: add Integration Version to Inventory Payload (#1153)

CHANGELOG.md

@@ -7,6 +7,9 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 
 ## Unreleased
 
+### enhancements
+- Add K8s Integration version to Inventory @TmNguyen12 [#1153](https://github.com/newrelic/nri-kubernetes/pull/1153)
+
 ## v3.32.4 - 2025-01-13
 
 ### ⛓️ Dependencies

src/definition/populate.go

@@ -39,6 +39,16 @@ func populateCluster(i *integration.Integration, clusterName string, k8sVersion
 		return err
 	}
 
+	err = e.Inventory.SetItem("cluster", "newrelic.integrationVersion", i.IntegrationVersion)
+	if err != nil {
+		return err //nolint: wrapcheck
+	}
+
+	err = e.Inventory.SetItem("cluster", "newrelic.integrationName", i.Name)
+	if err != nil {
+		return err //nolint: wrapcheck
+	}
+
 	return ms.SetMetric("clusterK8sVersion", k8sVersionStr, metric.ATTRIBUTE)
 }
 

src/definition/populate_test.go

@@ -767,6 +767,29 @@ func TestIntegrationPopulator_CustomMsTypeGuesser(t *testing.T) { //nolint: para
 	}
 }
 
+func TestIntegrationPopulator_IntegrationVersionInInventory(t *testing.T) {
+	t.Parallel()
+	integrationVersion := "2.3.1"
+	intgr, err := integration.New("com.newrelic.kubernetes", integrationVersion, integration.InMemoryStore())
+	require.NoError(t, err)
+	config := testConfig(intgr)
+
+	expectedInventory := inventory.New()
+	err = expectedInventory.SetItem("cluster", "name", defaultNS)
+	require.NoError(t, err)
+	err = expectedInventory.SetItem("cluster", "k8sVersion", config.K8sVersion.String())
+	require.NoError(t, err)
+	err = expectedInventory.SetItem("cluster", "newrelic.integrationVersion", integrationVersion)
+	require.NoError(t, err)
+	err = expectedInventory.SetItem("cluster", "newrelic.integrationName", "com.newrelic.kubernetes")
+	require.NoError(t, err)
+
+	populated, errs := definition.IntegrationPopulator(config)
+	assert.True(t, populated)
+	assert.Empty(t, errs)
+	assert.Equal(t, intgr.Entities[2].Inventory, expectedInventory)
+}
+
 type NamespaceFilterMock struct{}
 
 func (nf NamespaceFilterMock) IsAllowed(namespace string) bool {