Struct DataStoreSession 

pub struct DataStoreSession { /* private fields */ }

Implementations

impl DataStoreSession

pub fn new( runtime: DataStoreRuntime, store: StoreSessionConnection, lake: Connection, ) -> Self

pub fn observations(&self) -> &SessionObservations

pub fn authenticated_actor(&self) -> Option<&str>

The database principal admitted by the retained OAuth capability. Runtime-login subjects and caller-supplied actors are not substitutes.

pub fn current_study(&self) -> Option<&(ObjectRef, String)>

pub fn set_current_study(&mut self, study: Option<(ObjectRef, String)>)

pub fn with_observations(self, observations: SessionObservations) -> Self

pub fn with_scratch_attempt(self, attempt: Option<ScratchAttempt>) -> Self

pub fn with_dataset_executor(self, executor: Arc<DatasetExecutor>) -> Self

Supplies executor exclusion obtained from the configured Lake scratch capability. Unconfigured direct callers cannot materialize Datasets.

pub fn has_operation_recovery(&self) -> bool

Whether configured opening established the operation storage/recovery capability.

pub fn reconcile_dataset_attempts(&mut self) -> Result<(), AppError>

Retry known stopped attempts with the capability resolved for this Session. It cannot reopen user authority or admit output.

pub fn reconcile_disclosures(&mut self) -> Result<(), AppError>

Recovery owns no login credential and never resumes content delivery. One opportunistic pass is bounded so older evidence cannot consume a newly authorized Session’s admission deadline. Unprocessed receipts stay durable for a later pass; new disclosures project their own evidence.

pub fn scratch_attempt(&self) -> Option<&ScratchAttempt>

Returns the trusted scratch attempt retained by this live Session.

The returned capability is runtime-internal and its restricted path must never be serialized or projected to a client.

pub fn runtime(&self) -> &DataStoreRuntime

pub fn into_runtime(self) -> DataStoreRuntime

pub fn store_connection(&self) -> MutexGuard<'_, PgMetadataConnection>

pub fn direct_store_connection( &self, ) -> Option<MutexGuard<'_, PgMetadataConnection>>

pub fn oauth_store_connection( &self, ) -> Option<MutexGuard<'_, LibpqOAuthConnection>>

pub fn metadata_repositories( &self, ) -> Result<SessionMetadataRepositories, AppError>

pub fn lake_connection(&self) -> &Connection

pub fn lake_connection_mut(&mut self) -> &mut Connection

pub fn query_lake<A>( &self, request: &LakeQueryRequest, authorizer: &A, ) -> Result<LakeQueryResult, AppError>

where A: LakeQueryAuthorizer + ?Sized,

Trait Implementations

impl Debug for DataStoreSession

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

Formats the value using the given formatter.