Struct ComponentGraphBootstrapProvider 

pub struct ComponentGraphBootstrapProvider { /* private fields */ }

Bootstrap provider that generates data from the component graph Bootstrap provider that generates a consistent snapshot from the ComponentGraph.

Takes a single read lock on the graph, iterates all nodes and edges, and translates them into SourceChange::Insert elements. This replaces the previous approach of querying three separate managers independently.

Implementations

impl ComponentGraphBootstrapProvider

pub fn new(graph: Arc<RwLock<ComponentGraph>>) -> Self

Trait Implementations

impl BootstrapProvider for ComponentGraphBootstrapProvider

fn bootstrap<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request: BootstrapRequest, _context: &'life1 BootstrapContext, event_tx: BootstrapEventSender, _settings: Option<&'life2 SourceSubscriptionSettings>, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

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

Perform bootstrap operation for the given request Sends bootstrap events to the provided channel Returns the number of elements sent