tasks

queuestest

Adding documentation for dealing with DLQ messages (#5139 )

2023-11-23 02:22:43 +00:00

action_pending_task_count.go

Update slices.SortFunc for Go 1.21 (#4706 )

2023-08-24 22:30:40 -07:00

action_reader_stuck.go

Handle errors when registering new queue readers (#4055 )

2023-04-17 17:17:06 -07:00

action_slice_count.go

Use builtin min/max (#4901 )

2023-09-27 17:40:49 -07:00

action_slice_predicate.go

Use int64 as type for queue readerID (#4176 )

2023-04-21 15:59:44 -07:00

action.go

Handle errors when registering new queue readers (#4055 )

2023-04-17 17:17:06 -07:00

active_standby_executor_test.go

Improve task executor interface (#4860 )

2023-09-25 18:09:50 -07:00

active_standby_executor.go

Improve task executor interface (#4860 )

2023-09-25 18:09:50 -07:00

alerts.go

Use int64 as type for queue readerID (#4176 )

2023-04-21 15:59:44 -07:00

convert_test.go

Replace gogo/protobuf with google/protobuf (#5032 )

2023-11-21 15:19:37 -08:00

convert.go

Replace gogo/protobuf with google/protobuf (#5032 )

2023-11-21 15:19:37 -08:00

dlq_writer_test.go

Rename metricDefinition getters to follow Go's guidelines (#5185 )

2023-11-30 16:34:29 -08:00

dlq_writer.go

Rename metricDefinition getters to follow Go's guidelines (#5185 )

2023-11-30 16:34:29 -08:00

executable_factory.go

Sending a task to dlq after a number of attempts (#5367 )

2024-01-31 17:48:45 -08:00

executable_mock.go

Add a sentinel interface for terminal task errors (#5365 )

2024-01-31 17:47:39 -08:00

executable_test.go

Sending a task to dlq after a number of attempts (#5367 )

2024-01-31 17:48:45 -08:00

executable.go

Sending a task to dlq after a number of attempts (#5367 )

2024-01-31 17:48:45 -08:00

iterator_test.go

🧹 remove calls to rand.Seed (#4954 )

2023-10-10 14:34:15 -07:00

iterator.go

Use int64 as type for queue readerID (#4176 )

2023-04-21 15:59:44 -07:00

memory_scheduled_queue_test.go

Remove ExecutableWrapper (#5033 )

2023-10-25 16:34:01 -07:00

memory_scheduled_queue.go

Rename metricDefinition getters to follow Go's guidelines (#5185 )

2023-11-30 16:34:29 -08:00

metrics_test.go

Fix metric tag for delete execution task (#4275 )

2023-05-03 13:26:19 -07:00

metrics.go

In memory timeout timer queue for speculative workflow task (#4254 )

2023-05-09 13:00:15 -07:00

mitigator_test.go

Handle errors when registering new queue readers (#4055 )

2023-04-17 17:17:06 -07:00

mitigator.go

Rename metricDefinition getters to follow Go's guidelines (#5185 )

2023-11-30 16:34:29 -08:00

monitor_test.go

Handle errors when registering new queue readers (#4055 )

2023-04-17 17:17:06 -07:00

monitor.go

Fix typos in struct field / variable names (#4945 )

2023-10-09 13:05:52 -04:00

priority_assigner_test.go

Add an archival queue factory (#3562 )

2022-12-13 13:23:13 -08:00

priority_assigner.go

Remove ExecutableWrapper (#5033 )

2023-10-25 16:34:01 -07:00

queue_base_test.go

Sending a task to dlq after a number of attempts (#5367 )

2024-01-31 17:48:45 -08:00

queue_base.go

Rename metricDefinition getters to follow Go's guidelines (#5185 )

2023-11-30 16:34:29 -08:00

queue_immediate.go

Add a pluggable ExecutableWrapper to our queue factories (#4875 )

2023-09-27 13:58:37 -07:00

queue_mock.go

Deprecate old namespace change callback (#3774 )

2023-01-06 16:43:41 -08:00

queue_scheduled_test.go

Sending a task to dlq after a number of attempts (#5367 )

2024-01-31 17:48:45 -08:00

queue_scheduled.go

Rename metricDefinition getters to follow Go's guidelines (#5185 )

2023-11-30 16:34:29 -08:00

queue.go

Remove common.Daemon interface (#4573 )

2023-07-03 10:30:11 -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

Multi-cursor components: queue slice (#2996 )

2022-06-27 21:43:19 -07:00

reader_group_test.go

Use int64 as type for queue readerID (#4176 )

2023-04-21 15:59:44 -07:00

reader_group.go

Use int64 as type for queue readerID (#4176 )

2023-04-21 15:59:44 -07:00

reader_quotas.go

Per-shard per-namespace rate limiter (#4302 )

2023-05-16 09:24:45 -07:00

reader_test.go

Add a pluggable ExecutableWrapper to our queue factories (#4875 )

2023-09-27 13:58:37 -07:00

reader.go

Fix scheduled task rescheduling on failover (#5377 )

2024-01-31 16:38:52 -08:00

rescheduler_mock.go

Deprecate old namespace change callback (#3774 )

2023-01-06 16:43:41 -08:00

rescheduler_test.go

Fix scheduled task rescheduling on failover (#5377 )

2024-01-31 16:38:52 -08:00

rescheduler.go

Fix scheduled task rescheduling on failover (#5377 )

2024-01-31 16:38:52 -08:00

scheduler_mock.go

Rate limited task scheduler (#4857 )

2023-10-02 12:50:37 -07:00

scheduler_monitor.go

Rename metricDefinition getters to follow Go's guidelines (#5185 )

2023-11-30 16:34:29 -08:00

scheduler_quotas.go

Rate limited task scheduler (#4857 )

2023-10-02 12:50:37 -07:00

scheduler.go

Rate limited task scheduler (#4857 )

2023-10-02 12:50:37 -07:00

scheuduler_monitor_test.go

Rename metricDefinition getters to follow Go's guidelines (#5185 )

2023-11-30 16:34:29 -08:00

scope_test.go

Multi cursor: wire up implementation (#3176 )

2022-08-04 15:05:26 -07:00

scope.go

Multi cursor: wire up implementation (#3176 )

2022-08-04 15:05:26 -07:00

slice_test.go

Add a pluggable ExecutableWrapper to our queue factories (#4875 )

2023-09-27 13:58:37 -07:00

slice.go

Fix typos in struct field / variable names (#4945 )

2023-10-09 13:05:52 -04:00

speculative_workflow_task_timeout_executable.go

In memory timeout timer queue for speculative workflow task (#4254 )

2023-05-09 13:00:15 -07:00

speculative_workflow_task_timeout_queue.go

In memory timeout timer queue for speculative workflow task (#4254 )

2023-05-09 13:00:15 -07:00

test_util.go

Replace gogo/protobuf with google/protobuf (#5032 )

2023-11-21 15:19:37 -08:00

tracker.go

Fix typos in struct field / variable names (#4945 )

2023-10-09 13:05:52 -04:00

util_test.go

Use int64 as type for queue readerID (#4176 )

2023-04-21 15:59:44 -07:00

util.go

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

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