Struct statefun::Effects

pub struct Effects { /* fields omitted */ }

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.