feast-dev
diff --git a/‎docs/reference/feature-servers/registry-server.md
Copy file name to clipboard
+208Lines changed: 208 additions & 0 deletions b/‎docs/reference/feature-servers/registry-server.md
Copy file name to clipboard
+208Lines changed: 208 additions & 0 deletions
diff --git a/‎sdk/python/feast/api/registry/rest/data_sources.py
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions b/‎sdk/python/feast/api/registry/rest/data_sources.py
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions
diff --git a/‎sdk/python/feast/api/registry/rest/entities.py
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions b/‎sdk/python/feast/api/registry/rest/entities.py
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions
diff --git a/‎sdk/python/feast/api/registry/rest/feature_services.py
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions b/‎sdk/python/feast/api/registry/rest/feature_services.py
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions
@@ -16,6 +16,13 @@ Feast supports running the Registry Server in three distinct modes:
 
 The REST API provides HTTP/JSON endpoints for accessing all registry metadata. All endpoints are prefixed with `/api/v1` and return JSON responses.
 
+**Global `/all` Endpoints**
+
+- Endpoints with `/all` (e.g., `/entities/all`) aggregate results across all projects.
+- Each object in the response includes a `project` field.
+- Support global pagination, sorting, and relationships (where applicable).
+- No `project` parameter is required for `/all` endpoints.
+
 ### Authentication
 
 The REST API supports Bearer token authentication. Include your token in the Authorization header:
@@ -88,6 +95,37 @@ Most endpoints support these common query parameters:
     "https://localhost:6572/api/v1/entities/user_id?project=my_project&include_relationships=true"
   ```
 
+#### List All Entities (All Projects)
+- **Endpoint**: `GET /api/v1/entities/all`
+- **Description**: Retrieve all entities across all projects. Each entity includes a `project` field.
+- **Parameters**:
+  - `allow_cache` (optional): Whether to allow cached data
+  - `page` (optional): Page number for pagination
+  - `limit` (optional): Number of items per page
+  - `sort_by` (optional): Field to sort by
+  - `sort_order` (optional): Sort order ("asc" or "desc")
+  - `include_relationships` (optional): Include relationships for each entity
+- **Examples**:
+  ```bash
+  # List all entities across all projects
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/entities/all?page=1&limit=10&sort_by=name"
+  # With relationships
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/entities/all?include_relationships=true"
+  ```
+- **Response Example**:
+  ```json
+  {
+    "entities": [
+      { "name": "customer_id", "project": "project1", ... },
+      { "name": "driver_id", "project": "project2", ... }
+    ],
+    "pagination": { "page": 1, "limit": 10, "total": 25, "totalPages": 3 },
+    "relationships": { ... }
+  }
+  ```
+
 ### Data Sources
 
 #### List Data Sources
@@ -132,6 +170,36 @@ Most endpoints support these common query parameters:
     "https://localhost:6572/api/v1/data_sources/user_data?project=my_project&include_relationships=true"
   ```
 
+#### List All Data Sources (All Projects)
+- **Endpoint**: `GET /api/v1/data_sources/all`
+- **Description**: Retrieve all data sources across all projects. Each data source includes a `project` field.
+- **Parameters**:
+  - `allow_cache` (optional): Whether to allow cached data
+  - `page` (optional): Page number for pagination
+  - `limit` (optional): Number of items per page
+  - `sort_by` (optional): Field to sort by
+  - `sort_order` (optional): Sort order ("asc" or "desc")
+  - `include_relationships` (optional): Include relationships for each data source
+- **Examples**:
+  ```bash
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/data_sources/all?page=1&limit=10&sort_by=name"
+  # With relationships
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/data_sources/all?include_relationships=true"
+  ```
+- **Response Example**:
+  ```json
+  {
+    "dataSources": [
+      { "name": "user_data", "project": "project1", ... },
+      { "name": "item_data", "project": "project2", ... }
+    ],
+    "pagination": { "page": 1, "limit": 10, "total": 25, "totalPages": 3 },
+    "relationships": { ... }
+  }
+  ```
+
 ### Feature Views
 
 #### List Feature Views
