Struct RiResourcePool 

pub struct RiResourcePool { /* private fields */ }

Resource pool for managing multiple similar devices

This struct manages a pool of devices of the same type, tracking their availability, allocation status, and capacity. It provides methods for adding/removing devices, allocating/releasing devices, and collecting statistics.

Implementations

impl RiResourcePool

pub fn new(config: RiResourcePoolConfig) -> Self

Creates a new resource pool with the given configuration

Parameters

• config: The configuration for the resource pool

Returns

A new RiResourcePool instance with the specified configuration

pub fn add_device(&mut self, device: Arc<RiDevice>) -> bool

Adds a device to the pool

This method adds a device to the pool if it matches the pool’s device type and is not already in the pool.

Parameters

• device: The device to add to the pool

Returns

true if the device was successfully added, false otherwise

pub fn remove_device(&mut self, device_id: &str) -> bool

Removes a device from the pool

This method removes a device from the pool by its ID, updating capacity counters based on the device’s status.

Parameters

• device_id: The ID of the device to remove

Returns

true if the device was successfully removed, false otherwise

pub fn allocate(&mut self, _allocation_id: &str) -> Option<Arc<RiDevice>>

Allocates a device from the pool

This method allocates the first available device from the pool, updating capacity counters.

Parameters

• _allocation_id: The ID of the allocation (currently unused)

Returns

An Option<Arc<RiDevice>> containing the allocated device if successful, None otherwise

pub fn release(&mut self, allocation_id: &str) -> bool

Releases a device back to the pool

This method releases a device back to the pool by its allocation ID, updating capacity counters.

Parameters

• allocation_id: The ID of the allocation to release

Returns

true if the device was successfully released, false otherwise

pub fn get_status(&self) -> RiResourcePoolStatus

Gets the current status of the pool

This method returns a RiResourcePoolStatus struct containing information about the pool’s capacity, allocation, and utilization.

Returns

A RiResourcePoolStatus struct with the current pool status

pub fn name(&self) -> &str

Gets the name of the pool

Returns

The pool name as a string slice

pub fn device_type(&self) -> RiDeviceType

Gets the device type of the pool

Returns

The device type as a RiDeviceType enum

pub fn get_devices(&self) -> Vec<Arc<RiDevice>>

Gets all devices in the pool

Returns

A vector of Arc<RiDevice> containing all devices in the pool

pub fn get_available_devices(&self) -> Vec<Arc<RiDevice>>

Gets available devices in the pool

Returns

A vector of Arc<RiDevice> containing only available devices

pub fn get_allocated_devices(&self) -> Vec<Arc<RiDevice>>

Gets allocated devices in the pool

Returns

A vector of Arc<RiDevice> containing only allocated devices

pub fn has_available_capacity(&self) -> bool

Checks if the pool has available capacity

Returns

true if the pool has available devices, false otherwise

pub fn utilization_rate(&self) -> f64

Gets the utilization rate of the pool (0.0 - 1.0)

Returns

The utilization rate as a floating-point number between 0.0 and 1.0

pub fn is_healthy(&self) -> bool

Checks if the pool is healthy

A pool is considered healthy if it has available devices or allocated devices.

Returns

true if the pool is healthy, false otherwise

pub fn get_statistics(&self) -> RiResourcePoolStatistics

Gets comprehensive statistics for the pool

This method calculates and returns comprehensive statistics for the pool, including device counts, utilization, total compute units, memory, storage, bandwidth, and average health score.

Returns

A RiResourcePoolStatistics struct with comprehensive pool statistics

Trait Implementations

impl<'py> IntoPyObject<'py> for RiResourcePool

type Target = RiResourcePool

The Python output type

type Output = Bound<'py, <RiResourcePool 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 RiResourcePool

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for RiResourcePool

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 = /// allocating/releasing devices, and collecting statistics.

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<RiResourcePool>

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 PyTypeInfo for RiResourcePool

const NAME: &'static str = "RiResourcePool"

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 RiResourcePool

impl ExtractPyClassWithClone for RiResourcePool