We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cbeee27 commit 47593d3Copy full SHA for 47593d3
src/utils.rs
@@ -9,11 +9,9 @@ pub async fn setup_jetstream(nats_client: &async_nats::Client) -> Result<jetstre
9
let stream_config = stream::Config {
10
name: "PYTH_PRICE_UPDATES".to_string(),
11
subjects: vec!["pyth.price.updates".to_string()],
12
- max_age: Duration::from_secs(300),
13
max_bytes: 1024 * 1024 * 4000,
14
duplicate_window: Duration::from_secs(60),
15
- discard: stream::DiscardPolicy::New,
16
- max_messages_per_subject: 100,
+ discard: stream::DiscardPolicy::Old,
17
allow_direct: true,
18
allow_rollup: true,
19
..Default::default()
0 commit comments