 lingniu
|
bb59303a4b
|
feat: build vehicle data platform and production pipeline
|
2026-07-14 12:35:33 +08:00 |
|
|
lingniu
|
afb301cb7a
|
feat(go): expose async sink publish latency histogram
|
2026-07-03 19:02:24 +08:00 |
|
|
lingniu
|
fb03c80a95
|
feat(go): expose gateway async sink metrics
|
2026-07-03 18:28:07 +08:00 |
|
|
lingniu
|
535acdb2a6
|
feat(go): publish realtime fields stream
|
2026-07-03 14:08:32 +08:00 |
|
|
lingniu
|
2ae9794dda
|
refactor(go): default to go vehicle topics
|
2026-07-02 20:22:47 +08:00 |
|
|
lingniu
|
c27150cc15
|
feat(go): add nats kafka ingest bridge
|
2026-07-02 15:07:44 +08:00 |
|
|
lingniu
|
5145d156bc
|
feat(go): decouple gateway publish with async sink
|
2026-07-02 14:11:43 +08:00 |
|
|
lingniu
|
5a958616a3
|
fix(go): batch durable kafka replay
|
2026-07-02 14:01:50 +08:00 |
|
|
lingniu
|
c939cc6b0c
|
fix(go): stream durable spool batches
|
2026-07-02 13:47:53 +08:00 |
|
|
lingniu
|
75e7c3fbe5
|
fix(go): batch durable spool replay
|
2026-07-02 13:29:49 +08:00 |
|
|
lingniu
|
bc9025d566
|
fix(go): protect durable spool replay during shutdown
|
2026-07-02 13:25:15 +08:00 |
|
|
lingniu
|
924903feb4
|
fix(go): require kafka write acknowledgements
|
2026-07-02 13:06:18 +08:00 |
|
|
lingniu
|
ba5a28e636
|
fix(go): replay raw before unified events
|
2026-07-02 12:18:37 +08:00 |
|
|
lingniu
|
3a67f6e05f
|
feat: cache protocol realtime raw
|
2026-07-02 11:19:46 +08:00 |
|
|
lingniu
|
243de5c2b2
|
feat: spool gateway publishes to disk
|
2026-07-01 23:00:06 +08:00 |
|
|
lingniu
|
7e7066dd86
|
feat: retry gateway kafka publishes
|
2026-07-01 22:54:47 +08:00 |
|
|
lingniu
|
967981c040
|
feat: add go tcp gateway runtime
|
2026-07-01 21:45:28 +08:00 |
|
|
lingniu
|
1fdbc29e27
|
feat: scaffold go vehicle gateway core
|
2026-07-01 21:43:16 +08:00 |
|