Struct IngressContext 

pub struct IngressContext {
    pub message_id: Option<String>,
    pub source_class: SourceClass,
    pub sender: Option<String>,
    pub transport: Transport,
    pub trust: TrustClass,
    pub origin: TurnOrigin,
    pub internal_principal: Option<InternalPrincipal>,
}

The envelope stamped by the entry layer; travels with the turn into the engine. See the module docs.

Fields

message_id: Option<String>

Stable inbound id (e.g. a ChannelMessage.id) — provenance + audit handle. None for id-less internal turns.

source_class: SourceClass

Whether the turn is external or internally driven.

sender: Option<String>

Platform user id / principal of the sender, if any.

transport: Transport

The transport the turn arrived on.

trust: TrustClass

The resolved trust class of the sender.

origin: TurnOrigin

Who initiated the turn (see TurnOrigin). Serde-defaults to TurnOrigin::SubTurn so envelopes serialized before this field existed deserialize fail-closed (no origin-gated behavior).

internal_principal: Option<InternalPrincipal>

The internal principal that initiated the turn, when the dispatching surface stamps one (see InternalPrincipal). None for external turns, for internal paths that have no principal contract yet, and for envelopes serialized before this field existed (serde-defaults fail-closed to absent).

Implementations

impl IngressContext

pub fn interactive() -> Self

Envelope for an interactive operator turn (CLI chat loop, one-shot run).

pub fn channel() -> Self

Envelope for a turn the channel orchestrator dispatches for a channel peer. Keeps the placeholder source/transport/trust; the real channel transport identity is not stamped at the edge yet.

pub fn cron() -> Self

Envelope for a scheduled cron job turn.

pub fn daemon() -> Self

Envelope for a daemon-initiated turn (heartbeat task pipeline).

pub fn agent_direct() -> Self

Envelope for a direct embedded Agent::turn call.

pub fn sub_turn() -> Self

Envelope for a nested sub-turn inside a parent turn (delegate subagent, safety net, skills review). Sub-turns never receive origin-gated behavior such as context injection.

pub fn from_origin(origin: TurnOrigin) -> Self

Envelope for a turn whose origin is threaded in from the entry point (e.g. agent::run / process_message, whose one body serves several distinct entries: CLI, cron, daemon, subagent spawn). Equivalent to the per-origin constructors above.

pub fn from_parts( origin: TurnOrigin, internal_principal: Option<InternalPrincipal>, ) -> Self

Envelope for a turn whose origin and (optional) internal principal are both threaded in from the entry point. With None this is exactly IngressContext::from_origin.

pub fn cron_job(job_id: impl Into<String>, job_name: Option<String>) -> Self

Envelope for a scheduled cron job turn stamped with its initiating job. The principal is resolved from the job’s stored config at dispatch and is immutable for the turn’s lifetime.

pub fn peer_agent(sender_alias: impl Into<String>) -> Self

Envelope for a peer-agent dispatch stamped with the sending agent’s canonical alias — the initiator; the recipient turn still executes under the recipient’s own alias.

pub fn daemon_task(task: impl Into<String>) -> Self

Envelope for a daemon-driven turn stamped with a runtime-owned task identifier (never model-authored text).

Trait Implementations

impl Clone for IngressContext

fn clone(&self) -> IngressContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IngressContext

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IngressContext

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for IngressContext

impl PartialEq for IngressContext

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for IngressContext

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for IngressContext