pdoernerandRoey Berman cbdb09400b Refresh Nexus endpoints from db periodically (#6997) ...

## What changed?
<!-- Describe what has changed in this PR -->
Added a background routine to `matching/nexus_endpoint_client` which
checks whether the last known table version has changed.

## Why?
<!-- Tell your future self why have you made these changes -->
In rare cases, when a new node acquires ownership it may miss in-flight
updates from the previous owner and has no way of detecting this
inconsistency.

## How did you test it?
<!-- How have you verified this change? Tested locally? Added a unit
test? Checked in staging env? -->
Existing tests

2024-12-16 17:14:49 -08:00

..

cassandra

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

client

Retry on DataLoss error from persistence layer (#6789)

2024-11-12 19:06:24 +00:00

faultinjection

Switch to uber gomock (#6493)

2024-09-09 14:44:20 -07:00

mock

Switch to uber gomock (#6493)

2024-09-09 14:44:20 -07:00

nosql/nosqlplugin/cassandra

Switch to uber gomock (#6493)

2024-09-09 14:44:20 -07:00

persistence-tests

Different error message for per namespace per shard rate limiting (#6433)

2024-08-30 18:47:36 +00:00

persistencetest

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

schema

Bugfix: NoopResolver was always used for version compatibility check (#1233)

2021-01-28 07:47:41 -08:00

serialization

Add event version into Sync Versioned Transition task (#6790)

2024-11-12 19:54:55 +00:00

sql

Refresh Nexus endpoints from db periodically (#6997)

2024-12-16 17:14:49 -08:00

tests

Fix sqlite connection closed issue (#6815)

2024-11-14 21:31:03 +00:00

versionhistory

Fix State Based Replication handling backfill RetryReplication error (#6880)

2024-11-27 11:13:26 -08:00

visibility

Fix ES docID when workflowID contains multi-bytes unicode (#6929)

2024-12-04 17:02:24 -08:00

cluster_metadata_store.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

cluster_metadata.go

Make all Go source file names snake case (#4558)

2023-07-03 14:23:56 -04:00

data_blob.go

Replace gogo/protobuf with google/protobuf (#5032)

2023-11-21 15:19:37 -08:00

data_interfaces_mock.go

Switch to uber gomock (#6493)

2024-09-09 14:44:20 -07:00

data_interfaces.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

dlq_metrics_emitter_test.go

Clear dlq_message_count gauge when the host is not emitting this metric (#6649)

2024-10-15 09:36:11 -07:00

dlq_metrics_emitter.go

Clear dlq_message_count gauge when the host is not emitting this metric (#6649)

2024-10-15 09:36:11 -07:00

execution_manager.go

Refactor XDC cache (#6583)

2024-10-03 10:39:28 -07:00

health_signal_aggregator.go

Rename metricDefinition getters to follow Go's guidelines (#5185)

2023-11-30 16:34:29 -08:00

history_branch_util_mock.go

Switch to uber gomock (#6493)

2024-09-09 14:44:20 -07:00

history_branch_util_test.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

history_branch_util.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

history_manager_util.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

history_manager.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

history_node_util_test.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

history_node_util.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

history_task_queue_manager_test.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

history_task_queue_manager.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

json_history_token_serializer.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

metadata_manager.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

namespace_replication_queue_mock.go

Switch to uber gomock (#6493)

2024-09-09 14:44:20 -07:00

namespace_replication_queue.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

nexus_endpoint_manager.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

noop_health_signal_aggregator.go

Per shard per namespace RPS warning log (#4525)

2023-06-27 15:18:15 -07:00

operation_mode_validator_test.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

operation_mode_validator.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

persistence_interface.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

persistence_metric_clients.go

Add special handling for context.Canceled and context.DeadlineExceeded error types (#6597)

2024-10-04 14:09:30 -07:00

persistence_rate_limited_clients.go

Different error message for per namespace per shard rate limiting (#6433)

2024-08-30 18:47:36 +00:00

persistence_retryable_clients_test.go

Retry on DataLoss error from persistence layer (#6789)

2024-11-12 19:06:24 +00:00

persistence_retryable_clients.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

query_util_test.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

query_util.go

Better SQL query splitter (#3791)

2023-01-24 12:00:58 -08:00

queue_v2_util_test.go

Adding CancelDLQJob and DescribeDLQJob APIs to admin_handler (#5068)

2023-11-07 09:01:24 -08:00

queue_v2_util.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

queue_v2.go

Adding ListQueues for Cassandra and SQL (#5098)

2023-11-13 18:23:37 -08:00

serializer_test.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

shard_manager.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

size_util.go

Add persistence mutable state mutation / snapshot binary size util (#1925)

2021-09-15 17:47:17 -07:00

size.go

Add update counts to mutable state statistics (#4422)

2023-06-01 16:24:16 -04:00

task_manager.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

workflow_state_status_validator_test.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

workflow_state_status_validator.go

Import alignment (#6426)

2024-08-23 14:48:10 -06:00

xdc_cache.go

Refactor XDC cache (#6583)

2024-10-03 10:39:28 -07:00