| go.temporal.io/server/service/matching/ack_manager.go |
132 |
77 |
55 |
| go.temporal.io/server/service/matching/ack_manager_test.go |
235 |
0 |
235 |
| go.temporal.io/server/service/matching/backlog_age_tracker.go |
60 |
27 |
33 |
| go.temporal.io/server/service/matching/backlog_manager.go |
308 |
145 |
163 |
| go.temporal.io/server/service/matching/backlog_manager_test.go |
1156 |
0 |
1156 |
| go.temporal.io/server/service/matching/bits.go |
46 |
26 |
20 |
| go.temporal.io/server/service/matching/bits_test.go |
60 |
0 |
60 |
| go.temporal.io/server/service/matching/config.go |
608 |
293 |
315 |
| go.temporal.io/server/service/matching/db.go |
995 |
594 |
401 |
| go.temporal.io/server/service/matching/deployment_util.go |
13 |
0 |
13 |
| go.temporal.io/server/service/matching/fair_backlog_manager.go |
452 |
249 |
203 |
| go.temporal.io/server/service/matching/fair_level.go |
69 |
36 |
33 |
| go.temporal.io/server/service/matching/fair_level_test.go |
31 |
0 |
31 |
| go.temporal.io/server/service/matching/fair_task_reader.go |
728 |
429 |
299 |
| go.temporal.io/server/service/matching/fair_task_writer.go |
268 |
152 |
116 |
| go.temporal.io/server/service/matching/fairness_util.go |
67 |
29 |
38 |
| go.temporal.io/server/service/matching/fairness_util_test.go |
131 |
0 |
131 |
| go.temporal.io/server/service/matching/forwarder.go |
361 |
210 |
151 |
| go.temporal.io/server/service/matching/forwarder_test.go |
515 |
0 |
515 |
| go.temporal.io/server/service/matching/fx.go |
268 |
124 |
144 |
| go.temporal.io/server/service/matching/handler.go |
726 |
253 |
473 |
| go.temporal.io/server/service/matching/handler_test.go |
249 |
0 |
249 |
| go.temporal.io/server/service/matching/liveness.go |
49 |
18 |
31 |
| go.temporal.io/server/service/matching/liveness_test.go |
46 |
0 |
46 |
| go.temporal.io/server/service/matching/loadcause_string_gen.go |
32 |
3 |
29 |
| go.temporal.io/server/service/matching/matcher.go |
655 |
378 |
277 |
| go.temporal.io/server/service/matching/matcher_data.go |
740 |
455 |
285 |
| go.temporal.io/server/service/matching/matcher_data_test.go |
1265 |
0 |
1265 |
| go.temporal.io/server/service/matching/matcher_test.go |
868 |
0 |
868 |
| go.temporal.io/server/service/matching/matching_engine.go |
3939 |
1609 |
2330 |
| go.temporal.io/server/service/matching/matching_engine_interfaces.go |
54 |
0 |
54 |
| go.temporal.io/server/service/matching/matching_engine_test.go |
7207 |
0 |
7207 |
| go.temporal.io/server/service/matching/metrics_util.go |
55 |
24 |
31 |
| go.temporal.io/server/service/matching/metrics_util_test.go |
53 |
0 |
53 |
| go.temporal.io/server/service/matching/nexus_endpoint_client.go |
403 |
99 |
304 |
| go.temporal.io/server/service/matching/partition_scaler_interface.go |
52 |
0 |
52 |
| go.temporal.io/server/service/matching/partition_scaler_mock.go |
106 |
26 |
80 |
| go.temporal.io/server/service/matching/physical_task_queue_key.go |
204 |
106 |
98 |
| go.temporal.io/server/service/matching/physical_task_queue_key_test.go |
74 |
0 |
74 |
| go.temporal.io/server/service/matching/physical_task_queue_manager.go |
1001 |
524 |
477 |
| go.temporal.io/server/service/matching/physical_task_queue_manager_interface.go |
78 |
0 |
78 |
| go.temporal.io/server/service/matching/physical_task_queue_manager_mock.go |
473 |
64 |
409 |
| go.temporal.io/server/service/matching/physical_task_queue_manager_test.go |
785 |
0 |
785 |
| go.temporal.io/server/service/matching/poller_history.go |
78 |
41 |
37 |
| go.temporal.io/server/service/matching/poller_history_test.go |
61 |
0 |
61 |
| go.temporal.io/server/service/matching/pri_backlog_manager.go |
445 |
228 |
217 |
| go.temporal.io/server/service/matching/pri_forwarder.go |
305 |
140 |
165 |
| go.temporal.io/server/service/matching/pri_matcher.go |
702 |
318 |
384 |
| go.temporal.io/server/service/matching/pri_matcher_test.go |
273 |
0 |
273 |
| go.temporal.io/server/service/matching/pri_metrics_handler.go |
147 |
58 |
89 |
| go.temporal.io/server/service/matching/pri_task_reader.go |
566 |
329 |
237 |
| go.temporal.io/server/service/matching/pri_task_writer.go |
233 |
126 |
107 |
| go.temporal.io/server/service/matching/rate_limit_fraction_provider.go |
44 |
13 |
31 |
| go.temporal.io/server/service/matching/rate_limit_fraction_provider_test.go |
27 |
0 |
27 |
| go.temporal.io/server/service/matching/ratelimit_manager.go |
394 |
220 |
174 |
| go.temporal.io/server/service/matching/ratelimit_manager_test.go |
233 |
0 |
233 |
| go.temporal.io/server/service/matching/reachability.go |
349 |
168 |
181 |
| go.temporal.io/server/service/matching/reachability_test.go |
362 |
0 |
362 |
| go.temporal.io/server/service/matching/scale_manager.go |
476 |
295 |
181 |
| go.temporal.io/server/service/matching/scale_manager_mock.go |
55 |
18 |
37 |
| go.temporal.io/server/service/matching/scale_manager_test.go |
1354 |
0 |
1354 |
| go.temporal.io/server/service/matching/service.go |
125 |
61 |
64 |
| go.temporal.io/server/service/matching/simple_partition_scaler.go |
181 |
92 |
89 |
| go.temporal.io/server/service/matching/simple_partition_scaler_test.go |
179 |
0 |
179 |
| go.temporal.io/server/service/matching/task.go |
394 |
159 |
235 |
| go.temporal.io/server/service/matching/task_gc.go |
101 |
45 |
56 |
| go.temporal.io/server/service/matching/task_queue_partition_manager.go |
2486 |
1409 |
1077 |
| go.temporal.io/server/service/matching/task_queue_partition_manager_interface.go |
70 |
0 |
70 |
| go.temporal.io/server/service/matching/task_queue_partition_manager_mock.go |
394 |
77 |
317 |
| go.temporal.io/server/service/matching/task_queue_partition_manager_test.go |
2112 |
0 |
2112 |
| go.temporal.io/server/service/matching/task_reader.go |
312 |
189 |
123 |
| go.temporal.io/server/service/matching/task_tracker.go |
117 |
68 |
49 |
| go.temporal.io/server/service/matching/task_tracker_test.go |
66 |
0 |
66 |
| go.temporal.io/server/service/matching/task_validation.go |
220 |
103 |
117 |
| go.temporal.io/server/service/matching/task_validation_mock.go |
56 |
18 |
38 |
| go.temporal.io/server/service/matching/task_validation_test.go |
297 |
0 |
297 |
| go.temporal.io/server/service/matching/task_writer.go |
234 |
129 |
105 |
| go.temporal.io/server/service/matching/unloadcause_string_gen.go |
31 |
3 |
28 |
| go.temporal.io/server/service/matching/user_data_manager.go |
878 |
489 |
389 |
| go.temporal.io/server/service/matching/user_data_manager_mock.go |
180 |
16 |
164 |
| go.temporal.io/server/service/matching/user_data_manager_test.go |
1071 |
0 |
1071 |
| go.temporal.io/server/service/matching/validate_partition_counts_test.go |
176 |
0 |
176 |
| go.temporal.io/server/service/matching/version_rule_helper_test.go |
96 |
0 |
96 |
| go.temporal.io/server/service/matching/version_rule_helpers.go |
633 |
396 |
237 |
| go.temporal.io/server/service/matching/version_rule_test.go |
1278 |
0 |
1278 |
| go.temporal.io/server/service/matching/version_sets.go |
515 |
322 |
193 |
| go.temporal.io/server/service/matching/version_sets_merge.go |
151 |
102 |
49 |
| go.temporal.io/server/service/matching/version_sets_merge_test.go |
195 |
0 |
195 |
| go.temporal.io/server/service/matching/version_sets_test.go |
873 |
0 |
873 |