pub struct LocalRuntimeRegistry;Expand description
Local authenticated registry backed by harness discovery and private live-runtime receipts.
Implementations§
Source§impl LocalRuntimeRegistry
impl LocalRuntimeRegistry
Sourcepub fn new() -> LocalRuntimeRegistry
pub fn new() -> LocalRuntimeRegistry
Construct a stateless registry facade.
Sourcepub async fn list(
&self,
query: &RuntimeRegistryQuery,
authorization: &RuntimeAuthorization,
) -> Result<Vec<RuntimeRegistryEntry>, SdkError>
pub async fn list( &self, query: &RuntimeRegistryQuery, authorization: &RuntimeAuthorization, ) -> Result<Vec<RuntimeRegistryEntry>, SdkError>
List live and/or persisted sessions after enforcing observe authority.
Sourcepub async fn describe(
&self,
id: &str,
query: &RuntimeRegistryQuery,
authorization: &RuntimeAuthorization,
) -> Result<RuntimeRegistryEntry, SdkError>
pub async fn describe( &self, id: &str, query: &RuntimeRegistryQuery, authorization: &RuntimeAuthorization, ) -> Result<RuntimeRegistryEntry, SdkError>
Describe one stable entry without attaching an observer.
Sourcepub async fn source_state(
&self,
harness: &str,
session_id: &str,
authorization: &RuntimeAuthorization,
) -> Result<Option<RuntimeRegistryState>, SdkError>
pub async fn source_state( &self, harness: &str, session_id: &str, authorization: &RuntimeAuthorization, ) -> Result<Option<RuntimeRegistryState>, SdkError>
Reconciled lifecycle state of the live runtime registered for one persisted source session.
None means no live Supercode runtime is registered for that identity —
a harness running outside Supercode leaves no receipt, so its activity
is unknowable and is never guessed at. An endpoint that does not answer
is reported as None for that read, and its receipt is reconciled away
under exactly the policy Self::list uses.
Sourcepub async fn attach(
&self,
runtime_id: &str,
client_id: RuntimeClientId,
authorization: RuntimeAuthorization,
) -> Result<Arc<HttpFrontendRuntime>, SdkError>
pub async fn attach( &self, runtime_id: &str, client_id: RuntimeClientId, authorization: RuntimeAuthorization, ) -> Result<Arc<HttpFrontendRuntime>, SdkError>
Attach an authenticated SDK client to one live runtime.
Sourcepub fn load_persisted(
&self,
id: &str,
query: &RuntimeRegistryQuery,
authorization: &RuntimeAuthorization,
) -> Result<Session, SdkError>
pub fn load_persisted( &self, id: &str, query: &RuntimeRegistryQuery, authorization: &RuntimeAuthorization, ) -> Result<Session, SdkError>
Load one persisted descriptor through the same catalog used by list.
Sourcepub fn watch(
&self,
query: RuntimeRegistryQuery,
authorization: RuntimeAuthorization,
poll_interval: Duration,
) -> Result<RuntimeRegistryWatch, SdkError>
pub fn watch( &self, query: RuntimeRegistryQuery, authorization: RuntimeAuthorization, poll_interval: Duration, ) -> Result<RuntimeRegistryWatch, SdkError>
Watch joined registry state through a bounded change stream.
Trait Implementations§
Source§impl Clone for LocalRuntimeRegistry
impl Clone for LocalRuntimeRegistry
Source§fn clone(&self) -> LocalRuntimeRegistry
fn clone(&self) -> LocalRuntimeRegistry
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more