use crate::cassandra::util::{Protected, ProtectedInner};
use crate::cassandra_sys::cass_retry_policy_default_new;
use crate::cassandra_sys::cass_retry_policy_downgrading_consistency_new;
use crate::cassandra_sys::cass_retry_policy_fallthrough_new;
use crate::cassandra_sys::cass_retry_policy_free;
use crate::cassandra_sys::cass_retry_policy_logging_new;
use crate::cassandra_sys::CassRetryPolicy as _RetryPolicy;
#[derive(Debug)]
pub struct RetryPolicy(*mut _RetryPolicy);
unsafe impl Send for RetryPolicy {}
unsafe impl Sync for RetryPolicy {}
impl ProtectedInner<*mut _RetryPolicy> for RetryPolicy {
fn inner(&self) -> *mut _RetryPolicy {
self.0
}
}
impl Protected<*mut _RetryPolicy> for RetryPolicy {
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);
}
}
}