[streams] enable streams ui setting

src/platform/packages/shared/kbn-management/settings/setting_ids/index.ts

@@ -125,6 +125,7 @@ export const OBSERVABILITY_AI_ASSISTANT_SIMULATED_FUNCTION_CALLING =
 export const OBSERVABILITY_AI_ASSISTANT_SEARCH_CONNECTOR_INDEX_PATTERN =
   'observability:aiAssistantSearchConnectorIndexPattern';
 export const OBSERVABILITY_SEARCH_EXCLUDED_DATA_TIERS = 'observability:searchExcludedDataTiers';
+export const OBSERVABILITY_ENABLE_STREAMS_UI = 'observability:enableStreamsUI';
 
 // Reporting settings
 export const XPACK_REPORTING_CUSTOM_PDF_LOGO_ID = 'xpackReporting:customPdfLogo';

src/platform/packages/shared/serverless/settings/observability_project/index.ts

@@ -25,4 +25,5 @@ export const OBSERVABILITY_PROJECT_SETTINGS = [
   settings.OBSERVABILITY_AI_ASSISTANT_SIMULATED_FUNCTION_CALLING,
   settings.OBSERVABILITY_AI_ASSISTANT_SEARCH_CONNECTOR_INDEX_PATTERN,
   settings.OBSERVABILITY_LOGS_DATA_ACCESS_LOG_SOURCES_ID,
+  settings.OBSERVABILITY_ENABLE_STREAMS_UI,
 ];

src/platform/plugins/private/kibana_usage_collection/server/collectors/management/schema.ts

@@ -656,4 +656,10 @@ export const stackManagementSchema: MakeSchemaFrom<UsageStats> = {
       description: 'Enable the new logs overview component.',
     },
   },
+  'observability:enableStreamsUI': {
+    type: 'boolean',
+    _meta: {
+      description: 'Enable Streams UI.',
+    },
+  },
 };

src/platform/plugins/private/kibana_usage_collection/server/collectors/management/types.ts

@@ -171,4 +171,5 @@ export interface UsageStats {
   'securitySolution:excludedDataTiersForRuleExecution': string[];
   'securitySolution:maxUnassociatedNotes': number;
   'observability:searchExcludedDataTiers': string[];
+  'observability:enableStreamsUI': boolean;
 }

src/platform/plugins/shared/telemetry/schema/oss_platform.json

@@ -11537,6 +11537,12 @@
           "_meta": {
             "description": "Enable the new logs overview component."
           }
+        },
+        "observability:enableStreamsUI": {
+          "type": "boolean",
+          "_meta": {
+            "description": "Enable Streams UI."
+          }
         }
       }
     },

x-pack/platform/plugins/shared/streams/public/plugin.ts

@@ -5,9 +5,9 @@
  * 2.0.
  */
 
-import { ApplicationStart, CoreSetup, CoreStart, PluginInitializerContext } from '@kbn/core/public';
+import { CoreSetup, CoreStart, PluginInitializerContext } from '@kbn/core/public';
 import { Logger } from '@kbn/logging';
-
+import { OBSERVABILITY_ENABLE_STREAMS_UI } from '@kbn/management-settings-ids';
 import { createRepositoryClient } from '@kbn/server-route-repository-client';
 import { Observable, from, shareReplay, startWith } from 'rxjs';
 import { once } from 'lodash';
