David Reiss 9743d33e83 Revert "change the history cache key name to *Bytes (#4649)" ...

This reverts commit 587bbf371e.

2023-07-28 15:55:46 -07:00

..

ack_manager_mock.go

…

ack_manager_test.go

Revert "change the history cache key name to *Bytes (#4649)"

2023-07-28 15:55:46 -07:00

ack_manager.go

Fix prometheus metrics (#4393)

2023-05-26 01:06:15 -07:00

bi_direction_stream_test.go

Bugfix: do not leak gRPC stream (#4368)

2023-05-19 01:07:47 -07:00

bi_direction_stream.go

Bugfix: do not leak gRPC stream (#4368)

2023-05-19 01:07:47 -07:00

dlq_handler_mock.go

…

dlq_handler_test.go

…

dlq_handler.go

…

executable_activity_state_task_test.go

Properly handle replication task lifecycle (#4126)

2023-03-31 15:19:45 -07:00

executable_activity_state_task.go

Add more metrics for stream replication (#4539)

2023-06-29 14:39:56 -07:00

executable_history_task_test.go

Properly handle replication task lifecycle (#4126)

2023-03-31 15:19:45 -07:00

executable_history_task.go

Add more metrics for stream replication (#4539)

2023-06-29 14:39:56 -07:00

executable_noop_task_test.go

Add poison pill support for replication stream (#4116)

2023-03-29 12:33:00 -07:00

executable_noop_task.go

Use sequential task processor for replication (#4339)

2023-05-15 12:36:05 -07:00

executable_task_initializer.go

Use sequential task processor for replication (#4339)

2023-05-15 12:36:05 -07:00

executable_task_mock.go

Abort a task if schedule shuts down (#4125)

2023-04-17 12:18:59 -07:00

executable_task_test.go

Abort a task if schedule shuts down (#4125)

2023-04-17 12:18:59 -07:00

executable_task_tracker_mock.go

Bugfix: ExecutableTaskTracker LowWatermark funcion (#4343)

2023-05-15 15:47:48 -07:00

executable_task_tracker_test.go

Bugfix: ExecutableTaskTracker LowWatermark funcion (#4343)

2023-05-15 15:47:48 -07:00

executable_task_tracker.go

Bugfix: ExecutableTaskTracker LowWatermark funcion (#4343)

2023-05-15 15:47:48 -07:00

executable_task.go

Fix metrics tagging in stream replication task processing (#4625)

2023-07-20 21:48:47 -07:00

executable_unknown_task_test.go

Add poison pill support for replication stream (#4116)

2023-03-29 12:33:00 -07:00

executable_unknown_task.go

Use sequential task processor for replication (#4339)

2023-05-15 12:36:05 -07:00

executable_workflow_state_task_test.go

Handle replicate workflow state with exist workflow data (#4617)

2023-07-20 21:48:47 -07:00

executable_workflow_state_task.go

Handle replicate workflow state with exist workflow data (#4617)

2023-07-20 21:48:47 -07:00

fx.go

Use sequential task processor for replication (#4339)

2023-05-15 12:36:05 -07:00

grpc_stream_client.go

Enforce uniqueness of replication stream (#4448)

2023-06-08 11:18:04 -07:00

metrics.go

Add additional metrics for stream replication (#4323)

2023-05-14 20:08:17 -07:00

poller_manager_test.go

…

poller_manager.go

Add util to map shard IDs (#4175)

2023-04-17 18:18:50 -07:00

raw_task_converter_test.go

Validation API should use low priority lock (#4140)

2023-04-11 10:59:37 -07:00

raw_task_converter.go

Validation API should use low priority lock (#4140)

2023-04-11 10:59:37 -07:00

sequential_queue.go

Use sequential task processor for replication (#4339)

2023-05-15 12:36:05 -07:00

stream_receiver_mock.go

Enforce uniqueness of replication stream (#4448)

2023-06-08 11:18:04 -07:00

stream_receiver_monitor_test.go

Enforce uniqueness of replication stream (#4448)

2023-06-08 11:18:04 -07:00

stream_receiver_monitor.go

Better handle admin handler stream replication API lifecycle (#4647)

2023-07-20 21:50:23 -07:00

stream_receiver_test.go

Enforce uniqueness of replication stream (#4448)

2023-06-08 11:18:04 -07:00

stream_receiver.go

Enforce uniqueness of replication stream (#4448)

2023-06-08 11:18:04 -07:00

stream_sender_mock.go

Enforce uniqueness of replication stream (#4448)

2023-06-08 11:18:04 -07:00

stream_sender_test.go

Add namespace migration support for replication stream (#4488)

2023-06-14 12:46:32 -07:00

stream_sender.go

Add namespace migration support for replication stream (#4488)

2023-06-14 12:46:32 -07:00

stream.go

Enforce uniqueness of replication stream (#4448)

2023-06-08 11:18:04 -07:00

task_executor_mock.go

…

task_executor_test.go

…

task_executor.go

Handle replicate workflow state with exist workflow data (#4617)

2023-07-20 21:48:47 -07:00

task_fetcher_mock.go

…

task_fetcher_test.go

Remove unused metrics.ServiceIdx (#4454)

2023-06-08 22:12:26 -07:00

task_fetcher.go

…

task_processor_manager_test.go

Bugfix: backfill replication queue state read ID calculation (#4391)

2023-05-24 13:03:55 -07:00

task_processor_manager.go

Fix prometheus metrics (#4393)

2023-05-26 01:06:15 -07:00

task_processor_mock.go

…

task_processor_test.go

…

task_processor.go

Code style simplification and improved readability for returning errors (#4236)

2023-04-26 15:37:55 -07:00