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
use cassandra::util::Protected;
use cassandra_sys::CassRetryPolicy as _RetryPolicy;
use cassandra_sys::cass_retry_policy_default_new;
use cassandra_sys::cass_retry_policy_downgrading_consistency_new;
use cassandra_sys::cass_retry_policy_fallthrough_new;
use cassandra_sys::cass_retry_policy_free;
use cassandra_sys::cass_retry_policy_logging_new;
#[derive(Debug)]
pub struct RetryPolicy(*mut _RetryPolicy);
unsafe impl Send for RetryPolicy {}
impl Protected<*mut _RetryPolicy> for RetryPolicy {
fn inner(&self) -> *mut _RetryPolicy { self.0 }
fn build(inner: *mut _RetryPolicy) -> Self { if inner.is_null() { panic!("Unexpected null pointer") }; RetryPolicy(inner) }
}
impl RetryPolicy {
pub fn default_new() -> Self { unsafe { RetryPolicy::build(cass_retry_policy_default_new()) } }
pub fn downgrading_consistency_new() -> Self {
unsafe { RetryPolicy(cass_retry_policy_downgrading_consistency_new()) }
}
pub fn fallthrough_new() -> Self { unsafe { RetryPolicy(cass_retry_policy_fallthrough_new()) } }
pub fn logging_new(child_retry_policy: RetryPolicy) -> Self {
unsafe { RetryPolicy::build(cass_retry_policy_logging_new(child_retry_policy.0)) }
}
}
impl Drop for RetryPolicy {
fn drop(&mut self) {
unsafe {
cass_retry_policy_free(self.0);
}
}
}