object_transfer 1.2.0

An object transfer library for various message broker and/or protocols
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

/// Configuration for Redis stream subscribers, including fetch count and block time.
///
/// Defaults:
/// - `consumer_name`: same as `topic_name`
/// - `group_name`: same as `topic_name`
/// - `topic_name`: as provided
/// - `num_fetch`: 10
/// - `block_time`: 5000 ms (5 seconds)
/// - `auto_claim`: 30000 ms (min-idle-time for xauto-claim)
#[derive(Clone, Debug)]
pub struct SubscriberConfig {
  pub(in super::super) consumer_name: String,
  pub(in super::super) group_name: String,
  pub(in super::super) topic_name: String,
  pub(in super::super) num_fetch: usize,
  pub(in super::super) block_time: usize,
  pub(in super::super) auto_claim: usize,
}

impl SubscriberConfig {
  /// Creates a new configuration with defaults and the given topic name.
  /// # Parameters
  ///
  /// * `topic_name` - The name of the Redis stream topic.
  ///
  pub fn new(topic_name: impl Into<String>) -> Self {
    let topic_name = topic_name.into();
    Self {
      consumer_name: topic_name.clone(),
      group_name: topic_name.clone(),
      topic_name: topic_name,
      num_fetch: 10,     // Default number to fetch
      block_time: 5000,  // Default block time in milliseconds (5 seconds)
      auto_claim: 30000, // min-idle-time for xauto-claim in milliseconds (30 seconds)
    }
  }

  /// Sets the consumer name.
  pub fn consumer_name(mut self, consumer_name: impl Into<String>) -> Self {
    self.consumer_name = consumer_name.into();
    self
  }

  /// Sets the consumer group name.
  pub fn group_name(mut self, group_name: impl Into<String>) -> Self {
    self.group_name = group_name.into();
    self
  }

  /// Sets the topic (stream) name.
  pub fn topic_name(mut self, topic_name: impl Into<String>) -> Self {
    self.topic_name = topic_name.into();
    self
  }

  /// Sets how many messages to fetch per read.
  pub fn num_fetch(mut self, count: usize) -> Self {
    self.num_fetch = count;
    self
  }

  /// Sets the blocking time in milliseconds for each read.
  pub fn block_time(mut self, millis: usize) -> Self {
    self.block_time = millis;
    self
  }

  /// Sets the minimum idle time in milliseconds for auto-claiming pending messages.
  /// If the value is 0, auto-claiming is disabled.
  pub fn auto_claim(mut self, millis: usize) -> Self {
    self.auto_claim = millis;
    self
  }
}