feat(SourceMetrics): knowledge graph single kg annotations POC

src/AppDataTrail/DataTrail.tsx

@@ -53,6 +53,7 @@ import { GmdVizPanel } from 'shared/GmdVizPanel/GmdVizPanel';
 import { logger } from 'shared/logger/logger';
 
 import { resetYAxisSync } from '../MetricScene/Breakdown/MetricLabelsList/behaviors/syncYAxis';
+import { type KgEntityConfig } from '../MetricScene/kgAnnotations';
 import { MetricScene } from '../MetricScene/MetricScene';
 import { type PanelDataRequestPayload } from '../shared/GmdVizPanel/components/addToDashboard/addToDashboard';
 import { MetricSelectedEvent, trailDS, VAR_DATASOURCE, VAR_FILTERS } from '../shared/shared';
@@ -81,6 +82,8 @@ export interface DataTrailState extends SceneObjectState {
   initialDS?: string;
   initialFilters?: AdHocVariableFilter[];
 
+  kgEntityConfig?: KgEntityConfig;
+
   // Synced with url
   metric?: string;
 
@@ -179,11 +182,11 @@ export class DataTrail extends SceneObjectBase<DataTrailState> implements SceneO
         ? [...baseControls, new SelectNewMetricButton(), new SceneTimePicker({}), new SceneRefreshPicker({})]
         : [...baseControls, new SceneTimePicker({}), new SceneRefreshPicker({})];
 
-      this.setState({
-        metric,
-        topScene: metric ? new MetricScene({ metric }) : new MetricsReducer(),
-        controls,
-      });
+      const topScene = metric
+        ? new MetricScene({ metric, kgEntityConfig: this.state.kgEntityConfig })
+        : new MetricsReducer();
+
+      this.setState({ metric, topScene, controls });
     }
   }
 

src/MetricScene/MetricGraphScene.tsx

@@ -28,6 +28,7 @@ import { QUERY_RESOLUTION } from 'shared/GmdVizPanel/config/query-resolutions';
 import { GmdVizPanel } from 'shared/GmdVizPanel/GmdVizPanel';
 import { isClassicHistogramMetric } from 'shared/GmdVizPanel/matchers/isClassicHistogramMetric';
 
+import { buildKgAnnotationsLayer, type KgEntityConfig } from './kgAnnotations';
 import { MetricActionBar } from './MetricActionBar';
 import { PanelMenu } from './PanelMenu/PanelMenu';
 import { buildMiniBreakdownNavigationUrl } from '../exposedComponents/MiniBreakdown/buildNavigationUrl';
