Struct IntrospectResult

Source

pub struct IntrospectResult {
    pub identity: String,
    pub attrs: String,
    pub children: Vec<String>,
    pub parent: Option<String>,
    pub as_of: String,
}

Expand description

Internal introspection result. Carries attrs as a JSON string. The mesh layer constructs the API-facing NodePayload (with properties) from this via derive_properties.

This is the internal wire type — it travels over actor ports via IntrospectMessage. The presentation-layer NodePayload (with NodeProperties) lives in hyperactor_mesh::introspect.

Fields§

§identity: String

Canonical reference string for this node.

§attrs: String

JSON-serialized Attrs bag containing introspection attributes.

§children: Vec<String>

Reference strings the client can GET next to descend the tree.

§parent: Option<String>

Parent node reference for upward navigation.

§as_of: String

ISO 8601 timestamp indicating when this data was captured.

IntrospectResult

Struct IntrospectResult Copy item path

Fields§

Trait Implementations§

impl Clone for IntrospectResult

fn clone(&self) -> IntrospectResult

fn clone_from(&mut self, source: &Self)

impl Debug for IntrospectResult

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

impl<'de> Deserialize<'de> for IntrospectResult

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl Named for IntrospectResult

fn typename() -> &'static str

fn typehash() -> u64

fn typeid() -> TypeId

fn port() -> u64

fn arm(&self) -> Option<&'static str>

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

impl PartialEq for IntrospectResult

fn eq(&self, other: &IntrospectResult) -> bool

fn ne(&self, other: &Rhs) -> bool

impl Serialize for IntrospectResult

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl StructuralPartialEq for IntrospectResult

Auto Trait Implementations§

impl Freeze for IntrospectResult

impl RefUnwindSafe for IntrospectResult

impl Send for IntrospectResult

impl Sync for IntrospectResult

impl Unpin for IntrospectResult

impl UnwindSafe for IntrospectResult

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> Checkpointable for Twhere T: RemoteMessage + Clone,

type State = T

fn save<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<<T as Checkpointable>::State, CheckpointError>> + Send + 'async_trait>>where 'life0: 'async_trait, T: 'async_trait,

fn load<'async_trait>( state: <T as Checkpointable>::State, ) -> Pin<Box<dyn Future<Output = Result<T, CheckpointError>> + Send + 'async_trait>>where T: 'async_trait,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<A, M> Handler<IndexedErasedUnbound<M>> for Awhere A: Handler<M>, M: Castable,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, A>, msg: IndexedErasedUnbound<M>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where 'life0: 'async_trait, 'life1: 'async_trait, A: 'async_trait,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> QuoteExt for Twhere T: ?Sized,

fn push_quoted<'q, Q, S>(&mut self, _q: Q, s: S)where Q: QuoteInto<T>, S: Into<Quotable<'q>>,

impl<T> Serialize for Twhere T: Serialize + ?Sized,

fn erased_serialize(&self, serializer: &mut dyn Serializer) -> Result<(), Error>

fn do_erased_serialize( &self, serializer: &mut dyn Serializer, ) -> Result<(), ErrorImpl>

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

Struct IntrospectResult

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> Checkpointable for T
where T: RemoteMessage + Clone,

fn save<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<<T as Checkpointable>::State, CheckpointError>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: 'async_trait,

fn load<'async_trait>( state: <T as Checkpointable>::State, ) -> Pin<Box<dyn Future<Output = Result<T, CheckpointError>> + Send + 'async_trait>>
where T: 'async_trait,

impl<T> CloneToUninit for T
where T: Clone,

impl<A, M> Handler<IndexedErasedUnbound<M>> for A
where A: Handler<M>, M: Castable,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, A>, msg: IndexedErasedUnbound<M>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, A: 'async_trait,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T> QuoteExt for T
where T: ?Sized,

fn push_quoted<'q, Q, S>(&mut self, _q: Q, s: S)
where Q: QuoteInto<T>, S: Into<Quotable<'q>>,

impl<T> Serialize for T
where T: Serialize + ?Sized,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<M> Accepts<M> for M
where M: RemoteMessage,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,

impl<M> Message for M
where M: Send + Sync + 'static,

impl<M> RemoteMessage for M
where M: Message + Named + Serialize + DeserializeOwned,