about summary refs log tree commit diff
path: root/src/payload-processor (follow)
Commit message (Expand)AuthorAgeFilesLines
* misc: Update for working with new serverBaitinq2024-06-161-6/+6
* payload-processor: bulk insert filesBaitinq2024-06-091-8/+7
* payload-processor: fix bug inserting multiple filesBaitinq2024-06-081-1/+6
* payload-processor: Update file table schema nameBaitinq2024-06-071-1/+1
* payload-processor: take a list of filesBaitinq2024-05-304-20/+23
* rest-api: handle payloads with an api_keyBaitinq2024-05-295-18/+28
* rest-api: connect to db and add /file/ GET endpointBaitinq2024-05-276-16/+11
* payload-processor: fmtBaitinq2024-05-271-2/+4
* payload-processor: always commit to kafka (for now)Baitinq2024-05-271-2/+9
* payload-processor: insert to the file tableBaitinq2024-05-276-15/+58
* payload-processor: deploy with bazelBaitinq2024-05-251-5/+16
* rest-api: deploy with bazelBaitinq2024-05-252-10/+10
* cleanupBaitinq2024-05-201-2/+4
* payloads-processor: connect to DB and insert dummy dataBaitinq2024-05-117-12/+134
* payload-processor: print message partitionBaitinq2024-05-051-1/+1
* payload-processor: set up testingBaitinq2024-05-043-2/+39
* payload-processor: add concurrencyBaitinq2024-05-042-9/+27
* payload-processor: use consumer group and properly handle application shutdownBaitinq2024-05-042-5/+21
* payload-processor: fmtBaitinq2024-05-041-1/+1
* payload-processor: print current time when processingBaitinq2024-05-031-1/+2
* rest-api: Write to kafka asynchronouslyBaitinq2024-05-021-1/+1
* Switch to kafka :^)Baitinq2024-05-024-50/+37
* misc: clean up unnecessary use of ptrsBaitinq2024-05-021-3/+3
* payload-processor: add stubBaitinq2024-05-024-0/+144