Projects › Concept group

Concept group

1 concept · 176 files · 12 distinct tests · 705 introduced ranges

cg_bc00326f8716ca596e39ef95 · A concept group introduce ranges in exactly the same files.

Concepts

+fx.go ×44 12 tests · 18736 LOC · 572 files · introduces 0 tests · 4693 LOC · 176 files

Shared file neighborhood

go.temporal.io/server/api/adminservice/v1/service_grpc.pb.go 1894 LOC
go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go 1911 LOC
go.temporal.io/server/api/persistence/v1/cluster_metadata.pb.go 313 LOC
go.temporal.io/server/chasm/fx.go 11 LOC
go.temporal.io/server/chasm/lib/activity/activity_tasks.go 290 LOC
go.temporal.io/server/chasm/lib/activity/config.go 83 LOC
go.temporal.io/server/chasm/lib/activity/frontend.go 579 LOC
go.temporal.io/server/chasm/lib/activity/fx.go 41 LOC
go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/service_client.pb.go 513 LOC
go.temporal.io/server/chasm/lib/activity/handler.go 525 LOC
go.temporal.io/server/chasm/lib/activity/library.go 145 LOC
go.temporal.io/server/chasm/lib/callback/config.go 184 LOC
go.temporal.io/server/chasm/lib/callback/fx.go 64 LOC
go.temporal.io/server/chasm/lib/callback/library.go 60 LOC
go.temporal.io/server/chasm/lib/callback/tasks.go 182 LOC
go.temporal.io/server/chasm/lib/nexusoperation/cancellation_tasks.go 232 LOC
go.temporal.io/server/chasm/lib/nexusoperation/config.go 279 LOC
go.temporal.io/server/chasm/lib/nexusoperation/fx.go 178 LOC
go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go 325 LOC
go.temporal.io/server/chasm/lib/nexusoperation/handler.go 295 LOC
go.temporal.io/server/chasm/lib/nexusoperation/library.go 131 LOC
go.temporal.io/server/chasm/lib/nexusoperation/operation_tasks.go 413 LOC
go.temporal.io/server/chasm/lib/nexusoperation/task_handler_base.go 207 LOC
go.temporal.io/server/chasm/lib/scheduler/config.go 115 LOC
go.temporal.io/server/chasm/lib/scheduler/fx.go 38 LOC
go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go 454 LOC
go.temporal.io/server/chasm/lib/scheduler/library.go 118 LOC
go.temporal.io/server/chasm/lib/tests/fx.go 15 LOC
go.temporal.io/server/chasm/lib/workflow/fx.go 34 LOC
go.temporal.io/server/chasm/lib/workflow/library.go 96 LOC
go.temporal.io/server/chasm/lib/workflow/nexus_service.go 137 LOC
go.temporal.io/server/chasm/library.go 60 LOC
go.temporal.io/server/chasm/registry.go 389 LOC
go.temporal.io/server/client/admin/client.go 60 LOC
go.temporal.io/server/client/admin/metric_client.go 82 LOC
go.temporal.io/server/client/admin/retryable_client.go 40 LOC
go.temporal.io/server/client/client_bean.go 248 LOC
go.temporal.io/server/client/clientfactory.go 245 LOC
go.temporal.io/server/client/frontend/client.go 48 LOC
go.temporal.io/server/client/frontend/metric_client.go 68 LOC
go.temporal.io/server/client/frontend/retryable_client.go 23 LOC
go.temporal.io/server/client/history/connections.go 187 LOC
go.temporal.io/server/client/history/metric_client.go 119 LOC
go.temporal.io/server/client/history/retryable_client.go 40 LOC
go.temporal.io/server/client/matching/client.go 535 LOC
go.temporal.io/server/client/matching/client_gen.go 702 LOC
go.temporal.io/server/client/matching/loadbalancer.go 230 LOC
go.temporal.io/server/client/matching/metric_client.go 263 LOC
go.temporal.io/server/client/matching/metric_client_gen.go 500 LOC
go.temporal.io/server/client/matching/retryable_client.go 44 LOC
go.temporal.io/server/client/matching/retryable_client_gen.go 642 LOC
go.temporal.io/server/common/archiver/archival_metadata.go 210 LOC
go.temporal.io/server/common/authorization/interceptor.go 417 LOC
go.temporal.io/server/common/client_cache.go 146 LOC
go.temporal.io/server/common/cluster/frontend_http_client.go 109 LOC
go.temporal.io/server/common/cluster/fx.go 35 LOC
go.temporal.io/server/common/cluster/metadata.go 612 LOC
go.temporal.io/server/common/config/persistence.go 323 LOC
go.temporal.io/server/common/deadlock/deadlock.go 209 LOC
go.temporal.io/server/common/deadlock/fx.go 12 LOC
go.temporal.io/server/common/dynamicconfig/collection.go 779 LOC
go.temporal.io/server/common/dynamicconfig/fx.go 19 LOC
go.temporal.io/server/common/log/slog.go 188 LOC
go.temporal.io/server/common/log/tag/tags.go 1039 LOC
go.temporal.io/server/common/membership/hostinfo_provider.go 17 LOC
go.temporal.io/server/common/metrics/fx.go 32 LOC
go.temporal.io/server/common/metrics/grpc_stats.go 52 LOC
go.temporal.io/server/common/metrics/runtime.go 128 LOC
go.temporal.io/server/common/namespace/nsregistry/fx.go 17 LOC
go.temporal.io/server/common/namespace/nsregistry/registry.go 898 LOC
go.temporal.io/server/common/nexus/trace.go 180 LOC
go.temporal.io/server/common/persistence/client/factory.go 301 LOC
go.temporal.io/server/common/persistence/client/fx.go 241 LOC
go.temporal.io/server/common/persistence/client/health_request_rate_limiter.go 159 LOC
go.temporal.io/server/common/persistence/client/quotas.go 300 LOC
go.temporal.io/server/common/persistence/cluster_metadata_store.go 218 LOC
go.temporal.io/server/common/persistence/health_signal_aggregator.go 202 LOC
go.temporal.io/server/common/persistence/metadata_manager.go 267 LOC
go.temporal.io/server/common/persistence/nexus_endpoint_manager.go 138 LOC
go.temporal.io/server/common/persistence/persistence_metric_clients.go 1465 LOC
go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go 1186 LOC
go.temporal.io/server/common/persistence/persistence_retryable_clients.go 1262 LOC
go.temporal.io/server/common/persistence/shard_manager.go 96 LOC
go.temporal.io/server/common/persistence/sql/queue.go 391 LOC
go.temporal.io/server/common/persistence/sql/shard.go 175 LOC
go.temporal.io/server/common/persistence/visibility/chasm_visibility_manager.go 94 LOC
go.temporal.io/server/common/persistence/visibility/defs.go 35 LOC
go.temporal.io/server/common/persistence/visibility/visibility_manager_impl.go 619 LOC
go.temporal.io/server/common/persistence/visibility/visibility_manager_rate_limited.go 185 LOC
go.temporal.io/server/common/persistence/visibility/visiblity_manager_metrics.go 237 LOC
go.temporal.io/server/common/pprof/pprof.go 66 LOC
go.temporal.io/server/common/quotas/multi_request_rate_limiter_impl.go 106 LOC
go.temporal.io/server/common/quotas/noop_reservation_impl.go 42 LOC
go.temporal.io/server/common/resource/fx.go 533 LOC
go.temporal.io/server/common/rpc/grpc.go 137 LOC
go.temporal.io/server/common/rpc/interceptor/health.go 47 LOC
go.temporal.io/server/common/rpc/interceptor/health_check.go 267 LOC
go.temporal.io/server/common/rpc/interceptor/mask_internal_error.go 112 LOC
go.temporal.io/server/common/rpc/interceptor/namespace_handover.go 204 LOC
go.temporal.io/server/common/rpc/interceptor/namespace_logger.go 61 LOC
go.temporal.io/server/common/rpc/interceptor/namespace_validator.go 406 LOC
go.temporal.io/server/common/rpc/interceptor/redirection.go 375 LOC
go.temporal.io/server/common/rpc/interceptor/retry.go 44 LOC
go.temporal.io/server/common/rpc/interceptor/sdk_version.go 75 LOC
go.temporal.io/server/common/rpc/interceptor/telemetry.go 412 LOC
go.temporal.io/server/common/rpc/multistats.go 36 LOC
go.temporal.io/server/common/rpc/rpc.go 413 LOC
go.temporal.io/server/common/sdk/factory.go 150 LOC
go.temporal.io/server/common/sdk/metrics_handler.go 68 LOC
go.temporal.io/server/common/tasks/rate_limited_scheduler.go 129 LOC
go.temporal.io/server/common/util.go 791 LOC
go.temporal.io/server/common/worker_versioning/version_membership_cache.go 129 LOC
go.temporal.io/server/components/callbacks/config.go 154 LOC
go.temporal.io/server/components/callbacks/fx.go 54 LOC
go.temporal.io/server/components/nexusoperations/config.go 225 LOC
go.temporal.io/server/components/nexusoperations/fx.go 22 LOC
go.temporal.io/server/service/frontend/fx.go 1057 LOC
go.temporal.io/server/service/frontend/nexus_completion_http_handler.go 620 LOC
go.temporal.io/server/service/frontend/nexus_operation_http_handler.go 319 LOC
go.temporal.io/server/service/frontend/openapi_http_handler.go 68 LOC
go.temporal.io/server/service/frontend/service.go 568 LOC
go.temporal.io/server/service/frontend/version_checker.go 207 LOC
go.temporal.io/server/service/frontend/workflow_handler.go 7521 LOC
go.temporal.io/server/service/fx.go 180 LOC
go.temporal.io/server/service/history/chasm_engine.go 1330 LOC
go.temporal.io/server/service/history/configs/quotas.go 61 LOC
go.temporal.io/server/service/history/events/fx.go 15 LOC
go.temporal.io/server/service/history/fx.go 529 LOC
go.temporal.io/server/service/history/handler.go 2627 LOC
go.temporal.io/server/service/history/history_engine.go 1145 LOC
go.temporal.io/server/service/history/history_engine_factory.go 98 LOC
go.temporal.io/server/service/history/memory_scheduled_queue_factory.go 127 LOC
go.temporal.io/server/service/history/queue_factory_base.go 242 LOC
go.temporal.io/server/service/history/queues/queue_scheduled.go 301 LOC
go.temporal.io/server/service/history/queues/scheduler.go 324 LOC
go.temporal.io/server/service/history/queues/speculative_workflow_task_timeout_queue.go 102 LOC
go.temporal.io/server/service/history/replication/dlq_handler.go 329 LOC
go.temporal.io/server/service/history/replication/dlq_writer.go 151 LOC
go.temporal.io/server/service/history/replication/eventhandler/history_events_handler.go 228 LOC
go.temporal.io/server/service/history/replication/fx.go 422 LOC
go.temporal.io/server/service/history/replication/quotas.go 29 LOC
go.temporal.io/server/service/history/replication/stream_receiver_monitor.go 435 LOC
go.temporal.io/server/service/history/replication/task_fetcher.go 423 LOC
go.temporal.io/server/service/history/replication/task_processor_manager.go 365 LOC
go.temporal.io/server/service/history/service.go 176 LOC
go.temporal.io/server/service/history/shard/context_impl.go 2369 LOC
go.temporal.io/server/service/history/shard/controller_impl.go 598 LOC
go.temporal.io/server/service/history/shard/fx.go 72 LOC
go.temporal.io/server/service/history/timer_queue_factory.go 209 LOC
go.temporal.io/server/service/history/transfer_queue_factory.go 211 LOC
go.temporal.io/server/service/history/visibility_queue_factory.go 174 LOC
go.temporal.io/server/service/history/workflow/cache/fx.go 25 LOC
go.temporal.io/server/service/history/workflow_rebuilder.go 254 LOC
go.temporal.io/server/service/matching/configs/quotas.go 106 LOC
go.temporal.io/server/service/matching/fx.go 268 LOC
go.temporal.io/server/service/matching/handler.go 726 LOC
go.temporal.io/server/service/matching/matching_engine.go 3939 LOC
go.temporal.io/server/service/matching/rate_limit_fraction_provider.go 44 LOC
go.temporal.io/server/service/matching/service.go 125 LOC
go.temporal.io/server/service/matching/simple_partition_scaler.go 181 LOC
go.temporal.io/server/service/matching/workers/registry_impl.go 532 LOC
go.temporal.io/server/service/worker/batcher/fx.go 119 LOC
go.temporal.io/server/service/worker/deletenamespace/activities.go 227 LOC
go.temporal.io/server/service/worker/deletenamespace/deleteexecutions/activities.go 284 LOC
go.temporal.io/server/service/worker/deletenamespace/fx.go 144 LOC
go.temporal.io/server/service/worker/deletenamespace/reclaimresources/activities.go 163 LOC
go.temporal.io/server/service/worker/dummy/fx.go 35 LOC
go.temporal.io/server/service/worker/fx.go 231 LOC
go.temporal.io/server/service/worker/migration/fx.go 130 LOC
go.temporal.io/server/service/worker/parentclosepolicy/processor.go 93 LOC
go.temporal.io/server/service/worker/pernamespaceworker.go 585 LOC
go.temporal.io/server/service/worker/scheduler/fx.go 149 LOC
go.temporal.io/server/service/worker/service.go 402 LOC
go.temporal.io/server/service/worker/worker.go 116 LOC
go.temporal.io/server/service/worker/workerdeployment/fx.go 160 LOC
go.temporal.io/server/temporal/fx.go 1273 LOC