Struct Effects

pub struct Effects { /* private fields */ }

Effects (or side effects) of a stateful function invocation.

This can be used to:

• send messages ourselves or other stateful functions
• send messages to an egress
• update the state of this stateful function, which will be available on future invocations

Implementations

impl Effects

pub fn new() -> Effects

Creates a new empty Effects.

pub fn send<M: Message>(&mut self, address: Address, message: M)

Sends a message to the stateful function identified by the address.

pub fn send_after<M: Message>( &mut self, address: Address, delay: Duration, message: M, )

Sends a message to the stateful function identified by the address after a delay.

pub fn egress<M: Message>(&mut self, identifier: EgressIdentifier, message: M)

Sends a message to the egress identifier by the EgressIdentifier.

pub fn delete_state(&mut self, name: &str)

Deletes the state kept under the given name.

pub fn update_state<T: Message>(&mut self, name: &str, value: &T)

Updates the state stored under the given name to the given value.

Trait Implementations

impl Debug for Effects

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

Formats the value using the given formatter.

impl Default for Effects

fn default() -> Effects

Returns the “default value” for a type.

impl KafkaEgress for Effects

fn kafka_egress<M: Message>( &mut self, identifier: EgressIdentifier, topic: &str, message: M, )

Sends the given message to the Kafka topic topic via the egress specified using the EgressIdentifier.

fn kafka_keyed_egress<M: Message>( &mut self, identifier: EgressIdentifier, topic: &str, key: &str, message: M, )

Sends the given message to the Kafka topic topic via the egress specified using the EgressIdentifier.