Struct EntityBatchLoader 

pub struct EntityBatchLoader { /* private fields */ }

Entity batch loader that integrates with EntityCache.

Collects entity requests, checks the cache first, and issues batch calls to the underlying subgraph for cache misses.

Implementations

impl EntityBatchLoader

pub fn new( cache: Arc<EntityCache>, resolver: impl Fn(EntityBatch) -> Pin<Box<dyn Future<Output = Result<Vec<(String, String)>>> + Send>> + Send + Sync + 'static, max_batch_size: usize, default_ttl: Duration, ) -> Self

Create a new batch loader.

pub async fn load_many( &self, type_name: &str, key_jsons: Vec<String>, tenant_id: Option<&str>, ) -> Result<HashMap<String, String>>

Resolve a list of entity keys for a given type, using the cache.

Returns a map from key JSON to resolved data JSON.

pub async fn load_one( &self, type_name: &str, key_json: &str, tenant_id: Option<&str>, ) -> Result<Option<String>>

Load a single entity.

pub fn cache(&self) -> &Arc<EntityCache>

Return a reference to the underlying entity cache.

pub fn invalidate_type(&self, type_name: &str) -> usize

Invalidate all cached entities of a given type.

Trait Implementations

impl Debug for EntityBatchLoader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.