tasks

api

Simplify system retry logic: Part 1 (#3172 )

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

configs

Run task rescheduler in background (#3038 )

2022-08-12 11:55:37 -07:00

consts

Simplify system retry logic: Part 1 (#3172 )

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

events

Persistence Context Part 1: Execution Manager (#2622 )

2022-03-21 15:36:28 -07:00

queues

Improve task processing retry behavior (#3218 )

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

replication

Simplify system retry logic: Part 1 (#3172 )

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

shard

Fix shard close error type (#3215 )

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

tasks

Add version check for delete workflow transfer task (#3159 )

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

tests

Cancel activity when eager execution and request cancellation are in the same WFT (#3029 )

2022-07-08 12:23:14 -07:00

vclock

Add cluster ID to clock (#2871 )

2022-05-19 22:09:07 -07:00

workflow

Fix inline history archival (#3216 )

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

commandChecker_test.go

Remove namespace field from ScheduleActivityTaskCommandAttributes message (#2753 )

2022-04-22 20:00:21 -07:00

commandChecker.go

Remove namespace field from ScheduleActivityTaskCommandAttributes message (#2753 )

2022-04-22 20:00:21 -07:00

fx.go

Fix inline history archival (#3216 )

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

handler.go

Simplify system retry logic: Part 1 (#3172 )

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

historyEngine2_test.go

Simplify system retry logic: Part 1 (#3172 )

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

historyEngine3_eventsv2_test.go

Rename dt and di variables to workflowTask/wt (#2999 )

2022-06-15 16:25:24 -07:00

historyEngine_test.go

Simplify system retry logic: Part 1 (#3172 )

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

historyEngine.go

Simplify system retry logic: Part 1 (#3172 )

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

historyEngineFactory.go

Update replication processor/executor init logic (#2926 )

2022-06-02 22:46:38 -07:00

historyEngineInterfaces_mock.go

Fix failover queue shutdown (#3232 )

2022-08-16 12:28:55 -07:00

historyEngineInterfaces.go

Fix failover queue shutdown (#3232 )

2022-08-16 12:28:55 -07:00

nDCActivityReplicator_mock.go

…

nDCActivityReplicator_test.go

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

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

nDCActivityReplicator.go

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

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

nDCBranchMgr_mock.go

…

nDCBranchMgr_test.go

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

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

nDCBranchMgr.go

Handle NDC active -> passive transition with transient workflow & no buffered event (#2845 )

2022-05-24 18:41:54 -07:00

nDCConflictResolver_mock.go

…

nDCConflictResolver_test.go

Remove deprecated shard info ack level fields (#2884 )

2022-05-23 13:45:50 -07:00

nDCConflictResolver.go

…

nDCConstants.go

…

nDCEventsReapplier_mock.go

…

nDCEventsReapplier_test.go

Check workflow task after reapply events (#2840 )

2022-05-12 16:14:11 -07:00

nDCEventsReapplier.go

Check workflow task after reapply events (#2840 )

2022-05-12 16:14:11 -07:00

nDCHistoryReplicator_test.go

Update backfill history in sync workflow state (#3042 )

2022-06-30 17:28:19 -07:00

nDCHistoryReplicator.go

Clean up history branch ancestor operation (#3046 )

2022-07-08 12:28:05 -07:00

nDCReplicationTask.go

…

nDCStandbyTaskUtil.go

Use namespace Id for replication APIs (#2914 )

2022-05-27 15:45:05 -07:00

nDCStateRebuilder_mock.go

…

nDCStateRebuilder_test.go

Remove deprecated shard info ack level fields (#2884 )

2022-05-23 13:45:50 -07:00

nDCStateRebuilder.go

Update iterator to use go generics (#2672 )

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

nDCTaskUtil.go

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

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

nDCTransactionMgr_mock.go

…

nDCTransactionMgr_test.go

Remove deprecated shard info ack level fields (#2884 )

2022-05-23 13:45:50 -07:00

nDCTransactionMgr.go

Unify error handling of CRUD operation of workflow within shard context (#2662 )

2022-03-28 17:06:46 -07:00

nDCTransactionMgrForExistingWorkflow_mock.go

…

nDCTransactionMgrForExistingWorkflow_test.go

Persistence Context Part 1: Execution Manager (#2622 )

2022-03-21 15:36:28 -07:00

nDCTransactionMgrForExistingWorkflow.go

Persistence Context Part 1: Execution Manager (#2622 )

2022-03-21 15:36:28 -07:00

nDCTransactionMgrForNewWorkflow_mock.go

…

nDCTransactionMgrForNewWorkflow_test.go

Replicate workflow state (#2852 )

2022-05-19 23:27:31 -07:00

nDCTransactionMgrForNewWorkflow.go

Replicate workflow state (#2852 )

2022-05-19 23:27:31 -07:00

nDCWorkflow_mock.go

…

nDCWorkflow_test.go

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

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

nDCWorkflow.go

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

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

nDCWorkflowResetter_mock.go

…

nDCWorkflowResetter_test.go

Remove deprecated shard info ack level fields (#2884 )

2022-05-23 13:45:50 -07:00

nDCWorkflowResetter.go

Persistence Context Part 1: Execution Manager (#2622 )

2022-03-21 15:36:28 -07:00

queueAckMgr_test.go

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

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

queueAckMgr.go

Simplify system retry logic: Part 1 (#3172 )

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

queueProcessorBase.go

Fix formating

2022-08-16 14:08:56 -07:00

queueProcessorFactory.go

Metrics perf investigation (#3002 )

2022-06-16 16:58:02 -07:00

service.go

…

taskAllocator.go

Refactor task filter function and interface (#2556 )

2022-03-04 13:58:44 -08:00

timerQueueAckMgr_test.go

Properly initialize task key fire time (#2907 )

2022-05-26 14:51:42 -07:00

timerQueueAckMgr.go

Core persistence priority rate limiting (#3139 )

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

timerQueueActiveProcessor.go

Run task rescheduler in background (#3038 )

2022-08-12 11:55:37 -07:00

timerQueueActiveTaskExecutor_test.go

Metrics perf investigation (#3002 )

2022-06-16 16:58:02 -07:00

timerQueueActiveTaskExecutor.go

Metrics perf investigation (#3002 )

2022-06-16 16:58:02 -07:00

timerQueueProcessor.go

Fix shard close error type (#3215 )

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

timerQueueProcessorBase.go

Fix failover queue shutdown (#3232 )

2022-08-16 12:28:55 -07:00

timerQueueStandbyProcessor.go

Run task rescheduler in background (#3038 )

2022-08-12 11:55:37 -07:00

timerQueueStandbyTaskExecutor_test.go

Core persistence priority rate limiting (#3139 )

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

timerQueueStandbyTaskExecutor.go

Core persistence priority rate limiting (#3139 )

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

timerQueueTaskExecutorBase_test.go

Don't check delete workflow execution transfer task version (#3021 )

2022-07-08 12:22:23 -07:00

timerQueueTaskExecutorBase.go

Don't check delete workflow execution transfer task version (#3021 )

2022-07-08 12:22:23 -07:00

transferQueueActiveProcessor.go

Run task rescheduler in background (#3038 )

2022-08-12 11:55:37 -07:00

transferQueueActiveTaskExecutor_test.go

Add version check for delete workflow transfer task (#3159 )

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

transferQueueActiveTaskExecutor.go

Simplify system retry logic: Part 1 (#3172 )

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

transferQueueProcessor.go

Fix shard close error type (#3215 )

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

transferQueueProcessorBase.go

Core persistence priority rate limiting (#3139 )

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

transferQueueStandbyProcessor.go

Run task rescheduler in background (#3038 )

2022-08-12 11:55:37 -07:00

transferQueueStandbyTaskExecutor_test.go

Core persistence priority rate limiting (#3139 )

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

transferQueueStandbyTaskExecutor.go

Core persistence priority rate limiting (#3139 )

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

transferQueueTaskExecutorBase.go

Add version check for delete workflow transfer task (#3159 )

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

visibilityQueueProcessor.go

Fix shard close error type (#3215 )

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

visibilityQueueTaskExecutor_test.go

Metrics perf investigation (#3002 )

2022-06-16 16:58:02 -07:00

visibilityQueueTaskExecutor.go

Metrics perf investigation (#3002 )

2022-06-16 16:58:02 -07:00

workflowRebuilder.go

Add NamespaceInvalidState and NamespaceNotFound errors (#2785 )

2022-04-30 00:03:47 -07:00

workflowResetter_mock.go

…

workflowResetter_test.go

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

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

workflowResetter.go

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

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

workflowTaskHandler.go

Cancel activity when eager execution and request cancellation are in the same WFT (#3029 )

2022-07-08 12:23:14 -07:00

workflowTaskHandlerCallbacks_test.go

Rename dt and di variables to workflowTask/wt (#2999 )

2022-06-15 16:25:24 -07:00

workflowTaskHandlerCallbacks.go

Simplify system retry logic: Part 1 (#3172 )

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