bus-nats 0.1.1

NATS JetStream backend for eventbus-rs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use async_nats::jetstream::consumer::{AckPolicy, DeliverPolicy, pull};
use std::time::Duration;

/// Build a pull consumer config for durable, exactly-once-capable consumption.
pub fn build_pull_config(
    durable: &str,
    filter: &str,
    max_deliver: i64,
    ack_wait: Duration,
    backoff: &[Duration],
) -> pull::Config {
    pull::Config {
        durable_name: Some(durable.into()),
        filter_subject: filter.into(),
        ack_policy: AckPolicy::Explicit,
        deliver_policy: DeliverPolicy::All,
        ack_wait,
        max_deliver,
        backoff: backoff.to_vec(),
        ..Default::default()
    }
}