event_store 0.1.1

Crate to deal with every aspect of an eventstore
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use super::subscriber::Subscriber;
use crate::prelude::*;
use actix::prelude::*;
use std::collections::HashMap;

#[derive(Default, Debug)]
pub struct SubscriptionState {
    pub(crate) subscribers: HashMap<Recipient<RecordedEvents>, Addr<Subscriber>>,
    // :serializer,
    // :schema,
    stream_uuid: String,
    start_from: String,
    subscription_name: String,
    subscription_id: i64,
    // :selector,
    // :mapper,
    max_size: usize,
    partition_by: String,
    lock_ref: String,
    last_received: usize,
    last_sent: usize,
    last_ack: usize,
    queue_size: usize,
    buffer_size: usize,
    // partitions: %{},
    // processed_event_numbers: MapSet.new(),
    transient: bool,
}