Struct eventific::Eventific

pub struct Eventific<S, D: 'static + Send + Sync + Debug, St: Store<D> = MemoryStore<D>> { /* fields omitted */ }

Methods

impl<S, D: 'static + Send + Sync + Debug, St: Store<D>> Eventific<S, D, St>

pub fn get_logger(&self) -> &Logger

pub fn spawn<F: Future<Item = (), Error = ()> + Send + 'static>(
    &self,
    future: F
)

impl<S, D: 'static + Send + Sync + Debug + Clone, St: Store<D>> Eventific<S, D, St>

pub fn new(
) -> EventificBuilder<S, D, MemoryStore<D>, MemorySender, MemoryListener>

impl<S: Default, D: 'static + Send + Sync + Debug + Clone + AsRef<str>, St: Store<D>> Eventific<S, D, St>

pub fn create_aggregate(
    &self,
    aggregate_id: Uuid,
    event_data: Vec<D>,
    metadata: Option<HashMap<String, String>>
) -> impl Future<Item = (), Error = EventificError<D>>

pub fn aggregate(
    &self,
    aggregate_id: Uuid
) -> impl Future<Item = Aggregate<S>, Error = EventificError<D>>

pub fn add_events_to_aggregate<F: Fn(Aggregate<S>) -> IF, IF: IntoFuture<Item = Vec<D>, Error = Error, Future = FF>, FF: Future<Item = Vec<D>, Error = Error>>(
    &self,
    aggregate_id: Uuid,
    _metadata: Option<HashMap<String, String>>,
    callback: F
) -> impl Future<Item = (), Error = EventificError<D>>

pub fn total_events(&self) -> impl Future<Item = u64, Error = EventificError<D>>

pub fn total_events_for_aggregate(
    &self,
    aggregate_id: Uuid
) -> impl Future<Item = u64, Error = EventificError<D>>

pub fn total_aggregates(
    &self
) -> impl Future<Item = u64, Error = EventificError<D>>

pub fn all_aggregates(
    &self
) -> impl Stream<Item = Aggregate<S>, Error = EventificError<D>>

pub fn updated_aggregates(
    &self
) -> impl Stream<Item = Aggregate<S>, Error = EventificError<D>>

impl<S: 'static + Default + Send, D: 'static + Send + Sync + Debug + Clone + AsRef<str>, St: Store<D> + Sync> Eventific<S, D, St>

pub fn grpc_create_aggregate<Input: 'static + Send, Resp: 'static + Send, IC: 'static + FnOnce(&Input) -> &str, VC: 'static + FnOnce(&Input) -> Result<Vec<D>, Error> + Send, RC: 'static + FnOnce() -> Resp + Send>(
    &self,
    ctx: RequestOptions,
    input: Input,
    id_callback: IC,
    event_callback: VC,
    result_callback: RC
) -> SingleResponse<Resp>

pub fn grpc_add_events_to_aggregate<Input: 'static + Sync + Send + Clone, Resp: 'static + Send, IC: 'static + FnOnce(&Input) -> &str, VC: 'static + Fn(&Input, Aggregate<S>) -> IF + Send, RC: 'static + FnOnce() -> Resp + Send, IF: 'static + IntoFuture<Item = Vec<D>, Error = Error, Future = FF>, FF: 'static + Future<Item = Vec<D>, Error = Error> + Send>(
    &self,
    ctx: RequestOptions,
    input: Input,
    id_callback: IC,
    event_callback: VC,
    result_callback: RC
) -> SingleResponse<Resp>

Trait Implementations

impl<S, D: 'static + Send + Sync + Debug, St: Store<D>> Clone for Eventific<S, D, St>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.