go.temporal.io/server/service/history/queues
1549 files · 43914 ranges · 25741 concepts · 19194 introducers · 12775 tests
| File | Coverage |
|---|---|
| action_move_group.go | 106 LOC · 66 covered · 40 uncovered · 11 ranges · 1 concepts · 1 introducers · 1 tests |
| action_pending_task_count.go | 201 LOC · 8 covered · 193 uncovered · 1 ranges · 2 concepts · 1 introducers · 2 tests |
| action_reader_stuck.go | 86 LOC · 6 covered · 80 uncovered · 1 ranges · 1 concepts · 1 introducers · 1 tests |
| action_slice_count.go | 192 LOC · 6 covered · 186 uncovered · 1 ranges · 1 concepts · 1 introducers · 1 tests |
| action_slice_predicate.go | 95 LOC · 40 covered · 55 uncovered · 13 ranges · 8 concepts · 5 introducers · 4 tests |
| active_standby_executor.go | 72 LOC · 29 covered · 43 uncovered · 8 ranges · 73 concepts · 4 introducers · 15 tests |
| convert.go | 378 LOC · 186 covered · 192 uncovered · 48 ranges · 48 concepts · 15 introducers · 22 tests |
| dlq_writer.go | 155 LOC · 81 covered · 74 uncovered · 14 ranges · 110 concepts · 7 introducers · 37 tests |
| executable.go | 979 LOC · 517 covered · 462 uncovered · 156 ranges · 587 concepts · 93 introducers · 243 tests |
| executable_factory.go | 112 LOC · 47 covered · 65 uncovered · 3 ranges · 124 concepts · 3 introducers · 36 tests |
| executable_mock.go | 494 LOC · 130 covered · 364 uncovered · 28 ranges · 184 concepts · 19 introducers · 103 tests |
| grouper.go | 72 LOC · 38 covered · 34 uncovered · 6 ranges · 73 concepts · 4 introducers · 35 tests |
| iterator.go | 112 LOC · 55 covered · 57 uncovered · 15 ranges · 220 concepts · 11 introducers · 57 tests |
| memory_scheduled_queue.go | 179 LOC · 87 covered · 92 uncovered · 23 ranges · 69 concepts · 5 introducers · 15 tests |
| metrics.go | 246 LOC · 157 covered · 89 uncovered · 80 ranges · 643 concepts · 73 introducers · 255 tests |
| mitigator.go | 106 LOC · 48 covered · 58 uncovered · 7 ranges · 126 concepts · 6 introducers · 31 tests |
| monitor.go | 327 LOC · 186 covered · 141 uncovered · 38 ranges · 267 concepts · 27 introducers · 66 tests |
| priority_assigner.go | 77 LOC · 35 covered · 42 uncovered · 13 ranges · 662 concepts · 12 introducers · 256 tests |
| queue_base.go | 460 LOC · 241 covered · 219 uncovered · 47 ranges · 123 concepts · 22 introducers · 29 tests |
| queue_immediate.go | 176 LOC · 85 covered · 91 uncovered · 19 ranges · 71 concepts · 5 introducers · 14 tests |
| queue_mock.go | 103 LOC · 26 covered · 77 uncovered · 6 ranges · 651 concepts · 2 introducers · 327 tests |
| queue_scheduled.go | 301 LOC · 164 covered · 137 uncovered · 40 ranges · 136 concepts · 16 introducers · 47 tests |
| range.go | 89 LOC · 38 covered · 51 uncovered · 13 ranges · 312 concepts · 11 introducers · 91 tests |
| reader.go | 578 LOC · 300 covered · 278 uncovered · 88 ranges · 142 concepts · 48 introducers · 34 tests |
| reader_group.go | 155 LOC · 88 covered · 67 uncovered · 26 ranges · 135 concepts · 14 introducers · 33 tests |
| reader_quotas.go | 68 LOC · 34 covered · 34 uncovered · 4 ranges · 189 concepts · 3 introducers · 45 tests |
| rescheduler.go | 299 LOC · 143 covered · 156 uncovered · 34 ranges · 105 concepts · 16 introducers · 26 tests |
| rescheduler_mock.go | 103 LOC · 36 covered · 67 uncovered · 9 ranges · 139 concepts · 5 introducers · 76 tests |
| scheduler.go | 324 LOC · 108 covered · 216 uncovered · 15 ranges · 92 concepts · 7 introducers · 21 tests |
| scheduler_mock.go | 142 LOC · 28 covered · 114 uncovered · 6 ranges · 156 concepts · 5 introducers · 83 tests |
| scheduler_monitor.go | 188 LOC · 91 covered · 97 uncovered · 17 ranges · 3 concepts · 3 introducers · 2 tests |
| scheduler_quotas.go | 87 LOC · 28 covered · 59 uncovered · 9 ranges · 87 concepts · 3 introducers · 20 tests |
| scope.go | 111 LOC · 53 covered · 58 uncovered · 18 ranges · 267 concepts · 14 introducers · 73 tests |
| slice.go | 513 LOC · 328 covered · 185 uncovered · 81 ranges · 203 concepts · 45 introducers · 51 tests |
| speculative_workflow_task_timeout_executable.go | 55 LOC · 13 covered · 42 uncovered · 3 ranges · 3 concepts · 2 introducers · 3 tests |
| speculative_workflow_task_timeout_queue.go | 102 LOC · 34 covered · 68 uncovered · 5 ranges · 64 concepts · 2 introducers · 12 tests |
| test_util.go | 97 LOC · 52 covered · 45 uncovered · 15 ranges · 122 concepts · 8 introducers · 74 tests |
| tracker.go | 115 LOC · 66 covered · 49 uncovered · 22 ranges · 203 concepts · 13 introducers · 51 tests |
| util.go | 34 LOC · 17 covered · 17 uncovered · 6 ranges · 7 concepts · 4 introducers · 3 tests |