diff options
Diffstat (limited to 'zenserver/upstream/upstreamapply.h')
| -rw-r--r-- | zenserver/upstream/upstreamapply.h | 33 |
1 files changed, 12 insertions, 21 deletions
diff --git a/zenserver/upstream/upstreamapply.h b/zenserver/upstream/upstreamapply.h index e48b67c61..c56a22ac3 100644 --- a/zenserver/upstream/upstreamapply.h +++ b/zenserver/upstream/upstreamapply.h @@ -115,26 +115,20 @@ struct UpstreamApplyEndpointStats }; /** - * The upstream apply endpont is responsible for handling remote execution. + * 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(const UpstreamApplyRecord& ApplyRecord) = 0; - - virtual GetUpstreamApplyUpdatesResult GetUpdates() = 0; - - virtual UpstreamApplyEndpointStats& Stats() = 0; + virtual UpstreamEndpointHealth Initialize() = 0; + virtual bool IsHealthy() const = 0; + virtual UpstreamEndpointHealth CheckHealth() = 0; + virtual std::string_view DisplayName() const = 0; + virtual PostUpstreamApplyResult PostApply(const UpstreamApplyRecord& ApplyRecord) = 0; + virtual GetUpstreamApplyUpdatesResult GetUpdates() = 0; + virtual UpstreamApplyEndpointStats& Stats() = 0; }; /** @@ -145,8 +139,7 @@ class UpstreamApply public: virtual ~UpstreamApply() = default; - virtual bool Initialize() = 0; - + virtual bool Initialize() = 0; virtual void RegisterEndpoint(std::unique_ptr<UpstreamApplyEndpoint> Endpoint) = 0; struct EnqueueResult @@ -161,11 +154,9 @@ public: 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; + virtual EnqueueResult EnqueueUpstream(UpstreamApplyRecord ApplyRecord) = 0; + virtual StatusResult GetStatus(const IoHash& WorkerId, const IoHash& ActionId) = 0; + virtual void GetStatus(CbObjectWriter& CbO) = 0; }; std::unique_ptr<UpstreamApply> MakeUpstreamApply(const UpstreamApplyOptions& Options, CasStore& CasStore, CidStore& CidStore); |