feat: add Streaming Query node type and actions/controls

Author: DaryaVorontsova

package-lock.json

@@ -59,7 +59,7 @@
     "use-query-params": "^2.2.1",
     "uuid": "^10.0.0",
     "web-vitals": "^1.1.2",
-    "ydb-ui-components": "^5.2.0",
+    "ydb-ui-components": "^5.3.0",
     "zod": "^3.24.1"
   },
   "scripts": {

package.json

@@ -175,6 +175,8 @@ const EXTERNAL_TABLE_PAGES = [overview, schema, describe, access];
 
 const VIEW_PAGES = [overview, schema, describe, access];
 
+const STREAMING_QUERY_PAGES = [overview, topShards, nodes, describe, access];
+
 // verbose mapping to guarantee correct tabs for new path types
 // TS will error when a new type is added but not mapped here
 const pathTypeToPages: Record<EPathType, Page[] | undefined> = {
@@ -198,6 +200,8 @@ const pathTypeToPages: Record<EPathType, Page[] | undefined> = {
     [EPathType.EPathTypeExternalDataSource]: EXTERNAL_DATA_SOURCE_PAGES,
     [EPathType.EPathTypeExternalTable]: EXTERNAL_TABLE_PAGES,
 
+    [EPathType.EPathTypeStreamingQuery]: STREAMING_QUERY_PAGES,
+
     [EPathType.EPathTypeView]: VIEW_PAGES,
 
     [EPathType.EPathTypeReplication]: ASYNC_REPLICATION_PAGES,

src/containers/Tenant/Diagnostics/DiagnosticsPages.ts

@@ -77,6 +77,7 @@ function Overview({type, path, database, databaseFullPath}: OverviewProps) {
                     data={data}
                 />
             ),
+            [EPathType.EPathTypeStreamingQuery]: undefined,
         };
 
         return (type && pathTypeToComponent[type]?.()) || <TableInfo data={data} type={type} />;

src/containers/Tenant/Diagnostics/Overview/Overview.tsx

@@ -343,6 +343,7 @@ export function ObjectSummary({
                     },
                 ];
             },
+            [EPathType.EPathTypeStreamingQuery]: undefined,
         };
 
         const pathTypeOverview = (PathType && getPathTypeOverview[PathType]?.()) || [];

src/containers/Tenant/ObjectSummary/ObjectSummary.tsx

@@ -90,5 +90,6 @@
   "entity-name_resource-pool": "Resource Pool",
   "entity-name_secondary-index-table": "Secondary Index Table",
   "entity-name_vector-index-table": "Vector Index Table",
-  "entity-name_fulltext-index-table": "Fulltext Index Table"
+  "entity-name_fulltext-index-table": "Fulltext Index Table",
+  "entity-name_streaming_query": "Streaming Query"
 }

src/containers/Tenant/i18n/en.json

@@ -87,6 +87,8 @@ export const getSchemaControls =
             external_data_source: undefined,
 
             view: openPreview,
+
+            streaming_query: undefined,
         };
 
         return nodeTypeToControls[type];

src/containers/Tenant/utils/controls.tsx

@@ -45,6 +45,8 @@ const pathTypeToNodeType: Record<EPathType, NavigationTreeNodeType | undefined>
     [EPathType.EPathTypeReplication]: 'async_replication',
     [EPathType.EPathTypeTransfer]: 'transfer',
     [EPathType.EPathTypeResourcePool]: 'resource_pool',
+
+    [EPathType.EPathTypeStreamingQuery]: 'streaming_query',
 };
 
 export const nodeTableTypeToPathType: Partial<Record<NavigationTreeNodeType, EPathType>> = {
@@ -94,6 +96,8 @@ const pathTypeToEntityName: Record<EPathType, string | undefined> = {
     [EPathType.EPathTypeExternalDataSource]: i18n('entity-name_external-data-source'),
     [EPathType.EPathTypeExternalTable]: i18n('entity-name_external-table'),
 
+    [EPathType.EPathTypeStreamingQuery]: i18n('entity-name_streaming_query'),
+
     [EPathType.EPathTypeView]: i18n('entity-name_view'),
 
     [EPathType.EPathTypeReplication]: i18n('entity-name_async-replication'),
@@ -154,6 +158,7 @@ const pathTypeToIsTable: Record<EPathType, boolean> = {
     [EPathType.EPathTypeReplication]: false,
     [EPathType.EPathTypeTransfer]: false,
     [EPathType.EPathTypeResourcePool]: false,
+    [EPathType.EPathTypeStreamingQuery]: false,
 };
 
 //if add entity with tableType, make sure that Schema is available in Diagnostics section
@@ -194,6 +199,8 @@ const pathTypeToIsColumn: Record<EPathType, boolean> = {
     [EPathType.EPathTypeExternalDataSource]: false,
     [EPathType.EPathTypeExternalTable]: false,
 
+    [EPathType.EPathTypeStreamingQuery]: false,
+
     [EPathType.EPathTypeView]: false,
 
     [EPathType.EPathTypeReplication]: false,
@@ -222,6 +229,8 @@ const pathTypeToIsDatabase: Record<EPathType, boolean> = {
     [EPathType.EPathTypeExternalDataSource]: false,
     [EPathType.EPathTypeExternalTable]: false,
 
+    [EPathType.EPathTypeStreamingQuery]: false,
+
     [EPathType.EPathTypeView]: false,
 
     [EPathType.EPathTypeReplication]: false,
@@ -272,6 +281,7 @@ const pathTypeToChildless: Record<EPathType, boolean> = {
     [EPathType.EPathTypeSubDomain]: false,
     [EPathType.EPathTypeTableIndex]: false,
     [EPathType.EPathTypeExtSubDomain]: false,
+    [EPathType.EPathTypeStreamingQuery]: false,
 };
 
 export const isChildlessPathType = (type?: EPathType, subType?: EPathSubType) =>

src/containers/Tenant/utils/schema.ts

@@ -361,6 +361,8 @@ export const getActions =
             external_data_source: EXTERNAL_DATA_SOURCE_SET,
 
             view: VIEW_SET,
+
+            streaming_query: JUST_COPY,
         };
 
         return nodeTypeToActions[type];

src/containers/Tenant/utils/schemaActions.tsx

@@ -301,6 +301,8 @@ export enum EPathType {
     EPathTypeReplication = 'EPathTypeReplication',
     EPathTypeTransfer = 'EPathTypeTransfer',
     EPathTypeResourcePool = 'EPathTypeResourcePool',
+
+    EPathTypeStreamingQuery = 'EPathTypeStreamingQuery',
 }
 
 export enum EPathSubType {