Commit Graph

444 Commits

Author SHA1 Message Date
lingniu
266a74f225 docs: document go service observability endpoints 2026-07-02 19:12:17 +08:00
lingniu
896e841902 feat(go): expose runtime ingest metrics 2026-07-02 19:06:24 +08:00
lingniu
1dfd540700 feat(go): add platform principles and health probes 2026-07-02 18:53:02 +08:00
lingniu
0bfd1191cb feat: add realtime snapshot and location APIs 2026-07-02 18:41:23 +08:00
lingniu
44a6bee4ac refactor(go): trim realtime mysql business columns 2026-07-02 17:16:00 +08:00
lingniu
12c15896d0 refactor(go): key realtime mysql tables by vin 2026-07-02 16:47:29 +08:00
lingniu
5333ed34b7 refactor(go): keep realtime mysql tables core only 2026-07-02 16:42:40 +08:00
lingniu
75b36f4011 fix(go): backfill realtime plate from binding 2026-07-02 16:36:52 +08:00
lingniu
bc399d2819 feat(go): cache realtime locations in mysql 2026-07-02 16:31:58 +08:00
lingniu
d0289b1b48 fix(go): flatten jt808 additional fields 2026-07-02 16:23:03 +08:00
lingniu
5b2e1abcdd fix(go): skip empty frames in realtime snapshot 2026-07-02 16:11:58 +08:00
lingniu
dac6718ee4 feat(go): persist realtime snapshots to mysql 2026-07-02 16:06:29 +08:00
lingniu
f4335641db fix(go): merge realtime raw arrays by serial 2026-07-02 15:48:14 +08:00
lingniu
f3b4cbbbb2 docs: add go data flow diagram 2026-07-02 15:48:14 +08:00
lingniu
c27150cc15 feat(go): add nats kafka ingest bridge 2026-07-02 15:07:44 +08:00
lingniu
079bd76d38 chore(go): tune gateway async publish defaults 2026-07-02 14:22:11 +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
b27f909109 fix(go): normalize tdengine phone tags 2026-07-02 13:43:15 +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
640f70636d fix(go): protect kafka message processing during shutdown 2026-07-02 13:20:46 +08:00
lingniu
a80eb2eab4 fix(go): decouple mqtt message publishing from shutdown context 2026-07-02 13:14:15 +08:00
lingniu
d10d5d75c3 fix(go): decouple frame publishing from shutdown context 2026-07-02 13:10:38 +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
7a9a6f441a feat(go): persist full raw payload chunks 2026-07-02 12:11:24 +08:00
lingniu
3a67f6e05f feat: cache protocol realtime raw 2026-07-02 11:19:46 +08:00
lingniu
e7d024405a fix: throttle jt808 registration touches 2026-07-02 10:24:44 +08:00
lingniu
a66f765e16 chore: keep go branch go-only 2026-07-02 09:58:44 +08:00
lingniu
cbb6f3b741 perf: skip raw freshness count scan 2026-07-02 09:30:15 +08:00
lingniu
42de422935 test: check raw freshness without event date filter 2026-07-02 09:27:22 +08:00
lingniu
318486b1e9 fix: verify raw freshness by received time 2026-07-02 09:16:45 +08:00
lingniu
0a024f9a76 chore: wait for gateway spool before acceptance 2026-07-02 09:11:50 +08:00
lingniu
ea9d9f5d35 chore: add go native ecs deploy script 2026-07-02 08:50:19 +08:00
lingniu
409f55b5ae test: verify go native release layout 2026-07-02 08:47:05 +08:00
lingniu
8def635bf5 test: verify realtime snapshots are fresh 2026-07-02 08:43:27 +08:00
lingniu
c211447747 test: verify daily metric formulas 2026-07-02 08:38:32 +08:00
lingniu
1741aacaaa test: verify history rows link raw frames 2026-07-02 08:35:34 +08:00
lingniu
27f4ad3468 test: verify raw parsed json in production smoke 2026-07-02 02:00:50 +08:00
lingniu
601150b364 test: verify gateway spool is drained 2026-07-02 01:57:53 +08:00
lingniu
5b7f386c5a test: verify go services are enabled 2026-07-02 01:55:39 +08:00
lingniu
f4d9c9ef5a test: add go production acceptance smoke 2026-07-02 01:53:43 +08:00
lingniu
96514898eb test: add go systemd production smoke 2026-07-02 01:51:41 +08:00
lingniu
0ef88e1a4c test: add kafka production smoke 2026-07-02 01:49:02 +08:00
lingniu
0fd4d319f9 docs: record go kafka production topics 2026-07-02 01:44:27 +08:00
lingniu
4e8434c511 test: verify mqtt history tables in production smoke 2026-07-02 01:41:08 +08:00
lingniu
576644eb65 test: verify gb32960 history tables in production smoke 2026-07-02 01:39:45 +08:00
lingniu
9bd48c5781 test: require fresh raw data in production smoke 2026-07-02 01:38:16 +08:00