Struct riker_es::Entity

pub struct Entity<E: ES> { /* fields omitted */ }

Entity is an actor that dispatches commands and manages aggregates that are being queried

Trait Implementations

impl<E: ES> Actor for Entity<E>

type Msg = CQRS<E::Cmd>

fn pre_start(&mut self, ctx: &Context<Self::Msg>)

Invoked when an actor is being started by the system.

fn recv(&mut self, ctx: &Context<Self::Msg>, msg: Self::Msg, sender: Sender)

Invoked when an actor receives a message

fn post_start(&mut self, ctx: &Context<Self::Msg>)

Invoked after an actor has started.

fn post_stop(&mut self)

Invoked after an actor has been stopped.

fn supervisor_strategy(&self) -> Strategy

Return a supervisor strategy that will be used when handling failed child actors.

fn sys_recv(
    &mut self,
    ctx: &Context<Self::Msg>,
    msg: SystemMsg,
    sender: Option<BasicActorRef>
)

Invoked when an actor receives a system message

impl<E, Args> ActorFactoryArgs<Args> for Entity<E> where
    Args: ActorArgs,
    E: ES<Args = Args>, 

fn create_args(args: Args) -> Self

impl<E: ES> Receive<Query> for Entity<E>

type Msg = CQRS<E::Cmd>

fn receive(&mut self, _ctx: &Context<Self::Msg>, q: Query, sender: Sender)

Invoked when an actor receives a message