gregl83 / accounts-aggregate Goto Github PK

program output needs to be purely csv result; however, using verbosity logging flags should toggle debug mode for quickly identifying issues.

add benchmarks covering events per second (EPS)

application needs custom errors for handling by callers.

at a minimum, public functions still need documentation.

add documentation w/examples to undocumented source code and increase docs throughout.

event structures need versioning for updates over time.

add version indicator on event body or metadata.

events should contain idempotency key.

currently, transaction id is used instead but at the very least emitting events with an extra field would work.

using sled or similar for temp aggregate persistence, test data set sizes exhausting transaction id u32.

implement integration tests using temp test file

performance can be improved with some basic and recommended serde optimizations.

• add version field to events (avoid optimistic concurrency bugs)
• implement rayon thread pool
• perform deserialize + process in worker thread
• use threads to read aggregates and write to stdout