@@ -176,6 +244,36 @@ Most endpoints support these common query parameters:
     "https://localhost:6572/api/v1/feature_views/user_features?project=my_project&include_relationships=true"
   ```
 
+#### List All Feature Views (All Projects)
+- **Endpoint**: `GET /api/v1/feature_views/all`
+- **Description**: Retrieve all feature views across all projects. Each feature view includes a `project` field.
+- **Parameters**:
+  - `allow_cache` (optional): Whether to allow cached data
+  - `page` (optional): Page number for pagination
+  - `limit` (optional): Number of items per page
+  - `sort_by` (optional): Field to sort by
+  - `sort_order` (optional): Sort order ("asc" or "desc")
+  - `include_relationships` (optional): Include relationships for each feature view
+- **Examples**:
+  ```bash
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/feature_views/all?page=1&limit=10&sort_by=name"
+  # With relationships
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/feature_views/all?include_relationships=true"
+  ```
+- **Response Example**:
+  ```json
+  {
+    "featureViews": [
+      { "name": "user_features", "project": "project1", ... },
+      { "name": "item_features", "project": "project2", ... }
+    ],
+    "pagination": { "page": 1, "limit": 10, "total": 25, "totalPages": 3 },
+    "relationships": { ... }
+  }
+  ```
+
 ### Feature Services
 
 #### List Feature Services
@@ -220,6 +318,36 @@ Most endpoints support these common query parameters:
     "https://localhost:6572/api/v1/feature_services/recommendation_service?project=my_project&include_relationships=true"
   ```
 
+#### List All Feature Services (All Projects)
+- **Endpoint**: `GET /api/v1/feature_services/all`
+- **Description**: Retrieve all feature services across all projects. Each feature service includes a `project` field.
+- **Parameters**:
+  - `allow_cache` (optional): Whether to allow cached data
+  - `page` (optional): Page number for pagination
+  - `limit` (optional): Number of items per page
+  - `sort_by` (optional): Field to sort by
+  - `sort_order` (optional): Sort order ("asc" or "desc")
+  - `include_relationships` (optional): Include relationships for each feature service
+- **Examples**:
+  ```bash
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/feature_services/all?page=1&limit=10&sort_by=name"
+  # With relationships
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/feature_services/all?include_relationships=true"
+  ```
+- **Response Example**:
+  ```json
+  {
+    "featureServices": [
+      { "name": "recommendation_service", "project": "project1", ... },
+      { "name": "scoring_service", "project": "project2", ... }
+    ],
+    "pagination": { "page": 1, "limit": 10, "total": 25, "totalPages": 3 },
+    "relationships": { ... }
+  }
+  ```
+
 ### Lineage and Relationships
 
 #### Get Registry Lineage
@@ -263,6 +391,56 @@ Most endpoints support these common query parameters:
     "https://localhost:6572/api/v1/lineage/complete?project=my_project"
   ```
 
+#### Get Registry Lineage (All Projects)
+- **Endpoint**: `GET /api/v1/lineage/registry/all`
+- **Description**: Retrieve registry lineage (relationships and indirect relationships) for all projects.
+- **Parameters**:
+  - `allow_cache` (optional): Whether to allow cached data
+  - `filter_object_type` (optional): Filter by object type (`dataSource`, `entity`, `featureView`, `featureService`)
+  - `filter_object_name` (optional): Filter by object name
+- **Example**:
+  ```bash
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/lineage/registry/all"
+  ```
+- **Response Example**:
+  ```json
+  {
+    "relationships": [ { ... , "project": "project1" }, ... ],
+    "indirect_relationships": [ { ... , "project": "project2" }, ... ]
+  }
+  ```
+
+#### Get Complete Registry Data (All Projects)
+- **Endpoint**: `GET /api/v1/lineage/complete/all`
+- **Description**: Retrieve complete registry data, including all objects and relationships, for all projects. Optimized for UI consumption.
+- **Parameters**:
+  - `allow_cache` (optional): Whether to allow cached data
+- **Example**:
+  ```bash
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/lineage/complete/all"
+  ```
+- **Response Example**:
+  ```json
+  {
+    "projects": [
+      {
+        "project": "project1",
+        "objects": {
+          "entities": [ ... ],
+          "dataSources": [ ... ],
+          "featureViews": [ ... ],
+          "featureServices": [ ... ]
+        },
+        "relationships": [ ... ],
+        "indirectRelationships": [ ... ]
+      },
+      { "project": "project2", ... }
+    ]
+  }
+  ```
+
 ### Permissions
 
 #### List Permissions
@@ -384,6 +562,36 @@ Most endpoints support these common query parameters:
     "https://localhost:6572/api/v1/saved_datasets/training_data?project=my_project&include_relationships=true"
   ```
 
