1 files changed, 0 insertions, 192 deletions
diff --git a/src/zenserver/upstream/upstreamapply.h b/src/zenserver/upstream/upstreamapply.h
deleted file mode 100644
index 4a095be6c..000000000
--- a/src/zenserver/upstream/upstreamapply.h
+++ /dev/null
@@ -1,192 +0,0 @@
-// Copyright Epic Games, Inc. All Rights Reserved.
-
-#pragma once
-
-#if ZEN_WITH_COMPUTE_SERVICES
-
-#	include <zencore/compactbinarypackage.h>
-#	include <zencore/iobuffer.h>
-#	include <zencore/iohash.h>
-#	include <zencore/stats.h>
-#	include <zencore/zencore.h>
-
-#	include <chrono>
-#	include <map>
-#	include <unordered_map>
-#	include <unordered_set>
-
-namespace zen {
-
-class AuthMgr;
-class CbObjectWriter;
-class CidStore;
-class CloudCacheTokenProvider;
-class WorkerThreadPool;
-class ZenCacheNamespace;
-struct CloudCacheClientOptions;
-struct UpstreamAuthConfig;
-
-enum class UpstreamApplyState : int32_t
-{
-	Queued	  = 0,
-	Executing = 1,
-	Complete  = 2,
-};
-
-enum class UpstreamApplyType
-{
-	Simple = 0,
-	Asset  = 1,
-};
-
-struct UpstreamApplyRecord
-{
-	CbObject						WorkerDescriptor;
-	CbObject						Action;
-	UpstreamApplyType				Type;
-	std::map<std::string, uint64_t> Timepoints{};
-};
-
-struct UpstreamApplyOptions
-{
-	std::chrono::seconds HealthCheckInterval{5};
-	std::chrono::seconds UpdatesInterval{5};
-	uint32_t			 UpstreamThreadCount   = 4;
-	uint32_t			 DownstreamThreadCount = 4;
-	bool				 StatsEnabled		   = false;
-};
-
-struct UpstreamApplyError
-{
-	int32_t		ErrorCode{};
-	std::string Reason{};
-
-	explicit operator bool() const { return ErrorCode != 0; }
-};
-
-struct PostUpstreamApplyResult
-{
-	UpstreamApplyError				Error{};
-	int64_t							Bytes{};
-	double							ElapsedSeconds{};
-	std::map<std::string, uint64_t> Timepoints{};
-	bool							Success = false;
-};
-
-struct GetUpstreamApplyResult
-{
-	// UpstreamApplyType::Simple
-	std::map<std::filesystem::path, IoHash> OutputFiles{};
-	std::map<IoHash, IoBuffer>				FileData{};
-
-	// UpstreamApplyType::Asset
-	CbPackage OutputPackage{};
-	int64_t	  TotalAttachmentBytes{};
-	int64_t	  TotalRawAttachmentBytes{};
-
-	UpstreamApplyError				Error{};
-	int64_t							Bytes{};
-	double							ElapsedSeconds{};
-	std::string						StdOut{};
-	std::string						StdErr{};
-	std::string						Agent{};
-	std::string						Detail{};
-	std::map<std::string, uint64_t> Timepoints{};
-	bool							Success = false;
-};
-
-using UpstreamApplyCompleted = std::unordered_map<IoHash, std::unordered_map<IoHash, GetUpstreamApplyResult>>;
-
-struct GetUpstreamApplyUpdatesResult
-{
-	UpstreamApplyError	   Error{};
-	int64_t				   Bytes{};
-	double				   ElapsedSeconds{};
-	UpstreamApplyCompleted Completed{};
-	bool				   Success = false;
-};
-
-struct UpstreamApplyStatus
-{
-	UpstreamApplyState					  State{};
-	GetUpstreamApplyResult				  Result{};
-	std::chrono::steady_clock::time_point ExpireTime{};
-	std::map<std::string, uint64_t>		  Timepoints{};
-};
-
-using UpstreamApplyTasks = std::unordered_map<IoHash, std::unordered_map<IoHash, UpstreamApplyStatus>>;
-
-struct UpstreamEndpointHealth
-{
-	std::string Reason;
-	bool		Ok = false;
-};
-
-struct UpstreamApplyEndpointStats
-{
-	metrics::Counter PostCount;
-	metrics::Counter CompleteCount;
-	metrics::Counter UpdateCount;
-	metrics::Counter ErrorCount;
-	metrics::Counter UpBytes;
-	metrics::Counter DownBytes;
-};
-
-/**
- * The upstream apply endpoint is responsible for handling remote execution.
- */
-class UpstreamApplyEndpoint
-{
-public:
-	virtual ~UpstreamApplyEndpoint() = default;
-
-	virtual UpstreamEndpointHealth		  Initialize()								 = 0;
-	virtual bool						  IsHealthy() const							 = 0;
-	virtual UpstreamEndpointHealth		  CheckHealth()								 = 0;
-	virtual std::string_view			  DisplayName() const						 = 0;
-	virtual PostUpstreamApplyResult		  PostApply(UpstreamApplyRecord ApplyRecord) = 0;
-	virtual GetUpstreamApplyUpdatesResult GetUpdates(WorkerThreadPool& ThreadPool)	 = 0;
-	virtual UpstreamApplyEndpointStats&	  Stats()									 = 0;
-
-	static std::unique_ptr<UpstreamApplyEndpoint> CreateHordeEndpoint(const CloudCacheClientOptions& ComputeOptions,
-																	  const UpstreamAuthConfig&		 ComputeAuthConfig,
-																	  const CloudCacheClientOptions& StorageOptions,
-																	  const UpstreamAuthConfig&		 StorageAuthConfig,
-																	  CidStore&						 CidStore,
-																	  AuthMgr&						 Mgr);
-};
-
-/**
- * Manages one or more upstream compute endpoints.
- */
-class UpstreamApply
-{
-public:
-	virtual ~UpstreamApply() = default;
-
-	virtual bool Initialize()													   = 0;
-	virtual bool IsHealthy() const												   = 0;
-	virtual void RegisterEndpoint(std::unique_ptr<UpstreamApplyEndpoint> Endpoint) = 0;
-
-	struct EnqueueResult
-	{
-		IoHash ApplyId{};
-		bool   Success = false;
-	};
-
-	struct StatusResult
-	{
-		UpstreamApplyStatus Status{};
-		bool				Success = false;
-	};
-
-	virtual EnqueueResult EnqueueUpstream(UpstreamApplyRecord ApplyRecord)			= 0;
-	virtual StatusResult  GetStatus(const IoHash& WorkerId, const IoHash& ActionId) = 0;
-	virtual void		  GetStatus(CbObjectWriter& CbO)							= 0;
-
-	static std::unique_ptr<UpstreamApply> Create(const UpstreamApplyOptions& Options, CidStore& CidStore);
-};
-
-}  // namespace zen
-
-#endif	// ZEN_WITH_COMPUTE_SERVICES