Struct ServiceManagerContainerProvider 

pub struct ServiceManagerContainerProvider { /* private fields */ }

Provides container IDs for services from ServiceManager

Implements the scheduler’s ServiceContainerProvider trait to bridge ServiceManager with CgroupsMetricsSource.

Example

use zlayer_agent::metrics_providers::ServiceManagerContainerProvider;
use zlayer_agent::ServiceManager;
use zlayer_scheduler::metrics::CgroupsMetricsSource;
use std::sync::Arc;

let manager = Arc::new(ServiceManager::new(runtime));
let provider = Arc::new(ServiceManagerContainerProvider::new(manager.clone()));

// Use with CgroupsMetricsSource
let stats_provider = Arc::new(RuntimeStatsProvider::new(runtime));
let source = CgroupsMetricsSource::new(provider, stats_provider);

Implementations

impl ServiceManagerContainerProvider

pub fn new(manager: Arc<ServiceManager>) -> Self

Create a new provider wrapping a ServiceManager

Trait Implementations

impl ServiceContainerProvider for ServiceManagerContainerProvider

fn get_container_ids<'life0, 'life1, 'async_trait>( &'life0 self, service_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Vec<MetricsContainerId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all container IDs for a given service

fn get_all_services<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = HashMap<String, Vec<MetricsContainerId>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get all services and their containers