Struct QueryApplicationService 

pub struct QueryApplicationService<G, D, S> { /* private fields */ }

Implementations

impl<G, D, S> QueryApplicationService<G, D, S>

where G: GraphNeighborhoodReader + Send + Sync, D: NodeDetailReader + Send + Sync, S: SnapshotStore + Send + Sync,

pub async fn get_context( &self, query: GetContextQuery, ) -> Result<GetContextResult, ApplicationError>

impl<G, D, S> QueryApplicationService<G, D, S>

where G: GraphNeighborhoodReader + Send + Sync, D: NodeDetailReader + Send + Sync, S: SnapshotStore + Send + Sync,

pub async fn get_context_path( &self, query: GetContextPathQuery, ) -> Result<GetContextPathResult, ApplicationError>

impl<G, D, S> QueryApplicationService<G, D, S>

where G: GraphNeighborhoodReader + Send + Sync, D: NodeDetailReader + Send + Sync,

pub async fn get_node_detail( &self, query: GetNodeDetailQuery, ) -> Result<GetNodeDetailResult, ApplicationError>

impl<G, D, S> QueryApplicationService<G, D, S>

where G: GraphNeighborhoodReader + Send + Sync, D: NodeDetailReader + Send + Sync,

pub async fn get_node_details( &self, node_ids: Vec<String>, ) -> Result<Vec<Option<GetNodeDetailResult>>, ApplicationError>

Materialize already selected refs in order, retaining absent nodes and absent bodies as different states. Use this service’s operation snapshot when graph and bodies must describe the same committed state.

impl<G, D, S> QueryApplicationService<G, D, S>

where G: NodeRelationshipReader + Send + Sync,

pub async fn get_node_relationships( &self, query: GetNodeRelationshipsQuery, ) -> Result<GetNodeRelationshipsResult, ApplicationError>

impl<G, D, S> QueryApplicationService<G, D, S>

where G: MemoryAboutIndexReader + Send + Sync, S: SnapshotStore + Send + Sync,

pub async fn list_memory_abouts(&self) -> Result<Vec<String>, ApplicationError>

pub async fn list_memory_abouts_by_dimensions( &self, dimension_ids: &[String], ) -> Result<Vec<String>, ApplicationError>

impl<G, D, S> QueryApplicationService<G, D, S>

pub fn new( graph_reader: Arc<G>, detail_reader: Arc<D>, snapshot_store: Arc<S>, generator_version: &'static str, ) -> Self

pub fn with_read_snapshots( self, provider: Arc<dyn ReadSnapshotProvider<G, D>>, ) -> Self

Configure a backend that owns graph and bodies in one store. Without this provider separate adapters retain their best-effort read semantics. A configured provider error propagates; it never falls back to live reads.

pub async fn read_snapshot(&self) -> Result<Option<Self>, ApplicationError>

impl<G: GraphNeighborhoodReader + Send + Sync, D, S> QueryApplicationService<G, D, S>

pub async fn read_nodes( &self, request: &MemoryNodesRequest, ) -> Result<MemoryNodesResult, ApplicationError>

pub async fn evidence_paths( &self, request: &EvidencePathRequest, ) -> Result<EvidencePathResult, ApplicationError>

pub async fn trace_search( &self, request: &TraceSearchRequest, ) -> Result<TraceSearchResult, ApplicationError>

impl<G, D, S> QueryApplicationService<G, D, S>

where G: GraphNeighborhoodReader + Send + Sync, D: NodeDetailReader + Send + Sync, S: SnapshotStore + Send + Sync,

pub async fn rehydrate_session( &self, query: RehydrateSessionQuery, ) -> Result<RehydrateSessionResult, ApplicationError>

pub async fn warmup_bundle(&self) -> Result<KmpBundle, ApplicationError>

impl<G, D, S> QueryApplicationService<G, D, S>

pub fn validate_scope(&self, query: ValidateScopeQuery) -> ScopeValidation

Trait Implementations

impl<G: Debug, D: Debug, S: Debug> Debug for QueryApplicationService<G, D, S>

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

Formats the value using the given formatter.