Struct AnonymizedAggregateServiceProvider

pub struct AnonymizedAggregateServiceProvider<C: ComponentInstanceInterface> {
    pub containing_component: WeakComponentInstanceInterface<C>,
    pub members: Vec<AggregateMember>,
    pub capability_name: Name,
    pub capability_type: CapabilityTypeName,
    pub sources: Sources,
}

Provides capabilities exposed by an anonymized aggregates.

Given a set of collections and static children and the name of a capability, this provider returns a list of children within them that expose the capability, and routes to a particular child’s exposed capability with that name.

This is used during collection routing from anonymized aggregate service instances.

Fields

containing_component: WeakComponentInstanceInterface<C>

Component that defines the aggregate.

members: Vec<AggregateMember>

The members relative to containing_component that make up the aggregate.

capability_name: Name

Name of the capability as exposed by children in the collection.

capability_type: CapabilityTypeName

sources: Sources

Implementations

impl<C> AnonymizedAggregateServiceProvider<C>

where C: ComponentInstanceInterface + 'static,

pub async fn new_from_capability_source( source: &CapabilitySource, source_component_instance: &Arc<C>, ) -> Option<Self>

Creates a new AnonymizedAggregateServiceProvider from a CapabilitySource::AnonymizedAggregate. The source_component_instance must have a moniker that matches the moniker value in the source. None is returned if source is not a CapabilitySource::AnonymizedAggregate.

pub async fn list_instances( &self, ) -> Result<Vec<AggregateInstance>, RoutingError>

Returns a list of instances contributing capabilities to this provider.

In the case of service capabilities, they are not instances inside that service, but rather service capabilities with the same name that are exposed by different components.

pub async fn route_instance<V>( &self, instance: &AggregateInstance, visitor: &mut V, ) -> Result<CapabilitySource, RoutingError>

where V: OfferVisitor + ExposeVisitor + CapabilityVisitor + Clone + Send + Sync + 'static,

Returns a CapabilitySource to a capability exposed by a child.

instance is the name of the child that exposes the capability, as returned by list_instances.

Trait Implementations

impl<C: Clone + ComponentInstanceInterface> Clone for AnonymizedAggregateServiceProvider<C>

fn clone(&self) -> AnonymizedAggregateServiceProvider<C>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.