temporal

mirror of https://github.com/temporalio/temporal.git synced 2026-08-30 18:41:49 -07:00

Files

Rodrigo Zhou b6dd0ef35b Capture panic in ServiceErrorInterceptor (#11813 )

## What changed?
Capture panic in `ServiceErrorInterceptor`

## Why?
`ServiceErrorInterceptor` is a top-level interceptor for frontend,
history and matching. Capturing panics to make sure unhandled panics
won't crash the service.

## How did you test it?
- [x] built
- [ ] run locally and tested manually
- [ ] covered by existing tests
- [x] added new unit test(s)
- [ ] added new functional test(s)

## Potential risks

2026-08-27 15:41:10 -07:00

configs

Move CancelOutstandingWorkerPolls partition fan out to matching server (#9424 )

2026-07-14 20:50:43 +00:00

counter

Fairness counter: reseed CMS (#9443 )

2026-03-19 16:40:06 -07:00

hooks

Add SyncMatchOutcome to hooks API with rate limiting signal (#10045 )

2026-05-13 20:10:52 -07:00

workers

Implement CountWorkers API (#9476 )

2026-06-11 17:44:13 +00:00

ack_manager_test.go

Apply lint fixes for oss-matching (#10798 )

2026-06-22 12:24:52 -07:00

ack_manager.go

Remove license header from every file (#7689 )

2025-05-01 18:50:21 -07:00

backlog_age_tracker.go

Remove license header from every file (#7689 )

2025-05-01 18:50:21 -07:00

backlog_manager_test.go

Fix read and ack levels moving backwards in priTaskReader (#11570 )

2026-08-15 01:16:07 +00:00

backlog_manager.go

Replace errors.As with errors.AsType (#11674 )

2026-08-25 09:04:00 -07:00

bits_test.go

Dynamic partitioning: scale manager (#10365 )

2026-06-04 17:34:25 -07:00

bits.go

Dynamic partitioning: scale manager (#10365 )

2026-06-04 17:34:25 -07:00

config.go

Remove matching.enableMigration (#11133 )

2026-07-24 15:20:52 -07:00

db.go

Add subqueue-id tag to some logs (#11603 )

2026-08-17 19:47:10 -07:00

deployment_util.go

Pin workflows across ContinueAsNew and implement Cross-TQ inheritance (#7776 )

2025-05-30 02:21:12 +00:00

fair_backlog_manager.go

Replace errors.As with errors.AsType (#11674 )

2026-08-25 09:04:00 -07:00

fair_level_test.go

Matching fairness: testTaskManager implementation (#7953 )

2025-07-22 16:37:58 +01:00

fair_level.go

Migrate fairTaskReader outstanding tasks to a CoW btree (#11371 )

2026-08-06 18:54:08 -07:00

fair_task_reader.go

Replace errors.As with errors.AsType (#11674 )

2026-08-25 09:04:00 -07:00

fair_task_writer.go

Use buffered channel in task writers (#10848 )

2026-06-25 23:03:28 +00:00

fairness_util_test.go

Dither initial fairness pass (#10772 )

2026-06-23 11:04:37 -07:00

fairness_util.go

Dither initial fairness pass (#10772 )

2026-06-23 11:04:37 -07:00

fairness.md

Matching fairness: reader, writer, backlog manager (#7967 )

2025-07-22 16:43:59 +01:00

forwarder_test.go

Apply lint fixes for oss-matching (#10798 )

2026-06-22 12:24:52 -07:00

forwarder.go

Store worker attributes needed by server to propagate nexus tasks to worker (#9231 )

2026-04-10 17:51:46 -07:00

fx.go

Capture panic in ServiceErrorInterceptor (#11813 )

2026-08-27 15:41:10 -07:00

handler_test.go

Use task queue kind instead of name prefix for nexus metrics (#10141 )

2026-05-01 13:44:16 -07:00

handler.go

Add panic handlers to matching handler APIs for consistency (#11090 )

2026-07-15 14:08:41 -07:00

liveness_test.go

Remove license header from every file (#7689 )

2025-05-01 18:50:21 -07:00

liveness.go

Remove license header from every file (#7689 )

2025-05-01 18:50:21 -07:00

loadcause_string_gen.go

Update Go lint tooling (#11673 )

2026-08-20 09:47:39 -07:00

matcher_data_test.go

Migrate PollerPQ to an intrusive linked list. (#11345 )

2026-07-31 11:01:51 -05:00

matcher_data.go

Migrate PollerPQ to an intrusive linked list. (#11345 )

2026-07-31 11:01:51 -05:00

matcher_test.go

Add tasks_dropped observability metric to the matching service (#10759 )

2026-06-23 17:24:32 -07:00

matcher.go

Add tasks_dropped observability metric to the matching service (#10759 )

2026-06-23 17:24:32 -07:00

matching_engine_interfaces.go

Move CancelOutstandingWorkerPolls partition fan out to matching server (#9424 )

2026-07-14 20:50:43 +00:00

matching_engine_test.go

partition scaler: when checking backlog don't load unloaded partitions, do check all versioned queues that could have backlog (#11434 )

2026-08-06 22:37:41 -07:00

matching_engine.go

Add Worker Deployment and BuildID labels to (workflow,activity) task completion metrics (#11348 )

2026-08-27 16:38:22 +00:00

metrics_util_test.go

Remove tasks_expired metric, superseded by tasks_dropped (#10642 )

2026-07-21 16:19:15 -07:00

metrics_util.go

Remove tasks_expired metric, superseded by tasks_dropped (#10642 )

2026-07-21 16:19:15 -07:00

nexus_endpoint_client.go

Split Background task priority to PriorityHigh and PriorityLow (#7901 )

2025-06-12 08:57:53 -07:00

partition_scaler_interface.go

Dynamic partitioning: sync backlog counts (#10874 )

2026-07-15 15:06:08 -07:00

partition_scaler_mock.go

Dynamic partitioning: scale manager (#10365 )

2026-06-04 17:34:25 -07:00

physical_task_queue_key_test.go

Apply lint fixes for oss-matching (#10798 )

2026-06-22 12:24:52 -07:00

physical_task_queue_key.go

Implement new task queue kind to send worker commands (#9899 )

2026-04-20 18:57:03 +00:00

physical_task_queue_manager_interface.go

Fix poller scaling decisions for backlog tasks and rate-limited queues (#11618 )

2026-08-19 18:57:58 +00:00

physical_task_queue_manager_mock.go

Fix poller scaling decisions for backlog tasks and rate-limited queues (#11618 )

2026-08-19 18:57:58 +00:00

physical_task_queue_manager_test.go

Fix poller scaling decisions for backlog tasks and rate-limited queues (#11618 )

2026-08-19 18:57:58 +00:00

physical_task_queue_manager.go

Fix poller scaling decisions for backlog tasks and rate-limited queues (#11618 )

2026-08-19 18:57:58 +00:00

poller_history_test.go

Eagerly remove worker from poller history on worker shutdown (#9289 )

2026-02-12 21:08:01 -08:00

poller_history.go

Eagerly remove worker from poller history on worker shutdown (#9289 )

2026-02-12 21:08:01 -08:00

pri_backlog_manager.go

Replace errors.As with errors.AsType (#11674 )

2026-08-25 09:04:00 -07:00

pri_forwarder.go

Store worker attributes needed by server to propagate nexus tasks to worker (#9231 )

2026-04-10 17:51:46 -07:00

pri_matcher_test.go

Don't subscribe to dynamic config until partition manager Start, fixing loser-of-load-race leak (#11053 )

2026-07-20 18:02:43 -07:00

pri_matcher.go

Migrate PollerPQ to an intrusive linked list. (#11345 )

2026-07-31 11:01:51 -05:00

pri_metrics_handler.go

Fix data race in test and lint warnings (#8082 )

2025-07-22 11:52:22 -07:00

pri_task_reader.go

Replace errors.As with errors.AsType (#11674 )

2026-08-25 09:04:00 -07:00

pri_task_writer.go

Use buffered channel in task writers (#10848 )

2026-06-25 23:03:28 +00:00

rate_limit_fraction_provider_test.go

Add TaskQueueRateLimitFractionProvider interface to scale task queue rate limits (#10827 )

2026-07-02 09:13:36 -07:00

rate_limit_fraction_provider.go

Add TaskQueueRateLimitFractionProvider interface to scale task queue rate limits (#10827 )

2026-07-02 09:13:36 -07:00

ratelimit_manager_test.go

Don't subscribe to dynamic config until partition manager Start, fixing loser-of-load-race leak (#11053 )

2026-07-20 18:02:43 -07:00

ratelimit_manager.go

Don't subscribe to dynamic config until partition manager Start, fixing loser-of-load-race leak (#11053 )

2026-07-20 18:02:43 -07:00

reachability_test.go

Remove license header from every file (#7689 )

2025-05-01 18:50:21 -07:00

reachability.go

Apply lint fixes for oss-matching (#10798 )

2026-06-22 12:24:52 -07:00

README.md

Document Workflow Update internals (#6448 )

2024-09-03 12:09:06 -07:00

scale_manager_mock.go

Dynamic partitioning: scale manager (#10365 )

2026-06-04 17:34:25 -07:00

scale_manager_test.go

partition scaler: when checking backlog don't load unloaded partitions, do check all versioned queues that could have backlog (#11434 )

2026-08-06 22:37:41 -07:00

scale_manager.go

partition scaler: when checking backlog don't load unloaded partitions, do check all versioned queues that could have backlog (#11434 )

2026-08-06 22:37:41 -07:00

service.go

Remove license header from every file (#7689 )

2025-05-01 18:50:21 -07:00

simple_partition_scaler_test.go

Dynamic partitioning: sync backlog counts (#10874 )

2026-07-15 15:06:08 -07:00

simple_partition_scaler.go

Dynamic partitioning: sync backlog counts (#10874 )

2026-07-15 15:06:08 -07:00

task_gc.go

Use typed atomic values (#11675 )

2026-08-20 10:47:13 -07:00

task_queue_partition_manager_interface.go

partition scaler: when checking backlog don't load unloaded partitions, do check all versioned queues that could have backlog (#11434 )

2026-08-06 22:37:41 -07:00

task_queue_partition_manager_mock.go

partition scaler: when checking backlog don't load unloaded partitions, do check all versioned queues that could have backlog (#11434 )

2026-08-06 22:37:41 -07:00

task_queue_partition_manager_test.go

Fix sticky queue stats zeroed out (#11527 )

2026-08-14 12:30:08 -07:00

task_queue_partition_manager.go

Make Nexus log messages aggregatable (#11765 )

2026-08-27 15:07:29 -07:00

task_reader.go

Remove tasks_expired metric, superseded by tasks_dropped (#10642 )

2026-07-21 16:19:15 -07:00

task_tracker_test.go

Add simplePartitionScaler (#10544 )

2026-06-18 16:19:57 -07:00

task_tracker.go

Move locking for task tracker to higher levels (#10964 )

2026-07-07 19:57:10 -07:00

task_validation_mock.go

Fix task validator on root partition in pri matcher (#9237 )

2026-02-11 23:30:55 +00:00

task_validation_test.go

Validate activity task stamps before reuse (#8536 )

2025-11-04 00:27:12 +00:00

task_validation.go

Refactor business ID into a struct (#9956 )

2026-04-20 13:58:51 -07:00

task_writer.go

Use buffered channel in task writers (#10848 )

2026-06-25 23:03:28 +00:00

task.go

Migrate PollerPQ to an intrusive linked list. (#11345 )

2026-07-31 11:01:51 -05:00

unloadcause_string_gen.go

Update Go lint tooling (#11673 )

2026-08-20 09:47:39 -07:00

user_data_manager_mock.go

Dynamic partitioning: scale manager (#10365 )

2026-06-04 17:34:25 -07:00

user_data_manager_test.go

Separate ephemeral data for different task queue types (#9450 )

2026-03-25 14:52:52 -07:00

user_data_manager.go

Replace errors.As with errors.AsType (#11674 )

2026-08-25 09:04:00 -07:00

validate_partition_counts_test.go

Dynamic partitioning: server validation (#9997 )

2026-05-22 11:05:13 -07:00

version_rule_helper_test.go

go fix (#9337 )

2026-02-18 09:12:19 -08:00

version_rule_helpers.go

Refactor: use new serviceerror.New...f constructors (#7785 )

2025-05-17 00:21:32 +00:00

version_rule_test.go

go fix (#9337 )

2026-02-18 09:12:19 -08:00

version_sets_merge_test.go

Remove license header from every file (#7689 )

2025-05-01 18:50:21 -07:00

version_sets_merge.go

Apply lint fixes for oss-matching (#10798 )

2026-06-22 12:24:52 -07:00

version_sets_test.go

go fix (#9337 )

2026-02-18 09:12:19 -08:00

version_sets.go

Refactor: use new serviceerror.New...f constructors (#7785 )

2025-05-17 00:21:32 +00:00

README.md

See docs/architecture/matching-service.md.