pub fn new<B, S, T>(
        logger: &Logger,
        store: Arc<S>,
        host_builder: T,
        block_stream_builder: B,
        elastic_config: Option<ElasticLoggingConfig>,
    ) -> Self
    where
        S: Store + ChainStore,
        T: RuntimeHostBuilder,
        B: BlockStreamBuilder + 'static,
    {
        let logger = logger.new(o!("component" => "SubgraphInstanceManager"));

        // Create channel for receiving subgraph provider events.
        let (subgraph_sender, subgraph_receiver) = channel(100);

        // Handle incoming events from the subgraph provider.
        Self::handle_subgraph_events(
            logger.clone(),
            subgraph_receiver,
            store,
            host_builder,
            block_stream_builder,
            elastic_config,
        );

        SubgraphInstanceManager {
            logger,
            input: subgraph_sender,
        }
    }
/// Creates a new runtime manager.
Creates a new runtime manager.
Creates a new runtime manager .
pub fn new<B, S, T>(
        logger: &Logger,
        store: Arc<S>,
        host_builder: T,
        block_stream_builder: B,
        elastic_config: Option<ElasticLoggingConfig>,
    ) -> Self
    where
        S: Store + ChainStore,
        T: RuntimeHostBuilder,
        B: BlockStreamBuilder + 'static,
    {
        let logger = logger.new(o!("component" => "SubgraphInstanceManager"));
        // Create channel for receiving subgraph provider events.
        let (subgraph_sender, subgraph_receiver) = channel(100);
        // Handle incoming events from the subgraph provider.
        Self::handle_subgraph_events(
            logger.clone(),
            subgraph_receiver,
            store,
            host_builder,
            block_stream_builder,
            elastic_config,
        );
        SubgraphInstanceManager {
            logger,
            input: subgraph_sender,
        }
    }
pub fn new < B , S , T > ( logger : & Logger , store : Arc < S > , host_builder : T , block_stream_builder : B , elastic_config : Option < ElasticLoggingConfig > , ) -> Self where S : Store + ChainStore , T : RuntimeHostBuilder , B : BlockStreamBuilder + ' static , { let logger = logger . new ( o ! ( " " " " ) ) ; // Create channel for receiving subgraph provider events. let ( subgraph_sender , subgraph_receiver ) = channel ( 100 ) ; // Handle incoming events from the subgraph provider. Self :: handle_subgraph_events ( logger . clone ( ) , subgraph_receiver , store , host_builder , block_stream_builder , elastic_config , ) ; SubgraphInstanceManager { logger , input : subgraph_sender , } }
Creates a new runtime manager.
Creates a new runtime manager .
logger
&Logger
store
Arc<S>
host_builder
T
block_stream_builder
B
elastic_config
Option<ElasticLoggingConfig>
logger
&Logger
store
Arc<S>
host_builder
T
block_stream_builder
B
elastic_config
Option<ElasticLoggingConfig>