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

1 files changed, 32 insertions, 0 deletions

diff --git a/src/zenhorde/hordecomputechannel.h b/src/zenhorde/hordecomputechannel.h
new file mode 100644
index 000000000..c1dff20e4
--- /dev/null
+++ b/src/zenhorde/hordecomputechannel.h
@@ -0,0 +1,32 @@
+// Copyright Epic Games, Inc. All Rights Reserved.
+
+#pragma once
+
+#include "hordecomputebuffer.h"
+
+namespace zen::horde {
+
+/** Bidirectional communication channel using a pair of compute buffers.
+ *
+ *  Pairs a ComputeBufferReader (for receiving data) with a ComputeBufferWriter
+ *  (for sending data). Used by ComputeSocket to represent one logical channel
+ *  within a multiplexed connection.
+ */
+class ComputeChannel : public TRefCounted<ComputeChannel>
+{
+public:
+	ComputeBufferReader Reader;
+	ComputeBufferWriter Writer;
+
+	ComputeChannel(ComputeBufferReader InReader, ComputeBufferWriter InWriter);
+
+	bool IsValid() const;
+
+	size_t Send(const void* Data, size_t Size, int TimeoutMs = -1);
+	size_t Recv(void* Data, size_t Size, int TimeoutMs = -1);
+
+	/** Signal that no more data will be sent on this channel. */
+	void MarkComplete();
+};
+
+}  // namespace zen::horde