Skip to content

Commit afc2ddd

Browse files
committed
reformat
1 parent 5c8fa1d commit afc2ddd

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

src/callback/strategy/fixed_retry.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,15 +8,15 @@ use crate::callback::EventCallback;
88

99
use super::CallbackStrategy;
1010

11+
pub const BACK_OFF_MAX_RETRIES: u64 = 5;
12+
pub const BACK_OFF_MAX_DELAY_MS: u64 = 200;
13+
1114
#[derive(Clone, Copy, Debug)]
1215
pub struct FixedRetryConfig {
1316
pub max_attempts: u64,
1417
pub delay_ms: u64,
1518
}
1619

17-
pub const BACK_OFF_MAX_RETRIES: u64 = 5;
18-
pub const BACK_OFF_MAX_DELAY_MS: u64 = 200;
19-
2020
impl Default for FixedRetryConfig {
2121
fn default() -> Self {
2222
Self { max_attempts: BACK_OFF_MAX_RETRIES, delay_ms: BACK_OFF_MAX_DELAY_MS }

src/callback/strategy/state_sync_aware.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,11 @@ use crate::{FixedRetryConfig, callback::EventCallback};
88

99
use super::{CallbackStrategy, fixed_retry::FixedRetryStrategy};
1010

11+
pub const STATE_SYNC_RETRY_INTERVAL: Duration = Duration::from_secs(30);
12+
pub const STATE_SYNC_RETRY_MAX_INTERVAL: Duration = Duration::from_secs(120);
13+
pub const STATE_SYNC_RETRY_MAX_ELAPSED: Duration = Duration::from_secs(600);
14+
pub const STATE_SYNC_RETRY_MULTIPLIER: f64 = 1.5;
15+
1116
#[derive(Clone, Copy, Debug)]
1217
pub struct StateSyncConfig {
1318
pub initial_interval: Duration,
@@ -16,11 +21,6 @@ pub struct StateSyncConfig {
1621
pub multiplier: f64,
1722
}
1823

19-
pub const STATE_SYNC_RETRY_INTERVAL: Duration = Duration::from_secs(30);
20-
pub const STATE_SYNC_RETRY_MAX_INTERVAL: Duration = Duration::from_secs(120);
21-
pub const STATE_SYNC_RETRY_MAX_ELAPSED: Duration = Duration::from_secs(600);
22-
pub const STATE_SYNC_RETRY_MULTIPLIER: f64 = 1.5;
23-
2424
impl Default for StateSyncConfig {
2525
fn default() -> Self {
2626
Self {

0 commit comments

Comments
 (0)