object_transfer 2.0.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
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

use ::std::sync::Arc;

use ::async_nats::jetstream::{
  consumer::pull::Config as PullConfig, stream::Config as StreamConfig,
};

/// Configuration options for creating an acknowledgment-based subscriber.
///
/// This struct provides a builder pattern for configuring NATS JetStream
/// consumers with pull-based message consumption and automatic acknowledgment options.
#[derive(Debug, Clone)]
pub struct SubFetcherOpt {
  pub(super) stream_cfg: StreamConfig,
  pub(super) pull_cfg: PullConfig,
}

impl SubFetcherOpt {
  /// Creates a new `SubFetcherOpt` with the specified format and name.
  ///
  /// # Arguments
  /// * `name` - The name for both the stream and consumer
  ///
  /// # Returns
  /// A new `SubFetcherOpt` instance with default settings and auto-acknowledgment enabled
  pub fn new(name: Arc<str>) -> Self {
    Self {
      stream_cfg: StreamConfig {
        name: name.clone().to_string(),
        ..Default::default()
      },
      pull_cfg: PullConfig {
        name: Some(name.clone().to_string()),
        ..PullConfig::default()
      },
    }
  }

  /// Sets the stream name.
  ///
  /// # Arguments
  /// * `name` - The name to assign to the stream
  ///
  /// # Returns
  /// Self for method chaining
  pub fn name(mut self, name: impl Into<String>) -> Self {
    self.stream_cfg.name = name.into();
    self
  }

  /// Sets the subjects that the stream should listen to.
  ///
  /// # Arguments
  /// * `subjects` - A vector of subject patterns to subscribe to
  ///
  /// # Returns
  /// Self for method chaining
  pub fn subjects(mut self, subjects: Vec<impl Into<String>>) -> Self {
    self.stream_cfg.subjects = subjects.into_iter().map(Into::into).collect();
    self
  }

  /// Sets the durable name for the consumer.
  ///
  /// A durable consumer will persist its state and can resume consumption
  /// after disconnection.
  ///
  /// # Arguments
  /// * `durable_name` - The durable name for the consumer
  ///
  /// # Returns
  /// Self for method chaining
  pub fn durable_name(mut self, durable_name: impl Into<String>) -> Self {
    self.pull_cfg.durable_name = Some(durable_name.into());
    self
  }

  /// Sets the complete stream configuration.
  ///
  /// This replaces the entire stream configuration with the provided one.
  ///
  /// # Arguments
  /// * `stream_cfg` - The stream configuration to use
  ///
  /// # Returns
  /// Self for method chaining
  pub fn stream_config(mut self, stream_cfg: StreamConfig) -> Self {
    self.stream_cfg = stream_cfg;
    self
  }

  /// Sets the complete pull consumer configuration.
  ///
  /// This replaces the entire pull consumer configuration with the provided one.
  ///
  /// # Arguments
  /// * `pull_cfg` - The pull consumer configuration to use
  ///
  /// # Returns
  /// Self for method chaining
  pub fn pull_config(mut self, pull_cfg: PullConfig) -> Self {
    self.pull_cfg = pull_cfg;
    self
  }
}