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

Commit Graph

  • 06866b0fa7 feat(go): expose gateway connection close metrics lingniu 2026-07-03 19:28:06 +08:00
  • d08bf17111 feat(go): expose fast writer nats consumer metrics lingniu 2026-07-03 19:24:02 +08:00
  • c43b87d648 feat(go): expose fast writer batch pending metrics lingniu 2026-07-03 19:20:09 +08:00
  • 3b694671fa feat(go): batch nats fast writer tdengine writes lingniu 2026-07-03 19:17:02 +08:00
  • 2db05d100d feat(go): expose fast writer stage latency histogram lingniu 2026-07-03 19:12:58 +08:00
  • 07d17e5adf feat(go): expose stat writer latency histogram lingniu 2026-07-03 19:08:49 +08:00
  • 3900144ea4 feat(go): expose realtime store latency histogram lingniu 2026-07-03 19:05:58 +08:00
  • afb301cb7a feat(go): expose async sink publish latency histogram lingniu 2026-07-03 19:02:24 +08:00
  • 018015f9de feat(go): expose bridge batch pressure metrics lingniu 2026-07-03 18:58:37 +08:00
  • 16ee09180c feat(go): expose gateway frame duration histogram lingniu 2026-07-03 18:54:00 +08:00
  • 71905aca3d feat(go): expose history batch pending metrics lingniu 2026-07-03 18:46:40 +08:00
  • 1cbe29c5fc feat(go): generate unique load simulator frames lingniu 2026-07-03 18:43:15 +08:00
  • 09f3e68891 feat(go): batch tdengine history writes lingniu 2026-07-03 18:37:38 +08:00
  • 3b0c5fbd5a ops: record gateway async sink metrics rollout lingniu 2026-07-03 18:30:50 +08:00
  • fb03c80a95 feat(go): expose gateway async sink metrics lingniu 2026-07-03 18:28:07 +08:00
  • f8fbeb8936 test(go): record 100k gateway connection baseline lingniu 2026-07-03 18:24:07 +08:00
  • 65232812a1 test(go): record 10k gateway connection baseline lingniu 2026-07-03 18:09:53 +08:00
  • 291bffa340 feat(go): add load simulator hold mode lingniu 2026-07-03 18:01:40 +08:00
  • c1fe1fbfb5 ops: record 100k hardening ecs rollout lingniu 2026-07-03 17:59:44 +08:00
  • 79e591f864 feat(go): add 100k ingest hardening baseline lingniu 2026-07-03 17:55:22 +08:00
  • 378a5d5e57 feat(go): reuse parsed fields across projections lingniu 2026-07-03 17:38:50 +08:00
  • 368b18fc96 feat(go): flatten mysql realtime snapshots lingniu 2026-07-03 16:00:40 +08:00
  • 2b5de65e31 feat(go): remove mysql realtime kv lingniu 2026-07-03 15:52:53 +08:00
  • f292d4c0d6 feat(go): make identity binding read only lingniu 2026-07-03 15:45:47 +08:00
  • 1d79dc25e0 feat(go): add oem to identity binding schema lingniu 2026-07-03 15:31:52 +08:00
  • 9994f2baf4 feat(go): improve realtime pipeline resilience lingniu 2026-07-03 15:20:22 +08:00
  • b8299faefa feat(go): add realtime pipeline observability lingniu 2026-07-03 15:06:27 +08:00
  • 28c81611a1 feat(go): add post raw frame query lingniu 2026-07-03 14:54:52 +08:00
  • c0d3b41550 feat(go): filter raw parsed fields lingniu 2026-07-03 14:49:53 +08:00
  • a0a4997e79 fix(go): avoid gb32960 decimal float tails lingniu 2026-07-03 14:47:11 +08:00
  • 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