setting_gen.go ×3

Frontier kind: Code frontier

unlabeled · c_a295ec958e0e

1377 tests · 2884 LOC · 124 files · introduces 0 tests · 401 LOC · 2 files

Introduces — evidence that enters the hierarchy at this concept

Code: 4 ranges401 lines · 2 files
Tests: 0 tests

Contains — complete concept membership

All code (extent): 377 ranges2884 lines · 124 files · Browse complete extent
All tests (intent): 1377 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.

setting_gen.go ×3 — Focused concept Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
- go.temporal.io/server/service/history/configs/config.go
onebox.go ×75 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/cluster/metadata.go
- go.temporal.io/server/common/log/tag/tags.go
- go.temporal.io/server/common/membership/static/fx.go
- go.temporal.io/server/common/membership/static/monitor.go
- go.temporal.io/server/common/membership/static/service_resolver.go
- go.temporal.io/server/common/metrics/metricstest/capture_handler.go
- go.temporal.io/server/common/persistence/persistence-tests/persistence_test_base.go
- go.temporal.io/server/common/persistence/persistence-tests/setup.go
- go.temporal.io/server/common/persistence/sql/task_queues.go
- go.temporal.io/server/common/persistence/visibility/visibility_manager_impl.go
- go.temporal.io/server/common/persistence/visibility/visibility_manager_rate_limited.go
- go.temporal.io/server/common/persistence/visibility/visiblity_manager_metrics.go
- go.temporal.io/server/common/rpc/interceptor/dc_redirection_policy.go
- go.temporal.io/server/common/rpc/interceptor/namespace_logger.go
- go.temporal.io/server/common/rpc/rpc.go
- go.temporal.io/server/common/searchattribute/test_provider.go
- go.temporal.io/server/common/testing/taskpoller/taskpoller.go
- go.temporal.io/server/common/testing/testhooks/test_impl.go
- go.temporal.io/server/service/frontend/fx.go
- go.temporal.io/server/service/frontend/http_api_server.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/fx.go
- go.temporal.io/server/service/history/fx.go
- go.temporal.io/server/service/matching/db.go
- go.temporal.io/server/service/matching/matching_engine.go
- go.temporal.io/server/temporal/fx.go
- go.temporal.io/server/tests/testcore/clients.go
- go.temporal.io/server/tests/testcore/context.go
- go.temporal.io/server/tests/testcore/flag.go
- go.temporal.io/server/tests/testcore/functional_test_base.go
- go.temporal.io/server/tests/testcore/onebox.go
- go.temporal.io/server/tests/testcore/replication_stream_recorder.go
- go.temporal.io/server/tests/testcore/shared_cluster_t.go
- go.temporal.io/server/tests/testcore/test_cluster.go
- go.temporal.io/server/tests/testcore/test_cluster_pool.go
- go.temporal.io/server/tests/testcore/test_env.go
- go.temporal.io/server/tests/testcore/utils.go
Introduced tests:
- go.temporal.io/server/tests/testcore/TestFunctionalTestBaseSuite/TestWorkerServiceHealthCheck
fx.go ×44 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/adminservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/persistence/v1/cluster_metadata.pb.go
- go.temporal.io/server/chasm/fx.go
- go.temporal.io/server/chasm/lib/activity/activity_tasks.go
- go.temporal.io/server/chasm/lib/activity/config.go
- go.temporal.io/server/chasm/lib/activity/frontend.go
- go.temporal.io/server/chasm/lib/activity/fx.go
- go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/service_client.pb.go
- go.temporal.io/server/chasm/lib/activity/handler.go
- go.temporal.io/server/chasm/lib/activity/library.go
- go.temporal.io/server/chasm/lib/callback/config.go
- go.temporal.io/server/chasm/lib/callback/fx.go
- go.temporal.io/server/chasm/lib/callback/library.go
- go.temporal.io/server/chasm/lib/callback/tasks.go
- go.temporal.io/server/chasm/lib/nexusoperation/cancellation_tasks.go
- go.temporal.io/server/chasm/lib/nexusoperation/config.go
- go.temporal.io/server/chasm/lib/nexusoperation/fx.go
- go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go
- go.temporal.io/server/chasm/lib/nexusoperation/handler.go
- go.temporal.io/server/chasm/lib/nexusoperation/library.go
- go.temporal.io/server/chasm/lib/nexusoperation/operation_tasks.go
- go.temporal.io/server/chasm/lib/nexusoperation/task_handler_base.go
- go.temporal.io/server/chasm/lib/scheduler/config.go
- go.temporal.io/server/chasm/lib/scheduler/fx.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go
- go.temporal.io/server/chasm/lib/scheduler/library.go
- go.temporal.io/server/chasm/lib/tests/fx.go
- go.temporal.io/server/chasm/lib/workflow/fx.go
- go.temporal.io/server/chasm/lib/workflow/library.go
- go.temporal.io/server/chasm/lib/workflow/nexus_service.go
- go.temporal.io/server/chasm/library.go
- go.temporal.io/server/chasm/registry.go
- go.temporal.io/server/client/admin/client.go
- go.temporal.io/server/client/admin/metric_client.go
- go.temporal.io/server/client/admin/retryable_client.go
- go.temporal.io/server/client/client_bean.go
- go.temporal.io/server/client/clientfactory.go
- go.temporal.io/server/client/frontend/client.go
- go.temporal.io/server/client/frontend/metric_client.go
- go.temporal.io/server/client/frontend/retryable_client.go
- go.temporal.io/server/client/history/connections.go
- go.temporal.io/server/client/history/metric_client.go
- go.temporal.io/server/client/history/retryable_client.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/client/matching/client_gen.go
- go.temporal.io/server/client/matching/loadbalancer.go
- go.temporal.io/server/client/matching/metric_client.go
- go.temporal.io/server/client/matching/metric_client_gen.go
- go.temporal.io/server/client/matching/retryable_client.go
- go.temporal.io/server/client/matching/retryable_client_gen.go
- go.temporal.io/server/common/archiver/archival_metadata.go
- go.temporal.io/server/common/authorization/interceptor.go
- go.temporal.io/server/common/client_cache.go
- go.temporal.io/server/common/cluster/frontend_http_client.go
- go.temporal.io/server/common/cluster/fx.go
- go.temporal.io/server/common/cluster/metadata.go
- go.temporal.io/server/common/config/persistence.go
- go.temporal.io/server/common/deadlock/deadlock.go
- go.temporal.io/server/common/deadlock/fx.go
- go.temporal.io/server/common/dynamicconfig/collection.go
- go.temporal.io/server/common/dynamicconfig/fx.go
- go.temporal.io/server/common/log/slog.go
- go.temporal.io/server/common/log/tag/tags.go
- go.temporal.io/server/common/membership/hostinfo_provider.go
- go.temporal.io/server/common/metrics/fx.go
- go.temporal.io/server/common/metrics/grpc_stats.go
- go.temporal.io/server/common/metrics/runtime.go
- go.temporal.io/server/common/namespace/nsregistry/fx.go
- go.temporal.io/server/common/namespace/nsregistry/registry.go
- go.temporal.io/server/common/nexus/trace.go
- go.temporal.io/server/common/persistence/client/factory.go
- go.temporal.io/server/common/persistence/client/fx.go
- go.temporal.io/server/common/persistence/client/health_request_rate_limiter.go
- go.temporal.io/server/common/persistence/client/quotas.go
- go.temporal.io/server/common/persistence/cluster_metadata_store.go
- go.temporal.io/server/common/persistence/health_signal_aggregator.go
- go.temporal.io/server/common/persistence/metadata_manager.go
- go.temporal.io/server/common/persistence/nexus_endpoint_manager.go
- go.temporal.io/server/common/persistence/persistence_metric_clients.go
- go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go
- go.temporal.io/server/common/persistence/persistence_retryable_clients.go
- go.temporal.io/server/common/persistence/shard_manager.go
- go.temporal.io/server/common/persistence/sql/queue.go
- go.temporal.io/server/common/persistence/sql/shard.go
- go.temporal.io/server/common/persistence/visibility/chasm_visibility_manager.go
- go.temporal.io/server/common/persistence/visibility/defs.go
- go.temporal.io/server/common/persistence/visibility/visibility_manager_impl.go
- go.temporal.io/server/common/persistence/visibility/visibility_manager_rate_limited.go
- go.temporal.io/server/common/persistence/visibility/visiblity_manager_metrics.go
- go.temporal.io/server/common/pprof/pprof.go
- go.temporal.io/server/common/quotas/multi_request_rate_limiter_impl.go
- go.temporal.io/server/common/quotas/noop_reservation_impl.go
- go.temporal.io/server/common/resource/fx.go
- go.temporal.io/server/common/rpc/grpc.go
- go.temporal.io/server/common/rpc/interceptor/health.go
- go.temporal.io/server/common/rpc/interceptor/health_check.go
- go.temporal.io/server/common/rpc/interceptor/mask_internal_error.go
- go.temporal.io/server/common/rpc/interceptor/namespace_handover.go
- go.temporal.io/server/common/rpc/interceptor/namespace_logger.go
- go.temporal.io/server/common/rpc/interceptor/namespace_validator.go
- go.temporal.io/server/common/rpc/interceptor/redirection.go
- go.temporal.io/server/common/rpc/interceptor/retry.go
- go.temporal.io/server/common/rpc/interceptor/sdk_version.go
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/common/rpc/multistats.go
- go.temporal.io/server/common/rpc/rpc.go
- go.temporal.io/server/common/sdk/factory.go
- go.temporal.io/server/common/sdk/metrics_handler.go
- go.temporal.io/server/common/tasks/rate_limited_scheduler.go
- go.temporal.io/server/common/util.go
- go.temporal.io/server/common/worker_versioning/version_membership_cache.go
- go.temporal.io/server/components/callbacks/config.go
- go.temporal.io/server/components/callbacks/fx.go
- go.temporal.io/server/components/nexusoperations/config.go
- go.temporal.io/server/components/nexusoperations/fx.go
- go.temporal.io/server/service/frontend/fx.go
- go.temporal.io/server/service/frontend/nexus_completion_http_handler.go
- go.temporal.io/server/service/frontend/nexus_operation_http_handler.go
- go.temporal.io/server/service/frontend/openapi_http_handler.go
- go.temporal.io/server/service/frontend/service.go
- go.temporal.io/server/service/frontend/version_checker.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/fx.go
- go.temporal.io/server/service/history/chasm_engine.go
- go.temporal.io/server/service/history/configs/quotas.go
- go.temporal.io/server/service/history/events/fx.go
- go.temporal.io/server/service/history/fx.go
- go.temporal.io/server/service/history/handler.go
- go.temporal.io/server/service/history/history_engine.go
- go.temporal.io/server/service/history/history_engine_factory.go
- go.temporal.io/server/service/history/memory_scheduled_queue_factory.go
- go.temporal.io/server/service/history/queue_factory_base.go
- go.temporal.io/server/service/history/queues/queue_scheduled.go
- go.temporal.io/server/service/history/queues/scheduler.go
- go.temporal.io/server/service/history/queues/speculative_workflow_task_timeout_queue.go
- go.temporal.io/server/service/history/replication/dlq_handler.go
- go.temporal.io/server/service/history/replication/dlq_writer.go
- go.temporal.io/server/service/history/replication/eventhandler/history_events_handler.go
- go.temporal.io/server/service/history/replication/fx.go
- go.temporal.io/server/service/history/replication/quotas.go
- go.temporal.io/server/service/history/replication/stream_receiver_monitor.go
- go.temporal.io/server/service/history/replication/task_fetcher.go
- go.temporal.io/server/service/history/replication/task_processor_manager.go
- go.temporal.io/server/service/history/service.go
- go.temporal.io/server/service/history/shard/context_impl.go
- go.temporal.io/server/service/history/shard/controller_impl.go
- go.temporal.io/server/service/history/shard/fx.go
- go.temporal.io/server/service/history/timer_queue_factory.go
- go.temporal.io/server/service/history/transfer_queue_factory.go
- go.temporal.io/server/service/history/visibility_queue_factory.go
- go.temporal.io/server/service/history/workflow/cache/fx.go
- go.temporal.io/server/service/history/workflow_rebuilder.go
- go.temporal.io/server/service/matching/configs/quotas.go
- go.temporal.io/server/service/matching/fx.go
- go.temporal.io/server/service/matching/handler.go
- go.temporal.io/server/service/matching/matching_engine.go
- go.temporal.io/server/service/matching/rate_limit_fraction_provider.go
- go.temporal.io/server/service/matching/service.go
- go.temporal.io/server/service/matching/simple_partition_scaler.go
- go.temporal.io/server/service/matching/workers/registry_impl.go
- go.temporal.io/server/service/worker/batcher/fx.go
- go.temporal.io/server/service/worker/deletenamespace/activities.go
- go.temporal.io/server/service/worker/deletenamespace/deleteexecutions/activities.go
- go.temporal.io/server/service/worker/deletenamespace/fx.go
- go.temporal.io/server/service/worker/deletenamespace/reclaimresources/activities.go
- go.temporal.io/server/service/worker/dummy/fx.go
- go.temporal.io/server/service/worker/fx.go
- go.temporal.io/server/service/worker/migration/fx.go
- go.temporal.io/server/service/worker/parentclosepolicy/processor.go
- go.temporal.io/server/service/worker/pernamespaceworker.go
- go.temporal.io/server/service/worker/scheduler/fx.go
- go.temporal.io/server/service/worker/service.go
- go.temporal.io/server/service/worker/worker.go
- go.temporal.io/server/service/worker/workerdeployment/fx.go
- go.temporal.io/server/temporal/fx.go
api.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/get_history_util.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
workflow_task_completed_handler.go ×5 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/history/tasks/signal_task.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestRespondWorkflowTaskCompletedSignalExternalWorkflowSuccess
TestRecordChildExecutionCompleted — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/TestEngine2Suite/TestRecordChildExecutionCompleted
empty_child_first_run_id — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/TestEngine2Suite/TestRecordChildExecutionCompleted_ChildFirstRunId/empty_child_first_run_id
api.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/recordchildworkflowcompleted/api.go
mutable_state_impl.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
workflow_task_completed_handler.go ×4 — 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
command_attr_validator.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/util.go
- go.temporal.io/server/service/history/api/command_attr_validator.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
mutable_state_impl.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
workflow_task_completed_handler.go ×11 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/persistence/v1/executions.pb.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
workflow_size_checker.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_size_checker.go
get_workflow_util.go ×5 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/get_workflow_util.go
- go.temporal.io/server/service/history/api/queryworkflow/api.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngineSuite/TestQueryWorkflow_WorkflowTaskDispatch_Unblocked
mutable_state_impl.go ×6 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/requestcancelworkflow/api.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngine2Suite/TestRequestCancelWorkflowExecution_Running
context_impl.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/context_impl.go
api.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondactivitytaskcompleted/api.go
api.go ×5 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/consistency_checker.go
- go.temporal.io/server/service/history/api/refreshworkflow/api.go
- go.temporal.io/server/service/history/history_engine.go
Introduced tests:
- go.temporal.io/server/service/history/TestEngine2Suite/TestRefreshWorkflowTasks
chasm_engine.go ×5 — Ancestor (broader) Introduced files:
- go.temporal.io/server/chasm/tree.go
- go.temporal.io/server/service/history/chasm_engine.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
mutable_state_impl.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
visibility_queue_task_executor.go ×10 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/persistence/v1/executions.pb.go
- go.temporal.io/server/service/history/queues/metrics.go
- go.temporal.io/server/service/history/visibility_queue_task_executor.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
mutable_state_impl.go ×12 — Ancestor (broader) Introduced files:
- go.temporal.io/server/components/callbacks/tasks.go
- go.temporal.io/server/service/history/outbound_queue_factory.go
- go.temporal.io/server/service/history/tasks/state_machine_task.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
mutate.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/namespace/mutate.go
- go.temporal.io/server/common/namespace/replication_resolver.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
api.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/reapplyevents/api.go
- go.temporal.io/server/service/history/history_engine.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 ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
workflow_task_completed_handler.go ×2 — 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
mutable_state_impl.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
visibility_queue_task_executor.go ×9 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/queues/metrics.go
- go.temporal.io/server/service/history/tasks/start_visibility_task.go
- go.temporal.io/server/service/history/visibility_queue_task_executor.go
worker_versioning_util.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/worker_versioning_util.go
mutable_state_impl.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
test_vars.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/testing/testvars/test_vars.go
api.go ×22 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/service/history/api/consistency_checker.go
- go.temporal.io/server/service/history/api/startworkflow/api.go
- go.temporal.io/server/service/history/history_engine.go
workflow_task_timer.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/tasks/workflow_task_timer.go
api.go ×6 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
link_util.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/link_util.go
task_generator.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/enums/v1/workflow_task_type.pb.go
- go.temporal.io/server/service/history/shard/context_impl.go
- go.temporal.io/server/service/history/tasks/workflow_task_timer.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
- go.temporal.io/server/service/history/workflow/task_generator.go
- go.temporal.io/server/service/history/workflow/workflow_task_state_machine.go
create_workflow_util.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/create_workflow_util.go
chasm_engine.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/chasm_engine.go
consistency_checker.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/consistency_checker.go
chasm_engine.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/chasm_engine.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 ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
api.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/recordworkflowtaskstarted/api.go
worker_versioning.go ×6 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/worker_versioning/worker_versioning.go
context.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/context.go
workflow_task_state_machine.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
- go.temporal.io/server/service/history/workflow/workflow_task_state_machine.go
serializer.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/persistence/serialization/serializer.go
upsert_visibility_task.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/enums/v1/task.pb.go
- go.temporal.io/server/service/history/tasks/upsert_visibility_task.go
context.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/context.go
get_workflow_util.go ×14 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/service/history/api/get_workflow_util.go
transfer_queue_active_task_executor.go ×7 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/transfer_queue_active_task_executor.go
Introduced tests:
- go.temporal.io/server/service/history/TestTransferQueueActiveTaskExecutorSuite/TestExecuteChasmSideEffectTransferTask_ExecutesTask
transfer_queue_standby_task_executor.go ×5 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/queues/metrics.go
- go.temporal.io/server/service/history/transfer_queue_standby_task_executor.go
chasm_engine.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/chasm_engine.go
test_vars.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/testing/testvars/test_vars.go
timer_queue_task_executor_base.go ×6 — Ancestor (broader) Introduced files:
- go.temporal.io/server/components/dummy/statemachine.go
- go.temporal.io/server/components/dummy/tasks.go
- go.temporal.io/server/service/history/hsm/tasks.go
- go.temporal.io/server/service/history/queues/metrics.go
- go.temporal.io/server/service/history/timer_queue_task_executor_base.go
chasm_tree_mock.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/chasm_tree_mock.go
- go.temporal.io/server/service/history/timer_queue_task_executor_base.go
metrics.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/queues/metrics.go
- go.temporal.io/server/service/history/tasks/utils.go
context.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/context.go
transfer_queue_active_task_executor.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/tasks/delete_execution_task.go
- go.temporal.io/server/service/history/tasks/utils.go
- go.temporal.io/server/service/history/transfer_queue_active_task_executor.go
- go.temporal.io/server/service/history/transfer_queue_task_executor_base.go
workflow_state_replicator_mock.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/ndc/workflow_state_replicator_mock.go
statemachine_environment.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/statemachine_environment.go
api.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/getworkflowexecutionrawhistoryv2/api.go
statemachine_environment.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/statemachine_environment.go
request_response.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
chasm_engine.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/chasm_engine.go
request_response.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/service/history/api/getworkflowexecutionrawhistoryv2/api.go
- go.temporal.io/server/service/history/history_engine.go
api.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/getworkflowexecutionrawhistory/api.go
- go.temporal.io/server/service/history/history_engine.go
telemetry.go ×10 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/service/frontend/configs/quotas.go
mutable_state_rebuilder.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/mutable_state_rebuilder.go
workflow_state_replicator.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/ndc/workflow_state_replicator.go
workflow_state_replicator.go ×8 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/ndc/workflow_state_replicator.go
archival_queue_factory.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/archival_queue_factory.go
statemachine_environment.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/statemachine_environment.go
current_run_running — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/TestGetCurrentWorkflowExecutionContext/current_run_running
mutable_state_mock.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestCommandProtocolMessage/deliver_message_success
workflow_resetter.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/ndc/workflow_resetter.go
statemachine_environment.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/statemachine_environment.go
handler.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/common/namespace/registry_mock.go
- go.temporal.io/server/service/history/handler.go
Introduced tests:
- go.temporal.io/server/service/history/TestDescribeHistoryHost
request_response.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
api.go ×11 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/service/history/api/updateworkflowoptions/api.go
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
Introduced tests:
- go.temporal.io/server/service/history/api/updateworkflowoptions/TestUpdateWorkflowOptionsSuite/TestInvoke_Success
namespace.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/namespace/namespace.go
mutable_state_mock.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/api.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/TestWorkflowSuite/Test_CacheRefreshRequired_ReturnCacheStaleError
Test_ActivityTaskDoesNotExist_TokenVersionDoesNotMatchActivityVersion, Test_ActivityTaskDoesNotExist_TokenVersionNonZeroAndAttemptDoesNotMatchActivityAttempt — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/TestWorkflowSuite/Test_ActivityTaskDoesNotExist_TokenVersionDoesNotMatchActivityVersion
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/TestWorkflowSuite/Test_ActivityTaskDoesNotExist_TokenVersionNonZeroAndAttemptDoesNotMatchActivityAttempt
archival_queue_task_executor.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/archival/archiver_mock.go
- go.temporal.io/server/service/history/archival_queue_task_executor.go
- go.temporal.io/server/service/history/interfaces/shard_context_mock.go
ndc_task_util.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/ndc_task_util.go
Test_ActivityTaskDoesNotExist_ActivityNotRunning — Ancestor (broader) Introduced tests:
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/TestWorkflowSuite/Test_ActivityTaskDoesNotExist_ActivityNotRunning
create_workflow_util.go ×14 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/create_workflow_util.go
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/api/respondworkflowtaskcompleted/TestCommandProtocolMessage/deliver_message_failure
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/api.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/TestWorkflowSuite/Test_WorkflowExecutionIsNotRunning_ReturnWorkflowNotRunningError
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondactivitytaskcompleted/api.go
- go.temporal.io/server/service/history/history_engine.go
get_workflow_util.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/service/history/api/get_workflow_util.go
task_fetcher.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/adminservicemock/v1/service_grpc.pb.mock.go
- go.temporal.io/server/service/history/replication/task_fetcher.go
ndc_task_util.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/log/tag/tags.go
- go.temporal.io/server/service/history/ndc_task_util.go
workflow_task_completed_handler.go ×2 — 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/api/respondworkflowtaskcompleted/TestCommandProtocolMessage/update_not_found
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/api.go
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/api/respondworkflowtaskcompleted/TestCommandProtocolMessage/message_for_unsupported_protocol
test_resource.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/resourcetest/test_resource.go
update.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/testing/updateutils/update.go
workflow_task_completed_handler.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_size_checker.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestCommandProtocolMessage/message_too_large
get_history_util.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
stream_sender.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_sender.go
executable.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/queues/executable.go
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/api.go
queue_base.go ×6 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/queues/queue_base.go
- go.temporal.io/server/service/history/queues/reader_quotas.go
- go.temporal.io/server/service/history/shard/context_impl.go
signal_workflow_util.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/signal_workflow_util.go
signal_with_start_workflow.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/signalwithstartworkflow/signal_with_start_workflow.go
Introduced tests:
- go.temporal.io/server/service/history/api/signalwithstartworkflow/TestSignalWithStartWorkflowSuite/TestSignalWorkflow_Dedup
util.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/util.go
dlq_handler.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/dlq_handler.go
task_processor_manager.go ×7 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/shard_context_mock.go
- go.temporal.io/server/service/history/replication/task_fetcher_mock.go
- go.temporal.io/server/service/history/replication/task_processor_manager.go
mutable_state_mock.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
Introduced tests:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/TestHandlePostCommandEagerExecuteActivity
stream_sender.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/replication/v1/message.pb.go
- go.temporal.io/server/service/history/interfaces/shard_context_mock.go
- go.temporal.io/server/service/history/replication/stream_sender.go
resend_handler.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/eventhandler/resend_handler.go
signal_with_start_workflow.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/signalwithstartworkflow/signal_with_start_workflow.go
service_grpc.pb.mock.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/historyservicemock/v1/service_grpc.pb.mock.go
- go.temporal.io/server/service/history/replication/raw_task_converter_mock.go
- go.temporal.io/server/service/history/replication/stream_sender.go
- go.temporal.io/server/service/history/replication/stream_sender_flow_controller_mock.go
queue_factory_base.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/queue_factory_base.go
context.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/rpc/context.go
signal_workflow_util.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/signal_workflow_util.go
archival_queue_task_executor.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/archival_queue_task_executor.go
stream_receiver_monitor.go ×7 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/persistence/v1/queues.pb.go
- go.temporal.io/server/service/history/interfaces/engine_mock.go
- go.temporal.io/server/service/history/replication/stream_receiver_monitor.go
Introduced tests:
- go.temporal.io/server/service/history/replication/TestStreamReceiverMonitorSuite/TestGenerateStatusMap_Success
transaction_impl.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/transaction_impl.go
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
statemachine_environment.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/statemachine_environment.go
ndc_task_util.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/ndc_task_util.go
workflow_size_checker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_size_checker.go
stream_receiver_monitor.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_receiver_monitor.go
stream_receiver_monitor.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_receiver_monitor.go
stream_receiver_monitor.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_receiver_monitor.go
Introduced tests:
- go.temporal.io/server/service/history/replication/TestStreamReceiverMonitorSuite/TestEvaluateStreamStatus
transaction_impl.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/context.go
- go.temporal.io/server/service/history/workflow/transaction_impl.go
util.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/util.go
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
util.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/log/tag/tags.go
- go.temporal.io/server/common/util.go
api.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondactivitytaskfailed/api.go
statemachine_environment.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/statemachine_environment.go
statemachine_environment.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/statemachine_environment.go
transaction_impl.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/metrics.go
- go.temporal.io/server/service/history/workflow/transaction_impl.go
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
data_interfaces_mock.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/persistence/data_interfaces_mock.go
- go.temporal.io/server/service/history/replication/dlq_writer.go
mutable_state_mock.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
scheduler_quotas.go ×7 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/quotas/dynamic_rate_limiter_impl.go
- go.temporal.io/server/service/history/queues/scheduler_quotas.go
mutable_state_mock.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
stream_receiver.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_receiver.go
transaction_impl.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/transaction_impl.go
workflow_task_completed_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
context.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/context.go
transaction_impl.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/transaction_impl.go
scheduler.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/queues/scheduler.go
transaction_impl.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/context.go
- go.temporal.io/server/service/history/workflow/transaction_impl.go
mutable_state_mock.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
service_grpc.pb.mock.go ×6 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/adminservicemock/v1/service_grpc.pb.mock.go
transaction_impl.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/transaction_impl.go
worker_versioning_util.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/worker_versioning_util.go
task.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/enums/v1/task.pb.go
task.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/enums/v1/task.pb.go
multi_request_rate_limiter_impl.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/quotas/multi_request_rate_limiter_impl.go
stream.go ×3 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream.go
executions.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/persistence/v1/executions.pb.go
- go.temporal.io/server/service/history/workflow/relocatable_attributes_fetcher.go
stream.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream.go
controller_mock.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/controller_mock.go
controller_mock.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/controller_mock.go
controller_mock.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/controller_mock.go
stream_receiver_flow_controller.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_receiver_flow_controller.go
tags.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/metrics/tags.go
context_util.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/context_util.go
controller_impl.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/controller_impl.go
- go.temporal.io/server/service/history/shard/ownership.go
tags.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/metrics/tags.go
poller_manager.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/poller_manager.go
- go.temporal.io/server/service/history/replication/task_processor_manager.go
shard_context_mock.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/shard_context_mock.go
shard_context_mock.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/shard_context_mock.go
tags.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/log/tag/tags.go
remote_history_paginated_fetcher.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/eventhandler/remote_history_paginated_fetcher.go
tags.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/common/log/tag/tags.go
context_factory.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/context_factory.go
resend_handler.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/eventhandler/resend_handler.go
stream_receiver.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_receiver.go
stream_receiver_flow_controller.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_receiver_flow_controller.go
mutable_state_mock.go ×2 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
stream_receiver_monitor.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/stream_receiver_monitor.go
executable_task_converter.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/replication/executable_task_converter.go
controller_impl.go ×4 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/controller_impl.go
- go.temporal.io/server/service/history/shard/ownership.go
mutable_state_mock.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
mutable_state_mock.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/interfaces/mutable_state_mock.go
workflow_lease.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/workflow_lease.go
cache.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/cache/cache.go
relocatable_attributes_fetcher.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/workflow/relocatable_attributes_fetcher.go
consistency_checker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/api/consistency_checker.go
message.pb.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/api/clock/v1/message.pb.go
handover_tracker.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/handover_tracker.go
delete_manager.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/deletemanager/delete_manager.go
task_key_manager.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/shard/task_key_manager.go
vars.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/tests/vars.go
event_store.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/historybuilder/event_store.go
- go.temporal.io/server/service/history/historybuilder/history_builder.go
event_store.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/historybuilder/event_store.go
event_store.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/historybuilder/event_store.go
event_store.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/historybuilder/event_store.go
history_builder.go ×1 — Ancestor (broader) Introduced files:
- go.temporal.io/server/service/history/historybuilder/history_builder.go
task.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/service/history/configs/task.go
priority.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/tasks/priority.go
TestAPIPrioritiesOrdered, TestCallerTypeToPriorityMapping — Descendant (narrower) Introduced tests:
- go.temporal.io/server/service/history/configs/TestQuotasSuite/TestAPIPrioritiesOrdered
- go.temporal.io/server/service/history/configs/TestQuotasSuite/TestCallerTypeToPriorityMapping
operation.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/lib/nexusoperation/config.go
- go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/operation.pb.go
- go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/request_response.pb.go
- go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service.pb.go
- go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/tasks.pb.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
statemachine.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/chasm/statemachine.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
execution_maps.go ×6 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/sql/sqlplugin/postgresql/execution_maps.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/postgresql/plugin.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/postgresql/typeconv.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/postgresql/visibility.go
execution_maps.go ×5 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/sql/sqlplugin/mysql/execution_maps.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/mysql/plugin.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/mysql/typeconv.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/mysql/visibility.go
execution_maps.go ×5 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/conn_pool.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/execution_maps.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/plugin.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/typeconv.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/visibility.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
testconstructors.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/testconstructors.go
testconstructors.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/testconstructors.go
testconstructors.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/testconstructors.go
util.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/sql/sqlplugin/util.go
- go.temporal.io/server/common/persistence/sql/store.go
testconstructors.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/testconstructors.go
visibility_store.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/visibility/store/elasticsearch/visibility_store.go
constants.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/searchattribute/sadefs/constants.go
visibility.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/sql/sqlplugin/visibility.go
Introduced tests:
- go.temporal.io/server/common/persistence/sql/sqlplugin/TestDbFields_LastField_Version
constants.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/searchattribute/sadefs/constants.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
util.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/visibility/store/query/util.go
util.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/visibility/store/query/util.go
constants.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/searchattribute/sadefs/constants.go
data_interfaces.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/data_interfaces.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/contextpropagation/v1/message.pb.go
fixed_address_translator.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/persistence/nosql/nosqlplugin/cassandra/translator/fixed_address_translator.go
- go.temporal.io/server/common/persistence/nosql/nosqlplugin/cassandra/translator/translator_plugin.go
extension.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/routing/v1/extension.pb.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
test_impl.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/testing/testhooks/test_impl.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
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
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
collection.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/collection.go
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
collection.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/collection.go
collection.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/collection.go
collection.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/collection.go
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
setting_gen.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
collection.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/collection.go
- go.temporal.io/server/common/dynamicconfig/shared_structure.go
collection.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/dynamicconfig/collection.go
priority.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/tasks/priority.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 ×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
mutate.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/mutate.go
- go.temporal.io/server/common/namespace/replication_resolver.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
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
replication_resolver.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/namespace/replication_resolver.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
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/errordetails/v1/message.pb.go
constants.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/searchattribute/sadefs/constants.go
Introduced tests:
- go.temporal.io/server/common/searchattribute/sadefs/TestGetDbIndexSearchAttributesDefault
constants.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/searchattribute/sadefs/constants.go
Introduced tests:
- go.temporal.io/server/common/searchattribute/sadefs/TestValidateSqlDbSystemNameToColNameMap
constants.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/searchattribute/sadefs/constants.go
task.pb.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/enums/v1/task.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
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
noop_logger.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/log/noop_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
cluster.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/enums/v1/cluster.pb.go
- go.temporal.io/server/api/enums/v1/common.pb.go
- go.temporal.io/server/api/enums/v1/dlq.pb.go
- go.temporal.io/server/api/enums/v1/fairness_state.pb.go
- go.temporal.io/server/api/enums/v1/nexus.pb.go
- go.temporal.io/server/api/enums/v1/predicate.pb.go
- go.temporal.io/server/api/enums/v1/replication.pb.go
- go.temporal.io/server/api/enums/v1/task.pb.go
- go.temporal.io/server/api/enums/v1/workflow.pb.go
- go.temporal.io/server/api/enums/v1/workflow_task_type.pb.go
route.go ×6 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/routing/route.go
retrypolicy.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/backoff/retrypolicy.go
wildcard.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/util/wildcard.go
retrypolicy.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/backoff/retrypolicy.go
wildcard.go ×4 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/util/wildcard.go
retrypolicy.go ×3 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/backoff/retrypolicy.go
message.pb.go ×2 — Descendant (narrower) Introduced files:
- go.temporal.io/server/api/clock/v1/message.pb.go
payload.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/payload/payload.go
route.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/routing/route.go
route.go ×1 — Descendant (narrower) Introduced files:
- go.temporal.io/server/common/routing/route.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.

