asynq 0.1.8

Simple, reliable & efficient distributed task queue in Rust, inspired by hibiken/asynq
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162

//! WebSocket Inspector stub
//!
//! A minimal inspector implementation for WebSocket broker.
//! Most operations are not supported as they should be handled by the asynq-server directly.

use crate::backend::pagination::Pagination;
use crate::base::keys::TaskState;
use crate::error::{Error, Result};
use crate::inspector::InspectorTrait;
use crate::task::{DailyStats, QueueInfo, QueueStats, TaskInfo};
use async_trait::async_trait;

/// Error message for unsupported inspector operations
const UNSUPPORTED_MSG: &str =
  "Inspector operations not supported via WebSocket client. Use the asynq-server's API directly.";

/// WebSocket Inspector
///
/// A stub inspector for WebSocket backend. Most operations are not supported
/// because the asynq-server handles queue inspection directly.
pub struct WebSocketInspector;

impl WebSocketInspector {
  /// Create a new WebSocket inspector
  pub fn new() -> Self {
    Self
  }
}

impl Default for WebSocketInspector {
  fn default() -> Self {
    Self::new()
  }
}

#[async_trait]
impl InspectorTrait for WebSocketInspector {
  async fn get_queue_stats(&self, _queue: &str) -> Result<QueueStats> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_queue_info(&self, _queue: &str) -> Result<QueueInfo> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_all_queue_stats(&self) -> Result<Vec<QueueStats>> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_queues(&self) -> Result<Vec<String>> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_groups(&self, _queue: &str) -> Result<Vec<String>> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn list_tasks(
    &self,
    _queue: &str,
    _state: TaskState,
    _pagination: Pagination,
  ) -> Result<Vec<TaskInfo>> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_task_info(&self, _queue: &str, _task_id: &str) -> Result<TaskInfo> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn delete_task(&self, _queue: &str, _task_id: &str) -> Result<()> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn delete_all_archived_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn delete_all_retry_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn delete_all_scheduled_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn delete_all_pending_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn requeue_all_archived_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn requeue_all_retry_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn requeue_all_scheduled_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn run_task(&self, _queue: &str, _task_id: &str) -> Result<()> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn archive_task(&self, _queue: &str, _task_id: &str) -> Result<()> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn archive_all_pending_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn archive_all_retry_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn archive_all_scheduled_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn archive_all_aggregating_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn pause_queue(&self, _queue: &str) -> Result<()> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn unpause_queue(&self, _queue: &str) -> Result<()> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn is_queue_paused(&self, _queue: &str) -> Result<bool> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_task_result(&self, _queue: &str, _task_id: &str) -> Result<Option<Vec<u8>>> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn delete_expired_completed_tasks(&self, _queue: &str) -> Result<i64> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_servers(&self) -> Result<Vec<crate::proto::ServerInfo>> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_server_info(&self, _server_id: &str) -> Result<Option<crate::proto::ServerInfo>> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn get_history(&self, _queue: &str, _days: i32) -> Result<Vec<DailyStats>> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }

  async fn cancel_processing(&self, _task_id: &str) -> Result<()> {
    Err(Error::not_supported(UNSUPPORTED_MSG))
  }
}