tasks

api

Add separate metrics for memo size (#3365 )

2022-09-12 08:34:43 -07:00

configs

Add config filter by task type (#3455 )

2022-10-10 17:26:01 -04:00

consts

Simplify system retry logic: Part 1 (#3172 )

2022-08-04 14:39:10 -07:00

events

Make staticcheck great again (#3103 )

2022-07-15 10:01:11 -07:00

queues

Fix scheduled queue max read level update for single processor (#3474 )

2022-10-17 19:58:18 -04:00

replication

Fix replication task nil case (#3531 )

2022-10-31 13:36:59 -07:00

shard

Fix resilient shard (#3584 )

2022-11-15 11:34:32 -08:00

tasks

Update replication use branch token (#3447 )

2022-10-10 17:26:02 -04:00

tests

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

2022-06-28 18:00:47 -07:00

vclock

Add cluster ID to clock (#2871 )

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

workflow

Warning log on new event during set workflow (#3508 )

2022-10-18 17:33:59 -04:00

commandChecker_test.go

Support upsert memo (#3091 )

2022-08-25 09:12:58 -07:00

commandChecker.go

Log warning only when there is an error in SA size validation (#3443 )

2022-09-29 13:46:22 -07:00

fx.go

Increase default sendArchiveSignal timeout and make it configurable (#3325 )

2022-09-07 19:40:14 -07:00

handler.go

Move signal workflow to api package (#3348 )

2022-09-08 17:02:25 -07:00

historyEngine2_test.go

Fix timer task visibility timestamp for workflow refresh (#3460 )

2022-10-17 19:58:18 -04:00

historyEngine3_eventsv2_test.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

historyEngine_test.go

Fix fail workflow due to attributes size violation (#3388 )

2022-09-15 13:53:16 -07:00

historyEngine.go

Use multi-cursor queue state for workflow deletion check (#3332 )

2022-09-09 11:23:41 -07:00

historyEngineFactory.go

Use multi-cursor queue state for workflow deletion check (#3332 )

2022-09-09 11:23:41 -07:00

historyEngineInterfaces_mock.go

Fix failover queue shutdown (#3232 )

2022-08-15 23:08:10 -07:00

historyEngineInterfaces.go

Fix failover queue shutdown (#3232 )

2022-08-15 23:08:10 -07:00

nDCActivityReplicator_mock.go

Add 'make ci-build' step to Buildkite (#1173 )

2021-01-10 09:31:56 -08:00

nDCActivityReplicator_test.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

nDCActivityReplicator.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

nDCBranchMgr_mock.go

Add 'make ci-build' step to Buildkite (#1173 )

2021-01-10 09:31:56 -08:00

nDCBranchMgr_test.go

Make staticcheck great again (#3103 )

2022-07-15 10:01: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

Restructure history service mutable state & related logics (#1641 )

2021-06-17 01:05:20 -07:00

nDCConflictResolver_test.go

Remove deprecated shard info ack level fields (#2884 )

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

nDCConflictResolver.go

Add RebuildMutableState API (#2532 )

2022-02-22 23:15:55 -08:00

nDCConstants.go

Update LICENSE file and all go files with new license header (#285 )

2020-04-08 20:39:01 -07:00

nDCEventsReapplier_mock.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

nDCEventsReapplier_test.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

nDCEventsReapplier.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

nDCHistoryReplicator_test.go

Fix timer task visibility timestamp for workflow refresh (#3460 )

2022-10-17 19:58:18 -04:00

nDCHistoryReplicator.go

Fix sanitize mutable state after replication (#3479 )

2022-10-17 19:58:18 -04:00

nDCReplicationTask.go

Make staticcheck great again (#3103 )

2022-07-15 10:01:11 -07:00

nDCStandbyTaskUtil.go

Remove deprecated namespace fields (#3329 )

2022-09-07 20:51:37 -07:00

nDCStateRebuilder_mock.go

Add RebuildMutableState API (#2532 )

2022-02-22 23:15:55 -08:00

nDCStateRebuilder_test.go

Make branch token initialization part of data persistence interface (#3187 )

2022-08-04 22:18:24 -07:00

nDCStateRebuilder.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

nDCTaskUtil.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

nDCTransactionMgr_mock.go

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

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

nDCTransactionMgr_test.go

Fix reset workflow in replication reapply (#3449 )

2022-10-10 17:26:01 -04:00

nDCTransactionMgr.go

Fix reset workflow in replication reapply (#3449 )

2022-10-10 17:26:01 -04:00

nDCTransactionMgrForExistingWorkflow_mock.go

Add 'make ci-build' step to Buildkite (#1173 )

2021-01-10 09:31:56 -08:00

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

Add 'make ci-build' step to Buildkite (#1173 )

2021-01-10 09:31:56 -08:00

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

Restructure history service mutable state & related logics (#1641 )

2021-06-17 01:05:20 -07:00

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

Restructure history service mutable state & related logics (#1641 )

2021-06-17 01:05:20 -07:00

nDCWorkflowResetter_test.go

Remove deprecated shard info ack level fields (#2884 )

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

nDCWorkflowResetter.go

Make staticcheck great again (#3103 )

2022-07-15 10:01:11 -07:00

queueAckMgr_test.go

Multi-cursor: improve namespace failover (#3279 )

2022-09-01 10:38:55 -07:00

queueAckMgr.go

Simplify system retry logic: Part 1 (#3172 )

2022-08-04 14:39:10 -07:00

queueFactoryBase.go

Prioritize task loading persistence requests (#3217 )

2022-09-09 12:57:17 -07:00

queueProcessorBase.go

Add more queue and task processing metrics (#3274 )

2022-08-31 11:37:10 -07:00

service.go

Make staticcheck great again (#3103 )

2022-07-15 10:01:11 -07:00

taskAllocator.go

Refactor task filter function and interface (#2556 )

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

timerQueueAckMgr_test.go

Fix scheduled queue max read level update for single processor (#3474 )

2022-10-17 19:58:18 -04:00

timerQueueAckMgr.go

Fix scheduled queue max read level update for single processor (#3474 )

2022-10-17 19:58:18 -04:00

timerQueueActiveProcessor.go

Fix scheduled queue max read level update for single processor (#3474 )

2022-10-17 19:58:18 -04:00

timerQueueActiveTaskExecutor_test.go

Remove deprecated namespace fields (#3329 )

2022-09-07 20:51:37 -07:00

timerQueueActiveTaskExecutor.go

Remove deprecated namespace fields (#3329 )

2022-09-07 20:51:37 -07:00

timerQueueFactory.go

Prioritize task loading persistence requests (#3217 )

2022-09-09 12:57:17 -07:00

timerQueueProcessor.go

Queue processor handle shard ownership lost (#3553 )

2022-11-15 11:34:06 -08:00

timerQueueProcessorBase.go

Add more queue and task processing metrics (#3274 )

2022-08-31 11:37:10 -07:00

timerQueueStandbyProcessor.go

Fix scheduled queue max read level update for single processor (#3474 )

2022-10-17 19:58:18 -04:00

timerQueueStandbyTaskExecutor_test.go

Add config filter by task type (#3455 )

2022-10-10 17:26:01 -04:00

timerQueueStandbyTaskExecutor.go

Add config filter by task type (#3455 )

2022-10-10 17:26:01 -04:00

timerQueueTaskExecutorBase_test.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

timerQueueTaskExecutorBase.go

Update replication use branch token (#3447 )

2022-10-10 17:26:02 -04:00

transferQueueActiveProcessor.go

Fix scheduled queue max read level update for single processor (#3474 )

2022-10-17 19:58:18 -04:00

transferQueueActiveTaskExecutor_test.go

Remove deprecated namespace fields (#3329 )

2022-09-07 20:51:37 -07:00

transferQueueActiveTaskExecutor.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

transferQueueFactory.go

Prioritize task loading persistence requests (#3217 )

2022-09-09 12:57:17 -07:00

transferQueueProcessor.go

Queue processor handle shard ownership lost (#3553 )

2022-11-15 11:34:06 -08:00

transferQueueProcessorBase.go

Make task scheduler TrySubmit always non-blocking (#3267 )

2022-08-25 22:56:59 -07:00

transferQueueStandbyProcessor.go

Fix scheduled queue max read level update for single processor (#3474 )

2022-10-17 19:58:18 -04:00

transferQueueStandbyTaskExecutor_test.go

Add config filter by task type (#3455 )

2022-10-10 17:26:01 -04:00

transferQueueStandbyTaskExecutor.go

Add config filter by task type (#3455 )

2022-10-10 17:26:01 -04:00

transferQueueTaskExecutorBase.go

Remove deprecated namespace fields (#3329 )

2022-09-07 20:51:37 -07:00

visibilityQueueFactory.go

Prioritize task loading persistence requests (#3217 )

2022-09-09 12:57:17 -07:00

visibilityQueueProcessor.go

Queue processor handle shard ownership lost (#3553 )

2022-11-15 11:34:06 -08:00

visibilityQueueTaskExecutor_test.go

Add metrics tags back to task executor response (#3298 )

2022-09-01 23:53:28 -07:00

visibilityQueueTaskExecutor.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

workflowRebuilder.go

Make staticcheck great again (#3103 )

2022-07-15 10:01:11 -07:00

workflowResetter_mock.go

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

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

workflowResetter_test.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

workflowResetter.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

workflowTaskHandler.go

Change search attribute validator to expect field names instead of alias (#3398 )

2022-09-16 12:29:57 -07:00

workflowTaskHandlerCallbacks_test.go

Cleanup leftover after "mutable state builder" to "mutable state" rename (#3343 )

2022-09-08 15:57:06 -07:00

workflowTaskHandlerCallbacks.go

Fix fail workflow due to attributes size violation (#3388 )

2022-09-15 13:53:16 -07:00