llkv-runtime 0.8.2-alpha

Execution runtime for the LLKV toolkit.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! ContextProvider implementation for TableProvider trait

use crate::runtime_context::RuntimeContext;
use llkv_executor::{ExecutorTable, ExecutorTableProvider};
use llkv_result::Result;
use llkv_storage::pager::Pager;
use simd_r_drive_entry_handle::EntryHandle;
use std::sync::Arc;

/// Internal provider struct that wraps RuntimeContext for use with llkv_executor.
pub(crate) struct ContextProvider<P>
where
    P: Pager<Blob = EntryHandle> + Send + Sync,
{
    pub(crate) context: Arc<RuntimeContext<P>>,
}

impl<P> ExecutorTableProvider<P> for ContextProvider<P>
where
    P: Pager<Blob = EntryHandle> + Send + Sync,
{
    fn get_table(&self, canonical_name: &str) -> Result<Arc<ExecutorTable<P>>> {
        self.context.lookup_table(canonical_name)
    }
}