| 3119 | } |
| 3120 | |
| 3121 | void AdmissionController::PoolStats::InitMetrics() { |
| 3122 | metrics_.total_admitted = parent_->metrics_group_->AddCounter( |
| 3123 | TOTAL_ADMITTED_METRIC_KEY_FORMAT, 0, name_); |
| 3124 | metrics_.total_queued = parent_->metrics_group_->AddCounter( |
| 3125 | TOTAL_QUEUED_METRIC_KEY_FORMAT, 0, name_); |
| 3126 | metrics_.total_dequeued = parent_->metrics_group_->AddCounter( |
| 3127 | TOTAL_DEQUEUED_METRIC_KEY_FORMAT, 0, name_); |
| 3128 | metrics_.total_rejected = parent_->metrics_group_->AddCounter( |
| 3129 | TOTAL_REJECTED_METRIC_KEY_FORMAT, 0, name_); |
| 3130 | metrics_.total_timed_out = parent_->metrics_group_->AddCounter( |
| 3131 | TOTAL_TIMED_OUT_METRIC_KEY_FORMAT, 0, name_); |
| 3132 | metrics_.total_released = parent_->metrics_group_->AddCounter( |
| 3133 | TOTAL_RELEASED_METRIC_KEY_FORMAT, 0, name_); |
| 3134 | metrics_.time_in_queue_ms = parent_->metrics_group_->AddCounter( |
| 3135 | TIME_IN_QUEUE_METRIC_KEY_FORMAT, 0, name_); |
| 3136 | |
| 3137 | metrics_.agg_num_running = parent_->metrics_group_->AddGauge( |
| 3138 | AGG_NUM_RUNNING_METRIC_KEY_FORMAT, 0, name_); |
| 3139 | metrics_.agg_num_queued = parent_->metrics_group_->AddGauge( |
| 3140 | AGG_NUM_QUEUED_METRIC_KEY_FORMAT, 0, name_); |
| 3141 | metrics_.agg_mem_reserved = parent_->metrics_group_->AddGauge( |
| 3142 | AGG_MEM_RESERVED_METRIC_KEY_FORMAT, 0, name_); |
| 3143 | metrics_.agg_current_users = SetMetric<std::string>::CreateAndRegister( |
| 3144 | parent_->metrics_group_, AGG_CURRENT_USERS_METRIC_KEY_FORMAT, set<string>(), name_); |
| 3145 | |
| 3146 | metrics_.local_mem_admitted = parent_->metrics_group_->AddGauge( |
| 3147 | LOCAL_MEM_ADMITTED_METRIC_KEY_FORMAT, 0, name_); |
| 3148 | metrics_.local_num_admitted_running = parent_->metrics_group_->AddGauge( |
| 3149 | LOCAL_NUM_ADMITTED_RUNNING_METRIC_KEY_FORMAT, 0, name_); |
| 3150 | metrics_.local_num_queued = parent_->metrics_group_->AddGauge( |
| 3151 | LOCAL_NUM_QUEUED_METRIC_KEY_FORMAT, 0, name_); |
| 3152 | metrics_.local_backend_mem_usage = parent_->metrics_group_->AddGauge( |
| 3153 | LOCAL_BACKEND_MEM_USAGE_METRIC_KEY_FORMAT, 0, name_); |
| 3154 | metrics_.local_backend_mem_reserved = parent_->metrics_group_->AddGauge( |
| 3155 | LOCAL_BACKEND_MEM_RESERVED_METRIC_KEY_FORMAT, 0, name_); |
| 3156 | metrics_.local_current_users = |
| 3157 | SetMetric<std::string>::CreateAndRegister(parent_->metrics_group_, |
| 3158 | LOCAL_CURRENT_USERS_METRIC_KEY_FORMAT, set<string>(), name_); |
| 3159 | |
| 3160 | metrics_.pool_max_mem_resources = parent_->metrics_group_->AddGauge( |
| 3161 | POOL_MAX_MEM_RESOURCES_METRIC_KEY_FORMAT, 0, name_); |
| 3162 | metrics_.pool_max_requests = parent_->metrics_group_->AddGauge( |
| 3163 | POOL_MAX_REQUESTS_METRIC_KEY_FORMAT, 0, name_); |
| 3164 | metrics_.pool_max_queued = parent_->metrics_group_->AddGauge( |
| 3165 | POOL_MAX_QUEUED_METRIC_KEY_FORMAT, 0, name_); |
| 3166 | metrics_.pool_queue_timeout = parent_->metrics_group_->AddGauge( |
| 3167 | POOL_QUEUE_TIMEOUT_METRIC_KEY_FORMAT, 0, name_); |
| 3168 | metrics_.max_query_mem_limit = parent_->metrics_group_->AddGauge( |
| 3169 | POOL_MAX_QUERY_MEM_LIMIT_METRIC_KEY_FORMAT, 0, name_); |
| 3170 | metrics_.min_query_mem_limit = parent_->metrics_group_->AddGauge( |
| 3171 | POOL_MIN_QUERY_MEM_LIMIT_METRIC_KEY_FORMAT, 0, name_); |
| 3172 | metrics_.clamp_mem_limit_query_option = parent_->metrics_group_->AddProperty<bool>( |
| 3173 | POOL_CLAMP_MEM_LIMIT_QUERY_OPTION_METRIC_KEY_FORMAT, false, name_); |
| 3174 | metrics_.max_query_cpu_core_per_node_limit = parent_->metrics_group_->AddGauge( |
| 3175 | POOL_MAX_QUERY_CPU_CORE_PER_NODE_LIMIT_METRIC_KEY_FORMAT, 0, name_); |
| 3176 | metrics_.max_query_cpu_core_coordinator_limit = parent_->metrics_group_->AddGauge( |
| 3177 | POOL_MAX_QUERY_CPU_CORE_COORDINATOR_LIMIT_METRIC_KEY_FORMAT, 0, name_); |
| 3178 | } |