pri_backlog_manager.go ×1
Frontier kind: Code frontier
unlabeled · c_b3733d8c225d
206 tests · 3252 LOC · 149 files · introduces 0 tests · 10 LOC · 3 files
Introduces — evidence that enters the hierarchy at this concept
Code
3 ranges 10 lines · 3 files
Tests
0 tests
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.
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.
pri_backlog_manager.go ×1 Introduced files:
request_response.pb.go ×12 Introduced files:
pri_task_writer.go ×3 Introduced files:
service_grpc.pb.go ×19 Introduced files:
task_queue_partition_manager.go ×2 Introduced files:
Introduced tests:
TestAddConsumeWorkflowTasksDBErrors Introduced tests:
DataLoss Introduced tests:
Internal Introduced tests:
pri_task_writer.go ×1 Introduced files:
DataLoss Introduced tests:
Internal Introduced tests:
ObsoleteMatchingTask Introduced tests:
TestLesserNumberOfPollersThanTasksNoDBErrors Introduced tests:
TestPollWorkflowTaskQueues_DataLossError Introduced tests:
TestPollWorkflowTaskQueues_InternalError Introduced tests:
TestAddConsumeWorkflowTasksNoDBErrors Introduced tests:
ObsoleteMatchingTask Introduced tests:
ActivityStartDuringTransition Introduced tests:
NotFound Introduced tests:
ObsoleteDispatchBuildId Introduced tests:
TestPollActivityTaskQueues_DataLossError Introduced tests:
TestPollActivityTaskQueues_InternalError Introduced tests:
TaskAlreadyStarted Introduced tests:
ObsoleteDispatchBuildId Introduced tests:
TestDemotedMatch Introduced tests:
TaskAlreadyStarted Introduced tests:
DataLoss Introduced tests:
Internal Introduced tests:
DataLoss Introduced tests:
Internal Introduced tests:
ObsoleteMatchingTask Introduced tests:
TestAddConsumeWorkflowTasksNoDBErrors Introduced tests:
TestPollWorkflowTaskQueues_DataLossError Introduced tests:
TestPollWorkflowTaskQueues_InternalError Introduced tests:
TestDroppedTaskMetric_LabelKeysAreVersionScoped Introduced tests:
ObsoleteMatchingTask Introduced tests:
ActivityStartDuringTransition Introduced tests:
TestDemotedMatch Introduced tests:
NotFound Introduced tests:
ObsoleteDispatchBuildId Introduced tests:
TaskAlreadyStarted Introduced tests:
TestPollActivityTaskQueues_DataLossError Introduced tests:
TestPollActivityTaskQueues_InternalError Introduced tests:
ObsoleteDispatchBuildId Introduced tests:
TaskAlreadyStarted Introduced tests:
ResourceExhausted Introduced tests:
NamespaceHandover Introduced tests:
TestDroppedTaskMetric_LabelKeysAreVersionScoped Introduced tests:
TestPollWorkflowTaskQueues_NamespaceHandover Introduced tests:
NamespaceHandover Introduced tests:
ResourceExhausted Introduced tests:
TestUnknownBuildId_Match Introduced tests:
fair_task_reader.go ×2 Introduced files:
TestUnknownBuildId_Match Introduced tests:
TestPollWorkflowTaskQueues, TestPollWorkflowTaskQueues Introduced tests:
TestFailAddTaskWithHistoryExhausted, TestFailAddTaskWithHistoryExhausted Introduced tests:
pri_backlog_manager.go ×1 Introduced files:
fair_task_writer.go ×1 Introduced files:
db.go ×2 Introduced files:
util.go ×1 Introduced files:
TestAddWorkflowTasks Introduced tests:
TestAddActivityTasks Introduced tests:
pri_task_writer.go ×2 Introduced files:
Introduced tests:
TestAddWorkflowAutoEnable Introduced tests:
TestFailAddTaskWithHistoryError, TestFailAddTaskWithHistoryError Introduced tests:
fair_backlog_manager.go ×5 Introduced files:
TestAddWorkflowTasks Introduced tests:
TestSkipAutoEnable Introduced tests:
TestAddActivityTasks Introduced tests:
TestAddWorkflowAutoEnable Introduced tests:
TestForceUnloadTaskQueue, TestForceUnloadTaskQueue Introduced tests:
pri_task_writer.go ×5 Introduced files:
task_queue_partition_manager.go ×6 Introduced files:
task_queue_partition_manager.go ×1 Introduced files:
TestLogicalBacklogMetrics_CurrentOnly Introduced tests:
TestRedirectRuleLoadUpstream Introduced tests:
TestLogicalBacklogMetrics_CurrentAndRamping Introduced tests:
TestLogicalBacklogMetrics_BreakdownByBuildIDDisabled Introduced tests:
TestLogicalBacklogMetrics_SmallBacklog Introduced tests:
TestNoRecentPollerMetric_NewlyLoadedPartitionWithRecentPollers Introduced tests:
TestDescribeTaskQueuePartition_UnloadedVersionedQueues Introduced tests:
task_queue_partition_manager.go ×2 Introduced files:
TestTaskAddHooks_NotRateLimited, TestTaskAddHooks_AddHookNoSyncMatch Introduced tests:
TestGetTaskQueueUserData_LongPoll_WakesUp_FromNothing Introduced tests:
TestSyncDeploymentUserData_UpdateRoutingConfig_MigratesOldVersionsToNewFormat Introduced tests:
TestSyncDeploymentUserData_UpdateRoutingConfig_MigratesOldVersionsToNewFormat Introduced tests:
TestGetTaskQueueUserData_LongPoll_WakesUp_FromNothing Introduced tests:
TestSyncDeploymentUserData_ForgetOldFormat_RemovesNewFormatMembership Introduced tests:
TestSyncDeploymentUserData_ForgetOldFormat_RemovesNewFormatMembership Introduced tests:
TestGetTaskQueueUserData_LongPoll_WakesUp_From2to3 Introduced tests:
TestGetTaskQueueUserData_LongPoll_WakesUp_From2to3 Introduced tests:
TestSyncDeploymentUserData_ForgetNewFormat_RemovesOldFormatMembership Introduced tests:
TestSyncDeploymentUserData_ForgetNewFormat_RemovesOldFormatMembership Introduced tests:
TestSyncDeploymentUserData_UnsetOldFormatRamp_ClearsNewFormatRamp Introduced tests:
TestSyncDeploymentUserData_UnsetOldFormatRamp_ClearsNewFormatRamp Introduced tests:
TestSyncDeploymentUserData_OldFormatSetSameCurrent_ClearsNewFormatCurrent Introduced tests:
TestSyncDeploymentUserData_OldFormatSetSameCurrent_ClearsNewFormatCurrent Introduced tests:
TestSyncDeploymentUserData_CleanupOldDeletedVersions Introduced tests:
TestSyncDeploymentUserData_CleanupOldDeletedVersions Introduced tests:
TestSyncDeploymentUserData_DeletedVersionRemovesOldFormat Introduced tests:
TestSyncDeploymentUserData_DeletedVersionRemovesOldFormat Introduced tests:
TestSyncDeploymentUserData_NewDeploymentDataRemovesOldVersions Introduced tests:
TestSyncDeploymentUserData_NewDeploymentDataRemovesOldVersions Introduced tests:
TestSyncDeploymentUserData_VersionDataRevisionGating Introduced tests:
TestPollWorkflowTaskQueuesEmptyResultWithShortContext Introduced tests:
TestPollWorkflowTaskQueuesEmptyResultWithShortContext Introduced tests:
TestSyncDeploymentUserData_UpsertAndForgetVersions_WithoutRoutingConfig Introduced tests:
TestSyncDeploymentUserData_UpsertAndForgetVersions_WithoutRoutingConfig Introduced tests:
TestPollWorkflowTaskQueuesEmptyResult Introduced tests:
TestPollWorkflowTaskQueuesEmptyResult Introduced tests:
TestSyncDeploymentUserData_RoutingConfigRevisionGating Introduced tests:
TestSyncDeploymentUserData_RoutingConfigRevisionGating Introduced tests:
TestPollActivityTaskQueuesEmptyResultWithShortContext Introduced tests:
TestPollActivityTaskQueuesEmptyResultWithShortContext Introduced tests:
TestPollActivityTaskQueuesEmptyResult Introduced tests:
TestPollActivityTaskQueuesEmptyResult Introduced tests:
TestNoRecentPollerMetric_NewlyLoadedPartitionWithNoRecentPoller Introduced tests:
TestGetVersioningData Introduced tests:
TestGetVersioningData Introduced tests:
TestTaskAddHooks_MultipleHooksInvoked Introduced tests:
TestSyncDeploymentUserData_UpsertedVersionsData Introduced tests:
TestSyncDeploymentUserData_UpsertedVersionsData Introduced tests:
TestLogicalBacklogMetrics_NoVersioning Introduced tests:
TestAddWorkflowTasksForwarded Introduced tests:
TestAddWorkflowTasksForwarded Introduced tests:
TestTaskAddHooks_RateLimited Introduced tests:
TestTaskAddHooks_QueryDispatch_UsesSelectedQueueVersion Introduced tests:
TestPollWithExpiredContext Introduced tests:
TestPollWithExpiredContext Introduced tests:
TestTaskAddHooks_AddHookSyncMatch Introduced tests:
TestUnloadOnMembershipChange Introduced tests:
TestUnloadOnMembershipChange Introduced tests:
TestGetTaskQueueUserData_LongPoll_Expires Introduced tests:
TestGetTaskQueueUserData_LongPoll_Expires Introduced tests:
TestTaskAddHooks_ForwardedSyncMatch_HooksNotInvoked Introduced tests:
TestGetTaskQueueUserData_LongPoll_Closes Introduced tests:
TestGetTaskQueueUserData_LongPoll_Closes Introduced tests:
TestTaskAddHooks_NexusDispatch_FiresWhenNoPollers Introduced tests:
TestGetTaskQueueUserData_ReturnsData Introduced tests:
TestGetTaskQueueUserData_ReturnsData Introduced tests:
TestUpdateUserData_FailsOnKnownVersionMismatch Introduced tests:
TestUpdateUserData_FailsOnKnownVersionMismatch Introduced tests:
TestGetTaskQueueUserData_ReturnsEmpty Introduced tests:
TestGetTaskQueueUserData_ReturnsEmpty Introduced tests:
TestUpdateTaskQueuePartitionGauge_NonRootPartition Introduced tests:
physical_task_queue_manager.go ×1 Introduced files:
Introduced tests:
TestGetTaskQueueUserData_NoData Introduced tests:
TestGetTaskQueueUserData_NoData Introduced tests:
TestTaskAddHooks_QueryDispatch_FiresWhenNoPollers Introduced tests:
TestUpdateTaskQueuePartitionGauge_RootPartitionWorkflowType Introduced tests:
TestUpdateTaskQueuePartitionGauge_RootPartitionWorkflowType Introduced tests:
TestUpdatePhysicalTaskQueueGauge_UnVersioned, TestUpdateTaskQueuePartitionGauge_RootPartitionActivityType Introduced tests:
TestUpdatePhysicalTaskQueueGauge_UnVersioned, TestUpdateTaskQueuePartitionGauge_RootPartitionActivityType Introduced tests:
TestTaskAddHooks_QueryDispatch_DoesNotFireWithRecentPoller Introduced tests:
TestTaskAddHooks_NexusDispatch_DoesNotFireForForwardedTask Introduced tests:
TestTaskAddHooks_ForwardedNoSyncMatch_HooksNotInvoked Introduced tests:
TestTaskQueueManager_CyclingBehavior Introduced tests:
TestTaskQueueManager_CyclingBehavior Introduced tests:
TestTaskAddHooks_QueryDispatch_DoesNotFireForForwardedQuery Introduced tests:
pri_task_reader.go ×3 Introduced files:
pri_matcher.go ×2 Introduced files:
TestAddTaskStandby Introduced tests:
TestDrainCompletionNoReloadDraining Introduced tests:
TestTQMInterruptsPollOnClose Introduced tests:
pri_backlog_manager.go ×5 Introduced files:
TestCheckIdleTaskQueue Introduced tests:
physical_task_queue_manager.go ×3 Introduced files:
physical_task_queue_manager.go ×1 Introduced files:
physical_task_queue_manager.go ×1 Introduced files:
pri_task_reader.go ×4 Introduced files:
TestSkipExpiredTasks_ExpiredThenValid, TestSkipExpiredTasks_ValidExpiredValid Introduced tests:
TestExpiredTasksOnRead_EmitTasksDropped Introduced tests:
pri_metrics_handler.go ×2 Introduced files:
pri_task_reader.go ×1 Introduced files:
pri_task_reader.go ×1 Introduced files:
TestApproximateBacklogCount_IncrementedBySpoolTask Introduced tests:
TestBypassReader Introduced tests:
pri_task_reader.go ×1 Introduced files:
TestApproximateBacklogCount_NotIncrementedBySpoolTask_PersistenceLimit Introduced tests:
TestApproximateBacklogCount_NotIncrementedBySpoolTask_ConcurrentLimit Introduced tests:
TestApproximateBacklogCount_IncrementedBySpoolTask_Unavailable Introduced tests:
pri_task_reader.go ×1 Introduced files:
pri_task_writer.go ×1 Introduced files:
Introduced tests:
pri_task_reader.go ×6 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
TestSyncState_UnloadsOnOwnershipLoss Introduced tests:
pri_task_writer.go ×1 Introduced files:
pri_task_reader.go ×1 Introduced files:
pri_task_reader.go ×1 Introduced files:
pri_task_reader.go ×13 Introduced files:
pri_task_reader.go ×5 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
pri_backlog_manager.go ×2 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
db.go ×1 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
pri_backlog_manager.go ×1 Introduced files:
pri_backlog_manager.go ×9 Introduced files:
config.go ×1 Introduced files:
physical_task_queue_key.go ×2 Introduced files:
config.go ×1 Introduced files:
pri_task_reader.go ×2 Introduced files:
db.go ×1 Introduced files:
db.go ×1 Introduced files:
db.go ×11 Introduced files:
config.go ×1 Introduced files:
physical_task_queue_key.go ×2 Introduced files:
db.go ×1 Introduced files:
backlog_age_tracker.go ×1 Introduced files:
config.go ×1 Introduced files:
setting_gen.go ×2 Introduced files:
physical_task_queue_key.go ×1 Introduced files:
physical_task_queue_key.go ×1 Introduced files:
fair_level.go ×1 Introduced files:
physical_task_queue_key.go ×1 Introduced files:
task_queue_id.go ×4 Introduced files:
Introduced tests:
tasks.pb.go ×3 Introduced files:
message.pb.go ×2 Introduced files:
tasks.pb.go ×1 Introduced files:
tasks.pb.go ×1 Introduced files:
message.pb.go ×2 Introduced files:
retrypolicy.go ×1 Introduced files:
util.go ×1 Introduced files:
TestExecutionInfo_Marshal_Cloud Introduced tests:
state.pb.go ×2 Introduced files:
TestAPIPrioritiesOrdered, TestCallerTypeToPriorityMapping Introduced tests:
operation.pb.go ×2 Introduced files:
message.pb.go ×2 Introduced files:
statemachine.go ×1 Introduced files:
query_converter_util_legacy.go ×3 Introduced files:
execution_maps.go ×6 Introduced files:
execution_maps.go ×5 Introduced files:
execution_maps.go ×5 Introduced files:
fx.go ×1 Introduced files:
Introduced tests:
testconstructors.go ×1 Introduced files:
testconstructors.go ×1 Introduced files:
activity_state.pb.go ×2 Introduced files:
testconstructors.go ×1 Introduced files:
util.go ×2 Introduced files:
testconstructors.go ×1 Introduced files:
visibility_store.go ×3 Introduced files:
constants.go ×1 Introduced files:
visibility.go ×2 Introduced files:
Introduced tests:
constants.go ×1 Introduced files:
message.pb.go ×2 Introduced files:
Introduced tests:
util.go ×1 Introduced files:
util.go ×1 Introduced files:
constants.go ×2 Introduced files:
data_interfaces.go ×3 Introduced files:
message.pb.go ×2 Introduced files:
fixed_address_translator.go ×2 Introduced files:
task.pb.go ×1 Introduced files:
extension.pb.go ×2 Introduced files:
message.pb.go ×1 Introduced files:
softassert.go ×2 Introduced files:
stale_partition_counts.go ×1 Introduced files:
time.go ×1 Introduced files:
message.pb.go ×1 Introduced files:
search_attribute.go ×1 Introduced files:
time.go ×1 Introduced files:
noop_moving_window_average.go ×1 Introduced files:
test_impl.go ×2 Introduced files:
search_attribute.go ×12 Introduced files:
workflow_key.go ×1 Introduced files:
key.go ×1 Introduced files:
setting_gen.go ×1 Introduced files:
collection.go ×1 Introduced files:
collection.go ×1 Introduced files:
collection.go ×1 Introduced files:
collection.go ×1 Introduced files:
message.pb.go ×2 Introduced files:
setting_gen.go ×1 Introduced files:
setting_gen.go ×1 Introduced files:
setting_gen.go ×1 Introduced files:
setting_gen.go ×1 Introduced files:
setting_gen.go ×1 Introduced files:
collection.go ×1 Introduced files:
collection.go ×2 Introduced files:
priority.go ×1 Introduced files:
setting_gen.go ×51 Introduced files:
Introduced tests:
testconstructors.go ×1 Introduced files:
testconstructors.go ×1 Introduced files:
testconstructors.go ×2 Introduced files:
duration.go ×2 Introduced files:
namespace.go ×1 Introduced files:
mutate.go ×1 Introduced files:
mutate.go ×1 Introduced files:
namespace.go ×3 Introduced files:
grpc_resolver.go ×2 Introduced files:
message.pb.go ×1 Introduced files:
duration.go ×1 Introduced files:
message.pb.go ×1 Introduced files:
namespace.go ×1 Introduced files:
namespace.go ×1 Introduced files:
replication_resolver.go ×1 Introduced files:
sm.go ×1 Introduced files:
util.go ×1 Introduced files:
predicates.pb.go ×21 Introduced files:
service.pb.go ×2 Introduced files:
message.pb.go ×2 Introduced files:
constants.go ×3 Introduced files:
Introduced tests:
constants.go ×1 Introduced files:
Introduced tests:
constants.go ×1 Introduced files:
task.pb.go ×1 Introduced files:
message.pb.go ×2 Introduced files:
task_queue_id.go ×1 Introduced files:
defs.go ×1 Introduced files:
metrics.go ×1 Introduced files:
defs.go ×5 Introduced files:
Introduced tests:
task_queue_id.go ×1 Introduced files:
noop_logger.go ×1 Introduced files:
zap_tag.go ×1 Introduced files:
tags.go ×9 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
task_queue_id.go ×1 Introduced files:
message.pb.go ×2 Introduced files:
cluster.pb.go ×2 Introduced files:
retry.go ×1 Introduced files:
retry.go ×1 Introduced files:
retry.go ×2 Introduced files:
route.go ×6 Introduced files:
retrypolicy.go ×2 Introduced files:
wildcard.go ×1 Introduced files:
retrypolicy.go ×1 Introduced files:
retrypolicy.go ×1 Introduced files:
wildcard.go ×4 Introduced files:
future_impl.go ×2 Introduced files:
retrypolicy.go ×3 Introduced files:
future_impl.go ×1 Introduced files:
message.pb.go ×2 Introduced files:
time_source.go ×1 Introduced files:
Introduced tests:
future_impl.go ×1 Introduced files:
payload.go ×1 Introduced files:
route.go ×1 Introduced files:
route.go ×1 Introduced files:
time_source.go ×1 Introduced files:
TestOperatorServiceMetadata, TestWorkflowServiceMetadata Introduced tests:
Introduced tests
Every collected test enters the hierarchy at exactly one concept.
No tests are introduced at this concept. Its intent tests are introduced by other concepts.
Introduced code
Every collected source range enters the hierarchy at exactly one concept.
3 files ranked by introduced lines: 10 introduced LOC across 3 ranges.
Expand a file to inspect source; the > gutter marks introduced lines.
go.temporal.io/server/service/matching/pri_backlog_manager.go 6 introduced LOC · 1 range
Open complete file
124
}
125
127
>
// Maybe try to write one final update of ack level. Skip the update if we never
128
>
// initialized. Also skip if we're stopping due to lost ownership (the update will
129
>
// fail in that case). Ignore any errors. Don't bother with GC, the next reload will
130
>
// handle that.
131
>
if ! c . initializedError . Ready () || c . skipFinalUpdate . Load () {
132
return
133
}
go.temporal.io/server/service/matching/pri_task_reader.go 2 introduced LOC · 1 range
Open complete file
162
for {
163
select {
165
>
return
166
case <- tr . notifyC :
167
}
go.temporal.io/server/service/matching/pri_task_writer.go 2 introduced LOC · 1 range
Open complete file
174
}
175
177
>
return
178
}
179
}