/StorageExamples

Primary LanguageJavaScript

Overview

This is a simple CQRS + Event Sourcing system with a little bit of DDD.

Theere are 2 storages represented in Powerdiary.Storage. In general they share the same idea - store values in buckets. Ofcourse the current realization is not production-ready, but the idea can be extended to KKV store.

Time based store Powerdiary.Storage.TimeBaseStore. [Faster reads than writes]

Bucket-based store, where bucket represented by key which is DateTime. The size of the bucket can be adjusted by choosing appropriate key from Powerdiary.Storage.TimeBaseStore.Keys.

The main idea

  • precalculate data before we need it, to avoid (or at least reduce) calculations when we need to read data;
  • since multiple events with the same timestamp are possible - do not try store events, but store system state at some point of time (pre-aggregated data), there is onle one system state at some point of time.

Bucket store Powerdiary.Storage.BucketBaseStore. [Faster writes than reads]

The main idea

  • store events in chronological order in partially sorted manner, use this storage as source of truth for calculating Powerdiary.Storage.TimeBaseStore;
  • use BinarySearch [O(log n)] for searching events.

Append-only stoe Powerdiary.Storage.AppendOnlyStore. [Faster writes than reads]

...comming soon.

Quick start

  • start Powerdiary.Api project frmo solution
  • seed with test data: curl --location --request POST 'https://localhost:44334/api/Chatroom/SeedWithTestData' \ --data-raw ''
  • read data: curl --location --request GET 'https://localhost:44334/api/Chatroom/GetEventsCountByOneMinute' \ --header 'Content-Type: application/json' \ --data-raw '{ "start":"2020-10-10 01:01:00" , "end":"2020-10-10 01:06:02", "granularity":"5" }'
  • read data: curl --location --request GET 'https://localhost:44334/api/Chatroom/GetEventsWholeHistory' \ --header 'Content-Type: application/json' \ --data-raw '{ "start":"2020-10-10 01:01:00" , "end":"2020-10-12 01:06:02", "granularity":"1" }'
  • read data: curl --location --request GET 'https://localhost:44334/api/Chatroom/GetEventsCountDetailedByOneMinute' \ --header 'Content-Type: application/json' \ --data-raw '{ "start":"2020-10-10 01:01:00" , "end":"2020-10-10 01:06:02", "granularity":"2" }'
  • read data: curl --location --request GET 'https://localhost:44334/api/Chatroom/GetEventsCountExtendedByFourMinute' \ --header 'Content-Type: application/json' \ --data-raw '{ "start":"2020-10-10 01:01:00" , "end":"2020-10-10 01:06:02", "granularity":"5" }'

By the way

Found this materials, may be it will be useful: