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

use std::time::Duration;

/// 默认队列名称
pub const DEFAULT_QUEUE_NAME: &str = "default";

/// 默认最大重试次数
pub const DEFAULT_MAX_RETRY: i32 = 3;
pub const DEFAULT_MAX_ARCHIVE_SIZE: i64 = 10240;
pub const DEFAULT_ARCHIVED_EXPIRATION_IN_DAYS: i64 = 90;
/// 默认任务超时时间
pub const DEFAULT_TIMEOUT: Duration = Duration::from_secs(30 * 60); // 30 分钟

/// 版本信息
pub const VERSION: &str = env!("CARGO_PKG_VERSION");
pub const TIME_LAYOUT_YMD: &str = "%Y-%m-%d";
#[cfg(test)]
mod tests {
  use super::*;

  #[test]
  fn test_constants() {
    assert_eq!(DEFAULT_QUEUE_NAME, "default");
    assert_eq!(DEFAULT_MAX_RETRY, 3);
    assert_eq!(DEFAULT_TIMEOUT, Duration::from_secs(1800));
  }
}