event-store-adapter-rs 0.2.3

crate to make DynamoDB an Event Store
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
29
30
31
32
33
34
35
36
37
38
39
40

use crate::types::AggregateId;
use std::collections::hash_map::DefaultHasher;
use std::fmt::Debug;
use std::hash::{Hash, Hasher};

pub trait KeyResolver: Debug + Send + 'static {
  type ID: AggregateId;

  fn resolve_partition_key(&self, id: &Self::ID, shard_count: u64) -> String;
  fn resolve_sort_key(&self, id: &Self::ID, seq_nr: usize) -> String;
}

#[derive(Debug, Clone)]
pub struct DefaultKeyResolver<AID> {
  _phantom: std::marker::PhantomData<AID>,
}

impl<AID> Default for DefaultKeyResolver<AID> {
  fn default() -> Self {
    DefaultKeyResolver {
      _phantom: std::marker::PhantomData,
    }
  }
}

impl<AID: AggregateId> KeyResolver for DefaultKeyResolver<AID> {
  type ID = AID;

  fn resolve_partition_key(&self, id: &Self::ID, shard_count: u64) -> String {
    let mut hasher = DefaultHasher::new();
    id.value().hash(&mut hasher);
    let hash_value = hasher.finish();
    let remainder = hash_value % shard_count;
    format!("{}-{}", id.type_name(), remainder)
  }

  fn resolve_sort_key(&self, id: &Self::ID, seq_nr: usize) -> String {
    format!("{}-{}-{}", id.type_name(), id.value(), seq_nr)
  }
}