buffer.go ×2

Frontier kind: Code frontier

unlabeled · c_4c57c5fd638b

28 tests · 6 LOC · 1 file · introduces 0 tests · 6 LOC · 1 file

Introduces — evidence that enters the hierarchy at this concept

Code: 2 ranges6 lines · 1 files
Tests: 0 tests

Contains — complete concept membership

All code (extent): 2 ranges6 lines · 1 file · Browse complete extent
All tests (intent): 28 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.

Native relationship evidence

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

buffer.go ×2 — Focused concept Introduced files:
- go.temporal.io/server/common/effect/buffer.go
api.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/persistence/history_manager_util.go
- go.temporal.io/server/service/history/api/get_history_util.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestWorkflowTaskCompletedHandlerSuite/TestUpdateWorkflow/GetHistory_failed
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedSingleActivityScheduledAttribute
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/history/shard/context_testutil.go
- go.temporal.io/server/service/history/workflow/workflow_task_state_machine.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngine2Suite/TestRespondWorkflowTaskCompleted_StartChildWorkflow_ExceedsLimit
Write_failed_on_normal_task_queue — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestWorkflowTaskCompletedHandlerSuite/TestUpdateWorkflow/Write_failed_on_normal_task_queue
api.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/testing/testvars/test_vars.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestWorkflowTaskCompletedHandlerSuite/TestUpdateWorkflow/Write_failed_on_sticky_task_queue
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedConflictOnUpdate
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestStarTimer_DuplicateTimerID
command_attr_validator.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/command_attr_validator.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedBadCommandAttributes
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedCompleteWorkflowFailed
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedFailWorkflowFailed
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/history/workflow/workflow_task_state_machine.go
update.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/update/update.go
api.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestWorkflowTaskCompletedHandlerSuite/TestWorkflowTaskCompletionPagination/Per_workflow_buffer_overflow_terminates_the_workflow
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestCancelTimer_RespondWorkflowTaskCompleted_NoStartTimer
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRequestCancel_RespondWorkflowTaskCompleted_NotScheduled
tags.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/log/tag/tags.go
mutable_state_impl.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
mutable_state_impl.go ×5 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/namespace/mutate.go
- go.temporal.io/server/common/namespace/namespace.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
- go.temporal.io/server/service/history/workflow/workflow_task_state_machine.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedBadBinary
TestRespondWorkflowTaskCompletedUpdateExecutionFailed — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedUpdateExecutionFailed
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
api.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompleted_WorkflowTaskHeartbeatTimeout
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
api.go ×8 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
api.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedSignalExternalWorkflowFailed_UnKnownNamespace
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
Buffer_lost_on_eviction_between_pages — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestWorkflowTaskCompletedHandlerSuite/TestWorkflowTaskCompletionPagination/Buffer_lost_on_eviction_between_pages
Buffer_lost_when_an_intermediate_page_is_missing — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestWorkflowTaskCompletedHandlerSuite/TestWorkflowTaskCompletionPagination/Buffer_lost_when_an_intermediate_page_is_missing
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
context.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/context.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestWorkflowTaskCompletedHandlerSuite/TestWorkflowTaskCompletionPagination/Empty_intermediate_page_is_rejected
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestWorkflowTaskCompletedHandlerSuite/TestWorkflowTaskCompletionPagination/Pagination_request_rejected_when_pagination_is_disabled
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
update.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/update/update.go
Introduced tests:
- go.temporal.io/server/service/history/workflow/update/TestUpdateState/in_stateSent/fail_to_transition_to_stateAccepted/stateCompleted_on_store_write_failure
update.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/update/update.go
update.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/update/update.go
Introduced tests:
- go.temporal.io/server/service/history/workflow/update/TestUpdateState/in_stateSent/fail_to_transition_to_stateRejected_on_store_write_failure
fail_to_transition_to_stateCompleted_on_store_write_failure — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/workflow/update/TestUpdateState/in_stateAccepted/fail_to_transition_to_stateCompleted_on_store_write_failure
update.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/update/state.go
- go.temporal.io/server/service/history/workflow/update/update.go
Introduced tests:
- go.temporal.io/server/service/history/workflow/update/TestUpdateState/in_stateCreated/fail_to_transition_to_stateAdmitted_on_store_write_failure
update.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/update/update.go
update.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/update/update.go
TestBufferApplyAfterCancel — Ancestor (broader) Introduced tests:
- go.temporal.io/server/common/effect/TestBufferApplyAfterCancel
TestBufferCancelAfterApply — Ancestor (broader) Introduced tests:
- go.temporal.io/server/common/effect/TestBufferCancelAfterApply
buffer.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/effect/buffer.go
Introduced tests:
- go.temporal.io/server/common/effect/TestBufferRollbackOrder
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: 6 introduced LOC across 2 ranges. Expand a file to inspect source; the > gutter marks introduced lines.

go.temporal.io/server/common/effect/buffer.go 6 introduced LOC · 2 ranges

Open complete file

  41
  
  // that they were added to this Buffer.
  
  42
  
  // It returns true if any effects were canceled.
  
  43
  >
  func (b *Buffer) Cancel(ctx context.Context) bool {
  
buffer.go

  44
  >
  	canceled := false
  
  45
  >
  	b.effects = nil
  
  46
  >
  	for i := len(b.cancels) - 1; i >= 0; i-- {
  
  47
  
  		b.cancels[i](ctx)
  
  48
  
  		canceled = true
  
  49
  
  	}
  
  50
  >
  	b.cancels = nil
  
buffer.go

  51
  >
  	return canceled
  
  52
  
  }

buffer.go ×2

Introduces — evidence that enters the hierarchy at this concept

Contains — complete concept membership

Neighbourhood graph

Introduced tests

Introduced code

Direct hierarchy

Parents

Children