Commit Graph

  • 255d8f126d updating stream defauls like aysnc calls, wait timeout, max idle connection and keep alive counts to ensure the stream doesn't fail. Moving everything to a config file to easy updates main surbhi 2025-10-10 14:54:16 -04:00
  • 88fce17efc OHLC pipeline stuff surbhi 2025-10-09 13:03:31 -04:00
  • b4f1de9d0d removing price inversion in the swap ellaborator since we always want to represent the vlaue of the swap in its quote curency surbhi 2025-10-09 13:00:07 -04:00
  • 0d8df3df9c adding renamed elaborators surbhi 2025-10-08 13:21:12 -04:00
  • 2fc85c688b Using timestmap from blockhash. Also renaming elaborators to be more descriptive and removing unneeded logs and code surbhi 2025-10-08 13:16:35 -04:00
  • 47fe85b50b Swap object stream with verified amount in and amount out surbhi 2025-10-07 20:11:01 -04:00
  • 6b4cad1479 Remove .mvn/jvm.config file surbhi 2025-10-06 19:25:35 -04:00
  • 04d441d6b1 Remove SSH key files from repository surbhi 2025-10-06 19:18:33 -04:00
  • 00ae425700 Add token metadata logging to swap event stream sjhavar 2025-10-06 16:03:08 -04:00
  • e58fdc0b06 Add PoolElaborator for token address enrichment sjhavar 2025-10-06 13:19:02 -04:00
  • 7449b4b4b1 BlockElaborator bugfix tim 2025-10-06 14:41:18 -04:00
  • 6829053d94 BlockElaborator tim 2025-10-06 12:33:45 -04:00
  • 3a64f5630c UniswapV3Pool wrapper tim 2025-10-06 12:00:07 -04:00
  • 5429649a39 Implement token metadata enrichment for Uniswap v3 swap events feature/token-metadata-enrichment surbhi 2025-09-28 15:59:16 -04:00
  • 9f65c2e850 Merge remote-tracking branch 'origin/main' tim 2025-09-28 14:10:00 -04:00
  • 8c672f250e TokenElaborator tim 2025-09-28 14:09:16 -04:00
  • 267ff8baf2 Add Uniswap v3 swap event streaming Surbhi Jhavar 2025-09-24 15:25:00 -04:00
  • 21f0f986d2 Token DTO tim 2025-09-25 13:32:06 -04:00
  • ebce35c972 Swap DTO tim 2025-09-25 13:07:16 -04:00
  • adb80ee7c9 updated to Flink 2.1.0 and added flink-cep tim 2025-09-25 12:42:15 -04:00
  • bd82c431f9 added project files tim 2025-09-24 11:10:32 -04:00
  • a80593b9c2 DTO's and other infra tim 2025-09-22 17:34:05 -04:00
  • 0cd8e1e28f initial checkin with basic arbitrum head blocks working tim 2025-05-17 20:28:20 -04:00