Struct MetadataAggregator 

pub struct MetadataAggregator { /* private fields */ }

Metadata aggregator based on configurable collectors.

Metadata collectors are used to either scrape or listen for changes in workload metadata, which converts those changes into MetadataOperations that are applied to a MetadataStore. MetadataAggregator receives those operations and applies them to all configured MetadataStores.

Implementations

impl MetadataAggregator

pub fn new(health: Health) -> (Self, Sender<MetadataOperation>)

Creates a new MetadataAggregator, returning it along with the operations sender that should be cloned into each collector worker.

pub fn add_store<S>(&mut self, store: S)

where S: MetadataStore + Send + 'static,

Adds a metadata store to the aggregator.

This store will receive a copy of every metadata operation that’s emitted from the configured metadata collectors.

Trait Implementations

impl MemoryBounds for MetadataAggregator

fn specify_bounds(&self, builder: &mut MemoryBoundsBuilder<'_>)

Specifies the minimum and firm memory bounds for this component and its subcomponents.

impl Supervisable for MetadataAggregator

fn name(&self) -> &str

Returns the name of the process.

fn initialize<'life0, 'async_trait>( &'life0 self, process_shutdown: ShutdownHandle, ) -> Pin<Box<dyn Future<Output = Result<SupervisorFuture, InitializationError>> + Send + 'async_trait>>

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

Initializes the process asynchronously.

fn shutdown_strategy(&self) -> ShutdownStrategy

Returns the shutdown strategy for the process.

fn wants_shutdown_signal(&self) -> bool

Returns whether this process observes the shutdown signal it is given.