Yichao YangandDavid Reiss 0ed76e3359 Fix scheduled queue max read level update for single processor (#3474)

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

..

action_pending_task_count.go

Multi-cursor: fix scheduled queue look-ahead (#3364)

2022-09-12 11:45:41 -07:00

action_reader_stuck.go

Multi-cursor: fix scheduled queue look-ahead (#3364)

2022-09-12 11:45:41 -07:00

action_slice_count.go

Multi-cursor: fix scheduled queue look-ahead (#3364)

2022-09-12 11:45:41 -07:00

action_slice_predicate.go

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

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

action.go

Multi-cursor: reader watermark monitoring and mitigation (#3253)

2022-08-25 14:40:22 -07:00

alerts.go

Multi-cursor: pending task count monitoring & mitigation (#3275)

2022-08-31 13:12:43 -07:00

convert_test.go

…

convert.go

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

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

executable_mock.go

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

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

executable_test.go

Skip task namespaceNotActive check in single queue mode (#3369)

2022-09-12 14:52:32 -07:00

executable.go

Use separate metric for resource exhausted error in task processing (#3463)

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

executor_wrapper.go

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

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

iterator_test.go

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

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

iterator.go

…

metrics.go

Use separate metric for resource exhausted error in task processing (#3463)

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

mitigator_test.go

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

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

mitigator.go

Multi-cursor: move alert deduping to queue monitor (#3315)

2022-09-06 22:20:37 -07:00

monitor_test.go

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

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

monitor.go

Multi-cursor: move alert deduping to queue monitor (#3315)

2022-09-06 22:20:37 -07:00

priority_assigner_test.go

Multi-cursor: improve namespace failover (#3279)

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

priority_assigner.go

Multi-cursor: improve namespace failover (#3279)

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

queue_base_test.go

Multi-cursor: slice predicate action (#3312)

2022-09-06 22:36:27 -07:00

queue_base.go

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

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

queue_immediate.go

Multi-cursor: fix scheduled queue look-ahead (#3364)

2022-09-12 11:45:41 -07:00

queue_mock.go

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

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

queue_scheduled_test.go

Multi-cursor: fix scheduled queue look-ahead (#3364)

2022-09-12 11:45:41 -07:00

queue_scheduled.go

Multi-cursor: fix scheduled queue look-ahead (#3364)

2022-09-12 11:45:41 -07:00

queue.go

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

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

range_test.go

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

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

range.go

…

reader_group_test.go

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

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

reader_group.go

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

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

reader_quotas.go

Add more queue and task processing metrics (#3274)

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

reader_test.go

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

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

reader.go

Multi-cursor: fix scheduled queue look-ahead (#3364)

2022-09-12 11:45:41 -07:00

rescheduler_mock.go

Multi-cursor: improve namespace failover (#3279)

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

rescheduler_test.go

Multi-cursor: improve namespace failover (#3279)

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

rescheduler.go

Fix timerGate race condition in rescheduler (#3396)

2022-09-15 15:25:59 -07:00

scheduler_mock.go

Task channel aware rescheduling (#3266)

2022-08-25 16:11:03 -07:00

scheduler_monitor.go

Add more queue and task processing metrics (#3274)

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

scheduler.go

Improve task scheduler namespace change callback (#3293)

2022-09-01 21:55:33 -07:00

scheuduler_monitor_test.go

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

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

scope_test.go

…

scope.go

…

slice_test.go

Multi-cursor: shrink slice predicate (#3291)

2022-09-02 12:23:35 -07:00

slice.go

Multi-cursor: fix scheduled queue look-ahead (#3364)

2022-09-12 11:45:41 -07:00

test_util.go

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

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

tracker.go

Multi-cursor: shrink slice predicate (#3291)

2022-09-02 12:23:35 -07:00

util_test.go

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

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

util.go

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

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