DMSCDeviceControlModule

Struct DMSCDeviceControlModule 

Source
pub struct DMSCDeviceControlModule { /* private fields */ }
Expand description

Main device control module for DMSC.

This module provides comprehensive smart device control functionality, including device discovery, control, and resource scheduling. It manages devices and their resources across distributed environments.

Implementations§

Source§

impl DMSCDeviceControlModule

Source

pub fn new() -> Self

Creates a new device control module with default configuration.

§Returns

A new DMSCDeviceControlModule instance with default configuration

Source

pub fn with_config(self, config: DMSCDeviceControlConfig) -> Self

Configures the device control module with custom settings.

§Parameters
  • config: The custom configuration to apply
§Returns

The updated DMSCDeviceControlModule instance

Source

pub async fn discover_devices(&self) -> DMSCResult<DMSCDiscoveryResult>

Discovers devices in the network/environment.

This method performs a device discovery scan if discovery is enabled, returning information about discovered, updated, and removed devices.

§Returns

A DMSCResult<DMSCDiscoveryResult> containing the discovery results

Source

pub async fn allocate_resource( &self, request: DMSCResourceRequest, ) -> DMSCResult<Option<DMSCResourceAllocation>>

Allocates a device resource based on the given request.

This method finds a suitable device based on the requested device type and capabilities, allocates it using the device scheduler, and returns an allocation result if successful.

§Parameters
  • request: The resource allocation request
§Returns

A DMSCResult<Option<DMSCResourceAllocation>> containing the allocation result if successful, or None if allocation failed or auto-scheduling is disabled

Source

pub async fn release_resource(&self, allocation_id: &str) -> DMSCResult<()>

Releases a previously allocated device resource.

This method releases a device resource that was allocated with allocate_resource.

§Parameters
  • allocation_id: The ID of the allocation to release
§Returns

A DMSCResult<()> indicating success or failure

Source

pub async fn get_device_status(&self) -> DMSCResult<Vec<DMSCDevice>>

Gets the current status of all devices.

This method returns a list of all devices currently managed by the device controller.

§Returns

A DMSCResult<Vec<DMSCDevice>> containing all managed devices

Source

pub fn get_resource_pool_status( &self, ) -> HashMap<String, DMSCResourcePoolStatus>

Gets the status of all resource pools.

This method returns a map of resource pool names to their current status.

§Returns

A HashMap<String, DMSCResourcePoolStatus> containing the status of all resource pools

Trait Implementations§

Source§

impl DMSCModule for DMSCDeviceControlModule

Source§

fn name(&self) -> &str

Returns the name of the device control module.

§Returns

The module name as a string

Source§

fn is_critical(&self) -> bool

Indicates whether the device control module is critical.

The device control module is non-critical, meaning that if it fails to initialize or operate, it should not break the entire application. This allows the core functionality to continue even if device control features are unavailable.

§Returns

false since device control is non-critical

Source§

fn init<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 mut DMSCServiceContext, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Initializes the device control module asynchronously.

This method performs the following steps:

  1. Loads configuration from the service context
  2. Initializes real device discovery based on system hardware
  3. Sets up resource scheduling and management
Source§

fn priority(&self) -> i32

Returns the priority of the module. Read more
Source§

fn dependencies(&self) -> Vec<&str>

Returns the list of module dependencies. Read more
Source§

fn before_start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut DMSCServiceContext, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Prepares the module for startup. Read more
Source§

fn start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut DMSCServiceContext, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Starts the service module. Read more
Source§

fn after_start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut DMSCServiceContext, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Performs post-startup operations. Read more
Source§

fn before_shutdown<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut DMSCServiceContext, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Prepares the module for shutdown. Read more
Source§

fn shutdown<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut DMSCServiceContext, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Shuts down the service module. Read more
Source§

fn after_shutdown<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut DMSCServiceContext, ) -> Pin<Box<dyn Future<Output = DMSCResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Performs post-shutdown cleanup. Read more
Source§

impl Default for DMSCDeviceControlModule

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl<'py> IntoPyObject<'py> for DMSCDeviceControlModule

Source§

type Target = DMSCDeviceControlModule

The Python output type
Source§

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

The smart pointer type to use. Read more
Source§

type Error = PyErr

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

impl PyClass for DMSCDeviceControlModule

Source§

type Frozen = False

Whether the pyclass is frozen. Read more
Source§

impl PyClassImpl for DMSCDeviceControlModule

Source§

const IS_BASETYPE: bool = false

#[pyclass(subclass)]
Source§

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]
Source§