+#### List All Saved Datasets (All Projects)
+- **Endpoint**: `GET /api/v1/saved_datasets/all`
+- **Description**: Retrieve all saved datasets across all projects. Each saved dataset includes a `project` field.
+- **Parameters**:
+  - `allow_cache` (optional): Whether to allow cached data
+  - `page` (optional): Page number for pagination
+  - `limit` (optional): Number of items per page
+  - `sort_by` (optional): Field to sort by
+  - `sort_order` (optional): Sort order ("asc" or "desc")
+  - `include_relationships` (optional): Include relationships for each saved dataset
+- **Examples**:
+  ```bash
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/saved_datasets/all?page=1&limit=10&sort_by=name"
+  # With relationships
+  curl -H "Authorization: Bearer <token>" \
+    "https://localhost:6572/api/v1/saved_datasets/all?include_relationships=true"
+  ```
+- **Response Example**:
+  ```json
+  {
+    "savedDatasets": [
+      { "name": "training_data", "project": "project1", ... },
+      { "name": "validation_data", "project": "project2", ... }
+    ],
+    "pagination": { "page": 1, "limit": 10, "total": 25, "totalPages": 3 },
+    "relationships": { ... }
+  }
+  ```
+
 ### Response Formats
 
 All endpoints return JSON responses with the following general structure:
 
@@ -4,6 +4,7 @@
 from fastapi import APIRouter, Depends, Query
 
 from feast.api.registry.rest.rest_utils import (
+    aggregate_across_projects,
     create_grpc_pagination_params,
     create_grpc_sorting_params,
     get_object_relationships,
@@ -55,6 +56,31 @@ def list_data_sources(
 
         return result
 
+    @router.get("/data_sources/all")
+    def list_data_sources_all(
+        allow_cache: bool = Query(default=True),
+        page: int = Query(1, ge=1),
+        limit: int = Query(50, ge=1, le=100),
+        sort_by: str = Query(None),
+        sort_order: str = Query("asc"),
+        include_relationships: bool = Query(
+            False, description="Include relationships for each data source"
+        ),
+    ):
+        return aggregate_across_projects(
+            grpc_handler=grpc_handler,
+            list_method=grpc_handler.ListDataSources,
+            request_cls=RegistryServer_pb2.ListDataSourcesRequest,
+            response_key="dataSources",
+            object_type="dataSource",
+            allow_cache=allow_cache,
+            page=page,
+            limit=limit,
+            sort_by=sort_by,
+            sort_order=sort_order,
+            include_relationships=include_relationships,
+        )
+
     @router.get("/data_sources/{name}")
     def get_data_source(
         name: str,
 
@@ -3,6 +3,7 @@
 from fastapi import APIRouter, Depends, Query
 
 from feast.api.registry.rest.rest_utils import (
+    aggregate_across_projects,
     create_grpc_pagination_params,
     create_grpc_sorting_params,
     get_object_relationships,
@@ -51,6 +52,31 @@ def list_entities(
 
         return result
 
+    @router.get("/entities/all")
+    def list_all_entities(
+        allow_cache: bool = Query(default=True),
+        page: int = Query(1, ge=1),
+        limit: int = Query(50, ge=1, le=100),
+        sort_by: str = Query(None),
+        sort_order: str = Query("asc"),
+        include_relationships: bool = Query(
+            False, description="Include relationships for each entity"
+        ),
+    ):
+        return aggregate_across_projects(
+            grpc_handler=grpc_handler,
+            list_method=grpc_handler.ListEntities,
+            request_cls=RegistryServer_pb2.ListEntitiesRequest,
+            response_key="entities",
+            object_type="entity",
+            allow_cache=allow_cache,
+            page=page,
+            limit=limit,
+            sort_by=sort_by,
+            sort_order=sort_order,
+            include_relationships=include_relationships,
+        )
+
     @router.get("/entities/{name}")
     def get_entity(
         name: str,
 
@@ -3,6 +3,7 @@
 from fastapi import APIRouter, Depends, Query
 
 from feast.api.registry.rest.rest_utils import (
+    aggregate_across_projects,
     create_grpc_pagination_params,
     create_grpc_sorting_params,
     get_object_relationships,
@@ -52,6 +53,31 @@ def list_feature_services(
 
         return result
 
+    @router.get("/feature_services/all")
+    def list_feature_services_all(
+        allow_cache: bool = Query(default=True),
+        page: int = Query(1, ge=1),
+        limit: int = Query(50, ge=1, le=100),
+        sort_by: str = Query(None),
+        sort_order: str = Query("asc"),
+        include_relationships: bool = Query(
+            False, description="Include relationships for each feature service"
+        ),
+    ):
+        return aggregate_across_projects(
+            grpc_handler=grpc_handler,
+            list_method=grpc_handler.ListFeatureServices,
+            request_cls=RegistryServer_pb2.ListFeatureServicesRequest,
+            response_key="featureServices",
+            object_type="featureService",
+            allow_cache=allow_cache,
+            page=page,
+            limit=limit,
+            sort_by=sort_by,
+            sort_order=sort_order,
+            include_relationships=include_relationships,
+        )
+
     @router.get("/feature_services/{name}")
     def get_feature_service(
         name: str,