Struct DMSCHealthChecker 

pub struct DMSCHealthChecker { /* private fields */ }

Main health checker service.

This struct provides the core functionality for managing health checks, including registering health checks, starting background monitoring, and retrieving health status.

Implementations

impl DMSCHealthChecker

pub fn new(check_interval: Duration) -> Self

pub fn with_tracer(self, tracer: Arc<DMSCTracer>) -> Self

pub fn set_tracer(&mut self, tracer: Arc<DMSCTracer>)

pub async fn register_health_check( &self, service_name: &str, endpoint: &str, check_type: DMSCHealthCheckType, config: DMSCHealthCheckConfig, ) -> DMSCResult<()>

Registers a health check for a service.

This method registers a health check for a service and performs an immediate check.

Parameters

• service_name: Name of the service to check
• endpoint: Endpoint URL for health checks
• check_type: Type of health check to perform
• config: Health check configuration

Returns

A DMSCResult<()> indicating success or failure

pub async fn start_health_check( &self, service_name: &str, endpoint: &str, ) -> DMSCResult<()>

Starts background health checks for a service.

This method creates a background task that periodically checks the health of a service.

Parameters

• service_name: Name of the service to check
• endpoint: Endpoint URL for health checks

Returns

A DMSCResult<()> indicating success or failure

pub async fn stop_health_check( &self, service_name: &str, _endpoint: &str, ) -> DMSCResult<()>

Stops health checks for a specific service endpoint.

This method clears the health check results for the specified service. The background task will continue running but will no longer record results.

Parameters

• service_name: Name of the service
• endpoint: Endpoint URL

Returns

A DMSCResult<()> indicating success or failure

pub async fn start_health_check_with_type( &self, service_name: &str, endpoint: &str, check_type: DMSCHealthCheckType, ) -> DMSCResult<()>

Starts background health checks for a service with a specific health check type.

This method creates a background task that periodically checks the health of a service using the specified health check type.

Parameters

• service_name: Name of the service to check
• endpoint: Endpoint URL for health checks
• check_type: Type of health check to perform

Returns

A DMSCResult<()> indicating success or failure

pub async fn get_health_status( &self, service_name: &str, ) -> DMSCResult<Vec<DMSCHealthCheckResult>>

Gets the health check results for a service.

Parameters

• service_name: Name of the service to get results for

Returns

A DMSCResult<Vec<DMSCHealthCheckResult>> containing the health check results

pub async fn get_latest_health_status( &self, service_name: &str, ) -> DMSCResult<Option<DMSCHealthCheckResult>>

Gets the latest health check result for a service.

Parameters

• service_name: Name of the service to get the latest result for

Returns

A DMSCResult<Option<DMSCHealthCheckResult>> containing the latest health check result if available

pub async fn get_health_status_within( &self, service_name: &str, time_window: Duration, ) -> DMSCResult<Vec<DMSCHealthCheckResult>>

Gets the health check results for a service within a specified time window.

Parameters

• service_name: Name of the service to get results for
• time_window: Time window to filter results by

Returns

A DMSCResult<Vec<DMSCHealthCheckResult>> containing the filtered health check results

pub async fn get_service_health_summary( &self, service_name: &str, ) -> DMSCResult<DMSCHealthSummary>

Gets a health summary for a service.

This method aggregates health check results to provide a summary of the service’s health, including success rate, average response time, and overall status.

Parameters

• service_name: Name of the service to get a summary for

Returns

A DMSCResult<DMSCHealthSummary> containing the health summary

pub async fn start_background_tasks(&self) -> DMSCResult<()>

Starts background health check tasks.

This method initializes and starts all background health monitoring tasks, including periodic health checks for registered services and cleanup tasks.

Returns

A DMSCResult<()> indicating success or failure

pub async fn stop_background_tasks(&self) -> DMSCResult<()>

Stops all background health check tasks.

This method aborts all running background health check tasks and cleans up resources.

Returns

A DMSCResult<()> indicating success or failure

pub async fn health_check(&self) -> DMSCResult<bool>

Performs a health check on the health checker itself.

Returns

A DMSCResult<bool> indicating whether the health checker is healthy

Trait Implementations

impl<'py> IntoPyObject<'py> for DMSCHealthChecker

type Target = DMSCHealthChecker

The Python output type

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

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for DMSCHealthChecker

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"Main health checker service.\n\nThis struct provides the core functionality for managing health checks, including\nregistering health checks, starting background monitoring, and retrieving health status.\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<DMSCHealthChecker>

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 PyClassNewTextSignature for DMSCHealthChecker

const TEXT_SIGNATURE: &'static str = "(check_interval)"

impl PyMethods<DMSCHealthChecker> for PyClassImplCollector<DMSCHealthChecker>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for DMSCHealthChecker

const NAME: &'static str = "DMSCHealthChecker"

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 DMSCHealthChecker

impl ExtractPyClassWithClone for DMSCHealthChecker