about summary refs log tree commit diff
path: root/src/payload-processor (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Misc: Log to stdoutBaitinq2024-07-211-0/+1
|
* 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
| | | | TODO: Only get files for your specific user
* 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