@@ -47,11 +48,18 @@ interface MetricGraphSceneState extends SceneObjectState {
 }
 
 export class MetricGraphScene extends SceneObjectBase<MetricGraphSceneState> {
-  public constructor({ metric }: { metric: MetricGraphSceneState['metric'] }) {
+  public constructor({
+    metric,
+    kgEntityConfig,
+  }: {
+    metric: MetricGraphSceneState['metric'];
+    kgEntityConfig?: KgEntityConfig;
+  }) {
     super({
       metric,
       topView: new SceneFlexLayout({
         direction: 'column',
+        ...(kgEntityConfig ? { $data: buildKgAnnotationsLayer(kgEntityConfig) } : {}),
         $behaviors: [new behaviors.CursorSync({ key: 'metricCrosshairSync', sync: DashboardCursorSync.Crosshair })],
         children: [
           new SceneFlexItem({

src/MetricScene/MetricScene.tsx

@@ -18,6 +18,7 @@ import React, { useEffect } from 'react';
 import { RefreshMetricsEvent, VAR_FILTERS, VAR_METRIC, type MakeOptional } from '../shared/shared';
 import { GroupByVariable } from './Breakdown/GroupByVariable';
 import { EventActionViewDataLoadComplete } from './EventActionViewDataLoadComplete';
+import { type KgEntityConfig } from './kgAnnotations';
 import { actionViews, defaultActionView, getActionViewsDefinitions, type ActionViewType } from './MetricActionBar';
 import { MetricGraphScene } from './MetricGraphScene';
 import {
@@ -30,6 +31,7 @@ import { RelatedLogsScene } from './RelatedLogs/RelatedLogsScene';
 interface MetricSceneState extends SceneObjectState {
   body: MetricGraphScene;
   metric: string;
+  kgEntityConfig?: KgEntityConfig;
   actionView?: ActionViewType;
   relatedLogsCount?: number;
   isQueryResultsAvailable?: boolean;
@@ -58,7 +60,7 @@ export class MetricScene extends SceneObjectBase<MetricSceneState> {
   public constructor(state: MakeOptional<MetricSceneState, 'body'>) {
     super({
       $variables: state.$variables ?? getVariableSet(state.metric),
-      body: state.body ?? new MetricGraphScene({ metric: state.metric }),
+      body: state.body ?? new MetricGraphScene({ metric: state.metric, kgEntityConfig: state.kgEntityConfig }),
       ...state,
     });
 

src/MetricScene/kgAnnotations.ts

@@ -0,0 +1,63 @@
+import { dataLayers, SceneDataLayerSet } from '@grafana/scenes';
+import { type DataQuery } from '@grafana/schema';
+
+export type KgEntityScope = {
+  env?: string;
+  site?: string;
+  namespace?: string;
+};
+
+export type KgEntityConfig = {
+  datasourceUid: string;
+  entityType: string;
+  entityName: string;
+  entityScope?: KgEntityScope;
+};
+
+export function buildKgAnnotationsLayer({
+  datasourceUid,
+  entityType,
+  entityName,
+  entityScope,
+}: KgEntityConfig): SceneDataLayerSet {
+  return new SceneDataLayerSet({
+    layers: [
+      new dataLayers.AnnotationsDataLayer({
+        name: 'Asserts Insights',
+        isEnabled: true,
+        query: {
+          name: 'Asserts Insights',
+          enable: true,
+          iconColor: 'red',
+          datasource: { type: 'grafana-knowledgegraph-datasource', uid: datasourceUid },
+          target: {
+            refId: 'kgAnnotations',
+            queryType: 'annotations',
+            queryMode: 'advanced',
+            advancedQuery: {
+              filterCriteria: [
+                {
+                  entityType,
+                  propertyMatchers: [{ id: -1, name: 'name', op: '=', value: entityName, type: 'String' }],
+                  connectToEntityTypes: [],
+                  havingAssertion: false,
+                },
+              ],
+              ...(entityScope
+                ? {
+                    scopeCriteria: {
+                      nameAndValues: {
+                        env: entityScope.env ? [entityScope.env] : undefined,
+                        site: entityScope.site ? [entityScope.site] : undefined,
+                        namespace: entityScope.namespace ? [entityScope.namespace] : undefined,
+                      },
+                    },
+                  }
+                : {}),
+            },
+          } as unknown as DataQuery,
+        },
+      }),
+    ],
+  });
+}

src/exposedComponents/SourceMetrics/SourceMetrics.tsx

@@ -1,6 +1,6 @@
 import { type AdHocVariableFilter, type DataSourceApi } from '@grafana/data';
 import { locationService } from '@grafana/runtime';
-import React, { useEffect, useRef } from 'react';
+import React, { useEffect, useMemo, useRef } from 'react';
 
 import { ErrorView } from 'App/ErrorView';
 import { Trail } from 'App/Routes';
@@ -15,6 +15,7 @@ import { labelMatcherToAdHocFilter } from 'shared/utils/utils.variables';
 import { FilterGroupByAssertsLabelsBehavior } from './behaviors/FilterGroupByAssertsLabelsBehavior';
 import { HistogramPercentilesDefaultBehavior } from './behaviors/HistogramPercentilesDefaultBehavior';
 import { parsePromQLQuery } from '../../extensions/links';
+import { type KgEntityConfig, type KgEntityScope } from '../../MetricScene/kgAnnotations';
 import { type PromQLLabelMatcher } from '../../shared/utils/utils.promql';
 import { toSceneTimeRange } from '../../shared/utils/utils.timerange';
 
@@ -108,9 +109,13 @@ export interface SourceMetricsProps {
   initialEnd: string | number;
   dataSource: DataSourceApi;
   sourceMetrics?: SourceMetrics;
+  kgDatasourceUid?: string;
+  entityType?: string;
+  entityName?: string;
+  entityScope?: KgEntityScope;
 }
 
-const KnowledgeGraphSourceMetrics = (props: SourceMetricsProps) => {
+const KnowledgeGraphSourceMetrics = ({ kgDatasourceUid, entityType, entityName, entityScope, ...props }: SourceMetricsProps) => {
   const [error] = useCatchExceptions();
   const initRef = useRef(false);
 
@@ -121,6 +126,13 @@ const KnowledgeGraphSourceMetrics = (props: SourceMetricsProps) => {
     }
   }, []);
 
+  const kgEntityConfig = useMemo<KgEntityConfig | undefined>(() => {
+    if (!kgDatasourceUid || !entityType || !entityName) {
+      return undefined;
+    }
+    return { datasourceUid: kgDatasourceUid, entityType, entityName, entityScope };
+  }, [kgDatasourceUid, entityType, entityName, entityScope]);
+
   // Determine metric and filters based on data source
   let metric: string | undefined;
   let initialFilters: AdHocVariableFilter[] | undefined;
@@ -177,6 +189,7 @@ const KnowledgeGraphSourceMetrics = (props: SourceMetricsProps) => {
     $timeRange: toSceneTimeRange(props.initialStart, props.initialEnd),
     embedded: true,
     $behaviors: [new FilterGroupByAssertsLabelsBehavior({ metric }), new HistogramPercentilesDefaultBehavior()],
+    ...(kgEntityConfig ? { kgEntityConfig } : {}),
   });
 
   return (