Commit Graph
41 Commits
Author SHA1 Message Date
lingniu c3d67e4339 refactor: remove telemetry fields from tdengine history 2026-07-01 14:03:32 +08:00
lingniu a5cb0c9705 docs: clarify kafka-only sink semantics 2026-07-01 13:44:23 +08:00
lingniu 27f9cbf0d2 build: remove raw archive store prototype 2026-07-01 13:33:24 +08:00
lingniu 85013a0ebe build: remove unused testcontainers dependency 2026-07-01 13:18:07 +08:00
lingniu 7ce64e9963 refactor: remove legacy event file store 2026-07-01 11:04:11 +08:00
lingniu e80fa6f38c refactor: rename kafka sink module 2026-07-01 10:56:33 +08:00
lingniu 849e8f8a8b refactor: expose kafka sink configuration 2026-07-01 10:50:50 +08:00
lingniu 303b2eb47e refactor: enforce kafka mq sink type 2026-07-01 10:38:17 +08:00
lingniu 56a6c01f95 refactor: make event file store optional 2026-07-01 07:51:45 +08:00
lingniu e47e3eebb4 refactor: simplify history and mileage runtime 2026-07-01 07:18:06 +08:00
lingniu 6ccf8fdc26 fix: stop kafka consumers without concurrent close 2026-07-01 06:48:33 +08:00
lingniu b8ee90a996 docs: align history troubleshooting comments 2026-07-01 04:24:48 +08:00
lingniu 6ab2f25387 test: avoid real kafka clients in mq composition 2026-07-01 03:54:14 +08:00
lingniu 235cc46bf8 fix: use varchar for raw parsed json 2026-07-01 00:08:49 +08:00
lingniu cbba617801 feat: productionize raw history ingestion 2026-06-30 23:52:16 +08:00
lingniu e47e341034 feat: add optional parsed fields to raw frame query 2026-06-30 10:51:03 +08:00
lingniu 12ac1dab3b feat: add jt808 raw frame history query
ci/woodpecker/push/woodpecker Pipeline was canceled
2026-06-29 20:44:21 +08:00
lingniu 12de83e37f fix: harden jt808 tdengine ingestion
ci/woodpecker/push/woodpecker Pipeline was successful
2026-06-29 19:53:08 +08:00
lingniu 8804c01d99 fix: prevent tdengine raw frame overwrite
ci/woodpecker/push/woodpecker Pipeline was successful
2026-06-29 18:41:58 +08:00
lingniu 98b37e71e9 fix: keep jt808 raw history consumer current 2026-06-29 15:56:41 +08:00
lingniu 6646b9b1e1 fix: preserve jt808 location raw archive uri 2026-06-29 15:23:34 +08:00
lingniu b244984fcb fix: stabilize jt808 tdengine history writes 2026-06-29 15:17:31 +08:00
lingniu 00eee9a769 fix: start history kafka consumer after processor setup 2026-06-29 14:55:44 +08:00
lingniu 06423db8d4 fix: always register kafka consumer runner when enabled 2026-06-29 14:52:18 +08:00
lingniu 7abac30ea4 fix: drop history export and tolerate empty tdengine tables 2026-06-29 14:47:54 +08:00
lingniu 2273d72e95 fix: initialize tdengine schema before first write 2026-06-29 14:28:53 +08:00
lingniu 57ba7dca90 feat: configure tdengine history datasource 2026-06-29 14:21:56 +08:00
lingniu 90342fe5bf feat: query telemetry fields from tdengine 2026-06-29 13:55:25 +08:00
lingniu 3904dcf869 feat: persist telemetry fields to tdengine 2026-06-29 13:48:04 +08:00
lingniu 8466d622f6 feat: add tdengine history keyset queries 2026-06-29 13:38:39 +08:00
lingniu 4de723d0b4 feat: add tdengine jdbc history writer 2026-06-29 13:28:36 +08:00
lingniu f58fe51cf5 feat: add tdengine history store foundation 2026-06-29 13:25:31 +08:00
lingniu feb9552234 feat: persist raw frames and publish raw facts 2026-06-29 13:10:14 +08:00
lingniu 9c2779f82b feat: add fact payloads to kafka envelope 2026-06-29 12:58:27 +08:00
lingniu 0ec29a732c feat: add raw archive store contract 2026-06-29 12:56:50 +08:00
lingniu 6b82144f3c feat: ingest raw archive envelopes in history 2026-06-23 16:58:45 +08:00
lingniu 66807fdf3d feat: route gb32960 kafka topics 2026-06-23 16:50:07 +08:00
lingniu d7afb8e599 fix: harden local archive sink 2026-06-23 15:54:41 +08:00
lingniu 019512bac2 fix: restore sink archive implementation 2026-06-23 15:42:35 +08:00
kkfluous a096e4ce0e docs: add detailed 32960 pipeline comments 2026-06-23 13:17:37 +08:00
kkfluous ba68ffe061 feat: make gb32960 archive history query production ready 2026-06-23 11:55:44 +08:00