David ReissandAlex Shtin cefda12b18 Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00

..

configs

Core persistence priority rate limiting (#3139)

2022-07-29 10:40:20 -07:00

ackManager.go

Move ackLevel past gaps in task ids (#2281)

2021-12-09 12:34:44 -08:00

config.go

Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00

context.go

Use strong types for namespace Name and Id (#2082)

2021-10-29 18:21:26 -07:00

db_task_manager_test.go

Rename scheduleID to scheduledEventID and startedID to startedEventID (#2992)

2022-06-15 11:48:11 -07:00

db_task_manager.go

Update future to use generics (#2722)

2022-04-13 16:37:23 -07:00

db_task_queue_ownership_mock.go

Persistence Context Part 2: Shard, Task, Metadata, ClusterMetadata Manager (#2632)

2022-03-23 11:36:14 -07:00

db_task_queue_ownership_test.go

Rename scheduleID to scheduledEventID and startedID to startedEventID (#2992)

2022-06-15 11:48:11 -07:00

db_task_queue_ownership.go

Persistence Context Part 2: Shard, Task, Metadata, ClusterMetadata Manager (#2632)

2022-03-23 11:36:14 -07:00

db_task_reader_mock.go

Update iterator to use go generics (#2672)

2022-03-29 13:30:40 -07:00

db_task_reader_test.go

Update iterator to use go generics (#2672)

2022-03-29 13:30:40 -07:00

db_task_reader.go

Update iterator to use go generics (#2672)

2022-03-29 13:30:40 -07:00

db_task_writer_mock.go

Update future to use generics (#2722)

2022-04-13 16:37:23 -07:00

db_task_writer_test.go

Rename scheduleID to scheduledEventID and startedID to startedEventID (#2992)

2022-06-15 11:48:11 -07:00

db_task_writer.go

Update future to use generics (#2722)

2022-04-13 16:37:23 -07:00

db.go

Persistence Context Part 2: Shard, Task, Metadata, ClusterMetadata Manager (#2632)

2022-03-23 11:36:14 -07:00

forwarder_test.go

Rename scheduleID to scheduledEventID and startedID to startedEventID (#2992)

2022-06-15 11:48:11 -07:00

forwarder.go

Rename scheduleID to scheduledEventID and startedID to startedEventID (#2992)

2022-06-15 11:48:11 -07:00

fx.go

Simplify system retry logic: Part 1 (#3172)

2022-08-12 12:32:18 -07:00

handler.go

Add resource_exhausted_cause metrics tag (#2423)

2022-01-27 17:08:39 -08:00

liveness_test.go

Consistent TaskQueueManager fatal signaling (#1933)

2021-09-21 06:05:18 -07:00

liveness.go

Separate liveness of task queue into a dedicated entity (#1699)

2021-07-01 10:57:10 -07:00

matcher_test.go

Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00

matcher.go

Matching cleanup (#2246)

2021-12-01 20:25:58 -08:00

matchingEngine_test.go

Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00

matchingEngine.go

Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00

matchingEngineInterfaces.go

Rename DecisionTask to WorkflowTask (#532)

2020-07-11 14:36:45 -07:00

pollerHistory.go

Fix 5s delay on sticky queue (#2811)

2022-05-06 20:13:24 -07:00

service.go

Use metrics.Client for sdk.metrics.Handler (#2302)

2021-12-15 15:05:21 -08:00

task.go

Use strong types for namespace Name and Id (#2082)

2021-10-29 18:21:26 -07:00

taskGC.go

Don't dispatch expired tasks from taskReader buffer (#3161)

2022-07-29 10:24:19 -07:00

taskqueue_test.go

Use Platform Stable Hashing; Reduce TaskQueueId Size (#647)

2020-07-31 00:59:18 -07:00

taskqueue.go

Remove extra namespace checks (#2975)

2022-06-09 11:36:21 -07:00

taskQueueManager_test.go

Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00

taskQueueManager.go

Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00

taskReader.go

Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00

tasks_test.go

Optimize matching ack manager loop perf (#1804)

2021-08-05 18:00:35 -07:00

tasks.go

Optimize matching ack manager loop perf (#1804)

2021-08-05 18:00:35 -07:00

taskWriter.go

Wait to acquire lease in matchingEngine (#3033)

2022-09-13 10:20:41 -07:00