Commit graph

17239 commits

Author SHA1 Message Date
WANG MINGMING
be7fffcde4
Merge branch 'feat/TS-6100-marks-new' into feat/TS-6100-3.0 2025-04-29 15:05:38 +07:00
wangmm0220
37a315fcc7 feat(stream): add thread worker for stream reader 2025-04-29 16:02:05 +08:00
dapan1121
2d499c9572 fix: stream queue issue 2025-04-29 15:32:56 +08:00
wangjiaming0909
1ccc6c69a8 new-stream: runner impl 2025-04-29 15:31:17 +08:00
Jing Sima
6ae805bb7a feat: [TS-6100] Process SCMCreateStreamReq ver-4
support placeHolderBitmap and interval offset in stream trigger.
remove useless code.
2025-04-29 15:19:30 +08:00
dapan1121
7f5cd8a70d fix: add stream id 2025-04-29 13:59:53 +08:00
dapan1121
b07fafa27f fix: stream hb rsp length issue 2025-04-29 11:02:56 +08:00
Jinqing Kuang
162d083951 fix(stream): fix compile issues 2025-04-29 09:23:09 +08:00
Jinqing Kuang
2a796e17ef feat(stream): implement stream trigger realtime calc 2025-04-29 09:23:05 +08:00
dapan1121
706d297232 fix: msg encode issues 2025-04-29 08:38:03 +08:00
dapan1121
ef1e51e9b9 enh: add stream obj name 2025-04-29 08:38:03 +08:00
dapan1121
87c8b3f8b7 fix: add stream phase 2025-04-29 08:38:03 +08:00
dapan1121
0c7504944f fix: add hb processing 2025-04-29 08:38:03 +08:00
wangmm0220
5d13d3a4ce feat(stream): add logic of stream reader 2025-04-28 19:26:02 +08:00
wangmm0220
c632dcf0c1 feat(stream): add logic of stream reader 2025-04-28 19:21:47 +08:00
wangmm0220
7158d4c76f Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-marks-new 2025-04-28 14:37:28 +08:00
wangmm0220
a78b09577a feat(stream): add thread worker for stream reader 2025-04-28 14:37:05 +08:00
Jing Sima
22ebaece7c feat: [TS-6100] Process SCMCreateStreamReq 2025-04-28 11:28:33 +08:00
dapan1121
992042cd00 fix: compile issues 2025-04-27 18:36:08 +08:00
dapan1121
3793eb2835 enh:add hb msg serilization 2025-04-27 17:53:12 +08:00
wangmm0220
2a1a6d0d95 feat(stream): add thread worker for stream reader 2025-04-27 09:11:50 +08:00
Jing Sima
e81a59b2e7 feat: [TS-6100] Fix compile error. 2025-04-27 09:08:26 +08:00
wangmm0220
11b625c63e feat(stream): add thread worker for stream reader 2025-04-25 18:47:25 +08:00
wangmm0220
eee6456cc4 feat(stream): add thread worker for stream reader 2025-04-25 18:18:17 +08:00
dapan1121
cc025dbd59 enh: add task plan update 2025-04-25 14:59:41 +08:00
wangmm0220
5ce115cc23 feat(stream): fix compile error 2025-04-24 18:02:12 +08:00
dapan1121
330cf9982d fix: compile issues 2025-04-24 09:11:54 +08:00
dapan1121
b8991295e1 Merge remote-tracking branch 'origin/feat/TS-6100-3.0' into feat/TS-6100-3.0.pw1 2025-04-22 17:49:01 +08:00
dapan1121
ae0e1ded7d enh: add hb processing 2025-04-22 17:46:17 +08:00
Jing Sima
c1cb4029a1 feat: [TS-6100] Build create request for create stream. 2025-04-21 17:47:15 +08:00
dapan1121
21e5aae05c enh: add stream hb processing 2025-04-19 18:58:51 +08:00
WANG MINGMING
c85b195421
Merge branch 'feat/TS-6100-marks' into feat/TS-6100-3.0 2025-04-19 16:18:09 +07:00
wangmm0220
80f368ba51 feat(stream): add stream reader logic 2025-04-19 17:10:43 +08:00
dapan1121
279595240e enh: add deploy processing 2025-04-18 19:28:43 +08:00
wangmm0220
919628568d feat(stream): add stream reader logic 2025-04-17 19:50:37 +08:00
dapan1121
7c714f7d5f Merge remote-tracking branch 'origin/feat/TS-6100-3.0.pw1' into feat/TS-6100-3.0 2025-04-17 10:48:44 +08:00
dapan1121
38bdafd329 enh: add deploy processing 2025-04-17 10:45:06 +08:00
wangjiaming0909
163dd33a0a new-stream: impl stream runner 2025-04-16 18:16:55 +08:00
wangjiaming0909
22b1eebb3a new-stream: define vnode build runner task 2025-04-16 18:16:55 +08:00
wangjiaming0909
ceaf69184c new-stream: create new-stream threads 2025-04-16 18:16:09 +08:00
dapan1121
b5b9ba0faa enh: add mnode processing 2025-04-14 13:20:57 +08:00
dapan1121
45d0af0a63 enh: add create stream 2025-04-10 19:41:37 +08:00
dapan1121
675790a63c fix: remove codes 2025-04-10 09:09:30 +08:00
Simon Guan
9a89db55ca
enh: allow ordinary users to execute the “show anodes” command. (#30464) 2025-03-25 20:17:16 +08:00
dongming chen
13475700c5
enh: [TD-34190] remove-wrong-log (#30408) 2025-03-25 12:37:20 +08:00
Haojun Liao
af06bea439
fix(stream): add start/stop message. (#30400) 2025-03-24 19:38:00 +08:00
Haojun Liao
cfcdfdd2e7
fix(stream): update the update node info. (#30364) 2025-03-24 10:18:06 +08:00
Haojun Liao
82ffeb82a9
fix(gpt): fix the bug for algo name case sensitive (#30362) 2025-03-23 13:20:24 +08:00
Simon Guan
24d4f37f83 Merge branch '3.0' into merge/mainto3.0 2025-03-22 23:41:39 +08:00
Simon Guan
c00f876638 Merge branch 'main' into merge/mainto3.0 2025-03-22 23:41:35 +08:00