feat(drainer): added drainer which reads from redis stream and executes queries on DB #142
feat(drainer): drainer setup
37678c6c
feat(router): making router and drainer compatible
c5fa7818
feat(drainer): add changes to execute sql queries and print stmt for …
066ce74f
feat(router): added kv types, stored pi insert in redis stream
0417d312
feat(router): executed PI insert from redis stream, POC
7d0c92cf
feat(router): added writing to redis stream for update PI, PA, and in…
ef01f637
feat(drainer): added code to exec queries from redis
e48fc41f
Merge branch 'main' into types-stream-drainer
97d65518
fix(storage_models): added traits for PI
a323998e
refactor(router, drainer): removed most of raw query code
53067f7b
feature(router): storing PI, PA, storing structs for update in redis
976b0eed
feat(router): merged code and made update query changes to qeuries ex…
75fea8db
feat(drainer): polished the code
147bbd91
refactor: deleted and restored some files accidentally commited
56b78a21
refactor: addressed refactoring changes suggested in review
d00d49ba
Apply suggestions from code review
08cb4cf8
refactor: addressed review comments
67ed6df4
Merge branch 'types-stream-drainer' of github.com:juspay/orca into ty…
614ff20f
refactor: addressed some of the review comments
af720e55
Apply suggestions from code review
f424ad91
refactor: addressed review comments
db65fc93
refactor(router, storage_models): addressing review comments move kv …
ae4b33ae
refactor(drainer): used kv types from storage models, drainer works
6c95926c
refactor(drainer): changed map_err to current_context
1ba31f23
refactor(drainer): addressing reciew comment, true into for redis type
cfb3fcda
Merge branch 'main' into types-stream-drainer
1fbd2dc4
fix(drainer): corrected construction of stream_name_flag key
3c7ccd3b
refactor(drainer): formatted
d8701be3
refactor: used redis type instead of fred type, todo similar changes …
3a2cb602
refactor: removed unused dependency, updates sub dependencies of drainer
78365904
Abhicodes-crypto
changed the title Drainer reading from redis stream and executing queries feat(drainer): added drainer which read from redis stream and executes queries on DB 1 year ago
Abhicodes-crypto
changed the title feat(drainer): added drainer which read from redis stream and executes queries on DB feat(drainer): added drainer which reads from redis stream and executes queries on DB 1 year ago
refactor: renamed some of the kv types, reverted cargo.lock to older …
2f8205ed
chore(drainer): updated serde_json
4896088f
refactor(drainer): addressing review comments
a5fd280f
lsampras
dismissed these changes
on 2022-12-15
Merge branch 'main' into types-stream-drainer
ebe817a5
refactor: updated cargo lock
0875e6a4
jarnura
requested changes
on 2022-12-15
Merge branch 'main' into types-stream-drainer
d0f1251f
refactor: made stream id get stream entries as static string
1690b4b3
refactor: removed let else stmt
591788b3
jarnura
approved these changes
on 2022-12-16
jarnura
merged
3bad58b0
into main 1 year ago
jarnura
deleted the types-stream-drainer branch 1 year ago
Labels
A-framework
C-feature
Login to write a write a comment.
Login via GitHub