Commit graph

31 commits

Author SHA1 Message Date
dapan1121
0e69cb3886 Merge remote-tracking branch 'origin/3.0' into feat/TS-6100-3.0 2025-06-27 14:53:03 +08:00
Minglei Jin
66c4ef3e90
feat(mqtt): mqtt subscription (#30127)
* feat(mqtt): Initial commit for mqtt

* chore(xnode/mnd): xnode message handlers for mnode

* chore(mnd/xnode): mnode part for xnode

* chore(xnode/translater): fix show commands

* fix(ast/creater): fix xnode create option

* fix(xnode/ci): fix ci & doc's error codes

* chore(xnode/sql): make create/drop/show work properly

* fix(xnode/sql): commit new files

* fix(xnode/sql): commit cmake files

* fix: fix testing cases

* fix(xnode/tsc): fix tokens

* fix(ast/anode): fix anode update decl.

* fix(xnode/error): fix xnode error codes

* fix: xnode make/destroy

* chore: xnode with option & dnode id

* chore: use taosmqtt for xnode

* chore: new error code for xnode launching

* chore(xnode): new error code

* chore: header for _xnode_mgmt_mqtt

* chore: source for _xnode_mgmt_mqtt

* chore: remove test directory from cmake

* chore: remove taosmqtt for ci to compile

* chore: remove taosudf header from xnode

* chore: new window macro

* chore: remove xnode mgmt mqtt for windows compilation

* Revert "chore: remove xnode mgmt mqtt for windows compilation"

This reverts commit 197e1640c7.

* chore: cleanup code

* chore: xnode mgmt comment windows part out

* chore: mgmt/mqtt, move uv head toppest

* xnode/mnode: create xnode once per dnode

* fix(xnode/systable/test): fix column count

* xnode/sdb: renumber sdb type for xnode to make start/stop order correct

* xnode/mqtt: new param mqttPort

* fix SXnode's struct type

* transfer dnode id to mqtt subscription

* tmqtt: remove uv_a linking

* tmqtt/tools: sources for tools

* tools: fix windows compilation

* tools/producer: fix windows sleep param

* tools/producer: fix uninited var rc

* make tools only for linux

* test/mnodes: wail 1 or 2 seconds for offline to be leader

* update topic producer tool for geometry data type testing

* format tool sql statements

* show xnodes' ep

* make shell auto complete xnodes

* use usleep instead of sleep

* mqtt/proto: first version mqtt protocol

* remove assert styles

* build with linux only

* fix libuv for taosmqtt building

* fix log printing

* mem: use ttq_ prefix instead of tmqtt

* xnode/parser/proto: protocol option for xnode

* xnode/translater/option: translate xnode option proto

* xnode/translator: translate proto param

* xnode/tmsg: encode/decode proto param

* xnode/mnode: proto parma for mndXnode

* xnode/proto: protocol param for xnode

* xnode/mqtt: save/load proto from xnode json

* rename tmqtt proto header

* rename head directories

* rename header name styles

* restyle func names

* update

* update

* use camel db

* use camel for cxt

* update count of information_schema

* fix exceptional cases

* fix w.r.t reviews

* fixes w.r.t reviews

* use ttq_free

* append xnode msgs

* update information schema count

* support tmq meta data sub

* success typo fix

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* fix error line var w.r.t. suggestions from copilot

* denote mqtt node with bnode instead of xnode

* smoke testing for mqtt

* soak testing

* new package for test framework: paho 2.1.0

* import mqtt into util

* fix soak testing

* test/soak: user 5 topics per client

* test/soak: cover qos

* update docker image references to tdengine-ci:0.1 in CI scripts and common.py

* refactor: rename bnode msg to backup node

* refactor: rename xnode to bnode 1

* refactor: rename xnode to bnode 2

* refactor: rename xnode to bnode 3

* refactor: rename xnode to bnode 4

* refactor: rename xnode to bnode 4

* refactor: rename xnode to bnode 5

* refactor: rename xnode to bnode 6

* refactor: rename some files 1

* refactor: rename some files 2

* refactor: rename some files 3

* refactor: rename some files 4

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
Co-authored-by: chenhaoran <haoran920c@163.com>
Co-authored-by: Simon Guan <guanshengliang@qq.com>
2025-06-25 14:58:51 +08:00
dapan1121
74fd91c52c enh: add snode process 2025-06-07 11:02:13 +08:00
dapan1121
66ab04dc49 enh: add stream and snode assignment 2025-05-17 10:55:32 +08:00
dapan1121
8ed0f7214e enh: add create snode processing 2025-05-13 14:37:07 +08:00
dapan1121
009e8aa41e Merge remote-tracking branch 'origin/3.0' into feat/TS-6100-3.0 2025-05-12 16:24:22 +08:00
dongming chen
7840f361dd
enh: update database fetch functions to include status in JSON output (#31005) 2025-05-09 15:58:31 +08:00
dapan1121
cc025dbd59 enh: add task plan update 2025-04-25 14:59:41 +08:00
dapan1121
330cf9982d fix: compile issues 2025-04-24 09:11:54 +08:00
Jing Sima
410324746b
feat:[TS-4897] virtual table (#30098)
* feat: [TS-4897] Support create/drop/alter/show/describe vtable

* feat: [TS-4897] Support vtable's query

* feat: [TS-4897] Support create virtual supertable

* feat: [TS-4897] Support explain analyze / where / count(*) and only select ts of vtable.

* feat: [TS-4897] Add create test and fix bugs

* feat: [TS-4897] Add alter/drop test and fix bugs

* feat: [TS-4897] Add describe/show test and fix bugs

* feat: [TS-4897] Add auth test and fix bugs

* feat: [TS-4897] Fix meta/catalog/cache bugs

* feat: [TS-4897] Support select tag from virtual child table

* feat: [TS-4897] Add select test and fix plenty of bugs

* feat: [TS-4897] Add optimize rule for vtable scan / support create vtable cross database / remove enterprise constraint / fix bugs.

* feat: [TS-4897] Fix 'schema is old'

* feat: [TS-4897] Support virtual stable query

* feat: [TS-4897] Add tests and Fix bugs

* feat: [TS-4897] resolve conflict.
2025-03-15 14:10:46 +08:00
factosea
fbe345a82e fix: cols funcs, sub query 2025-02-05 15:26:03 +08:00
dmchen
5934fe8857 fix/TD-31891-remove-void-mnode4 2024-09-20 06:17:33 +00:00
xsren
aea768d2c0 osFile 2024-09-10 17:40:19 +08:00
dmchen
0da625bf55 dmchen/delete-trans-tool 2024-09-03 02:21:31 +00:00
dmchen
b85dba328c fix/TD-30849 2024-08-15 03:55:20 +00:00
dmchen
6164e39433 fix/TD-30989 2024-07-29 11:38:04 +00:00
dmchen
929cb703e7 fix/TD-30989 2024-07-25 09:49:58 +00:00
dmchen
33ee871acf fix/TD-30989 2024-07-20 01:25:18 +00:00
kailixu
d64594932b feat: support database encryption 2024-03-27 20:03:38 +08:00
dmchen
262bb4cf12 fix/TD-28437 2024-01-24 02:30:03 +00:00
Yihao Deng
b5e5167b8f split sync/status channel 2024-01-10 09:57:08 +00:00
facetosea
845493294d osfile 2023-11-21 16:31:31 +08:00
wangmm0220
3f2d890560 feat:[TD-26056] add replay logic 2023-10-08 16:06:15 +08:00
Haojun Liao
2977a4d07f refactor: do some internal refactor. 2023-05-30 09:41:19 +08:00
wangmm0220
e17a105eff feat:[TD-23117] add schema for ins_topics 2023-05-12 18:14:43 +08:00
kailixu
ec8cd0c6b8 enh: support passwd version 2023-04-09 18:44:46 +08:00
Minglei Jin
0a782ef78c fix(mnd): coverity scan issues 2023-02-22 14:50:41 +08:00
Shengliang Guan
3a7d89a6bb refact: remove bnode codes 2022-10-18 17:34:58 +08:00
Hongze Cheng
6ed0634fb7 format more code 2022-10-13 11:56:16 +08:00
Shengliang Guan
a11b9dea8b enh: dump sdb info from mnode 2022-09-26 16:29:28 +08:00
Shengliang Guan
555a99bf90 enh: dump sdb info from mnode 2022-09-26 16:18:48 +08:00