Struct riker_es::Store

pub struct Store<T: Model> { /* fields omitted */ }

An actor that handles the persistance of events of entities using "commits" to track who made a change and why.

Trait Implementations

impl<T: Model> Actor for Store<T>

type Msg = StoreMsg<T>

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<T: Model> ActorFactoryArgs<ActorRef<ChannelMsg<Event<T>>>> for Store<T>

fn create_args(bus: EventBus<T>) -> Self

impl<T: Debug + Model> Debug for Store<T>

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

Formats the value using the given formatter.

impl<T: Model> Default for Store<T>

fn default() -> Self

Returns the "default value" for a type.

impl<T: Model> Receive<(EntityId, DateTime<Utc>)> for Store<T>

type Msg = StoreMsg<T>

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

Invoked when an actor receives a message

impl<T: Model> Receive<Commit<T>> for Store<T>

type Msg = StoreMsg<T>

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

Invoked when an actor receives a message

impl<T: Model> Receive<EntityId> for Store<T>

type Msg = StoreMsg<T>

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

Invoked when an actor receives a message

impl<T: Model> Receive<RangeTo<DateTime<Utc>>> for Store<T>

type Msg = StoreMsg<T>

fn receive(
    &mut self,
    _ctx: &Context<Self::Msg>,
    range: RangeTo<DateTime<Utc>>,
    sender: Sender
)

Invoked when an actor receives a message