-
feat(drainer): drainer setup
racnan committed on 2022-12-02 07:26
-
feat(router): making router and drainer compatible
-
feat(drainer): add changes to execute sql queries and print stmt for debug
-
feat(router): added kv types, stored pi insert in redis stream
-
feat(router): executed PI insert from redis stream, POC
-
feat(router): added writing to redis stream for update PI, PA, and insert PA
-
feat(drainer): added code to exec queries from redis
-
Merge branch 'main' into types-stream-drainer
-
fix(storage_models): added traits for PI
-
refactor(router, drainer): removed most of raw query code
-
feature(router): storing PI, PA, storing structs for update in redis
-
feat(router): merged code and made update query changes to qeuries execute correctly
-
feat(drainer): polished the code
-
refactor: deleted and restored some files accidentally commited
-
refactor: addressed refactoring changes suggested in review
-
Apply suggestions from code review
-
refactor: addressed review comments
-
Merge branch 'types-stream-drainer' of github.com:juspay/orca into types-stream-drainer
-
refactor: addressed some of the review comments
-
Apply suggestions from code review
-
refactor: addressed review comments
-
refactor(router, storage_models): addressing review comments move kv types into storage_models, router working, drainer doesn't yet
-
refactor(drainer): used kv types from storage models, drainer works
-
refactor(drainer): changed map_err to current_context
-
refactor(drainer): addressing reciew comment, true into for redis type
-
Merge branch 'main' into types-stream-drainer
-
fix(drainer): corrected construction of stream_name_flag key
-
refactor(drainer): formatted
-
refactor: used redis type instead of fred type, todo similar changes in rest of the file
-
refactor: removed unused dependency, updates sub dependencies of drainer
-
refactor: renamed some of the kv types, reverted cargo.lock to older version of tracing
-
chore(drainer): updated serde_json
-
refactor(drainer): addressing review comments
-
Merge branch 'main' into types-stream-drainer
-
refactor: updated cargo lock
-
Merge branch 'main' into types-stream-drainer
-
refactor: made stream id get stream entries as static string
-
refactor: removed let else stmt