Struct Activity 

pub struct Activity { /* private fields */ }

High-level activity payload exchanged with Greentic hosts.

Implementations

impl Activity

pub fn text(text: impl Into<String>) -> Activity

Create a text messaging activity payload.

pub fn custom(action: impl Into<String>, payload: Value) -> Activity

Build a custom activity with a raw payload body.

pub fn with_welcome_flow_hint(self, hint: WelcomeFlowHint) -> Activity

Attach the M1.5 welcome-flow override hint. See WelcomeFlowHint for the contract — the producer is responsible for only calling this when the activity is actually first contact on the asserted messaging endpoint. Attaching on every turn would route every no-active-wait turn through the welcome flow.

pub fn welcome_flow_hint(&self) -> Option<&WelcomeFlowHint>

Return the welcome-flow override hint, if any.

pub fn with_tenant(self, tenant: impl Into<String>) -> Activity

Attach a tenant identifier to the activity.

pub fn with_flow(self, flow_id: impl Into<String>) -> Activity

Target a specific flow identifier.

pub fn with_pack(self, pack_id: impl Into<String>) -> Activity

Target a specific pack identifier.

pub fn with_flow_type(self, flow_type: impl Into<String>) -> Activity

Hint which flow type should handle the activity.

pub fn with_session(self, session_id: impl Into<String>) -> Activity

Attach a session identifier used for retries/idempotency.

pub fn with_provider(self, provider: impl Into<String>) -> Activity

Attach a provider identifier for telemetry scoping.

pub fn with_messaging_endpoint(self, endpoint_id: impl Into<String>) -> Activity

Attach the receiving messaging endpoint id (M1.4). Distinguishes provider instances of the same provider_type (e.g. teams-legal vs teams-accounting); the runner threads it into the envelope so session keys and telemetry partition per-endpoint.

pub fn from_user(self, user: impl Into<String>) -> Activity

Attach the originating user for messaging activities.

pub fn in_channel(self, channel: impl Into<String>) -> Activity

Attach a channel identifier (chat, room, or queue) for canonical session keys.

pub fn in_conversation(self, conversation: impl Into<String>) -> Activity

Attach a conversation/thread identifier for canonical session keys.

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

Return the resolved tenant identifier, if any.

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

Return the resolved pack identifier, if any.

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

Return the resolved flow identifier hint.

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

Return the resolved flow type hint.

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

Return the originating session identifier, if supplied.

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

Return the originating provider identifier, if supplied.

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

Return the receiving messaging endpoint id (M1.4), if supplied.

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

Return the originating user identifier, if supplied.

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

Return the channel identifier, if supplied.

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

Return the conversation identifier, if supplied.

pub fn payload(&self) -> &Value

Underlying payload body.

Trait Implementations

impl Clone for Activity

fn clone(&self) -> Activity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Activity

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Activity

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Activity

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

where __S: Serializer,

Serialize this value into the given Serde serializer.