Struct riker::system::EsManager

pub struct EsManager<Evs: EventStore> { /* fields omitted */ }

Methods

impl<Evs: EventStore> EsManager<Evs>

pub fn props(config: &Config) -> BoxActorProd<Evs::Msg>

Trait Implementations

impl<Evs: EventStore> Actor for EsManager<Evs>

type Msg = Evs::Msg

fn other_receive(
    &mut self,
    _: &Context<Self::Msg>,
    msg: ActorMsg<Self::Msg>,
    sender: Option<ActorRef<Self::Msg>>
)

Invoked when an actor receives a Riker predefined message

fn receive(
    &mut self,
    _: &Context<Self::Msg>,
    _: Self::Msg,
    _: Option<ActorRef<Self::Msg>>
)

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 system_receive(
    &mut self,
    ctx: &Context<Self::Msg>,
    msg: SystemMsg<Self::Msg>,
    sender: Option<ActorRef<Self::Msg>>
)

Invoked when an actor receives a Riker system message

fn persistence_conf(&self) -> Option<PersistenceConf>

Return a Some(PersistenceConf) to enable actor persistence.

fn apply_event(
    &mut self,
    ctx: &Context<Self::Msg>,
    evt: Self::Msg,
    sender: Option<ActorRef<Self::Msg>>
)

Invoked after an event is successfully inserted into the event store.

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

Invoked for each event when the actor is recovering.

fn supervisor_strategy(&self) -> Strategy

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