pub struct RedisMessageBusConfig {
pub host: Option<String>,
pub port: Option<u16>,
pub username: Option<String>,
pub password: Option<String>,
pub ssl: bool,
pub connection_timeout: u16,
pub response_timeout: u16,
pub number_of_retries: usize,
pub exponent_base: u64,
pub max_delay: u64,
pub factor: u64,
}Expand description
Configuration for a Redis-backed message bus backing.
Redis 6.2 or higher is required for correct operation.
Fields§
§host: Option<String>The Redis host address. If None, 127.0.0.1 is used.
port: Option<u16>The Redis port. If None, 6379 is used.
username: Option<String>The Redis account username.
password: Option<String>The Redis account password.
ssl: boolIf Redis should use an SSL-enabled connection.
connection_timeout: u16The timeout (in seconds) to wait for a new connection.
response_timeout: u16The timeout (in seconds) to wait for a response.
number_of_retries: usizeThe number of retry attempts with exponential backoff for connection attempts.
exponent_base: u64The base value for exponential backoff calculation.
max_delay: u64The maximum delay between retry attempts (in seconds).
factor: u64The multiplication factor for retry delay calculation.
Trait Implementations§
Source§impl Clone for RedisMessageBusConfig
impl Clone for RedisMessageBusConfig
Source§fn clone(&self) -> RedisMessageBusConfig
fn clone(&self) -> RedisMessageBusConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for RedisMessageBusConfig
impl Debug for RedisMessageBusConfig
Source§impl Default for RedisMessageBusConfig
impl Default for RedisMessageBusConfig
impl DerefToPyAny for RedisMessageBusConfig
Source§impl<'de> Deserialize<'de> for RedisMessageBusConfigwhere
RedisMessageBusConfig: Default,
impl<'de> Deserialize<'de> for RedisMessageBusConfigwhere
RedisMessageBusConfig: Default,
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
impl Eq for RedisMessageBusConfig
Source§impl<'a, 'py> FromPyObject<'a, 'py> for RedisMessageBusConfigwhere
Self: Clone,
impl<'a, 'py> FromPyObject<'a, 'py> for RedisMessageBusConfigwhere
Self: Clone,
Source§impl<'py> IntoPyObject<'py> for RedisMessageBusConfig
impl<'py> IntoPyObject<'py> for RedisMessageBusConfig
Source§type Target = RedisMessageBusConfig
type Target = RedisMessageBusConfig
Source§type Output = Bound<'py, <RedisMessageBusConfig as IntoPyObject<'py>>::Target>
type Output = Bound<'py, <RedisMessageBusConfig as IntoPyObject<'py>>::Target>
Source§fn into_pyobject(
self,
py: Python<'py>,
) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>
fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>
Source§impl PartialEq for RedisMessageBusConfig
impl PartialEq for RedisMessageBusConfig
Source§fn eq(&self, other: &RedisMessageBusConfig) -> bool
fn eq(&self, other: &RedisMessageBusConfig) -> bool
self and other values to be equal, and is used by ==.Source§impl PyClass for RedisMessageBusConfig
impl PyClass for RedisMessageBusConfig
Source§impl PyClassImpl for RedisMessageBusConfig
impl PyClassImpl for RedisMessageBusConfig
Source§const IS_BASETYPE: bool = false
const IS_BASETYPE: bool = false
Source§const IS_SUBCLASS: bool = false
const IS_SUBCLASS: bool = false
Source§const IS_MAPPING: bool = false
const IS_MAPPING: bool = false
Source§const IS_SEQUENCE: bool = false
const IS_SEQUENCE: bool = false
Source§const IS_IMMUTABLE_TYPE: bool = false
const IS_IMMUTABLE_TYPE: bool = false
Source§const RAW_DOC: &'static CStr = /// Configuration for a Redis-backed message bus backing.
///
/// Redis 6.2 or higher is required for correct operation.
const RAW_DOC: &'static CStr = /// Configuration for a Redis-backed message bus backing. /// /// Redis 6.2 or higher is required for correct operation.
Source§const DOC: &'static CStr
const DOC: &'static CStr
text_signature if a constructor is defined. Read moreSource§type Layout = <<RedisMessageBusConfig as PyClassImpl>::BaseNativeType as PyClassBaseType>::Layout<RedisMessageBusConfig>
type Layout = <<RedisMessageBusConfig as PyClassImpl>::BaseNativeType as PyClassBaseType>::Layout<RedisMessageBusConfig>
Source§type ThreadChecker = NoopThreadChecker
type ThreadChecker = NoopThreadChecker
type Inventory = Pyo3MethodsInventoryForRedisMessageBusConfig
Source§type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild
type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild
Source§type BaseNativeType = PyAny
type BaseNativeType = PyAny
PyAny by default, and when you declare
#[pyclass(extends=PyDict)], it’s PyDict.fn items_iter() -> PyClassItemsIter
fn lazy_type_object() -> &'static LazyTypeObject<Self>
§fn dict_offset() -> Option<PyObjectOffset>
fn dict_offset() -> Option<PyObjectOffset>
§fn weaklist_offset() -> Option<PyObjectOffset>
fn weaklist_offset() -> Option<PyObjectOffset>
Source§impl PyStubType for RedisMessageBusConfig
impl PyStubType for RedisMessageBusConfig
Source§fn type_output() -> TypeInfo
fn type_output() -> TypeInfo
§fn type_input() -> TypeInfo
fn type_input() -> TypeInfo
Source§impl PyTypeInfo for RedisMessageBusConfig
impl PyTypeInfo for RedisMessageBusConfig
Source§const NAME: &str = <Self as ::pyo3::PyClass>::NAME
const NAME: &str = <Self as ::pyo3::PyClass>::NAME
prefer using ::type_object(py).name() to get the correct runtime value
Source§const MODULE: Option<&str> = <Self as ::pyo3::impl_::pyclass::PyClassImpl>::MODULE
const MODULE: Option<&str> = <Self as ::pyo3::impl_::pyclass::PyClassImpl>::MODULE
prefer using ::type_object(py).module() to get the correct runtime value
Source§fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject
fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject
§fn type_object(py: Python<'_>) -> Bound<'_, PyType>
fn type_object(py: Python<'_>) -> Bound<'_, PyType>
§fn is_type_of(object: &Bound<'_, PyAny>) -> bool
fn is_type_of(object: &Bound<'_, PyAny>) -> bool
object is an instance of this type or a subclass of this type.§fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool
fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool
object is an instance of this type.Source§impl RedisConnectionConfig for RedisMessageBusConfig
impl RedisConnectionConfig for RedisMessageBusConfig
fn host(&self) -> Option<&str>
fn port(&self) -> Option<u16>
fn username(&self) -> Option<&str>
fn password(&self) -> Option<&str>
fn ssl(&self) -> bool
fn connection_timeout(&self) -> u16
fn response_timeout(&self) -> u16
fn number_of_retries(&self) -> usize
fn exponent_base(&self) -> u64
fn max_delay(&self) -> u64
fn factor(&self) -> u64
Source§impl Serialize for RedisMessageBusConfig
impl Serialize for RedisMessageBusConfig
impl StructuralPartialEq for RedisMessageBusConfig
Auto Trait Implementations§
impl Freeze for RedisMessageBusConfig
impl RefUnwindSafe for RedisMessageBusConfig
impl Send for RedisMessageBusConfig
impl Sync for RedisMessageBusConfig
impl Unpin for RedisMessageBusConfig
impl UnsafeUnpin for RedisMessageBusConfig
impl UnwindSafe for RedisMessageBusConfig
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
impl<'py, T> FromPyObjectOwned<'py> for Twhere
T: for<'a> FromPyObject<'a, 'py>,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<'py, T> IntoPyObjectExt<'py> for Twhere
T: IntoPyObject<'py>,
impl<'py, T> IntoPyObjectExt<'py> for Twhere
T: IntoPyObject<'py>,
§fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>
fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>
self into an owned Python object, dropping type information.§fn into_py_any(self, py: Python<'py>) -> Result<Py<PyAny>, PyErr>
fn into_py_any(self, py: Python<'py>) -> Result<Py<PyAny>, PyErr>
self into an owned Python object, dropping type information and unbinding it
from the 'py lifetime.§fn into_pyobject_or_pyerr(self, py: Python<'py>) -> Result<Self::Output, PyErr>
fn into_pyobject_or_pyerr(self, py: Python<'py>) -> Result<Self::Output, PyErr>
self into a Python object. Read more§impl<'py, T> IntoPyObjectNautilusExt<'py> for Twhere
T: IntoPyObjectExt<'py>,
impl<'py, T> IntoPyObjectNautilusExt<'py> for Twhere
T: IntoPyObjectExt<'py>,
§fn into_py_any_unwrap(self, py: Python<'py>) -> Py<PyAny>
fn into_py_any_unwrap(self, py: Python<'py>) -> Py<PyAny>
§impl<T> PyErrArguments for T
impl<T> PyErrArguments for T
§impl<T> PyTypeCheck for Twhere
T: PyTypeInfo,
impl<T> PyTypeCheck for Twhere
T: PyTypeInfo,
§fn type_check(object: &Bound<'_, PyAny>) -> bool
fn type_check(object: &Bound<'_, PyAny>) -> bool
§fn classinfo_object(py: Python<'_>) -> Bound<'_, PyAny>
fn classinfo_object(py: Python<'_>) -> Bound<'_, PyAny>
isinstance and issubclass function. Read more