shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Commit Graph

  • 96e9382d73 fix(go): normalize history parsed field names lingniu 2026-07-03 14:42:10 +08:00
  • 6624930cc1 perf(go): gzip history raw field responses lingniu 2026-07-03 14:38:48 +08:00
  • 6318c10c41 perf(go): optimize tdengine raw frame queries lingniu 2026-07-03 14:25:48 +08:00
  • 535acdb2a6 feat(go): publish realtime fields stream lingniu 2026-07-03 14:08:32 +08:00
  • e1bf2d72e1 refactor(go): map realtime fields to semantic names lingniu 2026-07-03 13:51:57 +08:00
  • c359930009 refactor(go): simplify redis realtime projections lingniu 2026-07-03 13:42:15 +08:00
  • a96490618c fix(go): collapse gb32960 auxiliary snapshot lingniu 2026-07-03 13:17:31 +08:00
  • 112b02e8c5 fix(go): store protocol parsed fields in realtime kv lingniu 2026-07-03 12:08:12 +08:00
  • 7bf78f91ba fix(go): project full yutong mqtt data to realtime kv lingniu 2026-07-03 12:01:32 +08:00
  • 0344c65e5b feat(go): add nats fast writer lingniu 2026-07-03 11:59:33 +08:00
  • 76f5a20b79 perf(go): decouple realtime mysql projection lingniu 2026-07-03 11:49:13 +08:00
  • 6fb6262d0d feat(go): add realtime kv projection lingniu 2026-07-03 11:34:52 +08:00
  • b948a46e64 fix(go): normalize gb32960 realtime vendor fragments lingniu 2026-07-03 11:20:17 +08:00
  • 8789a92428 fix(go): merge gb32960 realtime snapshot payloads lingniu 2026-07-03 11:14:57 +08:00
  • 0fa5343ab3 fix(go): preserve sparse realtime location fields lingniu 2026-07-03 10:56:38 +08:00
  • 9c212815ef fix(go): filter realtime mysql snapshots by business events lingniu 2026-07-03 10:42:32 +08:00
  • 02075b5ea0 fix(go): resolve jt808 locations through registration lingniu 2026-07-03 10:30:20 +08:00
  • cabdac1fe2 feat(go): enrich realtime snapshot context lingniu 2026-07-03 10:17:10 +08:00
  • 75fbd92de9 fix(go): write tdengine timestamps as epoch millis lingniu 2026-07-03 09:17:53 +08:00
  • a16043c032 fix(go): guard realtime mysql against stale events lingniu 2026-07-03 09:03:46 +08:00
  • c2e4c2b955 perf(go): trim frame id from location history lingniu 2026-07-03 08:56:04 +08:00
  • c916120ea2 perf(go): skip empty parsed raw payloads lingniu 2026-07-03 08:51:30 +08:00
  • d4c164480f perf(go): avoid mqtt raw hex duplication lingniu 2026-07-03 08:48:07 +08:00
  • 1830798d2e fix(go): cache mileage after successful write lingniu 2026-07-03 08:43:58 +08:00
  • 8f5afd20a6 perf(go): deduplicate unchanged mileage samples lingniu 2026-07-03 08:39:48 +08:00
  • c1640b4332 perf(go): skip empty realtime payload snapshots lingniu 2026-07-03 08:35:14 +08:00
  • 97362e3205 perf(go): start realtime projector at latest offset lingniu 2026-07-03 08:30:18 +08:00
  • 4c34c1221b refactor(go): make raw topics the realtime source lingniu 2026-07-03 08:25:14 +08:00
  • c2d058bf75 refactor(go): keep realtime cache vin scoped lingniu 2026-07-03 08:12:21 +08:00
  • 400047e08c perf(go): cache identity binding lookups lingniu 2026-07-03 08:07:32 +08:00
  • 0b9e803139 perf(go): simplify identity binding lookup lingniu 2026-07-03 08:01:00 +08:00
  • 2af2ba3367 perf(go): simplify realtime plate lookup lingniu 2026-07-03 07:57:04 +08:00
  • 0aa71402d1 docs(go): document realtime total semantics lingniu 2026-07-03 07:53:30 +08:00
  • b3ea2bd91f refactor(go): make realtime totals opt in lingniu 2026-07-03 07:50:14 +08:00
  • eced1873cd refactor(go): drop unused realtime geo index lingniu 2026-07-03 07:46:21 +08:00
  • 1c0d7dc03e perf(go): cache realtime plate lookups lingniu 2026-07-03 07:42:24 +08:00
  • 9345fe60b5 refactor(go): drop redundant daily mileage vin index lingniu 2026-07-03 07:36:53 +08:00
  • cb63ceec2e refactor(go): make daily metric totals opt in lingniu 2026-07-03 07:32:09 +08:00
  • b149660b4b refactor(go): make history totals opt in lingniu 2026-07-03 07:28:02 +08:00
  • bb0d001d72 refactor(go): simplify identity table keys lingniu 2026-07-03 07:22:18 +08:00
  • 04bafb4cd6 refactor(go): simplify daily mileage table key lingniu 2026-07-03 07:16:49 +08:00
  • e89c9fd98f refactor(go): simplify realtime mysql current tables lingniu 2026-07-03 07:11:40 +08:00
  • 7c41b81654 refactor(go): remove duplicate mileage history api lingniu 2026-07-02 21:34:12 +08:00
  • e27af63025 refactor(go): simplify history location identity lingniu 2026-07-02 21:28:29 +08:00
  • ef2be36fce refactor(go): remove source endpoint from realtime snapshots lingniu 2026-07-02 21:16:39 +08:00
  • 04ca0d15d8 refactor(go): keep protocol realtime snapshots lightweight lingniu 2026-07-02 21:12:33 +08:00
  • d1e28b9e64 refactor(go): avoid duplicate realtime protocol payloads lingniu 2026-07-02 21:09:07 +08:00
  • da78a989b5 docs: record go topic configuration baseline lingniu 2026-07-02 21:05:46 +08:00
  • bec6326103 refactor(go): make daily mileage vin only lingniu 2026-07-02 21:02:02 +08:00
  • b23ae3410c refactor(go): remove realtime schema compatibility cleanup lingniu 2026-07-02 20:55:24 +08:00
  • 2ae9794dda refactor(go): default to go vehicle topics lingniu 2026-07-02 20:22:47 +08:00
  • 3248336bea docs: add production data plane inventory lingniu 2026-07-02 20:14:56 +08:00
  • 3c9678491a feat(go): bootstrap minimal identity schema lingniu 2026-07-02 20:06:38 +08:00
  • 593dc08870 refactor(go): simplify daily mileage storage lingniu 2026-07-02 20:01:03 +08:00
  • abc1b9870a docs: record storage simplification deployment lingniu 2026-07-02 19:51:48 +08:00
  • 29cd044a57 refactor(go): remove duplicate raw fields json lingniu 2026-07-02 19:47:32 +08:00
  • 0bbe87e6fc refactor(go): stop duplicate mileage history writes lingniu 2026-07-02 19:42:53 +08:00
  • be559c0f99 docs: define minimal vehicle storage contract lingniu 2026-07-02 19:38:24 +08:00
  • 8fd38eb87e docs: add vehicle ingest production runbook lingniu 2026-07-02 19:32:52 +08:00
  • df96ec8879 feat(go): expose nats bridge pending metrics lingniu 2026-07-02 19:27:36 +08:00
  • 1f4a23ff69 feat(go): expose kafka consumer lag metrics lingniu 2026-07-02 19:23:01 +08:00
  • 41ff0bcef4 feat(go): track gateway active connections lingniu 2026-07-02 19:16:25 +08:00
  • 266a74f225 docs: document go service observability endpoints lingniu 2026-07-02 19:12:17 +08:00
  • 896e841902 feat(go): expose runtime ingest metrics lingniu 2026-07-02 19:06:24 +08:00
  • 1dfd540700 feat(go): add platform principles and health probes lingniu 2026-07-02 18:53:02 +08:00
  • 0bfd1191cb feat: add realtime snapshot and location APIs lingniu 2026-07-02 18:41:23 +08:00
  • 44a6bee4ac refactor(go): trim realtime mysql business columns lingniu 2026-07-02 17:16:00 +08:00
  • 12c15896d0 refactor(go): key realtime mysql tables by vin lingniu 2026-07-02 16:47:29 +08:00
  • 5333ed34b7 refactor(go): keep realtime mysql tables core only lingniu 2026-07-02 16:42:40 +08:00
  • 75b36f4011 fix(go): backfill realtime plate from binding lingniu 2026-07-02 16:36:52 +08:00
  • bc399d2819 feat(go): cache realtime locations in mysql lingniu 2026-07-02 16:31:58 +08:00
  • d0289b1b48 fix(go): flatten jt808 additional fields lingniu 2026-07-02 16:23:03 +08:00
  • 5b2e1abcdd fix(go): skip empty frames in realtime snapshot lingniu 2026-07-02 16:11:58 +08:00
  • dac6718ee4 feat(go): persist realtime snapshots to mysql lingniu 2026-07-02 16:06:29 +08:00
  • f4335641db fix(go): merge realtime raw arrays by serial lingniu 2026-07-02 15:48:14 +08:00
  • f3b4cbbbb2 docs: add go data flow diagram lingniu 2026-07-02 15:48:14 +08:00
  • c27150cc15 feat(go): add nats kafka ingest bridge lingniu 2026-07-02 15:07:44 +08:00
  • 079bd76d38 chore(go): tune gateway async publish defaults lingniu 2026-07-02 14:22:11 +08:00
  • 5145d156bc feat(go): decouple gateway publish with async sink lingniu 2026-07-02 14:11:43 +08:00
  • 5a958616a3 fix(go): batch durable kafka replay lingniu 2026-07-02 14:01:50 +08:00
  • c939cc6b0c fix(go): stream durable spool batches lingniu 2026-07-02 13:47:53 +08:00
  • b27f909109 fix(go): normalize tdengine phone tags lingniu 2026-07-02 13:43:15 +08:00
  • 75e7c3fbe5 fix(go): batch durable spool replay lingniu 2026-07-02 13:29:49 +08:00
  • bc9025d566 fix(go): protect durable spool replay during shutdown lingniu 2026-07-02 13:25:15 +08:00
  • 640f70636d fix(go): protect kafka message processing during shutdown lingniu 2026-07-02 13:20:46 +08:00
  • a80eb2eab4 fix(go): decouple mqtt message publishing from shutdown context lingniu 2026-07-02 13:14:15 +08:00
  • d10d5d75c3 fix(go): decouple frame publishing from shutdown context lingniu 2026-07-02 13:10:38 +08:00
  • 924903feb4 fix(go): require kafka write acknowledgements lingniu 2026-07-02 13:06:18 +08:00
  • ba5a28e636 fix(go): replay raw before unified events lingniu 2026-07-02 12:18:37 +08:00
  • 7a9a6f441a feat(go): persist full raw payload chunks lingniu 2026-07-02 12:11:24 +08:00
  • 3a67f6e05f feat: cache protocol realtime raw lingniu 2026-07-02 11:19:46 +08:00
  • e7d024405a fix: throttle jt808 registration touches lingniu 2026-07-02 10:24:44 +08:00
  • a66f765e16 chore: keep go branch go-only lingniu 2026-07-02 09:58:44 +08:00
  • cbb6f3b741 perf: skip raw freshness count scan main lingniu 2026-07-02 09:30:15 +08:00
  • 42de422935 test: check raw freshness without event date filter lingniu 2026-07-02 09:27:22 +08:00
  • 318486b1e9 fix: verify raw freshness by received time lingniu 2026-07-02 09:16:45 +08:00
  • 0a024f9a76 chore: wait for gateway spool before acceptance lingniu 2026-07-02 09:11:50 +08:00
  • ea9d9f5d35 chore: add go native ecs deploy script lingniu 2026-07-02 08:50:19 +08:00
  • 409f55b5ae test: verify go native release layout lingniu 2026-07-02 08:47:05 +08:00
  • 8def635bf5 test: verify realtime snapshots are fresh lingniu 2026-07-02 08:43:27 +08:00