@@ -41,12 +41,7 @@ export class Plugin implements StreamsPluginClass {
   start(core: CoreStart, pluginsStart: StreamsPluginStartDependencies): StreamsPluginStart {
     return {
       streamsRepositoryClient: this.repositoryClient,
-      status$: createStreamsStatusObservable(
-        pluginsStart,
-        core.application,
-        this.repositoryClient,
-        this.logger
-      ),
+      status$: createStreamsStatusObservable(core, this.repositoryClient, this.logger),
     };
   }
 
@@ -59,21 +54,19 @@ const UNKNOWN_STATUS: StreamsStatus = { status: 'unknown' };
 
 const createStreamsStatusObservable = once(
   (
-    deps: StreamsPluginSetupDependencies | StreamsPluginStartDependencies,
-    application: ApplicationStart,
+    core: CoreStart,
     repositoryClient: StreamsRepositoryClient,
     logger: Logger
   ): Observable<StreamsStatus> => {
-    const isObservabilityServerless =
-      deps.cloud?.isServerlessEnabled && deps.cloud?.serverless.projectType === 'observability';
-
+    const { application, uiSettings } = core;
     const hasCapabilities = application.capabilities?.streams?.show;
+    const isUIEnabled = uiSettings.get(OBSERVABILITY_ENABLE_STREAMS_UI);
 
     if (!hasCapabilities) {
       return from([DISABLED_STATUS]);
     }
 
-    if (isObservabilityServerless) {
+    if (isUIEnabled) {
       return from([ENABLED_STATUS]);
     }
 

x-pack/platform/plugins/shared/streams/server/plugin.ts

@@ -19,6 +19,8 @@ import { KibanaFeatureScope } from '@kbn/features-plugin/common';
 import { i18n } from '@kbn/i18n';
 import { STREAMS_RULE_TYPE_IDS } from '@kbn/rule-data-utils';
 import { registerRoutes } from '@kbn/server-route-repository';
+import { schema } from '@kbn/config-schema';
+import { OBSERVABILITY_ENABLE_STREAMS_UI } from '@kbn/management-settings-ids';
 import { StreamsConfig, configSchema, exposeToBrowserConfig } from '../common/config';
 import {
   STREAMS_API_PRIVILEGES,
@@ -63,7 +65,7 @@ export class StreamsPlugin
   public logger: Logger;
   public server?: StreamsServer;
   private isDev: boolean;
-  private telemtryService = new StreamsTelemetryService();
+  private telemetryService = new StreamsTelemetryService();
 
   constructor(context: PluginInitializerContext<StreamsConfig>) {
     this.isDev = context.env.mode.dev;
@@ -80,7 +82,7 @@ export class StreamsPlugin
       logger: this.logger,
     } as StreamsServer;
 
-    this.telemtryService.setup(core.analytics);
+    this.telemetryService.setup(core.analytics);
 
     const isSignificantEventsEnabled = this.config.experimental?.significantEventsEnabled === true;
     const alertingFeatures = isSignificantEventsEnabled
@@ -157,7 +159,7 @@ export class StreamsPlugin
       dependencies: {
         assets: assetService,
         server: this.server,
-        telemetry: this.telemtryService.getClient(),
+        telemetry: this.telemetryService.getClient(),
         getScopedClients: async ({
           request,
         }: {
@@ -200,6 +202,30 @@ export class StreamsPlugin
       runDevModeChecks: this.isDev,
     });
 
+    const isObservabilityServerless =
+      plugins.cloud?.isServerlessEnabled &&
+      plugins.cloud?.serverless.projectType === 'observability';
+    core.uiSettings.register({
+      [OBSERVABILITY_ENABLE_STREAMS_UI]: {
+        category: ['observability'],
+        name: 'Streams UI',
+        value: isObservabilityServerless,
+        description: i18n.translate('xpack.streams.enableStreamsUIDescription', {
+          defaultMessage: '{technicalPreviewLabel} Enable the {streamsLink}.',
+          values: {
+            technicalPreviewLabel: `<em>[${i18n.translate('xpack.streams.technicalPreviewLabel', {
+              defaultMessage: 'Technical Preview',
+            })}]</em>`,
+            streamsLink: `<a href="https://www.elastic.co/docs/solutions/observability/logs/streams/streams">Streams UI</href>`,
+          },
+        }),
+        type: 'boolean',
+        schema: schema.boolean(),
+        requiresPageReload: true,
+        solution: 'oblt',
+      },
+    });
+
     return {};
   }
 

x-pack/platform/plugins/shared/streams/server/types.ts

@@ -23,6 +23,7 @@ import type {
   TaskManagerSetupContract,
   TaskManagerStartContract,
 } from '@kbn/task-manager-plugin/server';
+import type { CloudSetup } from '@kbn/cloud-plugin/server';
 import type { StreamsConfig } from '../common/config';
 
 export interface StreamsServer {
@@ -45,6 +46,7 @@ export interface StreamsPluginSetupDependencies {
   alerting: AlertingServerSetup;
   ruleRegistry: RuleRegistryPluginSetup;
   features: FeaturesPluginSetup;
+  cloud?: CloudSetup;
 }
 
 export interface StreamsPluginStartDependencies {

x-pack/platform/plugins/shared/streams/tsconfig.json

@@ -51,6 +51,7 @@
     "@kbn/zod-helpers",
     "@kbn/core-http-server-utils",
     "@kbn/inference-common",
-    "@kbn/lock-manager"
+    "@kbn/lock-manager",
+    "@kbn/management-settings-ids"
   ]
 }