Skip to main content

QueryRuntimeContext

Struct QueryRuntimeContext 

Source
pub struct QueryRuntimeContext {
    pub instance_id: String,
    pub query_id: String,
    pub update_tx: ComponentUpdateSender,
}
Expand description

Context provided to Query components during initialization.

Contains the DrasiLib instance ID and update channel for status reporting. Constructed by QueryManager when a query is added via add_query().

Unlike sources and reactions, queries are internal to drasi-lib (not plugins), but still follow the same context-based initialization pattern for consistency.

§Clone

This struct implements Clone and uses Arc internally for the update channel, making cloning cheap (just reference count increments).

Fields§

§instance_id: String

DrasiLib instance ID (for log routing isolation)

§query_id: String

Unique identifier for this query instance

§update_tx: ComponentUpdateSender

mpsc sender for fire-and-forget component status updates.

Status changes sent here are applied to the component graph by the graph update loop, which emits broadcast events to all subscribers.

Implementations§

Source§

impl QueryRuntimeContext

Source

pub fn new( instance_id: impl Into<String>, query_id: impl Into<String>, update_tx: ComponentUpdateSender, ) -> Self

Create a new query runtime context.

This is typically called by QueryManager when adding a query to DrasiLib.

§Arguments
  • instance_id - The DrasiLib instance ID
  • query_id - The unique identifier for this query
  • update_tx - mpsc sender for status updates to the component graph
Source

pub fn instance_id(&self) -> &str

Get the DrasiLib instance ID.

Source

pub fn query_id(&self) -> &str

Get the query’s unique identifier.

Trait Implementations§

Source§

impl Clone for QueryRuntimeContext

Source§

fn clone(&self) -> QueryRuntimeContext

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for QueryRuntimeContext

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

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

Source§

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

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

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

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

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

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more