headers.go ×1
Frontier kind: Code frontier
unlabeled · c_251dc4cbb6e4
88 tests · 1584 LOC · 64 files · introduces 0 tests · 1 LOC · 1 file
Introduces — evidence that enters the hierarchy at this concept
- Code
- 1 range1 lines · 1 files
- Tests
- 0 tests
Contains — complete concept membership
- All code (extent)
- 191 ranges1584 lines · 64 files · Browse complete extent
- All tests (intent)
- 88 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.
- headers.go ×1 — Focused concept Introduced files:
-
workflow_handler.go ×11 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/client/matching/client_gen.go
- go.temporal.io/server/client/matching/metric_client_gen.go
- go.temporal.io/server/client/matching/retryable_client_gen.go
- go.temporal.io/server/common/rpc/interceptor/routing_key_extractor_gen.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/matching/handler.go
-
common.go ×1 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/persistence/sql/common.go
- go.temporal.io/server/service/history/queues/queue_scheduled.go
- go.temporal.io/server/service/matching/db.go
- go.temporal.io/server/temporaltest/options.go
-
request_response.pb.go ×6 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/historyservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/client/history/client.go
- go.temporal.io/server/client/history/metric_client_gen.go
- go.temporal.io/server/client/history/retryable_client_gen.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/client/matching/metric_client.go
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/history/handler.go
- go.temporal.io/server/service/history/queues/executable.go
- go.temporal.io/server/service/history/queues/scheduler.go
- go.temporal.io/server/service/history/transfer_queue_task_executor_base.go
- go.temporal.io/server/service/history/worker_versioning_util.go
- go.temporal.io/server/service/matching/handler.go
- go.temporal.io/server/service/matching/matching_engine.go
- go.temporal.io/server/service/matching/pri_forwarder.go
-
visibility_store.go ×17 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/common/client_cache.go
- go.temporal.io/server/common/namespace/namespace.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/visibility.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/visibility.go
- go.temporal.io/server/common/persistence/visibility/store/sql/query_converter_legacy.go
- go.temporal.io/server/common/persistence/visibility/store/sql/query_converter_legacy_factory.go
- go.temporal.io/server/common/persistence/visibility/store/sql/query_converter_legacy_sqlite.go
- go.temporal.io/server/common/persistence/visibility/store/sql/visibility_store.go
- go.temporal.io/server/common/persistence/visibility/visibility_manager_impl.go
- go.temporal.io/server/common/searchattribute/mapper.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/matching/pri_matcher.go
- go.temporal.io/server/service/matching/task.go
- go.temporal.io/server/temporaltest/server.go
-
telemetry.go ×2 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/common/searchattribute/mapper.go
- go.temporal.io/server/temporaltest/options.go
- fx.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
-
collector.go ×7 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/testing/testtelemetry/collector.go
- go.temporal.io/server/temporal/fx.go
-
data_store_factory.go ×29 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/persistence/client/fx.go
- go.temporal.io/server/common/persistence/telemetry/cluster_metadata_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/data_store_factory.go
- go.temporal.io/server/common/persistence/telemetry/execution_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/nexus_endpoint_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/queue_gen.go
- go.temporal.io/server/common/persistence/telemetry/queue_v2_gen.go
- go.temporal.io/server/common/persistence/telemetry/shard_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/shared_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/task_store_gen.go
- go.temporal.io/server/common/resource/fx.go
- go.temporal.io/server/common/rpc/interceptor/logtags/admin_service_server_gen.go
- go.temporal.io/server/common/rpc/interceptor/logtags/history_service_server_gen.go
- go.temporal.io/server/common/rpc/interceptor/logtags/matching_service_server_gen.go
- go.temporal.io/server/common/rpc/interceptor/logtags/workflow_service_server_gen.go
- go.temporal.io/server/common/rpc/interceptor/logtags/workflow_tags.go
- go.temporal.io/server/common/telemetry/grpc.go
- go.temporal.io/server/service/frontend/fx.go
- go.temporal.io/server/service/fx.go
- go.temporal.io/server/service/history/queues/executable.go
- go.temporal.io/server/temporal/fx.go
- TestNewServer — Ancestor (broader) Introduced tests:
- pri_matcher.go ×1 — Ancestor (broader) Introduced files:
- timer_queue_active_task_executor.go ×1 — Ancestor (broader) Introduced files:
- TestNewServer — Ancestor (broader) Introduced tests:
-
metric_client.go ×3 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/persistence/v1/executions.pb.go
- go.temporal.io/server/api/persistence/v1/namespaces.pb.go
- go.temporal.io/server/client/history/client_gen.go
- go.temporal.io/server/client/history/metric_client.go
- go.temporal.io/server/service/frontend/workflow_handler.go
-
request_response.pb.go ×12 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/adminservice/v1/request_response.pb.go
- go.temporal.io/server/api/adminservice/v1/service_grpc.pb.go
- go.temporal.io/server/common/log/with_logger.go
- go.temporal.io/server/common/namespace/nsregistry/registry.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/sql/sqlplugin/sqlite/plugin.go
- go.temporal.io/server/common/resource/fx.go
- go.temporal.io/server/common/util.go
- go.temporal.io/server/service/frontend/admin_handler.go
- go.temporal.io/server/service/frontend/http_api_server.go
- go.temporal.io/server/temporal/server_option.go
-
workflow_task_completed_handler.go ×9 — Ancestor (broader)
Introduced files:
- 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/service/history/api/get_history_util.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
- go.temporal.io/server/service/matching/pri_forwarder.go
- pri_forwarder.go ×2 — Ancestor (broader) Introduced files:
- request_response.pb.go ×1 — Ancestor (broader) Introduced files:
- logger.go ×1 — Ancestor (broader) Introduced files:
- connections.go ×1 — Ancestor (broader) Introduced files:
- persistence_rate_limited_clients.go ×2 — Ancestor (broader) Introduced files:
- logger.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- metric_client.go ×2 — Ancestor (broader) Introduced files:
- pri_matcher.go ×1 — Ancestor (broader) Introduced files:
- task_queue_partition_manager.go ×2 — Ancestor (broader) Introduced files:
- connections.go ×2 — Ancestor (broader) Introduced files:
-
workflow_handler.go ×8 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/historyservice/v1/service_grpc.pb.go
- go.temporal.io/server/client/history/client_gen.go
- go.temporal.io/server/client/history/metric_client_gen.go
- go.temporal.io/server/client/history/retryable_client_gen.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/history/handler.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
- go.temporal.io/server/service/history/workflow/workflow_task_state_machine.go
- go.temporal.io/server/temporaltest/logger.go
- pri_matcher.go ×1 — Ancestor (broader) Introduced files:
- handler.go ×1 — Ancestor (broader) Introduced files:
- pri_matcher.go ×8 — Ancestor (broader) Introduced files:
- matching_engine.go ×1 — Ancestor (broader) Introduced files:
- server.go ×1 — Ancestor (broader) Introduced files:
- logger.go ×2 — Ancestor (broader) Introduced files:
- queue_scheduled.go ×1 — Ancestor (broader) Introduced files:
-
handler.go ×25 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/historyservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/taskqueue/v1/message.pb.go
- go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/request_response.pb.go
- go.temporal.io/server/chasm/lib/tests/gen/testspb/v1/request_response.pb.go
- go.temporal.io/server/client/history/client.go
- go.temporal.io/server/client/history/client_gen.go
- go.temporal.io/server/client/history/metric_client.go
- go.temporal.io/server/client/history/metric_client_gen.go
- go.temporal.io/server/client/history/retryable_client_gen.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/client/matching/loadbalancer.go
- go.temporal.io/server/client/matching/metric_client.go
- go.temporal.io/server/common/cluster/metadata.go
- go.temporal.io/server/common/membership/ringpop/service_resolver.go
- go.temporal.io/server/common/namespace/namespace.go
- go.temporal.io/server/common/namespace/nsregistry/registry.go
- go.temporal.io/server/common/persistence/client/quotas.go
- go.temporal.io/server/common/persistence/execution_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/sql/execution.go
- go.temporal.io/server/common/rpc/interceptor/health_check.go
- go.temporal.io/server/common/rpc/interceptor/namespace_rate_limit.go
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/common/rpc/rpc.go
- go.temporal.io/server/common/tasks/fifo_scheduler.go
- go.temporal.io/server/common/util.go
- go.temporal.io/server/common/worker_versioning/worker_versioning.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/history/api/get_history_util.go
- go.temporal.io/server/service/history/configs/quotas.go
- go.temporal.io/server/service/history/fx.go
- go.temporal.io/server/service/history/handler.go
- go.temporal.io/server/service/history/queues/executable.go
- go.temporal.io/server/service/history/queues/queue_base.go
- go.temporal.io/server/service/history/shard/controller_impl.go
- go.temporal.io/server/service/history/shard/ownership_based_quota_calculator.go
- go.temporal.io/server/service/history/workflow/cache/cache.go
- go.temporal.io/server/service/history/workflow/metrics.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
- go.temporal.io/server/service/matching/handler.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
-
metric_client_gen.go ×4 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/client/frontend/client.go
- go.temporal.io/server/client/frontend/client_gen.go
- go.temporal.io/server/client/frontend/metric_client.go
- go.temporal.io/server/client/frontend/metric_client_gen.go
- go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go
- go.temporal.io/server/service/frontend/namespace_handler.go
- pri_forwarder.go ×1 — Ancestor (broader) Introduced files:
- matching_service_server_gen.go ×1 — Ancestor (broader) Introduced files:
- http_api_server.go ×23 — Ancestor (broader) Introduced files:
- db.go ×1 — Ancestor (broader) Introduced files:
- pri_task_writer.go ×3 — Ancestor (broader) Introduced files:
- namespace_handover.go ×3 — Ancestor (broader) Introduced files:
- task_queue_partition_manager.go ×2 — Ancestor (broader) Introduced files:
- matching_engine.go ×3 — Ancestor (broader) Introduced files:
-
service_grpc.pb.go ×19 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/client/matching/client_gen.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_gen.go
- go.temporal.io/server/common/client_cache.go
- go.temporal.io/server/common/metrics/grpc.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/rpc/dial_tracer.go
- go.temporal.io/server/common/rpc/interceptor/context_metadata_interceptor.go
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/service/frontend/service.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/matching/handler.go
- go.temporal.io/server/service/matching/matching_engine.go
- go.temporal.io/server/service/matching/simple_partition_scaler.go
-
request_response.pb.go ×6 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/client/matching/client_gen.go
- go.temporal.io/server/client/matching/metric_client.go
- go.temporal.io/server/client/matching/metric_client_gen.go
- go.temporal.io/server/service/matching/handler.go
- go.temporal.io/server/service/matching/matching_engine.go
- go.temporal.io/server/service/matching/pri_forwarder.go
- reader.go ×2 — Ancestor (broader) Introduced files:
-
service_grpc.pb.go ×20 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/taskqueue/v1/message.pb.go
- go.temporal.io/server/client/clientfactory.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_gen.go
- go.temporal.io/server/common/client_cache.go
- go.temporal.io/server/common/namespace/nsregistry/registry.go
- go.temporal.io/server/common/persistence/client/quotas.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/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/quotas/rate_burst.go
- go.temporal.io/server/common/rpc/interceptor/redirection.go
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/common/rpc/rpc.go
- go.temporal.io/server/common/sdk/metrics_handler.go
- go.temporal.io/server/common/tqid/task_queue_id.go
- go.temporal.io/server/service/frontend/configs/quotas.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/fx.go
- go.temporal.io/server/service/matching/config.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/nexus_endpoint_client.go
- go.temporal.io/server/service/matching/simple_partition_scaler.go
- go.temporal.io/server/service/matching/task_queue_partition_manager.go
- go.temporal.io/server/service/matching/user_data_manager.go
-
endpoint_registry.go ×2 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/authorization/default_authorizer.go
- go.temporal.io/server/common/log/noop_logger.go
- go.temporal.io/server/common/nexus/endpoint_registry.go
- go.temporal.io/server/service/worker/scanner/scanner.go
- go.temporal.io/server/service/worker/service.go
- go.temporal.io/server/service/worker/worker.go
- go.temporal.io/server/temporaltest/options.go
- server.go ×3 — Ancestor (broader) Introduced files:
- scanner.go ×1 — Ancestor (broader) Introduced files:
- mask_internal_error.go ×1 — Ancestor (broader) Introduced files:
- matching_engine.go ×2 — Ancestor (broader) Introduced files:
-
service_resolver.go ×4 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/client/history/connections.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/common/dynamicconfig/collection.go
- go.temporal.io/server/common/membership/ringpop/factory.go
- go.temporal.io/server/common/membership/ringpop/monitor.go
- go.temporal.io/server/common/membership/ringpop/service_resolver.go
- go.temporal.io/server/temporal/fx.go
- go.temporal.io/server/temporal/server_impl.go
-
lite_server.go ×25 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/primitives/timestamp/duration.go
- go.temporal.io/server/schema/sqlite/setup.go
- go.temporal.io/server/service/frontend/fx.go
- go.temporal.io/server/service/frontend/service.go
- go.temporal.io/server/temporal/server_option.go
- go.temporal.io/server/temporaltest/internal/lite_server.go
- go.temporal.io/server/temporaltest/options.go
- go.temporal.io/server/temporaltest/server.go
-
fx.go ×44 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/client/clientfactory.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/client/matching/client_gen.go
- go.temporal.io/server/client/matching/metric_client.go
- go.temporal.io/server/common/config/archival.go
- go.temporal.io/server/common/config/config.go
- go.temporal.io/server/common/config/fx.go
- go.temporal.io/server/common/config/persistence.go
- go.temporal.io/server/common/dynamicconfig/collection.go
- go.temporal.io/server/common/membership/ringpop/factory.go
- go.temporal.io/server/common/membership/ringpop/fx.go
- go.temporal.io/server/common/membership/ringpop/monitor.go
- go.temporal.io/server/common/membership/ringpop/service_resolver.go
- go.temporal.io/server/common/persistence/cassandra/version_checker.go
- go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/db.go
- go.temporal.io/server/common/pprof/fx.go
- go.temporal.io/server/common/pprof/pprof.go
- go.temporal.io/server/common/resource/fx.go
- go.temporal.io/server/common/rpc/encryption/local_store_tls_provider.go
- go.temporal.io/server/common/rpc/interceptor/dc_redirection_policy.go
- go.temporal.io/server/common/rpc/rpc.go
- go.temporal.io/server/service/frontend/fx.go
- go.temporal.io/server/service/history/fx.go
- go.temporal.io/server/service/matching/fx.go
- go.temporal.io/server/service/worker/fx.go
- go.temporal.io/server/temporal/fx.go
- go.temporal.io/server/temporal/server.go
- go.temporal.io/server/temporal/server_impl.go
- go.temporal.io/server/temporal/server_option.go
- go.temporal.io/server/temporal/server_options.go
- adaptive_pool.go ×1 — Ancestor (broader) Introduced files:
- queue_immediate.go ×1 — Ancestor (broader) Introduced files:
- fx.go ×1 — Ancestor (broader) Introduced files:
-
service.go ×8 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/service_client.pb.go
- go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go
- go.temporal.io/server/client/client_bean.go
- go.temporal.io/server/client/history/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/redirector.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/client/matching/metric_client.go
- go.temporal.io/server/common/client_cache.go
- go.temporal.io/server/common/cluster/fx.go
- go.temporal.io/server/common/cluster/metadata.go
- go.temporal.io/server/common/deadlock/deadlock.go
- go.temporal.io/server/common/log/sdk_logger.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/persistence/health_signal_aggregator.go
- go.temporal.io/server/common/persistence/history_task_queue_manager.go
- go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go
- go.temporal.io/server/common/tasks/rate_limited_scheduler.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/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/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/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/fx.go
- go.temporal.io/server/service/history/workflow/cache/cache.go
- go.temporal.io/server/service/history/workflow/cache/fx.go
- go.temporal.io/server/service/matching/handler.go
- go.temporal.io/server/service/matching/service.go
- go.temporal.io/server/service/worker/pernamespaceworker.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
- rpc.go ×1 — Ancestor (broader) Introduced files:
- queue_scheduled.go ×1 — Ancestor (broader) Introduced files:
- fx.go ×1 — Ancestor (broader) Introduced files:
-
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
- namespace_burst_hit_when_burst_ratio_is_1_and_global_limit_is_set, namespace_burst_hit_when_burst_ratio_is_1.5_and_global_limit_is_set — Ancestor (broader) Introduced tests:
-
namespace_rate_hit_when_burst_ratio_is_1, namespace_burst_hit_when_burst_ratio_is_0.5, +1 — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/namespace_burst_hit_when_burst_ratio_is_0.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/namespace_burst_hit_when_burst_ratio_is_1.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/namespace_rate_hit_when_burst_ratio_is_1
-
replication_inducing_op_burst_hit_when_burst_ratio_is_1_and_global_limit_is_set, replication_inducing_op_burst_hit_when_burst_ratio_is_1.5_and_global_limit_is_set — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_burst_hit_when_burst_ratio_is_1.5_and_global_limit_is_setgo.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_burst_hit_when_burst_ratio_is_1_and_global_limit_is_set
-
replication_inducing_op_rate_hit_when_burst_ratio_is_1, replication_inducing_op_burst_hit_when_burst_ratio_is_0.5, +1 — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_burst_hit_when_burst_ratio_is_0.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_burst_hit_when_burst_ratio_is_1.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_rate_hit_when_burst_ratio_is_1
- visibility_burst_hit_when_burst_ratio_is_1_and_global_limit_is_set, visibility_burst_hit_when_burst_ratio_is_1.5_and_global_limit_is_set — Ancestor (broader) Introduced tests:
-
visibility_rate_hit_when_burst_ratio_is_1, visibility_burst_hit_when_burst_ratio_is_0.5, +1 — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/visibility_burst_hit_when_burst_ratio_is_0.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/visibility_burst_hit_when_burst_ratio_is_1.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/visibility_rate_hit_when_burst_ratio_is_1
- namespace_burst_allow_when_burst_ratio_is_1_and_global_limit_is_set, namespace_burst_allow_when_burst_ratio_is_1.5_and_global_limit_is_set — Ancestor (broader) Introduced tests:
-
namespace_rate_allow_when_burst_ratio_is_1, namespace_burst_allow_when_burst_ratio_is_0.5, +1 — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/namespace_burst_allow_when_burst_ratio_is_0.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/namespace_burst_allow_when_burst_ratio_is_1.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/namespace_rate_allow_when_burst_ratio_is_1
-
replication_inducing_op_burst_allow_when_burst_ratio_is_1_and_global_limit_is_set, replication_inducing_op_burst_allow_when_burst_ratio_is_1.5_and_global_limit_is_set — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_burst_allow_when_burst_ratio_is_1.5_and_global_limit_is_setgo.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_burst_allow_when_burst_ratio_is_1_and_global_limit_is_set
-
replication_inducing_op_rate_allow_when_burst_ratio_is_1, replication_inducing_op_burst_allow_when_burst_ratio_is_0.5, +1 — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_burst_allow_when_burst_ratio_is_0.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_burst_allow_when_burst_ratio_is_1.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/replication_inducing_op_rate_allow_when_burst_ratio_is_1
- global_limit_is_emitted_when_set — Ancestor (broader) Introduced tests:
- host_limit_emitted_when_frontend_service_count_is_not_set — Ancestor (broader) Introduced tests:
- host_limit_emitted_when_global_limit_is_not_set — Ancestor (broader) Introduced tests:
-
visibility_burst_allow_when_burst_ratio_is_1_and_global_limit_is_set, visibility_burst_allow_when_burst_ratio_is_1.5_and_global_limit_is_set — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/visibility_burst_allow_when_burst_ratio_is_1.5_and_global_limit_is_setgo.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/visibility_burst_allow_when_burst_ratio_is_1_and_global_limit_is_set
-
visibility_rate_allow_when_burst_ratio_is_1, visibility_burst_allow_when_burst_ratio_is_0.5, +1 — Ancestor (broader)
Introduced tests:
go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/visibility_burst_allow_when_burst_ratio_is_0.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/visibility_burst_allow_when_burst_ratio_is_1.5go.temporal.io/server/service/frontend/TestNamespaceRateLimitInterceptorProvider/visibility_rate_allow_when_burst_ratio_is_1
- namespace_rate_limit.go ×1 — Ancestor (broader) Introduced files:
- both_rate_limits_hit, global_rate_limit_hit — Ancestor (broader) Introduced tests:
- global_rate_limit_not_configured_and_per_instance_rate_limit_is_hit — Ancestor (broader) Introduced tests:
- neither_rate_limit_hit, per_instance_rate_limit_hit_but_ignored_because_global_rate_limit_is_not_hit — Ancestor (broader) Introduced tests:
- no_hosts_causes_global_RPS_limit_to_be_ignored — Ancestor (broader) Introduced tests:
- nil_service_resolver_causes_global_RPS_limit_to_be_ignored, global_rate_limit_not_configured_and_per_instance_rate_limit_not_hit — Ancestor (broader) Introduced tests:
- global_rate_limit_not_configured_and_zero_per-instance_rate_limit — Ancestor (broader) Introduced tests:
- namespace.go ×1 — Ancestor (broader) Introduced files:
- interfaces_mock.go ×1 — Ancestor (broader) Introduced files:
- quotas.go ×1 — Ancestor (broader) Introduced files:
- quotas.go ×1 — Ancestor (broader) Introduced files:
- interfaces_mock.go ×1 — Ancestor (broader) Introduced files:
- rate_burst.go ×3 — Ancestor (broader) Introduced files:
- fx.go ×3 — Ancestor (broader) Introduced files:
- fx.go ×3 — Ancestor (broader) Introduced files:
- quotas.go ×1 — Ancestor (broader) Introduced files:
- routing_rate_limiter_impl.go ×3 — Ancestor (broader) Introduced files:
- interceptor.go ×2 — Ancestor (broader) Introduced files: Introduced tests:
- TestAlternateHeaders — Ancestor (broader) Introduced tests:
- TestNoopClaimMapperWithoutTLS — Ancestor (broader) Introduced tests:
- interceptor.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
-
audience_mapper_mock.go ×3 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/authorization/audience_mapper_mock.go
- go.temporal.io/server/common/authorization/interceptor.go
-
headers.go ×2 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/authorization/interceptor.go
- go.temporal.io/server/common/headers/headers.go
- TestMultipleTargetNamespaces — Ancestor (broader) Introduced tests:
- SignalExternalWorkflow — Ancestor (broader) Introduced tests:
- interceptor.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- interceptor.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- namespace_rate_limit.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- interceptor.go ×2 — Ancestor (broader) Introduced files:
- interceptor.go ×3 — Ancestor (broader) Introduced files: Introduced tests:
- TestIntercept_PollMethod_WaitEnabled_RateLimited — Ancestor (broader) Introduced tests:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- TestPrincipalPropagation_Disabled, TestPrincipalPropagation_SpoofedHeadersStripped — Ancestor (broader) Introduced tests:
- interceptor.go ×5 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- interceptor.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- interceptor.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- audience_mapper_mock.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
-
SameNamespace, EmptyNamespace, +3 — Ancestor (broader)
Introduced tests:
go.temporal.io/server/common/authorization/TestAuthorizerInterceptorSuite/TestCrossNamespaceCommand_DisabledFeaturego.temporal.io/server/common/authorization/TestAuthorizerInterceptorSuite/TestIsAuthorizedgo.temporal.io/server/common/authorization/TestAuthorizerInterceptorSuite/TestIsAuthorizedWithNamespacego.temporal.io/server/common/authorization/TestAuthorizerInterceptorSuite/TestNoExtraAuthCheck/EmptyNamespacego.temporal.io/server/common/authorization/TestAuthorizerInterceptorSuite/TestNoExtraAuthCheck/SameNamespace
- TestIsUnauthorized — Ancestor (broader) Introduced tests:
- TestIsUnknown — Ancestor (broader) Introduced tests:
- TestIntercept_NonPollMethod_WaitEnabled — Ancestor (broader) Introduced tests:
- claim_mapper.go ×2 — Ancestor (broader) Introduced files:
- noop_authorizer.go ×1 — Ancestor (broader) Introduced files:
- TestIntercept_PollMethod_WaitDisabled — Ancestor (broader) Introduced tests:
- TestIntercept_PollMethod_WaitForTokenEnabled — Ancestor (broader) Introduced tests:
- interceptor.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- TestInterceptStream_Authorized — Ancestor (broader) Introduced tests:
- namespace_rate_limit.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- namespace_rate_limit.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×4 — Ancestor (broader) Introduced files:
- namespace_rate_limit.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- namespace_rate_limit.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- TestInterceptWithNoTokenConfig — Ancestor (broader) Introduced tests:
- authorizer_mock.go ×3 — Ancestor (broader) Introduced files:
- interceptor.go ×3 — Ancestor (broader) Introduced files:
- TestInterceptWithNonZeroTokenConfig — Ancestor (broader) Introduced tests:
- namespace_rate_limit.go ×7 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×2 — Ancestor (broader) Introduced files:
- rate_limit.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×2 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×2 — Ancestor (broader) Introduced files:
- namespace_rate_limit.go ×1 — Ancestor (broader) Introduced files:
- claim_mapper_mock.go ×3 — Ancestor (broader) Introduced files:
- namespace_rate_limit.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×3 — Ancestor (broader) Introduced files:
- headers.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×2 — Ancestor (broader) Introduced files:
- interceptor.go ×1 — Ancestor (broader) Introduced files:
- interceptor.go ×4 — Ancestor (broader) Introduced files:
- metadata.go ×3 — Ancestor (broader) Introduced files: Introduced tests:
- headers.go ×1 — Descendant (narrower) Introduced files:
- headers.go ×1 — Descendant (narrower) Introduced files:
-
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
go.temporal.io/server/common/circuitbreaker/TestTSCBWithDynamicSettingsgo.temporal.io/server/common/dynamicconfig/TestDeepCopy_OtherReferenceTypes_Nilgo.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIPrioritiesOrderedgo.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIToPriorityMapping
- grpc_resolver.go ×2 — Descendant (narrower) Introduced files:
-
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:
-
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
- tags.go ×9 — Descendant (narrower) Introduced files:
- message.pb.go ×2 — Descendant (narrower) Introduced files:
-
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
- wildcard.go ×1 — Descendant (narrower) Introduced files:
- wildcard.go ×4 — Descendant (narrower) Introduced files:
- retrypolicy.go ×3 — Descendant (narrower) Introduced files:
- message.pb.go ×2 — Descendant (narrower) Introduced files:
- TestOperatorServiceMetadata, TestWorkflowServiceMetadata — Descendant (narrower) Introduced tests:
Introduced tests
Every collected test enters the hierarchy at exactly one concept.
No tests are introduced at this concept. Its intent tests are introduced by other concepts.
Introduced code
Every collected source range enters the hierarchy at exactly one concept.
1 file ranked by introduced lines: 1 introduced LOC across 1 ranges. Expand a file to inspect source; the > gutter marks introduced lines.