Struct RiQueueManager 

pub struct RiQueueManager { /* private fields */ }

Central queue management component.

This struct is responsible for the lifecycle of queues, including creating, retrieving, listing, and deleting queues. It manages queues across different backend implementations.

Implementations

impl RiQueueManager

pub async fn new(config: RiQueueConfig) -> RiResult<Self>

Creates a new queue manager with the given configuration.

Parameters

• config: The queue configuration to use

Returns

A RiResult<Self> containing the new queue manager instance

impl RiQueueManager

pub async fn init(&self) -> RiResult<()>

Initializes the queue manager.

This method performs backend-specific initialization, such as setting up connection pools for external queue systems.

Returns

A RiResult<()> indicating success or failure

pub async fn create_queue(&self, name: &str) -> RiResult<Arc<dyn RiQueue>>

Creates a new queue or returns an existing one with the same name.

This method implements lazy initialization, creating the queue only when requested.

Parameters

• name: The name of the queue to create or retrieve

Returns

A RiResult<Arc<dyn RiQueue>> containing the queue instance

pub async fn get_queue(&self, name: &str) -> Option<Arc<dyn RiQueue>>

Retrieves an existing queue by name.

Parameters

• name: The name of the queue to retrieve

Returns

An Option<Arc<dyn RiQueue>> containing the queue instance if it exists, or None otherwise

pub async fn list_queues(&self) -> Vec<String>

Lists all currently created queues.

Returns

A Vec<String> containing the names of all created queues

pub async fn delete_queue(&self, name: &str) -> RiResult<()>

Deletes a queue by name.

This method removes the queue from the manager and calls the queue’s delete method to clean up any backend-specific resources.

Parameters

• name: The name of the queue to delete

Returns

A RiResult<()> indicating success or failure

pub async fn shutdown(&self) -> RiResult<()>

Shuts down the queue manager and cleans up resources.

This method purges all queues and cleans up any backend-specific resources.

Returns

A RiResult<()> indicating success or failure

Trait Implementations

impl Default for RiQueueManager

fn default() -> Self

Returns the “default value” for a type.

impl<'py> IntoPyObject<'py> for RiQueueManager

type Target = RiQueueManager

The Python output type

type Output = Bound<'py, <RiQueueManager as IntoPyObject<'py>>::Target>

The smart pointer type to use.

type Error = PyErr

The type returned in the event of a conversion error.

fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>

Performs the conversion.

impl PyClass for RiQueueManager

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for RiQueueManager

const IS_BASETYPE: bool = false

#[pyclass(subclass)]

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]

const IS_MAPPING: bool = false

#[pyclass(mapping)]

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]

const IS_IMMUTABLE_TYPE: bool = false

#[pyclass(immutable_type)]

const RAW_DOC: &'static CStr = c"Central queue management component.\n\nThis struct is responsible for the lifecycle of queues, including creating, retrieving,\nlisting, and deleting queues. It manages queues across different backend implementations.\x00"

Docstring for the class provided on the struct or enum.

const DOC: &'static CStr

Fully rendered class doc, including the text_signature if a constructor is defined.

type BaseType = PyAny

Base class

type ThreadChecker = SendablePyClass<RiQueueManager>

This handles following two situations:

type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

Immutable or mutable

type Dict = PyClassDummySlot

Specify this class has #[pyclass(dict)] or not.

type WeakRef = PyClassDummySlot

Specify this class has #[pyclass(weakref)] or not.

type BaseNativeType = PyAny

The closest native ancestor. This is 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<isize>

fn weaklist_offset() -> Option<isize>

impl PyMethods<RiQueueManager> for PyClassImplCollector<RiQueueManager>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for RiQueueManager

const NAME: &'static str = "RiQueueManager"

Class name.

const MODULE: Option<&'static str> = ::core::option::Option::None

Module name, if any.

fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

Returns the PyTypeObject instance for this type.

fn type_object(py: Python<'_>) -> Bound<'_, PyType>

Returns the safe abstraction over the type object.

fn is_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type or a subclass of this type.

fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type.

impl DerefToPyAny for RiQueueManager

impl ExtractPyClassWithClone for RiQueueManager