const IS_MAPPING: bool = false

#[pyclass(mapping)]
Source§

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]
Source§

const IS_IMMUTABLE_TYPE: bool = false

#[pyclass(immutable_type)]
Source§

const RAW_DOC: &'static CStr = c"Main device control module for DMSC.\n\nThis module provides comprehensive smart device control functionality, including device discovery,\ncontrol, and resource scheduling. It manages devices and their resources across distributed environments.\x00"

Docstring for the class provided on the struct or enum. Read more
Source§

const DOC: &'static CStr

Fully rendered class doc, including the text_signature if a constructor is defined. Read more
Source§

type BaseType = PyAny

Base class
Source§

type ThreadChecker = SendablePyClass<DMSCDeviceControlModule>

This handles following two situations: Read more
Source§

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

Immutable or mutable
Source§

type Dict = PyClassDummySlot

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

type WeakRef = PyClassDummySlot

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

type BaseNativeType = PyAny

The closest native ancestor. This is PyAny by default, and when you declare #[pyclass(extends=PyDict)], it’s PyDict.
Source§

fn items_iter() -> PyClassItemsIter

Source§

fn lazy_type_object() -> &'static LazyTypeObject<Self>

§

fn dict_offset() -> Option<isize>

§

fn weaklist_offset() -> Option<isize>

Source§

impl PyMethods<DMSCDeviceControlModule> for PyClassImplCollector<DMSCDeviceControlModule>

Source§

fn py_methods(self) -> &'static PyClassItems

Source§

impl PyTypeInfo for DMSCDeviceControlModule

Source§

const NAME: &'static str = "DMSCDeviceControlModule"

Class name.
Source§

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

Module name, if any.
Source§

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.
Source§

impl ServiceModule for DMSCDeviceControlModule

Source§

fn name(&self) -> &str

Returns the name of the service module. Read more
Source§

fn is_critical(&self) -> bool

Indicates if the module is critical to the operation of the system. Read more
Source§

fn priority(&self) -> i32

Returns the priority of the module. Read more
Source§

fn dependencies(&self) -> Vec<&str>

Returns the list of module dependencies. Read more
Source§

fn init(&mut self, _ctx: &mut DMSCServiceContext) -> DMSCResult<()>

Initializes the service module. Read more
Source§

fn start(&mut self, _ctx: &mut DMSCServiceContext) -> DMSCResult<()>

Starts the service module. Read more
Source§

fn shutdown(&mut self, _ctx: &mut DMSCServiceContext) -> DMSCResult<()>

Shuts down the service module. Read more
Source§

fn before_start(&mut self, _ctx: &mut DMSCServiceContext) -> DMSCResult<()>

Prepares the module for startup. Read more
Source§

fn after_start(&mut self, _ctx: &mut DMSCServiceContext) -> DMSCResult<()>

Performs post-startup operations. Read more
Source§

fn before_shutdown(&mut self, _ctx: &mut DMSCServiceContext) -> DMSCResult<()>

Prepares the module for shutdown. Read more
Source§

fn after_shutdown(&mut self, _ctx: &mut DMSCServiceContext) -> DMSCResult<()>

Performs post-shutdown cleanup. Read more
Source§

impl DerefToPyAny for DMSCDeviceControlModule

Source§

impl ExtractPyClassWithClone for DMSCDeviceControlModule

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
§

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

§

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

§

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

§

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts 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 more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts 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 T
where T: IntoPyObject<'py>,

§

fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>

Converts self into an owned Python object, dropping type information.
§

fn into_py_any(self, py: Python<'py>) -> Result<Py<PyAny>, PyErr>

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

Converts self into a Python object. Read more
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
§

impl<T> Pointable for T

§

const ALIGN: usize

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
§

impl<T> PyErrArguments for T
where T: for<'py> IntoPyObject<'py> + Send + Sync,

§

fn arguments(self, py: Python<'_>) -> Py<PyAny>

Arguments for exception
§

impl<T> PyTypeCheck for T
where T: PyTypeInfo,

§

const NAME: &'static str = T::NAME

👎Deprecated since 0.27.0: Use ::classinfo_object() instead and format the type name at runtime. Note that using built-in cast features is often better than manual PyTypeCheck usage.
Name of self. This is used in error messages, for example.
§

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

Checks if object is an instance of Self, which may include a subtype. Read more
§

fn classinfo_object(py: Python<'_>) -> Bound<'_, PyAny>

Returns the expected type as a possible argument for the isinstance and issubclass function. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

impl<T> Ungil for T
where T: Send,