shishengliang

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 08:12:03 +00:00

5b2e1abcdd fix(go): skip empty frames in realtime snapshot

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 08:06:32 +00:00

dac6718ee4 feat(go): persist realtime snapshots to mysql

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 07:48:26 +00:00

f4335641db fix(go): merge realtime raw arrays by serial

f3b4cbbbb2 docs: add go data flow diagram

Compare 2 commits »

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 07:08:06 +00:00

c27150cc15 feat(go): add nats kafka ingest bridge

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 06:22:30 +00:00

079bd76d38 chore(go): tune gateway async publish defaults

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 06:11:57 +00:00

5145d156bc feat(go): decouple gateway publish with async sink

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 06:01:59 +00:00

5a958616a3 fix(go): batch durable kafka replay

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 05:48:03 +00:00

c939cc6b0c fix(go): stream durable spool batches

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 05:43:26 +00:00

b27f909109 fix(go): normalize tdengine phone tags

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 05:30:04 +00:00

75e7c3fbe5 fix(go): batch durable spool replay

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 05:25:27 +00:00

bc9025d566 fix(go): protect durable spool replay during shutdown

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 05:20:56 +00:00

640f70636d fix(go): protect kafka message processing during shutdown

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 05:14:27 +00:00

a80eb2eab4 fix(go): decouple mqtt message publishing from shutdown context

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 05:10:47 +00:00

d10d5d75c3 fix(go): decouple frame publishing from shutdown context

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 05:06:36 +00:00

924903feb4 fix(go): require kafka write acknowledgements

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 04:18:38 +00:00

ba5a28e636 fix(go): replay raw before unified events

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 04:12:15 +00:00

7a9a6f441a feat(go): persist full raw payload chunks

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 03:19:55 +00:00

3a67f6e05f feat: cache protocol realtime raw

shishengliang pushed to go at shishengliang/lingniu-vehicle-ingest

2026-07-02 02:24:56 +00:00

e7d024405a fix: throttle jt808 registration touches

shishengliang created branch go in shishengliang/lingniu-vehicle-ingest

2026-07-02 02:01:37 +00:00