summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/sharding_data_transform_cumulative_metrics.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/sharding_data_transform_cumulative_metrics.h')
-rw-r--r--src/mongo/db/s/sharding_data_transform_cumulative_metrics.h4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/db/s/sharding_data_transform_cumulative_metrics.h b/src/mongo/db/s/sharding_data_transform_cumulative_metrics.h
index 814ef0790d4..21a107c8f53 100644
--- a/src/mongo/db/s/sharding_data_transform_cumulative_metrics.h
+++ b/src/mongo/db/s/sharding_data_transform_cumulative_metrics.h
@@ -119,9 +119,13 @@ protected:
virtual void reportCurrentInSteps(BSONObjBuilder* bob) const;
private:
+ enum EstimateType { kHigh, kLow };
+
MetricsSet& getMetricsSetForRole(Role role);
const MetricsSet& getMetricsSetForRole(Role role) const;
const InstanceObserver* getOldestOperation(WithLock, Role role) const;
+ int64_t getOldestOperationEstimateRemainingTimeMillis(Role role, EstimateType type) const;
+ boost::optional<Milliseconds> getEstimate(const InstanceObserver* op, EstimateType type) const;
MetricsSet::iterator insertMetrics(const InstanceObserver* metrics, MetricsSet& set);
void deregisterMetrics(const Role& role, const MetricsSet::iterator& metrics);