go.temporal.io/server/service/history/replication
1549 files · 43914 ranges · 25741 concepts · 19194 introducers · 12775 tests
| File | Coverage |
|---|---|
| ack_manager.go | 541 LOC · 174 covered · 367 uncovered · 38 ranges · 18 concepts · 16 introducers · 13 tests |
| batchable_task.go | 174 LOC · 67 covered · 107 uncovered · 21 ranges · 30 concepts · 19 introducers · 19 tests |
| batchable_task_mock.go | 299 LOC · 117 covered · 182 uncovered · 26 ranges · 28 concepts · 13 introducers · 17 tests |
| bi_direction_stream.go | 200 LOC · 92 covered · 108 uncovered · 25 ranges · 72 concepts · 18 introducers · 32 tests |
| dlq_handler.go | 329 LOC · 144 covered · 185 uncovered · 21 ranges · 71 concepts · 6 introducers · 15 tests |
| dlq_writer.go | 151 LOC · 41 covered · 110 uncovered · 8 ranges · 229 concepts · 8 introducers · 100 tests |
| eager_namespace_refresher.go | 114 LOC · 56 covered · 58 uncovered · 15 ranges · 75 concepts · 10 introducers · 17 tests |
| eager_namespace_refresher_mock.go | 57 LOC · 19 covered · 38 uncovered · 4 ranges · 139 concepts · 2 introducers · 74 tests |
| executable_activity_state_task.go | 285 LOC · 193 covered · 92 uncovered · 32 ranges · 17 concepts · 17 introducers · 10 tests |
| executable_backfill_history_events_task.go | 262 LOC · 124 covered · 138 uncovered · 23 ranges · 10 concepts · 10 introducers · 6 tests |
| executable_delete_execution_task.go | 203 LOC · 82 covered · 121 uncovered · 13 ranges · 3 concepts · 3 introducers · 2 tests |
| executable_noop_task.go | 67 LOC · 31 covered · 36 uncovered · 4 ranges · 4 concepts · 4 introducers · 3 tests |
| executable_sync_hsm_task.go | 200 LOC · 101 covered · 99 uncovered · 18 ranges · 12 concepts · 11 introducers · 7 tests |
| executable_task.go | 954 LOC · 525 covered · 429 uncovered · 106 ranges · 177 concepts · 56 introducers · 86 tests |
| executable_task_converter.go | 168 LOC · 31 covered · 137 uncovered · 7 ranges · 140 concepts · 3 introducers · 47 tests |
| executable_task_mock.go | 388 LOC · 129 covered · 259 uncovered · 26 ranges · 81 concepts · 14 introducers · 39 tests |
| executable_task_tracker.go | 192 LOC · 98 covered · 94 uncovered · 31 ranges · 75 concepts · 22 introducers · 37 tests |
| executable_task_tracker_mock.go | 341 LOC · 108 covered · 233 uncovered · 22 ranges · 60 concepts · 13 introducers · 41 tests |
| executable_unknown_task.go | 86 LOC · 42 covered · 44 uncovered · 4 ranges · 7 concepts · 4 introducers · 5 tests |
| executable_verify_versioned_transition_task.go | 333 LOC · 145 covered · 188 uncovered · 35 ranges · 18 concepts · 17 introducers · 9 tests |
| executable_workflow_state_task.go | 215 LOC · 105 covered · 110 uncovered · 19 ranges · 11 concepts · 11 introducers · 7 tests |
| fx.go | 422 LOC · 141 covered · 281 uncovered · 22 ranges · 64 concepts · 1 introducers · 12 tests |
| grpc_stream_client.go | 55 LOC · 23 covered · 32 uncovered · 4 ranges · 3 concepts · 2 introducers · 2 tests |
| metrics.go | 60 LOC · 11 covered · 49 uncovered · 6 ranges · 9 concepts · 4 introducers · 5 tests |
| poller_manager.go | 72 LOC · 17 covered · 55 uncovered · 6 ranges · 72 concepts · 5 introducers · 21 tests |
| progress_cache.go | 223 LOC · 99 covered · 124 uncovered · 18 ranges · 86 concepts · 2 introducers · 27 tests |
| quotas.go | 29 LOC · 11 covered · 18 uncovered · 3 ranges · 64 concepts · 1 introducers · 12 tests |
| raw_task_converter.go | 961 LOC · 135 covered · 826 uncovered · 27 ranges · 18 concepts · 4 introducers · 13 tests |
| raw_task_converter_mock.go | 58 LOC · 19 covered · 39 uncovered · 4 ranges · 40 concepts · 2 introducers · 21 tests |
| sequential_batch_queue.go | 117 LOC · 58 covered · 59 uncovered · 10 ranges · 10 concepts · 5 introducers · 6 tests |
| sequential_queue.go | 88 LOC · 3 covered · 85 uncovered · 1 ranges · 3 concepts · 1 introducers · 3 tests |
| stream.go | 152 LOC · 64 covered · 88 uncovered · 20 ranges · 34 concepts · 10 introducers · 13 tests |
| stream_receiver.go | 541 LOC · 303 covered · 238 uncovered · 77 ranges · 119 concepts · 42 introducers · 59 tests |
| stream_receiver_flow_controller.go | 67 LOC · 27 covered · 40 uncovered · 7 ranges · 55 concepts · 7 introducers · 28 tests |
| stream_receiver_flow_controller_mock.go | 55 LOC · 18 covered · 37 uncovered · 4 ranges · 31 concepts · 2 introducers · 21 tests |
| stream_receiver_mock.go | 80 LOC · 30 covered · 50 uncovered · 7 ranges · 3 concepts · 1 introducers · 2 tests |
| stream_receiver_monitor.go | 435 LOC · 249 covered · 186 uncovered · 59 ranges · 95 concepts · 25 introducers · 26 tests |
| stream_sender.go | 751 LOC · 414 covered · 337 uncovered · 84 ranges · 40 concepts · 33 introducers · 21 tests |
| stream_sender_flow_controller.go | 115 LOC · 67 covered · 48 uncovered · 14 ranges · 51 concepts · 9 introducers · 27 tests |
| stream_sender_flow_controller_mock.go | 69 LOC · 26 covered · 43 uncovered · 6 ranges · 40 concepts · 4 introducers · 21 tests |
| stream_sender_mock.go | 80 LOC · 36 covered · 44 uncovered · 8 ranges · 7 concepts · 3 introducers · 5 tests |
| sync_state_retriever.go | 610 LOC · 307 covered · 303 uncovered · 84 ranges · 104 concepts · 37 introducers · 28 tests |
| sync_state_retriever_mock.go | 129 LOC · 5 covered · 124 uncovered · 1 ranges · 18 concepts · 1 introducers · 13 tests |
| task_executor.go | 471 LOC · 228 covered · 243 uncovered · 36 ranges · 20 concepts · 20 introducers · 11 tests |
| task_executor_mock.go | 56 LOC · 18 covered · 38 uncovered · 4 ranges · 33 concepts · 2 introducers · 20 tests |
| task_fetcher.go | 423 LOC · 198 covered · 225 uncovered · 38 ranges · 74 concepts · 12 introducers · 19 tests |
| task_fetcher_mock.go | 157 LOC · 43 covered · 114 uncovered · 9 ranges · 24 concepts · 2 introducers · 17 tests |
| task_processor.go | 610 LOC · 232 covered · 378 uncovered · 41 ranges · 21 concepts · 20 introducers · 15 tests |
| task_processor_manager.go | 365 LOC · 131 covered · 234 uncovered · 23 ranges · 68 concepts · 6 introducers · 14 tests |