Method spawn_expression_cache

src/catalog/src/expr_cache.rs:390–422

Spawns a task responsible for managing the expression cache. See [`ExpressionCache::open`]. Returns a handle to interact with the cache and the initial contents of the cache.

(
        config: ExpressionCacheConfig,
    )

    ///
    /// Returns a handle to interact with the cache and the initial contents of the cache.
    pub async fn spawn_expression_cache(
        config: ExpressionCacheConfig,
    ) -> (
        Self,
        BTreeMap<GlobalId, LocalExpressions>,
        BTreeMap<GlobalId, GlobalExpressions>,
    ) {
        let (mut cache, local_expressions, global_expressions) =
            ExpressionCache::open(config).await;
        let (tx, mut rx) = mpsc::unbounded_channel();
        spawn(|| "expression-cache-task", async move {
            while let Some(op) = rx.recv().await {
                match op {
                    CacheOperation::Update {
                        new_local_expressions,
                        new_global_expressions,
                        invalidate_ids,
                        trigger: _trigger,
                    } => {
                        cache
                            .update(
                                new_local_expressions,
                                new_global_expressions,
                                invalidate_ids,
                            )
                            .await
                    }
                }
            }
        });

        (Self { tx }, local_expressions, global_expressions)
    }

    pub fn update(
        &self,