invoker.go ×1

Frontier kind: Code frontier

unlabeled · c_2685cc2cc9e8

36 tests · 5054 LOC · 168 files · introduces 0 tests · 8 LOC · 1 file

Introduces — evidence that enters the hierarchy at this concept

Code: 1 range8 lines · 1 files
Tests: 0 tests

Contains — complete concept membership

All code (extent): 1153 ranges5054 lines · 168 files · Browse complete extent
All tests (intent): 36 testsBrowse complete intent

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.

Focus concept
Ancestors (broader)
Descendants (narrower)
Introduced files
Introduced tests

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.

Native relationship evidence

Every exact file and test below is linked only from the concept that introduces it.

invoker.go ×1 — Focused concept Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
TestExecuteTask_RetryableFailure — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestExecuteTask_RetryableFailure
TestExecuteTask_BackoffUsesFrameworkClock — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestExecuteTask_BackoffUsesFrameworkClock
invoker_tasks.go ×5 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
- go.temporal.io/server/common/util.go
TestScheduleBackfillerTask_ConsistentLabels — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestScheduleBackfillerTask_ConsistentLabels
TestBackfillTask_InclusiveStartEnd — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestBackfillTask_InclusiveStartEnd
backfiller_tasks.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/backfiller_tasks.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestBackfillTask_PartialFill
TestExecuteTask_DistinctRequestsCanReuseCompletedWorkflowID — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestExecuteTask_DistinctRequestsCanReuseCompletedWorkflowID
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestExecuteTask_ExceedsMaxActionsPerExecution
TestBackfillTask_CompleteFill — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestBackfillTask_CompleteFill
TestExecuteTask_Basic — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestExecuteTask_Basic
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
invoker_tasks.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
backfiller_tasks.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/backfiller_tasks.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestBackfillTask_TriggerImmediate
backfiller_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/backfiller_tasks.go
scheduler.go ×9 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestUnpause_ResumesProcessing
invoker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestHandleNexusCompletion_ReenablesDeferredStarts
TestGeneratorTask_ExecuteBufferTask_Basic — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestGeneratorTask_ExecuteBufferTask_Basic
TestCreateSchedulerFromMigration_NoRunning — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestCreateSchedulerFromMigration_NoRunning
invoker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestRecordCompletedAction_UpdatesDesiredTimeOnNextPending
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestProcessBufferTask_NeedsCancel
TestProcessBufferTask_BufferOne — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestProcessBufferTask_BufferOne
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestProcessBufferTask_NeedsTerminate
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestProcessBufferTask_PausedDropsAutomatedKeepsManual
TestProcessBufferTask_AllowAll — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestProcessBufferTask_AllowAll
TestProcessBufferTask_RearmsBackedOffRetry — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestProcessBufferTask_RearmsBackedOffRetry
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
invoker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
TestProcessBufferTask_BackingOff — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestProcessBufferTask_BackingOff
TestHandleNexusCompletion_CompletionBeforeStart — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestHandleNexusCompletion_CompletionBeforeStart
TestProcessBufferTask_BackingOffReady — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestProcessBufferTask_BackingOffReady
TestHandleNexusCompletion_Failure — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestHandleNexusCompletion_Failure
scheduler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestHandleNexusCompletion_PauseOnFailure
TestHandleNexusCompletion_Canceled — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestHandleNexusCompletion_Canceled
scheduler.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
TestHandleNexusCompletion_Success — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestHandleNexusCompletion_Success
chasm.pb.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/persistence/v1/chasm.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
chasm.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/persistence/v1/chasm.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
chasm.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/persistence/v1/chasm.pb.go
tasks.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/tasks.pb.go
TestRecordCompletedAction_SingleRunningWorkflow — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestRecordCompletedAction_SingleRunningWorkflow
invoker.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
TestInvoker_AddTasks_AllDeferredEmitsNothing — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestInvoker_AddTasks_AllDeferredEmitsNothing
TestRecordCompletedAction_NoMatchingRequest — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestRecordCompletedAction_NoMatchingRequest
TestRecordCompletedAction_MultipleWorkflows — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestRecordCompletedAction_MultipleWorkflows
invoker_tasks.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
invoker.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
- go.temporal.io/server/chasm/lib/scheduler/invoker_tasks.go
invoker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestExecuteTask_RecordResultIdempotentOnRace
retried_counts_retryable_starts — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestExecuteTask_EventLog/retried_counts_retryable_starts
invoker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
TestCanceledWorkflowDoesNotPauseByDefault — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestCanceledWorkflowDoesNotPauseByDefault
scheduler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
TestExecuteTask_RecordResultIdempotentOnRetryableRace — Ancestor (broader) Introduced tests:
- go.temporal.io/server/chasm/lib/scheduler/TestExecuteTask_RecordResultIdempotentOnRetryableRace
scheduler.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
invoker.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
scheduler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
scheduler.go ×5 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/persistence/v1/chasm.pb.go
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
invoker.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
invoker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
invoker.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
tasks.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/tasks.pb.go
invoker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
invoker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
invoker.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
invoker.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
message.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/schedule/v1/message.pb.go
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
invoker.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
invoker.go ×4 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
message.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/schedule/v1/message.pb.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
message.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
scheduler.go ×19 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/eventlog.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/tasks.pb.go
- go.temporal.io/server/chasm/lib/scheduler/generator.go
- go.temporal.io/server/chasm/lib/scheduler/generator_tasks.go
- go.temporal.io/server/chasm/lib/scheduler/invoker.go
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
- go.temporal.io/server/chasm/lib/scheduler/util.go
- go.temporal.io/server/chasm/search_attribute.go
context.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/context.go
- go.temporal.io/server/chasm/lib/scheduler/config.go
- go.temporal.io/server/chasm/node_backend_mock.go
- go.temporal.io/server/chasm/registry.go
util.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/util.go
util.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/util.go
scheduler.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/scheduler.go
tree.go ×4 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×5 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
search_attribute.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/search_attribute.go
context.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/context.go
- go.temporal.io/server/chasm/registry.go
task.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/task.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
context.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/context.go
- go.temporal.io/server/chasm/tree.go
tree.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/registrable_task.go
- go.temporal.io/server/chasm/tree.go
- go.temporal.io/server/common/metrics/tags.go
node_backend_mock.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/node_backend_mock.go
node_backend_mock.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/node_backend_mock.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×6 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
message.pb.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
chasm_visibility.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/persistence/v1/chasm_visibility.pb.go
- go.temporal.io/server/chasm/tree.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
const.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testvars/const.go
- go.temporal.io/server/common/testing/testvars/test_vars.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
spec.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/service/worker/scheduler/spec.go
field.go ×5 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field.go
spec.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/service/worker/scheduler/spec.go
spec.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/service/worker/scheduler/spec.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×5 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
spec.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/service/worker/scheduler/spec.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
node_backend_mock.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/node_backend_mock.go
testlogger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testlogger/testlogger.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field_internal.go
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
any.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testvars/any.go
- go.temporal.io/server/common/testing/testvars/rand.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
util.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/util/util.go
context.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/context.go
node_backend_mock.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/node_backend_mock.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
field_internal.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field_internal.go
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
spec.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/service/worker/scheduler/spec.go
util.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/util/util.go
util.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/util/util.go
node_backend_mock.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/node_backend_mock.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×4 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
eventlog.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/config.go
- go.temporal.io/server/chasm/lib/scheduler/eventlog.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tags.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/tag/tags.go
eventlog.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/eventlog.go
field_internal.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field_internal.go
- go.temporal.io/server/chasm/tree.go
util.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/util.go
- go.temporal.io/server/service/history/queues/errors/errors.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
test_vars.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testvars/test_vars.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×9 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/component.go
- go.temporal.io/server/chasm/tree.go
any.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testvars/any.go
any.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testvars/any.go
- go.temporal.io/server/common/testing/testvars/rand.go
node_backend_mock.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/node_backend_mock.go
test_vars.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testvars/test_vars.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/callback/gen/callbackpb/v1/message.pb.go
- go.temporal.io/server/chasm/lib/callback/gen/callbackpb/v1/tasks.pb.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
statemachine.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/statemachine.go
chasm.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/persistence/v1/chasm.pb.go
node_backend_mock.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/node_backend_mock.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
registry.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/registry.go
registrable_component.go ×5 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/registrable_component.go
- go.temporal.io/server/chasm/registry.go
tags.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/metrics/tags.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
context.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/context.go
codec.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/serialization/codec.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
registry.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/registry.go
query_converter_util_legacy.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/visibility/store/sql/query_converter_util_legacy.go
registrable_component.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/registrable_component.go
fx.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/client/fx.go
- go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go
- go.temporal.io/server/common/util.go
- go.temporal.io/server/service/history/tasks/category.go
Introduced tests:
- go.temporal.io/server/common/persistence/client/TestQuotasSuite/TestAPITypeCallOriginPriorityOverrideMapping
- go.temporal.io/server/common/persistence/client/TestQuotasSuite/TestBackgroundTypeAPIPriorityOverrideMapping
- go.temporal.io/server/common/persistence/client/TestQuotasSuite/TestCallerTypeDefaultPriorityMapping
- go.temporal.io/server/common/persistence/client/TestQuotasSuite/TestRequestPrioritiesOrdered
parent_pointer.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/parent_pointer.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
parent_pointer.go ×7 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/parent_pointer.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
message.pb.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
path_encoder.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/path_encoder.go
fields_iterator.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/fields_iterator.go
registrable_component.go ×5 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/registrable_component.go
tree.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
path_encoder.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/path_encoder.go
message.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/schedule/v1/message.pb.go
testconstructors.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/testconstructors.go
message.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/schedule/v1/message.pb.go
testconstructors.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/testconstructors.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/schedule/v1/message.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/request_response.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/service.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/tasks.pb.go
util.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/util/util.go
visibility_store.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/visibility/store/elasticsearch/visibility_store.go
tree.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/tree.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/archiver/v1/message.pb.go
Introduced tests:
- go.temporal.io/server/common/archiver/gcloud/connector/TestClientSuite/TestNoGRPCUsage
field.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field.go
field.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field.go
visibility.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/visibility.go
constants.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/searchattribute/sadefs/constants.go
field.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field.go
field.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/contextpropagation/v1/message.pb.go
chasm.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/persistence/v1/chasm.pb.go
field.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field.go
visibility.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/visibility.go
extension.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/routing/v1/extension.pb.go
field_internal.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/field_internal.go
search_attribute.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/search_attribute.go
search_attribute.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/search_attribute.go
noop_moving_window_average.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/aggregate/noop_moving_window_average.go
- go.temporal.io/server/common/persistence/noop_health_signal_aggregator.go
search_attribute.go ×12 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/chasm/v1/message.pb.go
- go.temporal.io/server/api/visibilityservice/v1/request_response.pb.go
- go.temporal.io/server/chasm/library.go
- go.temporal.io/server/chasm/registrable_component.go
- go.temporal.io/server/chasm/search_attribute.go
codec.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/serialization/codec.go
codec.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/serialization/codec.go
workflow_key.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/definition/workflow_key.go
key.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/service/history/tasks/key.go
lru.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/cache/lru.go
lru.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/cache/lru.go
lru.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/cache/lru.go
lru.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/cache/lru.go
priority.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/tasks/priority.go
tags.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/tag/tags.go
setting_gen.go ×51 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/collection.go
- go.temporal.io/server/common/dynamicconfig/deepcopy.go
- go.temporal.io/server/common/dynamicconfig/gradual_change.go
- go.temporal.io/server/common/dynamicconfig/key.go
- go.temporal.io/server/common/dynamicconfig/registry.go
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
- go.temporal.io/server/common/dynamicconfig/shared_structure.go
- go.temporal.io/server/common/util/wildcard.go
Introduced tests:
- go.temporal.io/server/common/circuitbreaker/TestTSCBWithDynamicSettings
- go.temporal.io/server/common/dynamicconfig/TestDeepCopy_OtherReferenceTypes_Nil
- go.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIPrioritiesOrdered
- go.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIToPriorityMapping
testconstructors.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/testconstructors.go
testconstructors.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/testconstructors.go
duration.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/primitives/timestamp/duration.go
namespace.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/namespace.go
namespace.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/namespace.go
mutate.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/mutate.go
namespace.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/namespace.go
- go.temporal.io/server/common/util/util.go
transition_history.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/transitionhistory/transition_history.go
hsm.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/persistence/v1/hsm.pb.go
noop_impl.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/metrics/noop_impl.go
grpc_resolver.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/membership/grpc_resolver.go
duration.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/primitives/timestamp/duration.go
namespace.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/namespace.go
namespace.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/namespace.go
noop_impl.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/metrics/noop_impl.go
util.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/util.go
predicates.pb.go ×21 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/enums/v1/predicate.pb.go
- go.temporal.io/server/api/persistence/v1/predicates.go-helpers.pb.go
- go.temporal.io/server/api/persistence/v1/predicates.pb.go
service.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/adminservice/v1/request_response.pb.go
- go.temporal.io/server/api/adminservice/v1/service.pb.go
- go.temporal.io/server/api/cluster/v1/message.pb.go
- go.temporal.io/server/api/common/v1/api_category.pb.go
- go.temporal.io/server/api/common/v1/dlq.pb.go
- go.temporal.io/server/api/health/v1/message.pb.go
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/historyservice/v1/service.pb.go
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service.pb.go
- go.temporal.io/server/api/namespace/v1/message.pb.go
- go.temporal.io/server/api/replication/v1/message.pb.go
- go.temporal.io/server/api/token/v1/message.pb.go
hsm.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/persistence/v1/hsm.pb.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/errordetails/v1/message.pb.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/history/v1/message.pb.go
- go.temporal.io/server/api/persistence/v1/chasm.pb.go
- go.temporal.io/server/api/persistence/v1/chasm_visibility.pb.go
- go.temporal.io/server/api/persistence/v1/cluster_metadata.pb.go
- go.temporal.io/server/api/persistence/v1/executions.pb.go
- go.temporal.io/server/api/persistence/v1/history_tree.pb.go
- go.temporal.io/server/api/persistence/v1/hsm.pb.go
- go.temporal.io/server/api/persistence/v1/namespaces.pb.go
- go.temporal.io/server/api/persistence/v1/nexus.pb.go
- go.temporal.io/server/api/persistence/v1/predicates.pb.go
- go.temporal.io/server/api/persistence/v1/queue_metadata.pb.go
- go.temporal.io/server/api/persistence/v1/queues.pb.go
- go.temporal.io/server/api/persistence/v1/task_queues.pb.go
- go.temporal.io/server/api/persistence/v1/tasks.pb.go
- go.temporal.io/server/api/persistence/v1/update.pb.go
- go.temporal.io/server/api/persistence/v1/workflow_mutable_state.pb.go
- go.temporal.io/server/api/workflow/v1/message.pb.go
tags.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/metrics/tags.go
defs.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/metrics/defs.go
defs_base.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/metrics/defs_base.go
metrics.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/metrics/metrics.go
tags.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/metrics/tags.go
defs.go ×5 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/metrics/v1/message.pb.go
- go.temporal.io/server/common/build/build.go
- go.temporal.io/server/common/metrics/defs.go
- go.temporal.io/server/common/metrics/defs_base.go
- go.temporal.io/server/common/metrics/noop_impl.go
- go.temporal.io/server/common/metrics/option.go
- go.temporal.io/server/common/metrics/registry.go
Introduced tests:
- go.temporal.io/server/common/metrics/TestBaggageBenchSuite/TestMutexMapBaggage
- go.temporal.io/server/common/metrics/TestBaggageBenchSuite/TestSyncMapBaggage
testlogger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testlogger/testlogger.go
testlogger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testlogger/testlogger.go
zap_logger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/zap_logger.go
zap_logger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/zap_logger.go
zap_tag.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/tag/zap_tag.go
- go.temporal.io/server/common/log/zap_logger.go
with_logger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/with_logger.go
zap_logger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/zap_logger.go
with_logger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/with_logger.go
zap_logger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/zap_logger.go
tags.go ×9 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/tag/tags.go
- go.temporal.io/server/common/log/tag/zap_tag.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/deployment/v1/message.pb.go
- go.temporal.io/server/api/taskqueue/v1/message.pb.go
route.go ×6 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/routing/route.go
retrypolicy.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/backoff/retrypolicy.go
time_source.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/clock/time_source.go
Introduced tests:
- go.temporal.io/server/common/clock/TestNewRealClock_Now
time_source.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/clock/time_source.go
TestOperatorServiceMetadata, TestWorkflowServiceMetadata — Descendant (narrower) Introduced tests:
- go.temporal.io/server/common/api/TestOperatorServiceMetadata
- go.temporal.io/server/common/api/TestWorkflowServiceMetadata

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.

1 file ranked by introduced lines: 8 introduced LOC across 1 ranges. Expand a file to inspect source; the > gutter marks introduced lines.

go.temporal.io/server/chasm/lib/scheduler/invoker.go 8 introduced LOC · 1 range

Open complete file

  346
  
  	lastProcessedTime := i.LastProcessedTime.AsTime()
  
  347
  
  	for _, start := range i.GetBufferedStarts() {
  
  348
  >
  		backoff := start.GetBackoffTime().AsTime()
  
invoker.go

  349
  >
  		// We only care about starts that are retrying.
  
  350
  >
  		if start.GetAttempt() <= 0 ||
  
  351
  >
  			start.GetRunId() != "" ||
  
  352
  >
  			start.GetCompleted() != nil ||
  
  353
  >
  			// Backed-off starts will be selected by getEligibleBufferedStarts and kick off
  
  354
  >
  			// an Execute task, instead.
  
  355
  >
  			start.BackoffTime.AsTime().Before(lastProcessedTime) {
  
  356
  
  			continue
  
  357
  
  		}

invoker.go ×1

Introduces — evidence that enters the hierarchy at this concept

Contains — complete concept membership

Neighbourhood graph

Introduced tests

Introduced code

Direct hierarchy

Parents

Children