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

Files

Qian Chen 1863fbe665 Tag replicator errors by replication task type (#11760 )

## What changed?

`replicator_errors` now records the existing `replication_task_type`
metric dimension when a namespace replication processor exhausts its
task-application retries. This distinguishes values such as
`NamespaceTask` and `TaskQueueUserData` without introducing a new
metric.

A unit test verifies that the failure counter carries the task type from
the failed replication task.

## Why?

This is a prerequisite for splitting task queue user data
(`TaskQueueUserData`) failures from namespace metadata replication
(`NamespaceTask`) alerts. Today both task kinds feed `replicator_errors`
under `NamespaceReplicationTask` and are indistinguishable, so TQUD
failures can be reported as namespace replication poison pills.

This PR only adds the server metric label. Alert definitions will be
updated separately after the label is available in deployed server
versions.

## How did you test it?

- [x] built
- [x] covered by existing tests
- [x] added unit tests
- [ ] added new functional test(s)

Manual two-cluster XDC E2E using `development-cluster-a.yaml` and
`development-cluster-b.yaml`:

- A namespace replication conflict exported
`replicationTaskType="NamespaceTask"`.
- A TQUD apply failure exported
`replicationTaskType="TaskQueueUserData"`.

2026-08-27 13:19:48 -07:00

addsearchattributes

Remove license header from every file (#7689 )

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

batcher

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

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

common

Replace payload.Encode with sadefs.MustEncodeValue (#10432 )

2026-06-11 16:28:16 -05:00

deletenamespace

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

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

dlq

Apply lint fixes for oss-foundations (#10796 )

2026-06-24 11:04:58 -07:00

dummy

[Scheduled Actions] Wire in sentinels for CreateSchedule to prevent cross-ID-space collisions (#9594 )

2026-03-24 00:05:00 +00:00

migration

Emit namespace migration workflow lifecycle events (#11658 )

2026-08-20 11:32:16 -07:00

parentclosepolicy

Stop the SDK workers and clients the worker service starts (#11436 )

2026-08-11 17:18:55 -07:00

replicator

Tag replicator errors by replication task type (#11760 )

2026-08-27 13:19:48 -07:00

scanner

Fix: Schedule scanner false-positives for inactive NS (#11703 )

2026-08-27 08:26:51 -07:00

scheduler

Capture panics in Visibility query converter (#11800 )

2026-08-27 12:58:23 -07:00

workerdeployment

Add version labels to missing deployment metric (#11799 )

2026-08-26 19:37:44 +00:00

fx.go

Emit namespace replication lifecycle wide events (#11632 )

2026-08-19 18:05:00 -07:00

pernamespaceworker_test.go

Fix per-namespace worker shutdown go-routine leak! (#10802 )

2026-06-23 20:39:25 -04:00

pernamespaceworker.go

Use typed atomic values (#11675 )

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

README.md

Delete the archival workflow code (#4782 )

2023-09-05 15:51:33 -07:00

service.go

Emit namespace replication lifecycle wide events (#11632 )

2026-08-19 18:05:00 -07:00

worker.go

Use typed atomic values (#11675 )

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

README.md

Temporal Worker

Temporal Worker is a role for Temporal service used for hosting any components responsible for performing background processing on the Temporal cluster.

Replicator

Replicator is a background worker responsible for consuming replication tasks generated by remote Temporal clusters and pass it down to processor, so they can be applied to local Temporal cluster.

Quickstart for localhost development

Start Temporal development server for active zone:
```
make start-cdc-active
```
Start Temporal development server for standby(passive) zone:
```
make start-cdc-standby
```

Connect two Temporal clusters:

tctl --ad 127.0.0.1:7233 adm cl upsert-remote-cluster --frontend_address "localhost:8233"
tctl --ad 127.0.0.1:8233 adm cl upsert-remote-cluster --frontend_address "localhost:7233"

Create global namespaces

tctl --ns sample namespace register --gd true --ac active --cl active standby

Failover between zones:

Failover to standby:

tctl --ns sample namespace update --ac standby

Failback to active:

tctl --ns sample namespace update --ac active