Struct DMSCServiceMesh 

pub struct DMSCServiceMesh { /* private fields */ }

Main service mesh struct implementing the DMSCModule trait.

This struct provides comprehensive service mesh functionality, including service discovery, health checking, traffic management, load balancing, and circuit breaking.

Implementations

impl DMSCServiceMesh

pub fn new(config: DMSCServiceMeshConfig) -> DMSCResult<Self>

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

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

pub async fn register_service( &self, service_name: &str, endpoint: &str, weight: u32, metadata: Option<HashMap<String, String>>, ) -> DMSCResult<()>

Registers a service endpoint with the service mesh.

Parameters

• service_name: The name of the service
• endpoint: The endpoint URL of the service
• weight: The weight of the endpoint for load balancing
• metadata: Optional metadata associated with the service

Returns

A DMSCResult<()> indicating success or failure

pub async fn register_versioned_service( &self, service_name: &str, version: &str, endpoint: &str, weight: u32, metadata: Option<HashMap<String, String>>, ) -> DMSCResult<()>

Registers a service with full metadata including version information.

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

Unregisters a service endpoint from the service mesh.

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

Gets all registered endpoints for a service regardless of health status.

pub async fn get_stats(&self) -> DMSCServiceMeshStats

Gets service mesh statistics.

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

Discovers healthy endpoints for a service.

Parameters

• service_name: The name of the service to discover

Returns

A DMSCResult<Vec<DMSCServiceEndpoint>> containing the healthy endpoints for the service

pub async fn call_service( &self, service_name: &str, request_data: Vec<u8>, ) -> DMSCResult<Vec<u8>>

Calls a service with the given request data.

This method performs the following steps:

1. Discovers healthy endpoints for the service
2. Selects a server using the load balancer
3. Checks the circuit breaker status
4. Executes the service call with retry logic
5. Records success/failure with the circuit breaker

Parameters

• service_name: The name of the service to call
• request_data: The request data to send to the service

Returns

A DMSCResult<Vec<u8>> containing the response from the service

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

Updates the health status of a service endpoint.

Parameters

• service_name: The name of the service
• endpoint: The endpoint URL
• is_healthy: Whether the endpoint is healthy

Returns

A DMSCResult<()> indicating success or failure

pub fn get_circuit_breaker(&self) -> &DMSCCircuitBreaker

Returns a reference to the circuit breaker.

Returns

A reference to the DMSCCircuitBreaker instance

pub fn get_load_balancer(&self) -> &DMSCLoadBalancer

Returns a reference to the load balancer.

Returns

A reference to the DMSCLoadBalancer instance

pub fn get_health_checker(&self) -> &DMSCHealthChecker

Returns a reference to the health checker.

Returns

A reference to the DMSCHealthChecker instance

pub fn get_traffic_manager(&self) -> &DMSCTrafficManager

Returns a reference to the traffic manager.

Returns

A reference to the DMSCTrafficManager instance

pub fn get_service_discovery(&self) -> &DMSCServiceDiscovery

Returns a reference to the service discovery component.

Returns

A reference to the DMSCServiceDiscovery instance

Trait Implementations

impl DMSCModule for DMSCServiceMesh

fn name(&self) -> &str

Returns the name of the service mesh module.

Returns

The module name as a string

fn is_critical(&self) -> bool

Indicates whether the service mesh module is critical.

The service mesh is marked as critical because it’s essential for the operation of distributed services in the system.

Returns

true since service mesh is critical

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 mesh module.

This method starts background tasks for service discovery, health checking, and traffic management if they are enabled.

Parameters

• _ctx: Service context (not used in this implementation)

Returns

A DMSCResult<()> indicating success or failure

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 mesh module.

This method stops background tasks for service discovery, health checking, and traffic management if they are enabled.

Parameters

• _ctx: Service context (not used in this implementation)

Returns

A DMSCResult<()> indicating success or failure

fn priority(&self) -> i32

Returns the priority of the module.

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

Returns the list of module dependencies.

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 service module.

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.

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.

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.

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.

impl<'py> IntoPyObject<'py> for DMSCServiceMesh

type Target = DMSCServiceMesh

The Python output type

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

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for DMSCServiceMesh

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 service mesh struct implementing the DMSCModule trait.\n\nThis struct provides comprehensive service mesh functionality, including service discovery,\nhealth checking, traffic management, load balancing, and circuit breaking.\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<DMSCServiceMesh>

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 DMSCServiceMesh

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

impl PyMethods<DMSCServiceMesh> for PyClassImplCollector<DMSCServiceMesh>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for DMSCServiceMesh

const NAME: &'static str = "DMSCServiceMesh"

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 DMSCServiceMesh

impl ExtractPyClassWithClone for DMSCServiceMesh