2 files ranked by introduced lines: 401 introduced LOC across 4 ranges. Expand a file to inspect source; the > gutter marks introduced lines.

go.temporal.io/server/service/history/configs/config.go 392 introduced LOC · 1 range

Open complete file

  445
  
  	dc *dynamicconfig.Collection,
  
  446
  
  	numberOfShards int32,
  
  447
  >
  ) *Config {
  
config.go

  448
  >
  	cfg := &Config{
  
  449
  >
  		NumberOfShards: numberOfShards,
  
  450
  >
  
  451
  >
  		EnableReplicationStream:                       dynamicconfig.EnableReplicationStream.Get(dc),
  
  452
  >
  		EmitReplicationLifecycleEvents:                dynamicconfig.EmitReplicationLifecycleEvents.Get(dc),
  
  453
  >
  		EnableCloseInboundReplicationStreamOnShutdown: dynamicconfig.EnableCloseInboundReplicationStreamOnShutdown.Get(dc),
  
  454
  >
  		EnableSeparateReplicationEnableFlag:           dynamicconfig.EnableSeparateReplicationEnableFlag.Get(dc),
  
  455
  >
  		HistoryReplicationDLQV2:                       dynamicconfig.EnableHistoryReplicationDLQV2.Get(dc),
  
  456
  >
  
  457
  >
  		RPS:                                  dynamicconfig.HistoryRPS.Get(dc),
  
  458
  >
  		NamespaceRPS:                         dynamicconfig.HistoryNamespaceRPS.Get(dc),
  
  459
  >
  		OperatorRPSRatio:                     dynamicconfig.OperatorRPSRatio.Get(dc),
  
  460
  >
  		MaxIDLengthLimit:                     dynamicconfig.MaxIDLengthLimit.Get(dc),
  
  461
  >
  		PersistenceMaxQPS:                    dynamicconfig.HistoryPersistenceMaxQPS.Get(dc),
  
  462
  >
  		PersistenceGlobalMaxQPS:              dynamicconfig.HistoryPersistenceGlobalMaxQPS.Get(dc),
  
  463
  >
  		PersistenceNamespaceMaxQPS:           dynamicconfig.HistoryPersistenceNamespaceMaxQPS.Get(dc),
  
  464
  >
  		PersistenceGlobalNamespaceMaxQPS:     dynamicconfig.HistoryPersistenceGlobalNamespaceMaxQPS.Get(dc),
  
  465
  >
  		PersistencePerShardNamespaceMaxQPS:   dynamicconfig.HistoryPersistencePerShardNamespaceMaxQPS.Get(dc),
  
  466
  >
  		PersistenceDynamicRateLimitingParams: dynamicconfig.HistoryPersistenceDynamicRateLimitingParams.Get(dc),
  
  467
  >
  		PersistenceQPSBurstRatio:             dynamicconfig.PersistenceQPSBurstRatio.Get(dc),
  
  468
  >
  		AlignMembershipChange:                dynamicconfig.HistoryAlignMembershipChange.Get(dc),
  
  469
  >
  		ShutdownDrainDuration:                dynamicconfig.HistoryShutdownDrainDuration.Get(dc),
  
  470
  >
  		StartupMembershipJoinDelay:           dynamicconfig.HistoryStartupMembershipJoinDelay.Get(dc),
  
  471
  >
  		AllowResetWithPendingChildren:        dynamicconfig.AllowResetWithPendingChildren.Get(dc),
  
  472
  >
  		MaxAutoResetPoints:                   dynamicconfig.HistoryMaxAutoResetPoints.Get(dc),
  
  473
  >
  		DefaultWorkflowTaskTimeout:           dynamicconfig.DefaultWorkflowTaskTimeout.Get(dc),
  
  474
  >
  
  475
  >
  		MaxLocalParentWorkflowVerificationDuration: dynamicconfig.MaxLocalParentWorkflowVerificationDuration.Get(dc),
  
  476
  >
  
  477
  >
  		VisibilityPersistenceMaxReadQPS:         dynamicconfig.VisibilityPersistenceMaxReadQPS.Get(dc),
  
  478
  >
  		VisibilityPersistenceMaxWriteQPS:        dynamicconfig.VisibilityPersistenceMaxWriteQPS.Get(dc),
  
  479
  >
  		VisibilityPersistenceSlowQueryThreshold: dynamicconfig.VisibilityPersistenceSlowQueryThreshold.Get(dc),
  
  480
  >
  		EnableReadFromSecondaryVisibility:       dynamicconfig.EnableReadFromSecondaryVisibility.Get(dc),
  
  481
  >
  		VisibilityEnableShadowReadMode:          dynamicconfig.VisibilityEnableShadowReadMode.Get(dc),
  
  482
  >
  		SecondaryVisibilityWritingMode:          dynamicconfig.SecondaryVisibilityWritingMode.Get(dc),
  
  483
  >
  		VisibilityDisableOrderByClause:          dynamicconfig.VisibilityDisableOrderByClause.Get(dc),
  
  484
  >
  		VisibilityEnableManualPagination:        dynamicconfig.VisibilityEnableManualPagination.Get(dc),
  
  485
  >
  		VisibilityEnableUnifiedQueryConverter:   dynamicconfig.VisibilityEnableUnifiedQueryConverter.Get(dc),
  
  486
  >
  		VisibilityAllowList:                     dynamicconfig.VisibilityAllowList.Get(dc),
  
  487
  >
  		SuppressErrorSetSystemSearchAttribute:   dynamicconfig.SuppressErrorSetSystemSearchAttribute.Get(dc),
  
  488
  >
  
  489
  >
  		EmitShardLagLog:       dynamicconfig.EmitShardLagLog.Get(dc),
  
  490
  >
  		EnableDataLossMetrics: dynamicconfig.EnableDataLossMetrics.Get(dc),
  
  491
  >
  		// HistoryCacheLimitSizeBased should not change during runtime.
  
  492
  >
  		HistoryCacheLimitSizeBased:            dynamicconfig.HistoryCacheSizeBasedLimit.Get(dc)(),
  
  493
  >
  		HistoryHostLevelCacheMaxSize:          dynamicconfig.HistoryCacheHostLevelMaxSize.Get(dc),
  
  494
  >
  		HistoryHostLevelCacheMaxSizeBytes:     dynamicconfig.HistoryCacheHostLevelMaxSizeBytes.Get(dc),
  
  495
  >
  		HistoryCacheTTL:                       dynamicconfig.HistoryCacheTTL.Get(dc),
  
  496
  >
  		HistoryCacheNonUserContextLockTimeout: dynamicconfig.HistoryCacheNonUserContextLockTimeout.Get(dc),
  
  497
  >
  		HistoryCacheBackgroundEvict:           dynamicconfig.HistoryCacheBackgroundEvict.Get(dc),
  
  498
  >
  		EnableWorkflowExecutionTimeoutTimer:   dynamicconfig.EnableWorkflowExecutionTimeoutTimer.Get(dc),
  
  499
  >
  		EnableUpdateWorkflowModeIgnoreCurrent: dynamicconfig.EnableUpdateWorkflowModeIgnoreCurrent.Get(dc),
  
  500
  >
  		EnableTransitionHistory:               dynamicconfig.EnableTransitionHistory.Get(dc),
  
  501
  >
  		MaxCallbacksPerWorkflow:               dynamicconfig.MaxCallbacksPerWorkflow.Get(dc),
  
  502
  >
  		MaxCallbacksPerExecution:              callback.MaxPerExecution.Get(dc),
  
  503
  >
  		MaxCallbacksPerUpdateID:               dynamicconfig.MaxCallbacksPerUpdateID.Get(dc),
  
  504
  >
  		EnableChasm:                           dynamicconfig.EnableChasm.Get(dc),
  
  505
  >
  		EnableChasmNexusWorkflowOperations:    nexusoperation.EnableChasmWorkflowOperations.Get(dc),
  
  506
  >
  		ChasmMaxInMemoryPureTasks:             dynamicconfig.ChasmMaxInMemoryPureTasks.Get(dc),
  
  507
  >
  
  508
  >
  		EnableCHASMSchedulerCreation:  dynamicconfig.EnableCHASMSchedulerCreation.Get(dc),
  
  509
  >
  		EnableCHASMSchedulerMigration: dynamicconfig.EnableCHASMSchedulerMigration.Get(dc),
  
  510
  >
  
  511
  >
  		EnableCHASMCallbacks:          dynamicconfig.EnableCHASMCallbacks.Get(dc),
  
  512
  >
  		EnableCHASMSignalBacklinks:    dynamicconfig.EnableCHASMSignalBacklinks.Get(dc),
  
  513
  >
  		ExternalPayloadsEnabled:       dynamicconfig.ExternalPayloadsEnabled.Get(dc),
  
  514
  >
  		EnableWorkflowUpdateCallbacks: dynamicconfig.EnableWorkflowUpdateCallbacks.Get(dc),
  
  515
  >
  
  516
  >
  		EventsShardLevelCacheMaxSizeBytes: dynamicconfig.EventsCacheMaxSizeBytes.Get(dc),          // 512KB
  
  517
  >
  		EventsHostLevelCacheMaxSizeBytes:  dynamicconfig.EventsHostLevelCacheMaxSizeBytes.Get(dc), // 256MB
  
  518
  >
  		EventsCacheTTL:                    dynamicconfig.EventsCacheTTL.Get(dc),
  
  519
  >
  		EnableHostLevelEventsCache:        dynamicconfig.EnableHostLevelEventsCache.Get(dc),
  
  520
  >
  
  521
  >
  		RangeSizeBits: 20, // 20 bits for sequencer, 2^20 sequence number for any range
  
  522
  >
  
  523
  >
  		AcquireShardInterval:         dynamicconfig.AcquireShardInterval.Get(dc),
  
  524
  >
  		AcquireShardConcurrency:      dynamicconfig.AcquireShardConcurrency.Get(dc),
  
  525
  >
  		ShardIOConcurrency:           dynamicconfig.ShardIOConcurrency.Get(dc),
  
  526
  >
  		ShardIOTimeout:               dynamicconfig.ShardIOTimeout.Get(dc),
  
  527
  >
  		ShardLingerOwnershipCheckQPS: dynamicconfig.ShardLingerOwnershipCheckQPS.Get(dc),
  
  528
  >
  		ShardLingerTimeLimit:         dynamicconfig.ShardLingerTimeLimit.Get(dc),
  
  529
  >
  		ShardFinalizerTimeout:        dynamicconfig.ShardFinalizerTimeout.Get(dc),
  
  530
  >
  
  531
  >
  		HistoryClientOwnershipCachingEnabled: dynamicconfig.HistoryClientOwnershipCachingEnabled.Get(dc),
  
  532
  >
  
  533
  >
  		StandbyClusterDelay:                  dynamicconfig.StandbyClusterDelay.Get(dc),
  
  534
  >
  		StandbyTaskMissingEventsResendDelay:  dynamicconfig.StandbyTaskMissingEventsResendDelay.Get(dc),
  
  535
  >
  		StandbyTaskMissingEventsDiscardDelay: dynamicconfig.StandbyTaskMissingEventsDiscardDelay.Get(dc),
  
  536
  >
  		ChasmStandbyTaskDiscardDelay:         dynamicconfig.ChasmStandbyTaskDiscardDelay.Get(dc),
  
  537
  >
  
  538
  >
  		QueuePendingTaskCriticalCount:      dynamicconfig.QueuePendingTaskCriticalCount.Get(dc),
  
  539
  >
  		QueueReaderStuckCriticalAttempts:   dynamicconfig.QueueReaderStuckCriticalAttempts.Get(dc),
  
  540
  >
  		QueueCriticalSlicesCount:           dynamicconfig.QueueCriticalSlicesCount.Get(dc),
  
  541
  >
  		QueuePendingTaskMaxCount:           dynamicconfig.QueuePendingTaskMaxCount.Get(dc),
  
  542
  >
  		QueueMaxPredicateSize:              dynamicconfig.QueueMaxPredicateSize.Get(dc),
  
  543
  >
  		QueueShrinkPredicateMaxPendingKeys: dynamicconfig.QueueShrinkPredicateMaxPendingKeys.Get(dc),
  
  544
  >
  		QueueMoveGroupTaskCountBase:        dynamicconfig.QueueMoveGroupTaskCountBase.Get(dc),
  
  545
  >
  		QueueMoveGroupTaskCountMultiplier:  dynamicconfig.QueueMoveGroupTaskCountMultiplier.Get(dc),
  
  546
  >
  
  547
  >
  		TaskDLQEnabled:                 dynamicconfig.HistoryTaskDLQEnabled.Get(dc),
  
  548
  >
  		TaskDLQUnexpectedErrorAttempts: dynamicconfig.HistoryTaskDLQUnexpectedErrorAttempts.Get(dc),
  
  549
  >
  		TaskDLQInternalErrors:          dynamicconfig.HistoryTaskDLQInternalErrors.Get(dc),
  
  550
  >
  		TaskDLQErrorPattern:            dynamicconfig.HistoryTaskDLQErrorPattern.Get(dc),
  
  551
  >
  
  552
  >
  		TaskSchedulerEnableRateLimiter:                       dynamicconfig.TaskSchedulerEnableRateLimiter.Get(dc),
  
  553
  >
  		TaskSchedulerEnableRateLimiterShadowMode:             dynamicconfig.TaskSchedulerEnableRateLimiterShadowMode.Get(dc),
  
  554
  >
  		TaskSchedulerRateLimiterStartupDelay:                 dynamicconfig.TaskSchedulerRateLimiterStartupDelay.Get(dc),
  
  555
  >
  		TaskSchedulerGlobalMaxQPS:                            dynamicconfig.TaskSchedulerGlobalMaxQPS.Get(dc),
  
  556
  >
  		TaskSchedulerMaxQPS:                                  dynamicconfig.TaskSchedulerMaxQPS.Get(dc),
  
  557
  >
  		TaskSchedulerNamespaceMaxQPS:                         dynamicconfig.TaskSchedulerNamespaceMaxQPS.Get(dc),
  
  558
  >
  		TaskSchedulerGlobalNamespaceMaxQPS:                   dynamicconfig.TaskSchedulerGlobalNamespaceMaxQPS.Get(dc),
  
  559
  >
  		TaskSchedulerInactiveChannelDeletionDelay:            dynamicconfig.TaskSchedulerInactiveChannelDeletionDelay.Get(dc),
  
  560
  >
  		TaskSchedulerEnableExecutionQueueScheduler:           dynamicconfig.TaskSchedulerEnableExecutionQueueScheduler.Get(dc),
  
  561
  >
  		TaskSchedulerExecutionQueueSchedulerMaxQueues:        dynamicconfig.TaskSchedulerExecutionQueueSchedulerMaxQueues.Get(dc),
  
  562
  >
  		TaskSchedulerExecutionQueueSchedulerQueueTTL:         dynamicconfig.TaskSchedulerExecutionQueueSchedulerQueueTTL.Get(dc),
  
  563
  >
  		TaskSchedulerExecutionQueueSchedulerQueueConcurrency: dynamicconfig.TaskSchedulerExecutionQueueSchedulerQueueConcurrency.Get(dc),
  
  564
  >
  
  565
  >
  		TimerTaskBatchSize:                               dynamicconfig.TimerTaskBatchSize.Get(dc),
  
  566
  >
  		TimerProcessorSchedulerWorkerCount:               dynamicconfig.TimerProcessorSchedulerWorkerCount.Subscribe(dc),
  
  567
  >
  		TimerProcessorSchedulerActiveRoundRobinWeights:   dynamicconfig.TimerProcessorSchedulerActiveRoundRobinWeights.WithDefault(ConvertWeightsToDynamicConfigValue(DefaultActiveTaskPriorityWeight)).Get(dc),
  
  568
  >
  		TimerProcessorSchedulerStandbyRoundRobinWeights:  dynamicconfig.TimerProcessorSchedulerStandbyRoundRobinWeights.WithDefault(ConvertWeightsToDynamicConfigValue(DefaultStandbyTaskPriorityWeight)).Get(dc),
  
  569
  >
  		TimerProcessorUpdateAckInterval:                  dynamicconfig.TimerProcessorUpdateAckInterval.Get(dc),
  
  570
  >
  		TimerProcessorUpdateAckIntervalJitterCoefficient: dynamicconfig.TimerProcessorUpdateAckIntervalJitterCoefficient.Get(dc),
  
  571
  >
  		TimerProcessorMaxPollRPS:                         dynamicconfig.TimerProcessorMaxPollRPS.Get(dc),
  
  572
  >
  		TimerProcessorMaxPollHostRPS:                     dynamicconfig.TimerProcessorMaxPollHostRPS.Get(dc),
  
  573
  >
  		TimerProcessorMaxPollInterval:                    dynamicconfig.TimerProcessorMaxPollInterval.Get(dc),
  
  574
  >
  		TimerProcessorMaxPollIntervalJitterCoefficient:   dynamicconfig.TimerProcessorMaxPollIntervalJitterCoefficient.Get(dc),
  
  575
  >
  		TimerProcessorPollBackoffInterval:                dynamicconfig.TimerProcessorPollBackoffInterval.Get(dc),
  
  576
  >
  		TimerProcessorMaxTimeShift:                       dynamicconfig.TimerProcessorMaxTimeShift.Get(dc),
  
  577
  >
  		TransferQueueMaxReaderCount:                      dynamicconfig.TransferQueueMaxReaderCount.Get(dc),
  
  578
  >
  		RetentionTimerJitterDuration:                     dynamicconfig.RetentionTimerJitterDuration.Get(dc),
  
  579
  >
  
  580
  >
  		MemoryTimerProcessorSchedulerWorkerCount: dynamicconfig.MemoryTimerProcessorSchedulerWorkerCount.Subscribe(dc),
  
  581
  >
  
  582
  >
  		TransferTaskBatchSize:                               dynamicconfig.TransferTaskBatchSize.Get(dc),
  
  583
  >
  		TransferProcessorSchedulerWorkerCount:               dynamicconfig.TransferProcessorSchedulerWorkerCount.Subscribe(dc),
  
  584
  >
  		TransferProcessorSchedulerActiveRoundRobinWeights:   dynamicconfig.TransferProcessorSchedulerActiveRoundRobinWeights.WithDefault(ConvertWeightsToDynamicConfigValue(DefaultActiveTaskPriorityWeight)).Get(dc),
  
  585
  >
  		TransferProcessorSchedulerStandbyRoundRobinWeights:  dynamicconfig.TransferProcessorSchedulerStandbyRoundRobinWeights.WithDefault(ConvertWeightsToDynamicConfigValue(DefaultStandbyTaskPriorityWeight)).Get(dc),
  
  586
  >
  		TransferProcessorMaxPollRPS:                         dynamicconfig.TransferProcessorMaxPollRPS.Get(dc),
  
  587
  >
  		TransferProcessorMaxPollHostRPS:                     dynamicconfig.TransferProcessorMaxPollHostRPS.Get(dc),
  
  588
  >
  		TransferProcessorMaxPollInterval:                    dynamicconfig.TransferProcessorMaxPollInterval.Get(dc),
  
  589
  >
  		TransferProcessorMaxPollIntervalJitterCoefficient:   dynamicconfig.TransferProcessorMaxPollIntervalJitterCoefficient.Get(dc),
  
  590
  >
  		TransferProcessorUpdateAckInterval:                  dynamicconfig.TransferProcessorUpdateAckInterval.Get(dc),
  
  591
  >
  		TransferProcessorUpdateAckIntervalJitterCoefficient: dynamicconfig.TransferProcessorUpdateAckIntervalJitterCoefficient.Get(dc),
  
  592
  >
  		TransferProcessorPollBackoffInterval:                dynamicconfig.TransferProcessorPollBackoffInterval.Get(dc),
  
  593
  >
  		TransferProcessorEnsureCloseBeforeDelete:            dynamicconfig.TransferProcessorEnsureCloseBeforeDelete.Get(dc),
  
  594
  >
  		TimerQueueMaxReaderCount:                            dynamicconfig.TimerQueueMaxReaderCount.Get(dc),
  
  595
  >
  
  596
  >
  		OutboundTaskBatchSize:                               dynamicconfig.OutboundTaskBatchSize.Get(dc),
  
  597
  >
  		OutboundProcessorMaxPollRPS:                         dynamicconfig.OutboundProcessorMaxPollRPS.Get(dc),
  
  598
  >
  		OutboundProcessorMaxPollHostRPS:                     dynamicconfig.OutboundProcessorMaxPollHostRPS.Get(dc),
  
  599
  >
  		OutboundProcessorMaxPollInterval:                    dynamicconfig.OutboundProcessorMaxPollInterval.Get(dc),
  
  600
  >
  		OutboundProcessorMaxPollIntervalJitterCoefficient:   dynamicconfig.OutboundProcessorMaxPollIntervalJitterCoefficient.Get(dc),
  
  601
  >
  		OutboundProcessorUpdateAckInterval:                  dynamicconfig.OutboundProcessorUpdateAckInterval.Get(dc),
  
  602
  >
  		OutboundProcessorUpdateAckIntervalJitterCoefficient: dynamicconfig.OutboundProcessorUpdateAckIntervalJitterCoefficient.Get(dc),
  
  603
  >
  		OutboundProcessorPollBackoffInterval:                dynamicconfig.OutboundProcessorPollBackoffInterval.Get(dc),
  
  604
  >
  		OutboundQueuePendingTaskCriticalCount:               dynamicconfig.OutboundQueuePendingTaskCriticalCount.Get(dc),
  
  605
  >
  		OutboundQueuePendingTaskMaxCount:                    dynamicconfig.OutboundQueuePendingTaskMaxCount.Get(dc),
  
  606
  >
  		OutboundQueueMaxPredicateSize:                       dynamicconfig.OutboundQueueMaxPredicateSize.Get(dc),
  
  607
  >
  		OutboundQueueMaxReaderCount:                         dynamicconfig.OutboundQueueMaxReaderCount.Get(dc),
  
  608
  >
  		OutboundQueueGroupLimiterBufferSize:                 dynamicconfig.OutboundQueueGroupLimiterBufferSize.Get(dc),
  
  609
  >
  		OutboundQueueGroupLimiterConcurrency:                dynamicconfig.OutboundQueueGroupLimiterConcurrency.Get(dc),
  
  610
  >
  		OutboundQueueHostSchedulerMaxTaskRPS:                dynamicconfig.OutboundQueueHostSchedulerMaxTaskRPS.Get(dc),
  
  611
  >
  		OutboundQueueCircuitBreakerSettings:                 dynamicconfig.OutboundQueueCircuitBreakerSettings.Subscribe(dc),
  
  612
  >
  		OutboundStandbyTaskMissingEventsDestinationDownErr:  dynamicconfig.OutboundStandbyTaskMissingEventsDestinationDownErr.Get(dc),
  
  613
  >
  		OutboundStandbyTaskMissingEventsDiscardDelay:        dynamicconfig.OutboundStandbyTaskMissingEventsDiscardDelay.Get(dc),
  
  614
  >
  
  615
  >
  		ReplicatorProcessorMaxPollInterval:                  dynamicconfig.ReplicatorProcessorMaxPollInterval.Get(dc),
  
  616
  >
  		ReplicatorProcessorMaxPollIntervalJitterCoefficient: dynamicconfig.ReplicatorProcessorMaxPollIntervalJitterCoefficient.Get(dc),
  
  617
  >
  		ReplicatorProcessorFetchTasksBatchSize:              dynamicconfig.ReplicatorTaskBatchSize.Get(dc),
  
  618
  >
  		ReplicatorProcessorMaxSkipTaskCount:                 dynamicconfig.ReplicatorMaxSkipTaskCount.Get(dc),
  
  619
  >
  		ReplicationTaskProcessorHostQPS:                     dynamicconfig.ReplicationTaskProcessorHostQPS.Get(dc),
  
  620
  >
  		ReplicationTaskProcessorShardQPS:                    dynamicconfig.ReplicationTaskProcessorShardQPS.Get(dc),
  
  621
  >
  		ReplicationEnableDLQMetrics:                         dynamicconfig.ReplicationEnableDLQMetrics.Get(dc),
  
  622
  >
  		ReplicationEnableUpdateWithNewTaskMerge:             dynamicconfig.ReplicationEnableUpdateWithNewTaskMerge.Get(dc),
  
  623
  >
  		ReplicationStreamSyncStatusDuration:                 dynamicconfig.ReplicationStreamSyncStatusDuration.Get(dc),
  
  624
  >
  		ReplicationProcessorSchedulerQueueSize:              dynamicconfig.ReplicationProcessorSchedulerQueueSize.Get(dc),
  
  625
  >
  		ReplicationProcessorSchedulerWorkerCount:            dynamicconfig.ReplicationProcessorSchedulerWorkerCount.Subscribe(dc),
  
  626
  >
  		ReplicationLowPriorityProcessorSchedulerWorkerCount: dynamicconfig.ReplicationLowPriorityProcessorSchedulerWorkerCount.Subscribe(dc),
  
  627
  >
  		ReplicationLowPriorityTaskParallelism:               dynamicconfig.ReplicationLowPriorityTaskParallelism.Get(dc),
  
  628
  >
  		EnableReplicationTaskBatching:                       dynamicconfig.EnableReplicationTaskBatching.Get(dc),
  
  629
  >
  		EnableReplicationTaskTieredProcessing:               dynamicconfig.EnableReplicationTaskTieredProcessing.Get(dc),
  
  630
  >
  		ReplicationStreamSenderHighPriorityQPS:              dynamicconfig.ReplicationStreamSenderHighPriorityQPS.Get(dc),
  
  631
  >
  		ReplicationStreamSenderLowPriorityQPS:               dynamicconfig.ReplicationStreamSenderLowPriorityQPS.Get(dc),
  
  632
  >
  		ReplicationStreamEventLoopRetryMaxAttempts:          dynamicconfig.ReplicationStreamEventLoopRetryMaxAttempts.Get(dc),
  
  633
  >
  		ReplicationReceiverMaxOutstandingTaskCount:          dynamicconfig.ReplicationReceiverMaxOutstandingTaskCount.Get(dc),
  
  634
  >
  		ReplicationReceiverSlowSubmissionLatencyThreshold:   dynamicconfig.ReplicationReceiverSlowSubmissionLatencyThreshold.Get(dc),
  
  635
  >
  		ReplicationReceiverSlowSubmissionWindow:             dynamicconfig.ReplicationReceiverSlowSubmissionWindow.Get(dc),
  
  636
  >
  		EnableReplicationReceiverSlowSubmissionFlowControl:  dynamicconfig.EnableReplicationReceiverSlowSubmissionFlowControl.Get(dc),
  
  637
  >
  		ReplicationResendMaxBatchCount:                      dynamicconfig.ReplicationResendMaxBatchCount.Get(dc),
  
  638
  >
  		ReplicationProgressCacheMaxSize:                     dynamicconfig.ReplicationProgressCacheMaxSize.Get(dc),
  
  639
  >
  		ReplicationProgressCacheTTL:                         dynamicconfig.ReplicationProgressCacheTTL.Get(dc),
  
  640
  >
  		ReplicationEnableRateLimit:                          dynamicconfig.ReplicationEnableRateLimit.Get(dc),
  
  641
  >
  		ReplicationEnableRateLimitShadowMode:                dynamicconfig.ReplicationEnableRateLimitShadowMode.Get(dc),
  
  642
  >
  		ReplicationStreamSendEmptyTaskDuration:              dynamicconfig.ReplicationStreamSendEmptyTaskDuration.Get(dc),
  
  643
  >
  		ReplicationStreamReceiverLivenessMultiplier:         dynamicconfig.ReplicationStreamReceiverLivenessMultiplier.Get(dc),
  
  644
  >
  		ReplicationStreamSenderLivenessMultiplier:           dynamicconfig.ReplicationStreamSenderLivenessMultiplier.Get(dc),
  
  645
  >
  		EnableHistoryReplicationRateLimiter:                 dynamicconfig.EnableHistoryReplicationRateLimiter.Get(dc),
  
  646
  >
  
  647
  >
  		MaximumBufferedEventsBatch:       dynamicconfig.MaximumBufferedEventsBatch.Get(dc),
  
  648
  >
  		MaximumBufferedEventsSizeInBytes: dynamicconfig.MaximumBufferedEventsSizeInBytes.Get(dc),
  
  649
  >
  		MaximumSignalsPerExecution:       dynamicconfig.MaximumSignalsPerExecution.Get(dc),
  
  650
  >
  		MaximumEventBatchSizeInBytes:     dynamicconfig.MaximumEventBatchSizeInBytes.Get(dc),
  
  651
  >
  		ShardUpdateMinInterval:           dynamicconfig.ShardUpdateMinInterval.Get(dc),
  
  652
  >
  		ShardFirstUpdateInterval:         dynamicconfig.ShardFirstUpdateInterval.Get(dc),
  
  653
  >
  		ShardUpdateMinTasksCompleted:     dynamicconfig.ShardUpdateMinTasksCompleted.Get(dc),
  
  654
  >
  		ShardSyncMinInterval:             dynamicconfig.ShardSyncMinInterval.Get(dc),
  
  655
  >
  		ShardSyncTimerJitterCoefficient:  dynamicconfig.TransferProcessorMaxPollIntervalJitterCoefficient.Get(dc),
  
  656
  >
  
  657
  >
  		// history client: client/history/client.go set the client timeout 30s
  
  658
  >
  		// TODO: Return this value to the client: go.temporal.io/server/issues/294
  
  659
  >
  		LongPollExpirationInterval:          dynamicconfig.HistoryLongPollExpirationInterval.Get(dc),
  
  660
  >
  		EnableParentClosePolicy:             dynamicconfig.EnableParentClosePolicy.Get(dc),
  
  661
  >
  		NumParentClosePolicySystemWorkflows: dynamicconfig.NumParentClosePolicySystemWorkflows.Get(dc),
  
  662
  >
  		EnableParentClosePolicyWorker:       dynamicconfig.EnableParentClosePolicyWorker.Get(dc),
  
  663
  >
  		ParentClosePolicyThreshold:          dynamicconfig.ParentClosePolicyThreshold.Get(dc),
  
  664
  >
  
  665
  >
  		BlobSizeLimitError:                        dynamicconfig.BlobSizeLimitError.Get(dc),
  
  666
  >
  		BlobSizeLimitWarn:                         dynamicconfig.BlobSizeLimitWarn.Get(dc),
  
  667
  >
  		MemoSizeLimitError:                        dynamicconfig.MemoSizeLimitError.Get(dc),
  
  668
  >
  		MemoSizeLimitWarn:                         dynamicconfig.MemoSizeLimitWarn.Get(dc),
  
  669
  >
  		NumPendingChildExecutionsLimit:            dynamicconfig.NumPendingChildExecutionsLimitError.Get(dc),
  
  670
  >
  		NumPendingActivitiesLimit:                 dynamicconfig.NumPendingActivitiesLimitError.Get(dc),
  
  671
  >
  		NumPendingSignalsLimit:                    dynamicconfig.NumPendingSignalsLimitError.Get(dc),
  
  672
  >
  		NumPendingCancelsRequestLimit:             dynamicconfig.NumPendingCancelRequestsLimitError.Get(dc),
  
  673
  >
  		HistorySizeLimitError:                     dynamicconfig.HistorySizeLimitError.Get(dc),
  
  674
  >
  		HistorySizeLimitWarn:                      dynamicconfig.HistorySizeLimitWarn.Get(dc),
  
  675
  >
  		HistorySizeSuggestContinueAsNew:           dynamicconfig.HistorySizeSuggestContinueAsNew.Get(dc),
  
  676
  >
  		HistoryCountLimitError:                    dynamicconfig.HistoryCountLimitError.Get(dc),
  
  677
  >
  		HistoryCountLimitWarn:                     dynamicconfig.HistoryCountLimitWarn.Get(dc),
  
  678
  >
  		HistoryCountSuggestContinueAsNew:          dynamicconfig.HistoryCountSuggestContinueAsNew.Get(dc),
  
  679
  >
  		HistoryMaxPageSize:                        dynamicconfig.HistoryMaxPageSize.Get(dc),
  
  680
  >
  		MutableStateActivityFailureSizeLimitError: dynamicconfig.MutableStateActivityFailureSizeLimitError.Get(dc),
  
  681
  >
  		MutableStateActivityFailureSizeLimitWarn:  dynamicconfig.MutableStateActivityFailureSizeLimitWarn.Get(dc),
  
  682
  >
  		MutableStateSizeLimitError:                dynamicconfig.MutableStateSizeLimitError.Get(dc),
  
  683
  >
  		MutableStateSizeLimitWarn:                 dynamicconfig.MutableStateSizeLimitWarn.Get(dc),
  
  684
  >
  		MutableStateTombstoneCountLimit:           dynamicconfig.MutableStateTombstoneCountLimit.Get(dc),
  
  685
  >
  
  686
  >
  		ThrottledLogRPS:   dynamicconfig.HistoryThrottledLogRPS.Get(dc),
  
  687
  >
  		EnableStickyQuery: dynamicconfig.EnableStickyQuery.Get(dc),
  
  688
  >
  
  689
  >
  		DefaultActivityRetryPolicy:                       dynamicconfig.DefaultActivityRetryPolicy.Get(dc),
  
  690
  >
  		DefaultWorkflowRetryPolicy:                       dynamicconfig.DefaultWorkflowRetryPolicy.Get(dc),
  
  691
  >
  		WorkflowTaskHeartbeatTimeout:                     dynamicconfig.WorkflowTaskHeartbeatTimeout.Get(dc),
  
  692
  >
  		WorkflowTaskCriticalAttempts:                     dynamicconfig.WorkflowTaskCriticalAttempts.Get(dc),
  
  693
  >
  		WorkflowTaskRetryMaxInterval:                     dynamicconfig.WorkflowTaskRetryMaxInterval.Get(dc),
  
  694
  >
  		EnableWorkflowTaskStampIncrementOnFailure:        dynamicconfig.EnableWorkflowTaskStampIncrementOnFailure.Get(dc),
  
  695
  >
  		DiscardSpeculativeWorkflowTaskMaximumEventsCount: dynamicconfig.DiscardSpeculativeWorkflowTaskMaximumEventsCount.Get(dc),
  
  696
  >
  		EnableDropRepeatedWorkflowTaskFailures:           dynamicconfig.EnableDropRepeatedWorkflowTaskFailures.Get(dc),
  
  697
  >
  		SendTransientOrSpeculativeWorkflowTaskEvents:     dynamicconfig.SendTransientOrSpeculativeWorkflowTaskEvents.Get(dc),
  
  698
  >
  
  699
  >
  		ReplicationTaskApplyTimeout:                  dynamicconfig.ReplicationTaskApplyTimeout.Get(dc),
  
  700
  >
  		ReplicationTaskFetcherParallelism:            dynamicconfig.ReplicationTaskFetcherParallelism.Get(dc),
  
  701
  >
  		ReplicationTaskFetcherAggregationInterval:    dynamicconfig.ReplicationTaskFetcherAggregationInterval.Get(dc),
  
  702
  >
  		ReplicationTaskFetcherTimerJitterCoefficient: dynamicconfig.ReplicationTaskFetcherTimerJitterCoefficient.Get(dc),
  
  703
  >
  		ReplicationTaskFetcherErrorRetryWait:         dynamicconfig.ReplicationTaskFetcherErrorRetryWait.Get(dc),
  
  704
  >
  
  705
  >
  		ReplicationTaskProcessorErrorRetryWait:               dynamicconfig.ReplicationTaskProcessorErrorRetryWait.Get(dc),
  
  706
  >
  		ReplicationTaskProcessorErrorRetryBackoffCoefficient: dynamicconfig.ReplicationTaskProcessorErrorRetryBackoffCoefficient.Get(dc),
  
  707
  >
  		ReplicationTaskProcessorErrorRetryMaxInterval:        dynamicconfig.ReplicationTaskProcessorErrorRetryMaxInterval.Get(dc),
  
  708
  >
  		ReplicationTaskProcessorErrorRetryMaxAttempts:        dynamicconfig.ReplicationTaskProcessorErrorRetryMaxAttempts.Get(dc),
  
  709
  >
  		ReplicationTaskProcessorErrorRetryExpiration:         dynamicconfig.ReplicationTaskProcessorErrorRetryExpiration.Get(dc),
  
  710
  >
  		ReplicationTaskProcessorNoTaskRetryWait:              dynamicconfig.ReplicationTaskProcessorNoTaskInitialWait.Get(dc),
  
  711
  >
  		ReplicationTaskProcessorCleanupInterval:              dynamicconfig.ReplicationTaskProcessorCleanupInterval.Get(dc),
  
  712
  >
  		ReplicationTaskProcessorCleanupJitterCoefficient:     dynamicconfig.ReplicationTaskProcessorCleanupJitterCoefficient.Get(dc),
  
  713
  >
  		ReplicationMultipleBatches:                           dynamicconfig.ReplicationMultipleBatches.Get(dc),
  
  714
  >
  
  715
  >
  		ReplicationStreamSenderErrorRetryWait:               dynamicconfig.ReplicationStreamSenderErrorRetryWait.Get(dc),
  
  716
  >
  		ReplicationStreamSenderErrorRetryBackoffCoefficient: dynamicconfig.ReplicationStreamSenderErrorRetryBackoffCoefficient.Get(dc),
  
  717
  >
  		ReplicationStreamSenderErrorRetryMaxInterval:        dynamicconfig.ReplicationStreamSenderErrorRetryMaxInterval.Get(dc),
  
  718
  >
  		ReplicationStreamSenderErrorRetryMaxAttempts:        dynamicconfig.ReplicationStreamSenderErrorRetryMaxAttempts.Get(dc),
  
  719
  >
  		ReplicationStreamSenderErrorRetryExpiration:         dynamicconfig.ReplicationStreamSenderErrorRetryExpiration.Get(dc),
  
  720
  >
  
  721
  >
  		ReplicationExecutableTaskErrorRetryWait:               dynamicconfig.ReplicationExecutableTaskErrorRetryWait.Get(dc),
  
  722
  >
  		ReplicationExecutableTaskErrorRetryBackoffCoefficient: dynamicconfig.ReplicationExecutableTaskErrorRetryBackoffCoefficient.Get(dc),
  
  723
  >
  		ReplicationExecutableTaskErrorRetryMaxInterval:        dynamicconfig.ReplicationExecutableTaskErrorRetryMaxInterval.Get(dc),
  
  724
  >
  		ReplicationExecutableTaskErrorRetryMaxAttempts:        dynamicconfig.ReplicationExecutableTaskErrorRetryMaxAttempts.Get(dc),
  
  725
  >
  		ReplicationExecutableTaskErrorRetryExpiration:         dynamicconfig.ReplicationExecutableTaskErrorRetryExpiration.Get(dc),
  
  726
  >
  
  727
  >
  		MaxBufferedQueryCount:                 dynamicconfig.MaxBufferedQueryCount.Get(dc),
  
  728
  >
  		MutableStateChecksumGenProbability:    dynamicconfig.MutableStateChecksumGenProbability.Get(dc),
  
  729
  >
  		MutableStateChecksumVerifyProbability: dynamicconfig.MutableStateChecksumVerifyProbability.Get(dc),
  
  730
  >
  		MutableStateChecksumInvalidateBefore:  dynamicconfig.MutableStateChecksumInvalidateBefore.Get(dc),
  
  731
  >
  
  732
  >
  		StandbyTaskReReplicationContextTimeout: dynamicconfig.StandbyTaskReReplicationContextTimeout.Get(dc),
  
  733
  >
  
  734
  >
  		SkipReapplicationByNamespaceID: dynamicconfig.SkipReapplicationByNamespaceID.Get(dc),
  
  735
  >
  
  736
  >
  		// ===== Visibility related =====
  
  737
  >
  		VisibilityTaskBatchSize:                               dynamicconfig.VisibilityTaskBatchSize.Get(dc),
  
  738
  >
  		VisibilityProcessorMaxPollRPS:                         dynamicconfig.VisibilityProcessorMaxPollRPS.Get(dc),
  
  739
  >
  		VisibilityProcessorMaxPollHostRPS:                     dynamicconfig.VisibilityProcessorMaxPollHostRPS.Get(dc),
  
  740
  >
  		VisibilityProcessorSchedulerWorkerCount:               dynamicconfig.VisibilityProcessorSchedulerWorkerCount.Subscribe(dc),
  
  741
  >
  		VisibilityProcessorSchedulerActiveRoundRobinWeights:   dynamicconfig.VisibilityProcessorSchedulerActiveRoundRobinWeights.WithDefault(ConvertWeightsToDynamicConfigValue(DefaultActiveTaskPriorityWeight)).Get(dc),
  
  742
  >
  		VisibilityProcessorSchedulerStandbyRoundRobinWeights:  dynamicconfig.VisibilityProcessorSchedulerStandbyRoundRobinWeights.WithDefault(ConvertWeightsToDynamicConfigValue(DefaultStandbyTaskPriorityWeight)).Get(dc),
  
  743
  >
  		VisibilityProcessorMaxPollInterval:                    dynamicconfig.VisibilityProcessorMaxPollInterval.Get(dc),
  
  744
  >
  		VisibilityProcessorMaxPollIntervalJitterCoefficient:   dynamicconfig.VisibilityProcessorMaxPollIntervalJitterCoefficient.Get(dc),
  
  745
  >
  		VisibilityProcessorUpdateAckInterval:                  dynamicconfig.VisibilityProcessorUpdateAckInterval.Get(dc),
  
  746
  >
  		VisibilityProcessorUpdateAckIntervalJitterCoefficient: dynamicconfig.VisibilityProcessorUpdateAckIntervalJitterCoefficient.Get(dc),
  
  747
  >
  		VisibilityProcessorPollBackoffInterval:                dynamicconfig.VisibilityProcessorPollBackoffInterval.Get(dc),
  
  748
  >
  		VisibilityProcessorEnsureCloseBeforeDelete:            dynamicconfig.VisibilityProcessorEnsureCloseBeforeDelete.Get(dc),
  
  749
  >
  		VisibilityProcessorEnableCloseWorkflowCleanup:         dynamicconfig.VisibilityProcessorEnableCloseWorkflowCleanup.Get(dc),
  
  750
  >
  		VisibilityProcessorRelocateAttributesMinBlobSize:      dynamicconfig.VisibilityProcessorRelocateAttributesMinBlobSize.Get(dc),
  
  751
  >
  		VisibilityQueueMaxReaderCount:                         dynamicconfig.VisibilityQueueMaxReaderCount.Get(dc),
  
  752
  >
  
  753
  >
  		DisableFetchRelocatableAttributesFromVisibility: dynamicconfig.DisableFetchRelocatableAttributesFromVisibility.Get(dc),
  
  754
  >
  
  755
  >
  		SearchAttributesNumberOfKeysLimit: dynamicconfig.SearchAttributesNumberOfKeysLimit.Get(dc),
  
  756
  >
  		SearchAttributesSizeOfValueLimit:  dynamicconfig.SearchAttributesSizeOfValueLimit.Get(dc),
  
  757
  >
  		SearchAttributesTotalSizeLimit:    dynamicconfig.SearchAttributesTotalSizeLimit.Get(dc),
  
  758
  >
  		IndexerConcurrency:                dynamicconfig.WorkerIndexerConcurrency.Get(dc),
  
  759
  >
  		ESProcessorNumOfWorkers:           dynamicconfig.WorkerESProcessorNumOfWorkers.Get(dc),
  
  760
  >
  		// Should not be greater than number of visibility task queue workers VisibilityProcessorSchedulerWorkerCount (default 512)
  
  761
  >
  		// Otherwise, visibility queue processors won't be able to fill up bulk with documents (even under heavy load) and bulk will flush due to interval, not number of actions.
  
  762
  >
  		ESProcessorBulkActions: dynamicconfig.WorkerESProcessorBulkActions.Get(dc),
  
  763
  >
  		// 16MB - just a sanity check. With ES document size ~1Kb it should never be reached.
  
  764
  >
  		ESProcessorBulkSize: dynamicconfig.WorkerESProcessorBulkSize.Get(dc),
  
  765
  >
  		// Bulk processor will flush every this interval regardless of last flush due to bulk actions.
  
  766
  >
  		ESProcessorFlushInterval: dynamicconfig.WorkerESProcessorFlushInterval.Get(dc),
  
  767
  >
  		ESProcessorAckTimeout:    dynamicconfig.WorkerESProcessorAckTimeout.Get(dc),
  
  768
  >
  
  769
  >
  		EnableCrossNamespaceCommands:      dynamicconfig.EnableCrossNamespaceCommands.Get(dc),
  
  770
  >
  		EnableActivityEagerExecution:      dynamicconfig.EnableActivityEagerExecution.Get(dc),
  
  771
  >
  		EnableActivityRetryStampIncrement: dynamicconfig.EnableActivityRetryStampIncrement.Get(dc),
  
  772
  >
  		EnableCancelActivityWorkerCommand: dynamicconfig.EnableCancelActivityWorkerCommand.Get(dc),
  
  773
  >
  		EnableEagerWorkflowStart:          dynamicconfig.EnableEagerWorkflowStart.Get(dc),
  
  774
  >
  		NamespaceCacheRefreshInterval:     dynamicconfig.NamespaceCacheRefreshInterval.Get(dc),
  
  775
  >
  
  776
  >
  		// Archival related
  
  777
  >
  		ArchivalTaskBatchSize:                               dynamicconfig.ArchivalTaskBatchSize.Get(dc),
  
  778
  >
  		ArchivalProcessorMaxPollRPS:                         dynamicconfig.ArchivalProcessorMaxPollRPS.Get(dc),
  
  779
  >
  		ArchivalProcessorMaxPollHostRPS:                     dynamicconfig.ArchivalProcessorMaxPollHostRPS.Get(dc),
  
  780
  >
  		ArchivalProcessorSchedulerWorkerCount:               dynamicconfig.ArchivalProcessorSchedulerWorkerCount.Subscribe(dc),
  
  781
  >
  		ArchivalProcessorMaxPollInterval:                    dynamicconfig.ArchivalProcessorMaxPollInterval.Get(dc),
  
  782
  >
  		ArchivalProcessorMaxPollIntervalJitterCoefficient:   dynamicconfig.ArchivalProcessorMaxPollIntervalJitterCoefficient.Get(dc),
  
  783
  >
  		ArchivalProcessorUpdateAckInterval:                  dynamicconfig.ArchivalProcessorUpdateAckInterval.Get(dc),
  
  784
  >
  		ArchivalProcessorUpdateAckIntervalJitterCoefficient: dynamicconfig.ArchivalProcessorUpdateAckIntervalJitterCoefficient.Get(dc),
  
  785
  >
  		ArchivalProcessorPollBackoffInterval:                dynamicconfig.ArchivalProcessorPollBackoffInterval.Get(dc),
  
  786
  >
  		ArchivalProcessorArchiveDelay:                       dynamicconfig.ArchivalProcessorArchiveDelay.Get(dc),
  
  787
  >
  		ArchivalBackendMaxRPS:                               dynamicconfig.ArchivalBackendMaxRPS.Get(dc),
  
  788
  >
  		ArchivalQueueMaxReaderCount:                         dynamicconfig.ArchivalQueueMaxReaderCount.Get(dc),
  
  789
  >
  
  790
  >
  		// workflow update related
  
  791
  >
  		WorkflowExecutionMaxInFlightUpdates:                           dynamicconfig.WorkflowExecutionMaxInFlightUpdates.Get(dc),
  
  792
  >
  		WorkflowExecutionMaxInFlightUpdatePayloads:                    dynamicconfig.WorkflowExecutionMaxInFlightUpdatePayloads.Get(dc),
  
  793
  >
  		WorkflowExecutionMaxTotalUpdates:                              dynamicconfig.WorkflowExecutionMaxTotalUpdates.Get(dc),
  
  794
  >
  		WorkflowExecutionMaxTotalUpdatesSuggestContinueAsNewThreshold: dynamicconfig.WorkflowExecutionMaxTotalUpdatesSuggestContinueAsNewThreshold.Get(dc),
  
  795
  >
  		EnableUpdateWithStartRetryOnClosedWorkflowAbort:               dynamicconfig.EnableUpdateWithStartRetryOnClosedWorkflowAbort.Get(dc),
  
  796
  >
  		EnableUpdateWithStartRetryableErrorOnClosedWorkflowAbort:      dynamicconfig.EnableUpdateWithStartRetryableErrorOnClosedWorkflowAbort.Get(dc),
  
  797
  >
  
  798
  >
  		SendRawHistoryBetweenInternalServices:    dynamicconfig.SendRawHistoryBetweenInternalServices.Get(dc),
  
  799
  >
  		SendRawHistoryBytesToMatchingService:     dynamicconfig.SendRawHistoryBytesToMatchingService.Get(dc),
  
  800
  >
  		SendRawWorkflowHistory:                   dynamicconfig.SendRawWorkflowHistory.Get(dc),
  
  801
  >
  		WorkflowIdReuseMinimalInterval:           dynamicconfig.WorkflowIdReuseMinimalInterval.Get(dc),
  
  802
  >
  		EnableWorkflowIdReuseStartTimeValidation: dynamicconfig.EnableWorkflowIdReuseStartTimeValidation.Get(dc),
  
  803
  >
  		BusinessIDReuseRate:                      dynamicconfig.BusinessIDReuseRate.Get(dc),
  
  804
  >
  		BusinessIDReuseBurstRatio:                dynamicconfig.BusinessIDReuseBurstRatio.Get(dc),
  
  805
  >
  		BusinessIDReuseLimiterCacheSize:          dynamicconfig.BusinessIDReuseLimiterCacheSize.Get(dc),
  
  806
  >
  		BusinessIDReuseLimiterCacheTTL:           dynamicconfig.BusinessIDReuseLimiterCacheTTL.Get(dc),
  
  807
  >
  
  808
  >
  		HealthPersistenceLatencyFailure:     dynamicconfig.HealthPersistenceLatencyFailure.Get(dc),
  
  809
  >
  		HealthPersistenceLatencyPercentiles: dynamicconfig.PersistenceHealthSignalPercentileLatencySettings.Get(dc),
  
  810
  >
  		HealthPersistenceErrorRatio:         dynamicconfig.HealthPersistenceErrorRatio.Get(dc),
  
  811
  >
  		HealthRPCLatencyFailure:             dynamicconfig.HealthRPCLatencyFailure.Get(dc),
  
  812
  >
  		HealthRPCLatencyPercentiles:         dynamicconfig.HistoryHealthSignalPercentileLatencySettings.Get(dc),
  
  813
  >
  		HealthRPCErrorRatio:                 dynamicconfig.HealthRPCErrorRatio.Get(dc),
  
  814
  >
  		HealthHistoryInitializationTime:     dynamicconfig.HealthHistoryInitializationTime.Get(dc),
  
  815
  >
  
  816
  >
  		BreakdownMetricsByTaskQueue: dynamicconfig.MetricsBreakdownByTaskQueue.Get(dc),
  
  817
  >
  
  818
  >
  		LogAllReqErrors: dynamicconfig.LogAllReqErrors.Get(dc),
  
  819
  >
  
  820
  >
  		NumConsecutiveWorkflowTaskProblemsToTriggerSearchAttribute: dynamicconfig.NumConsecutiveWorkflowTaskProblemsToTriggerSearchAttribute.Get(dc),
  
  821
  >
  
  822
  >
  		// Worker-Versioning related
  
  823
  >
  		UseRevisionNumberForWorkerVersioning: dynamicconfig.UseRevisionNumberForWorkerVersioning.Get(dc),
  
  824
  >
  		EnableSuggestCaNOnNewTargetVersion:   dynamicconfig.EnableSuggestCaNOnNewTargetVersion.Get(dc),
  
  825
  >
  		EnableSendTargetVersionChanged:       dynamicconfig.EnableSendTargetVersionChanged.Get(dc),
  
  826
  >
  		VersionMembershipCacheTTL:            dynamicconfig.VersionMembershipCacheTTL.Get(dc),
  
  827
  >
  		VersionMembershipCacheMaxSize:        dynamicconfig.VersionMembershipCacheMaxSize.Get(dc),
  
  828
  >
  		EnableVersionReactivationSignals:     dynamicconfig.EnableVersionReactivationSignals.Get(dc),
  
  829
  >
  		RoutingInfoCacheTTL:                  dynamicconfig.RoutingInfoCacheTTL.Get(dc),
  
  830
  >
  		RoutingInfoCacheMaxSize:              dynamicconfig.RoutingInfoCacheMaxSize.Get(dc),
  
  831
  >
  
  832
  >
  		// Workflow task completion pagination
  
  833
  >
  		EnableWorkflowTaskCompletionPagination: dynamicconfig.EnableWorkflowTaskCompletionPagination.Get(dc),
  
  834
  >
  		WorkflowTaskCompletionBufferSizeLimit:  dynamicconfig.WorkflowTaskCompletionBufferSizeLimit.Get(dc),
  
  835
  >
  	}
  
  836
  >
  
  837
  >
  	return cfg
  
  838
  >
  }
  
  839
  
  840
  
  // GetShardID return the corresponding shard ID for a given namespaceID and workflowID pair

go.temporal.io/server/common/dynamicconfig/setting_gen.go 9 introduced LOC · 3 ranges