feat(server-utils): Add first-party Flue instrumentation

packages/aws-serverless/src/index.ts

@@ -64,6 +64,7 @@ export {
   langGraphIntegration,
   mastraIntegration,
   SentryMastraExporter,
+  createFlueInstrumentation,
   modulesIntegration,
   nodeRuntimeMetricsIntegration,
   type NodeRuntimeMetricsOptions,

packages/bun/src/index.ts

@@ -86,6 +86,7 @@ export {
   langGraphIntegration,
   mastraIntegration,
   SentryMastraExporter,
+  createFlueInstrumentation,
   modulesIntegration,
   contextLinesIntegration,
   nodeContextIntegration,

packages/cloudflare/src/index.ts

@@ -107,7 +107,7 @@ export {
   spanStreamingIntegration,
 } from '@sentry/core';
 export { trpcMiddleware, wrapMcpServerWithSentry } from '@sentry/core/server';
-export { instrumentPostgresJsSql } from '@sentry/server-utils';
+export { createFlueInstrumentation, instrumentPostgresJsSql } from '@sentry/server-utils';
 
 export { withSentry } from './withSentry';
 export { defineCloudflareOptions } from './defineCloudflareOptions';

packages/deno/src/index.ts

@@ -135,6 +135,7 @@ export {
   langGraphIntegration,
   mastraIntegration,
   SentryMastraExporter,
+  createFlueInstrumentation,
   lruMemoizerIntegration,
   mongoIntegration,
   mongooseIntegration,

packages/google-cloud-serverless/src/index.ts

@@ -64,6 +64,7 @@ export {
   langGraphIntegration,
   mastraIntegration,
   SentryMastraExporter,
+  createFlueInstrumentation,
   modulesIntegration,
   nodeRuntimeMetricsIntegration,
   type NodeRuntimeMetricsOptions,

packages/node/src/index.ts

@@ -20,6 +20,7 @@ export {
   langChainIntegration,
   langGraphIntegration,
   lruMemoizerIntegration,
+  createFlueInstrumentation,
   mastraIntegration,
   SentryMastraExporter,
   mongoIntegration,

packages/server-utils/src/ai/flue/constants.ts

@@ -0,0 +1,20 @@
+export const FLUE_INTEGRATION_NAME = 'Flue' as const;
+
+export const FLUE_MODULE_NAME = '@flue/runtime';
+
+export const FLUE_ORIGIN = 'auto.ai.flue';
+
+/**
+ * Identifies our registration in Flue's keyed instrumentation registry. A distinct key lets us
+ * coexist with `@flue/opentelemetry` (which registers under its own key) and makes a repeated
+ * `instrument()` call a no-op instead of throwing `InstrumentationAlreadyInstalledError`.
+ */
+export const FLUE_INSTRUMENTATION_KEY = Symbol.for('sentry.flue.instrumentation');
+
+/**
+ * Flue drives one LLM call through many `model` operations (one per stream read), and its `agent`
+ * operation nests inside itself once per submission. Only `agent` is spanned from the interceptor,
+ * and only at the outermost depth; the turn span is driven from the observation stream instead,
+ * where `turn_start`/`turn` are exactly one-to-one with a model call.
+ */
+export const SPANNED_OPERATION_TYPE = 'agent';