reifydb-client 0.9.0

Official Rust client library for ReifyDB
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

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2026 ReifyDB

#[allow(clippy::disallowed_types)]
use std::{sync::Arc, time::Duration as StdDuration};

use reifydb_value::value::duration::Duration;

pub(crate) fn fire(callback: &Option<Arc<dyn Fn() + Send + Sync>>) {
	if let Some(callback) = callback {
		callback();
	}
}

/// Exponential backoff in milliseconds for a 1-based `attempt`, capped at 30s.
pub(crate) fn backoff_millis(base_ms: u64, attempt: u32) -> u64 {
	let factor = 1u64.checked_shl(attempt.saturating_sub(1).min(20)).unwrap_or(u64::MAX);
	base_ms.saturating_mul(factor).min(30_000)
}

#[allow(clippy::disallowed_types)]
pub(crate) fn millis_to_std(ms: u64) -> StdDuration {
	Duration::from_milliseconds(ms.min(i64::MAX as u64) as i64).unwrap().to_std()
}