aboutsummaryrefslogtreecommitdiff
path: root/src/zenserver/storage
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2026-03-04 14:13:46 +0100
committerGitHub Enterprise <[email protected]>2026-03-04 14:13:46 +0100
commit0763d09a81e5a1d3df11763a7ec75e7860c9510a (patch)
tree074575ba6ea259044a179eab0bb396d37268fb09 /src/zenserver/storage
parentnative xmake toolchain definition for UE-clang (#805) (diff)
downloadzen-0763d09a81e5a1d3df11763a7ec75e7860c9510a.tar.xz
zen-0763d09a81e5a1d3df11763a7ec75e7860c9510a.zip
compute orchestration (#763)
- Added local process runners for Linux/Wine, Mac with some sandboxing support - Horde & Nomad provisioning for development and testing - Client session queues with lifecycle management (active/draining/cancelled), automatic retry with configurable limits, and manual reschedule API - Improved web UI for orchestrator, compute, and hub dashboards with WebSocket push updates - Some security hardening - Improved scalability and `zen exec` command Still experimental - compute support is disabled by default
Diffstat (limited to 'src/zenserver/storage')
-rw-r--r--src/zenserver/storage/zenstorageserver.cpp17
-rw-r--r--src/zenserver/storage/zenstorageserver.h4
2 files changed, 14 insertions, 7 deletions
diff --git a/src/zenserver/storage/zenstorageserver.cpp b/src/zenserver/storage/zenstorageserver.cpp
index 3d81db656..bca26e87a 100644
--- a/src/zenserver/storage/zenstorageserver.cpp
+++ b/src/zenserver/storage/zenstorageserver.cpp
@@ -183,10 +183,15 @@ ZenStorageServer::RegisterServices()
m_Http->RegisterService(*m_AdminService);
+ if (m_ApiService)
+ {
+ m_Http->RegisterService(*m_ApiService);
+ }
+
#if ZEN_WITH_COMPUTE_SERVICES
- if (m_HttpFunctionService)
+ if (m_HttpComputeService)
{
- m_Http->RegisterService(*m_HttpFunctionService);
+ m_Http->RegisterService(*m_HttpComputeService);
}
#endif
}
@@ -279,8 +284,8 @@ ZenStorageServer::InitializeServices(const ZenStorageServerConfig& ServerOptions
{
ZEN_OTEL_SPAN("InitializeComputeService");
- m_HttpFunctionService =
- std::make_unique<compute::HttpFunctionService>(*m_CidStore, m_StatsService, ServerOptions.DataDir / "functions");
+ m_HttpComputeService =
+ std::make_unique<compute::HttpComputeService>(*m_CidStore, m_StatsService, ServerOptions.DataDir / "functions");
}
#endif
@@ -316,6 +321,8 @@ ZenStorageServer::InitializeServices(const ZenStorageServerConfig& ServerOptions
.AttachmentPassCount = ServerOptions.GcConfig.AttachmentPassCount};
m_GcScheduler.Initialize(GcConfig);
+ m_ApiService = std::make_unique<HttpApiService>(*m_Http);
+
// Create and register admin interface last to make sure all is properly initialized
m_AdminService = std::make_unique<HttpAdminService>(
m_GcScheduler,
@@ -832,7 +839,7 @@ ZenStorageServer::Cleanup()
Flush();
#if ZEN_WITH_COMPUTE_SERVICES
- m_HttpFunctionService.reset();
+ m_HttpComputeService.reset();
#endif
m_AdminService.reset();
diff --git a/src/zenserver/storage/zenstorageserver.h b/src/zenserver/storage/zenstorageserver.h
index 456447a2a..5b163fc8e 100644
--- a/src/zenserver/storage/zenstorageserver.h
+++ b/src/zenserver/storage/zenstorageserver.h
@@ -25,7 +25,7 @@
#include "workspaces/httpworkspaces.h"
#if ZEN_WITH_COMPUTE_SERVICES
-# include <zencompute/httpfunctionservice.h>
+# include <zencompute/httpcomputeservice.h>
#endif
namespace zen {
@@ -93,7 +93,7 @@ private:
std::unique_ptr<HttpApiService> m_ApiService;
#if ZEN_WITH_COMPUTE_SERVICES
- std::unique_ptr<compute::HttpFunctionService> m_HttpFunctionService;
+ std::unique_ptr<compute::HttpComputeService> m_HttpComputeService;
#endif
};