Struct actor_es::Store

pub struct Store<M: Model, S: CommitStore<M>> { /* fields omitted */ }

An actor that handles the persistance of changes of an entity using "commits" to track who made the change and why.

Trait Implementations

impl<M, S> Actor for Store<M, S> where
    M: Model,
    S: CommitStore<M>, 

type Msg = StoreMsg<M>

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

Invoked when an actor receives a message

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

Invoked when an actor is being started by the system.

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<M, S> ActorFactoryArgs<(S, ActorRef<ChannelMsg<Event<M>>>)> for Store<M, S> where
    M: Model,
    S: CommitStore<M>, 

fn create_args((backend, bus): (S, EventBus<M>)) -> Self

impl<M, S> ActorFactoryArgs<S> for Store<M, S> where
    M: Model,
    S: CommitStore<M>, 

fn create_args(backend: S) -> Self

impl<M: Debug + Model, S: Debug + CommitStore<M>> Debug for Store<M, S>

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

Formats the value using the given formatter.

impl<M, S> Receive<(EntityId, DateTime<Utc>)> for Store<M, S> where
    M: Model,
    S: CommitStore<M>, 

type Msg = StoreMsg<M>

fn receive(
    &mut self,
    cx: &Context<Self::Msg>,
    (id, until): (EntityId, DateTime<Utc>),
    sender: Sender
)

Invoked when an actor receives a message

impl<M, S> Receive<Commit<M>> for Store<M, S> where
    M: Model,
    S: CommitStore<M>, 

type Msg = StoreMsg<M>

fn receive(&mut self, cx: &Context<Self::Msg>, c: Commit<M>, _sender: Sender)

Invoked when an actor receives a message

impl<M, S> Receive<DateTime<Utc>> for Store<M, S> where
    M: Model,
    S: CommitStore<M>, 

type Msg = StoreMsg<M>

fn receive(
    &mut self,
    cx: &Context<Self::Msg>,
    until: DateTime<Utc>,
    sender: Sender
)

Invoked when an actor receives a message

impl<M, S> Receive<EntityId> for Store<M, S> where
    M: Model,
    S: CommitStore<M>, 

type Msg = StoreMsg<M>

fn receive(&mut self, _cx: &Context<Self::Msg>, _id: EntityId, _sender: Sender)

Invoked when an actor receives a message