Searched defs:stats_aggregator (Results 1 – 14 of 14) sorted by relevance
78 StatsAggregatorResource(std::unique_ptr<StatsAggregator> stats_aggregator) in StatsAggregatorResource()82 std::shared_ptr<StatsAggregator> stats_aggregator() const { in stats_aggregator() function
343 std::shared_ptr<StatsAggregator> stats_aggregator = nullptr; member400 std::shared_ptr<StatsAggregator> stats_aggregator() { in stats_aggregator() function
29 def set_stats_aggregator(stats_aggregator, prefix="", counter_prefix=""): argument
108 const auto& stats_aggregator = ctx->stats_aggregator(); in GetNextInternal() local233 const auto& stats_aggregator = ctx->stats_aggregator(); in Consume() local
205 const auto& stats_aggregator = ctx->stats_aggregator(); in CallCompleted() local300 const auto& stats_aggregator = ctx->stats_aggregator(); in RunnerThread() local
504 const auto& stats_aggregator = ctx->stats_aggregator(); in CurrentElementsManager() local564 const auto& stats_aggregator = ctx->stats_aggregator(); in FetchResults() local617 const auto& stats_aggregator = ctx->stats_aggregator(); in FutureElementsManager() local
187 auto stats_aggregator = ctx->stats_aggregator(); in GetNextInternal() local
452 Status s) { in RunAsync()
109 auto stats_aggregator = ctx->stats_aggregator(); in GetNextInternal() local217 auto stats_aggregator = ctx->stats_aggregator(); in GetNextInternal() local
31 std::shared_ptr<StatsAggregator> stats_aggregator, const string& tag, in StatsAggregatorWithTagAndPrefix()
401 const auto& stats_aggregator = ctx->stats_aggregator(); in CallCompleted() local645 const auto& stats_aggregator = ctx->stats_aggregator(); in RunnerThread() local
281 auto stats_aggregator = ctx->stats_aggregator(); in MapFunc() local
159 StatsAggregator stats_aggregator(stats, vstate.get()); in AggregateStats() local