Struct actor_es::Entity

pub struct Entity<E: ES, S: CommitStore<E::Model>> { /* fields omitted */ }

Entity is an actor that handles user commands running the buissiness logic defined in the handler callback and "commit" changes of the model to the configured event store. Will also use the store to query a stored entity data applying any change that has been recorded up to the specified moment in time.

Trait Implementations

impl<E, S> Actor for Entity<E, S> where
    E: ES,
    S: CommitStore<E::Model>, 

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, S, Args> ActorFactoryArgs<(S, Args)> for Entity<E, S> where
    Args: ActorArgs,
    E: ES<Args = Args>,
    S: CommitStore<E::Model>, 

fn create_args((store_backend, args): (S, Args)) -> Self

impl<E, S> Receive<Query> for Entity<E, S> where
    E: ES,
    S: CommitStore<E::Model>, 

type Msg = CQRS<E::Cmd>

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

Invoked when an actor receives a message