history_task_queue_manager.go ×1
Frontier kind: Joint frontier
unlabeled · c_1891c2a3e05c
1 test · 1939 LOC · 87 files · introduces 1 test · 2 LOC · 1 file
Introduces — evidence that enters the hierarchy at this concept
Code
1 range 2 lines · 1 files
Tests
1 test
Contains — complete concept membership
Neighbourhood graph
The orange circle is the focus. Violet and green circles are every ancestor and descendant, broader and narrower, at any distance; blue squares and pink diamonds are the introduced files and exact introduced tests of every visible concept, not only the focus's. Arrows point from broader to narrower concepts and bridge only concepts omitted from this view. Undirected links show source or test introduction. Concept and file size follows LOC; exact test nodes use test-count units.
Introduced files, introduced tests, and structurally relevant concept specialization
In the embedded map, ordinary wheel input scrolls the page; use the visible controls to zoom and drag to pan. Open the full-screen map for canvas navigation: wheel pans, Ctrl/Command plus wheel zooms, and arrow keys pan when this region is focused. On touch screens, open the full-screen map to pan or pinch. If JavaScript or WebGL is unavailable, use the native relationship evidence on this page.
Introduced files, introduced tests, and structurally relevant concept specialization history_task_queue_manager.go ×2 · 18 introduced LOC history_task_queue_manag… queues.pb.go ×1 · 8 introduced LOC queues.pb.go ×1 history_task_queue_manager.go ×1 · 2 introduced LOC history_task_queue_manag… history_task_queue_manager.go ×1 · 3 introduced LOC history_task_queue_manag… history_task_queue_manager.go ×1 · 3 introduced LOC history_task_queue_manag… history_task_queue_manager.go ×2 · 11 introduced LOC history_task_queue_manag… history_task_queue_manager.go ×1 · 6 introduced LOC history_task_queue_manag… history_task_queue_manager.go ×1 · 2 introduced LOC history_task_queue_manag… fx.go ×1 · 12 introduced LOC fx.go ×1 visibility.go ×2 · 10 introduced LOC visibility.go ×2 util.go ×1 · 7 introduced LOC util.go ×1 constants.go ×2 · 6 introduced LOC constants.go ×2 data_interfaces.go ×3 · 6 introduced LOC data_interfaces.go ×3 fixed_address_translator.go ×2 · 9 introduced LOC fixed_address_translator… noop_moving_window_average.go ×1 · 2 introduced LOC noop_moving_window_avera… search_attribute.go ×12 · 121 introduced LOC search_attribute.go ×12 codec.go ×1 · 2 introduced LOC codec.go ×1 codec.go ×1 · 3 introduced LOC codec.go ×1 codec.go ×1 · 2 introduced LOC codec.go ×1 codec.go ×1 · 1 introduced LOC codec.go ×1 serializer.go ×1 · 3 introduced LOC serializer.go ×1 serializer.go ×1 · 3 introduced LOC serializer.go ×1 category.go ×1 · 3 introduced LOC category.go ×1 codec.go ×1 · 2 introduced LOC codec.go ×1 codec.go ×1 · 3 introduced LOC codec.go ×1 predicates.pb.go ×1 · 1 introduced LOC predicates.pb.go ×1 serializer.go ×1 · 6 introduced LOC serializer.go ×1 key.go ×1 · 6 introduced LOC key.go ×1 priority.go ×1 · 3 introduced LOC priority.go ×1 setting_gen.go ×51 · 335 introduced LOC setting_gen.go ×51 grpc_resolver.go ×2 · 7 introduced LOC grpc_resolver.go ×2 predicates.pb.go ×21 · 54 introduced LOC predicates.pb.go ×21 service.pb.go ×2 · 342 introduced LOC service.pb.go ×2 message.pb.go ×2 · 20 introduced LOC message.pb.go ×2 constants.go ×3 · 11 introduced LOC constants.go ×3 constants.go ×1 · 3 introduced LOC constants.go ×1 constants.go ×1 · 6 introduced LOC constants.go ×1 task.pb.go ×1 · 3 introduced LOC task.pb.go ×1 message.pb.go ×2 · 442 introduced LOC message.pb.go ×2 defs.go ×5 · 91 introduced LOC defs.go ×5 tags.go ×9 · 37 introduced LOC tags.go ×9 message.pb.go ×2 · 49 introduced LOC message.pb.go ×2 cluster.pb.go ×2 · 200 introduced LOC cluster.pb.go ×2 retrypolicy.go ×2 · 11 introduced LOC retrypolicy.go ×2 wildcard.go ×1 · 2 introduced LOC wildcard.go ×1 retrypolicy.go ×1 · 4 introduced LOC retrypolicy.go ×1 wildcard.go ×4 · 14 introduced LOC wildcard.go ×4 retrypolicy.go ×3 · 19 introduced LOC retrypolicy.go ×3 message.pb.go ×2 · 20 introduced LOC message.pb.go ×2 payload.go ×1 · 3 introduced LOC payload.go ×1 TestOperatorServiceMetadata, TestWorkflowServiceMetadata · 0 introduced LOC TestOperatorServiceMetad… go.temporal.io/server/api/adminservice/v1/request_response.pb.go · 6661 LOC v1/request_response.pb.g… go.temporal.io/server/api/adminservice/v1/service.pb.go · 297 LOC v1/service.pb.go go.temporal.io/server/api/chasm/v1/message.pb.go · 230 LOC v1/message.pb.go go.temporal.io/server/api/clock/v1/message.pb.go · 217 LOC v1/message.pb.go go.temporal.io/server/api/cluster/v1/message.pb.go · 366 LOC v1/message.pb.go go.temporal.io/server/api/common/v1/api_category.pb.go · 230 LOC v1/api_category.pb.go go.temporal.io/server/api/common/v1/dlq.pb.go · 319 LOC v1/dlq.pb.go go.temporal.io/server/api/deployment/v1/message.pb.go · 4650 LOC v1/message.pb.go go.temporal.io/server/api/enums/v1/cluster.pb.go · 233 LOC v1/cluster.pb.go go.temporal.io/server/api/enums/v1/common.pb.go · 288 LOC v1/common.pb.go go.temporal.io/server/api/enums/v1/dlq.pb.go · 211 LOC v1/dlq.pb.go go.temporal.io/server/api/enums/v1/fairness_state.pb.go · 147 LOC v1/fairness_state.pb.go go.temporal.io/server/api/enums/v1/nexus.pb.go · 182 LOC v1/nexus.pb.go go.temporal.io/server/api/enums/v1/predicate.pb.go · 194 LOC v1/predicate.pb.go go.temporal.io/server/api/enums/v1/replication.pb.go · 338 LOC v1/replication.pb.go go.temporal.io/server/api/enums/v1/task.pb.go · 480 LOC v1/task.pb.go go.temporal.io/server/api/enums/v1/workflow.pb.go · 299 LOC v1/workflow.pb.go go.temporal.io/server/api/enums/v1/workflow_task_type.pb.go · 148 LOC v1/workflow_task_type.pb… go.temporal.io/server/api/errordetails/v1/message.pb.go · 649 LOC v1/message.pb.go go.temporal.io/server/api/health/v1/message.pb.go · 324 LOC v1/message.pb.go go.temporal.io/server/api/history/v1/message.pb.go · 522 LOC v1/message.pb.go go.temporal.io/server/api/historyservice/v1/request_response.pb.go · 12003 LOC v1/request_response.pb.g… go.temporal.io/server/api/historyservice/v1/service.pb.go · 452 LOC v1/service.pb.go go.temporal.io/server/api/matchingservice/v1/request_response.pb.go · 6878 LOC v1/request_response.pb.g… go.temporal.io/server/api/matchingservice/v1/service.pb.go · 274 LOC v1/service.pb.go go.temporal.io/server/api/metrics/v1/message.pb.go · 128 LOC v1/message.pb.go go.temporal.io/server/api/namespace/v1/message.pb.go · 138 LOC v1/message.pb.go go.temporal.io/server/api/persistence/v1/chasm.pb.go · 1215 LOC v1/chasm.pb.go go.temporal.io/server/api/persistence/v1/chasm_visibility.pb.go · 170 LOC v1/chasm_visibility.pb.g… go.temporal.io/server/api/persistence/v1/cluster_metadata.pb.go · 313 LOC v1/cluster_metadata.pb.g… go.temporal.io/server/api/persistence/v1/executions.pb.go · 5768 LOC v1/executions.pb.go go.temporal.io/server/api/persistence/v1/history_tree.pb.go · 298 LOC v1/history_tree.pb.go go.temporal.io/server/api/persistence/v1/hsm.pb.go · 929 LOC v1/hsm.pb.go go.temporal.io/server/api/persistence/v1/namespaces.pb.go · 560 LOC v1/namespaces.pb.go go.temporal.io/server/api/persistence/v1/nexus.pb.go · 509 LOC v1/nexus.pb.go go.temporal.io/server/api/persistence/v1/predicates.go-helpers.pb.go · 413 LOC v1/predicates.go-helpers… go.temporal.io/server/api/persistence/v1/predicates.pb.go · 864 LOC v1/predicates.pb.go go.temporal.io/server/api/persistence/v1/queue_metadata.pb.go · 129 LOC v1/queue_metadata.pb.go go.temporal.io/server/api/persistence/v1/queues.pb.go · 641 LOC v1/queues.pb.go go.temporal.io/server/api/persistence/v1/task_queues.pb.go · 924 LOC v1/task_queues.pb.go go.temporal.io/server/api/persistence/v1/tasks.pb.go · 870 LOC v1/tasks.pb.go go.temporal.io/server/api/persistence/v1/update.pb.go · 455 LOC v1/update.pb.go go.temporal.io/server/api/persistence/v1/workflow_mutable_state.pb.go · 560 LOC v1/workflow_mutable_stat… go.temporal.io/server/api/replication/v1/message.pb.go · 2481 LOC v1/message.pb.go go.temporal.io/server/api/taskqueue/v1/message.pb.go · 1363 LOC v1/message.pb.go go.temporal.io/server/api/token/v1/message.pb.go · 809 LOC v1/message.pb.go go.temporal.io/server/api/visibilityservice/v1/request_response.pb.go · 426 LOC v1/request_response.pb.g… go.temporal.io/server/api/workflow/v1/message.pb.go · 302 LOC v1/message.pb.go go.temporal.io/server/chasm/library.go · 60 LOC chasm/library.go go.temporal.io/server/chasm/registrable_component.go · 233 LOC chasm/registrable_compon… go.temporal.io/server/chasm/search_attribute.go · 525 LOC chasm/search_attribute.g… go.temporal.io/server/common/aggregate/noop_moving_window_average.go · 13 LOC aggregate/noop_moving_wi… go.temporal.io/server/common/backoff/retrypolicy.go · 347 LOC backoff/retrypolicy.go go.temporal.io/server/common/build/build.go · 56 LOC build/build.go go.temporal.io/server/common/dynamicconfig/collection.go · 779 LOC dynamicconfig/collection… go.temporal.io/server/common/dynamicconfig/deepcopy.go · 78 LOC dynamicconfig/deepcopy.g… go.temporal.io/server/common/dynamicconfig/gradual_change.go · 196 LOC dynamicconfig/gradual_ch… go.temporal.io/server/common/dynamicconfig/key.go · 21 LOC dynamicconfig/key.go go.temporal.io/server/common/dynamicconfig/registry.go · 44 LOC dynamicconfig/registry.g… go.temporal.io/server/common/dynamicconfig/setting_gen.go · 1972 LOC dynamicconfig/setting_ge… go.temporal.io/server/common/dynamicconfig/shared_structure.go · 69 LOC dynamicconfig/shared_str… go.temporal.io/server/common/log/tag/tags.go · 1039 LOC tag/tags.go go.temporal.io/server/common/log/tag/zap_tag.go · 242 LOC tag/zap_tag.go go.temporal.io/server/common/membership/grpc_resolver.go · 169 LOC membership/grpc_resolver… go.temporal.io/server/common/metrics/defs.go · 76 LOC metrics/defs.go go.temporal.io/server/common/metrics/defs_base.go · 30 LOC metrics/defs_base.go go.temporal.io/server/common/metrics/noop_impl.go · 58 LOC metrics/noop_impl.go go.temporal.io/server/common/metrics/option.go · 21 LOC metrics/option.go go.temporal.io/server/common/metrics/registry.go · 75 LOC metrics/registry.go go.temporal.io/server/common/payload/payload.go · 127 LOC payload/payload.go go.temporal.io/server/common/persistence/client/fx.go · 241 LOC client/fx.go go.temporal.io/server/common/persistence/data_interfaces.go · 1453 LOC persistence/data_interfa… go.temporal.io/server/common/persistence/history_task_queue_manager.go · 263 LOC persistence/history_task… go.temporal.io/server/common/persistence/noop_health_signal_aggregator.go · 31 LOC persistence/noop_health_… go.temporal.io/server/common/persistence/nosql/nosqlplugin/cassandra/translator/fixed_address_translator.go · 84 LOC translator/fixed_address… go.temporal.io/server/common/persistence/nosql/nosqlplugin/cassandra/translator/translator_plugin.go · 35 LOC translator/translator_pl… go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go · 1186 LOC persistence/persistence_… go.temporal.io/server/common/persistence/serialization/codec.go · 121 LOC serialization/codec.go go.temporal.io/server/common/persistence/serialization/serializer.go · 700 LOC serialization/serializer… go.temporal.io/server/common/persistence/sql/sqlplugin/visibility.go · 336 LOC sqlplugin/visibility.go go.temporal.io/server/common/persistence/visibility/store/query/util.go · 165 LOC query/util.go go.temporal.io/server/common/searchattribute/sadefs/constants.go · 396 LOC sadefs/constants.go go.temporal.io/server/common/tasks/priority.go · 81 LOC tasks/priority.go go.temporal.io/server/common/util.go · 791 LOC common/util.go go.temporal.io/server/common/util/wildcard.go · 50 LOC util/wildcard.go go.temporal.io/server/service/history/tasks/category.go · 123 LOC tasks/category.go go.temporal.io/server/service/history/tasks/key.go · 144 LOC tasks/key.go TestOperatorServiceMetadata · introduced test · go.temporal.io/server/common/api/TestOperatorServiceMetadata TestOperatorServiceMetad… TestWorkflowServiceMetadata · introduced test · go.temporal.io/server/common/api/TestWorkflowServiceMetadata TestWorkflowServiceMetad… TestTSCBWithDynamicSettings · introduced test · go.temporal.io/server/common/circuitbreaker/TestTSCBWithDynamicSettings TestTSCBWithDynamicSetti… TestDeepCopy_OtherReferenceTypes_Nil · introduced test · go.temporal.io/server/common/dynamicconfig/TestDeepCopy_OtherReferenceTypes_Nil TestDeepCopy_OtherRefere… TestMutexMapBaggage · introduced test · go.temporal.io/server/common/metrics/TestBaggageBenchSuite/TestMutexMapBaggage TestMutexMapBaggage TestSyncMapBaggage · introduced test · go.temporal.io/server/common/metrics/TestBaggageBenchSuite/TestSyncMapBaggage TestSyncMapBaggage TestHistoryTaskQueueManager_ReadTasks_ErrDeserializeRawHistoryTask · introduced test · go.temporal.io/server/common/persistence/TestHistoryTaskQueueManager_ReadTasks_ErrDeserializeRawHistoryTask TestHistoryTaskQueueMana… (a,b_c)_and_(a_b,c) · introduced test · go.temporal.io/server/common/persistence/TestQueueKey_Conflicts/(a,b_c)_and_(a_b,c) (a,b_c)_and_(a_b,c) (x_,x)_and_(x,_x) · introduced test · go.temporal.io/server/common/persistence/TestQueueKey_Conflicts/(x_,x)_and_(x,_x) (x_,x)_and_(x,_x) TestQueueKey_Determinism · introduced test · go.temporal.io/server/common/persistence/TestQueueKey_Determinism TestQueueKey_Determinism TestAPITypeCallOriginPriorityOverrideMapping · introduced test · go.temporal.io/server/common/persistence/client/TestQuotasSuite/TestAPITypeCallOriginPriorityOverrideMapping TestAPITypeCallOriginPri… TestBackgroundTypeAPIPriorityOverrideMapping · introduced test · go.temporal.io/server/common/persistence/client/TestQuotasSuite/TestBackgroundTypeAPIPriorityOverrideMapping TestBackgroundTypeAPIPri… TestCallerTypeDefaultPriorityMapping · introduced test · go.temporal.io/server/common/persistence/client/TestQuotasSuite/TestCallerTypeDefaultPriorityMapping TestCallerTypeDefaultPri… TestRequestPrioritiesOrdered · introduced test · go.temporal.io/server/common/persistence/client/TestQuotasSuite/TestRequestPrioritiesOrdered TestRequestPrioritiesOrd… TestDbFields_LastField_Version · introduced test · go.temporal.io/server/common/persistence/sql/sqlplugin/TestDbFields_LastField_Version TestDbFields_LastField_V… TestGetDbIndexSearchAttributesDefault · introduced test · go.temporal.io/server/common/searchattribute/sadefs/TestGetDbIndexSearchAttributesDefault TestGetDbIndexSearchAttr… TestValidateSqlDbSystemNameToColNameMap · introduced test · go.temporal.io/server/common/searchattribute/sadefs/TestValidateSqlDbSystemNameToColNameMap TestValidateSqlDbSystemN… TestAPIPrioritiesOrdered · introduced test · go.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIPrioritiesOrdered TestAPIPrioritiesOrdered TestAPIToPriorityMapping · introduced test · go.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIToPriorityMapping TestAPIToPriorityMapping Focused concept · history_task_queue_manager.go ×1 · 2 introduced LOC history_task_queue_manag…
Graph controls are ready.
Interactive rendering requires JavaScript and WebGL. Use the native relationship evidence on this page while the interactive map is unavailable.
JavaScript is disabled; use the native relationship evidence on this page to explore the same evidence.
Native relationship evidence
Every exact file and test below is linked only from the concept that introduces it.
Introduced tests
Every collected test enters the hierarchy at exactly one concept.
1 test introduced at this concept.
Introduced code
Every collected source range enters the hierarchy at exactly one concept.
1 file ranked by introduced lines: 2 introduced LOC across 1 ranges.
Expand a file to inspect source; the > gutter marks introduced lines.
go.temporal.io/server/common/persistence/history_task_queue_manager.go 2 introduced LOC · 1 range
Open complete file
133
err := serialization . Decode ( message . Data , & task )
134
if err != nil {
136
>
}
137
responseTasks [ i ]. MessageMetadata = message . MetaData
138
responseTasks [ i ]. Payload = & task