Proto commits in robustmq/robustmq

These commits are when the Protocol Buffers files have changed: (only the last 100 relevant commits are shown)

2025-11-06

refactor: Optimize the meta service and performance (#1563) * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * get_expire_session_list_test Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * ev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> --------- Signed-off-by: socutes <socutes@gmail.com> Co-authored-by: socutes <socutes@gmail.com>

The documentation is generated from this commit.

2025-11-05

refactor: Continue to optimize the storage adapter (#1562) * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> * dev Signed-off-by: socutes <socutes@gmail.com> --------- Signed-off-by: socutes <socutes@gmail.com> Co-authored-by: socutes <socutes@gmail.com>

2025-10-18

fix: Fix Proto3 syntax violations and type mismatches in mqtt.proto Signed-off-by: Tinuvile <3145593233@qq.com>

2025-10-16

refactor: Optimize the HTTP interfaces related to admin (#1473) * dev Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> * dev Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> * dev Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> * dev Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> * dev Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> --------- Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> Co-authored-by: wenqiang.xu <wenqiang.xu@okg.com>

2025-10-14

fix: Fix the bug caused by the topic ID (#1469) * dev Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> * dev Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> --------- Signed-off-by: wenqiang.xu <wenqiang.xu@okg.com> Co-authored-by: wenqiang.xu <wenqiang.xu@okg.com>

2025-03-25

refactor(protocol): split proto file to independent repo and remove t… (#989) * refactor(protocol): split proto file to independent repo and remove these files * chore: upgrade robustmq-proto-build

This commit does not contain any .proto files.

style: Organize gRPC interfaces (#965) * style: move placement center to other file * style: move placement center to other file * style: move borker grpc interface to other file * style: fix style * style: fix style error * style: fix style erros * style: set auto subscribe * bug: fix bug * style: style format --------- Co-authored-by: Yikrr8 <790556471@qq.com>

2025-03-24

feat: Journal server supports list_shard (#987)

2025-03-20

feat: MQTT Broker supports automatic subscription (#945) * feat: MQTT Broker supports automatic subscription

2025-03-19

test: mqtt broker Test Case optimization (#944) * test: mqtt broker Test Case optimization

2025-03-17

feat: Implement StorageAdapter for placement center (#932) * dev * ignore placement adapter unit tests

2025-03-11

release version

2025-03-09

feat: support quic server service (#896) * feat: support quic server service

2025-03-05

feat: Add Mqtt-broker schema Admin GRPC and CLI (#898) * Add Mqtt-broker schema Admin GRPC and CLI

2025-03-03

feat: MQTT Broker supports schema (#894) * feat: MQTT Broker supports schema

2025-02-24

feat: MQTT Connector data integration framework development (#876) * feat: MQTT Connector data integration framework development

2025-02-23

feat: subtask-create a quic server and quic client (#868) * feat: quic server demo * refactor: quic server * chore: merge cargo.lock * refactor: refactor a quic client by quinn * test: test a quic_client connect to a quic_server * refactor: server can use default config * test: add some test case to test quic server * style: fix style error * style: fix style * style: fix style * style: fix style error * style: fix error style * style: fix style erors * chore: delete demo code * style: delete unused import * test: fix test case error * update new pictures

2025-02-20

feat: MQTT Connector data integration framework development (#867) * feat: MQTT Connector data integration framework development

2025-02-19

feat: MQTT Connector data integration framework developmen (#864) * feat: MQTT Connector data integration framework developmen

2025-02-18

feat: MQTT Connector data integration framework development (#862) * feat: MQTT Connector data integration framework development

2025-02-10

feat: Optimizing the subscription process (#840) * feat: Optimizing the subscription process

2025-02-07

feat: Optimizing subscription logic (#832) * feat: Optimizing subscription logic

2025-01-28

feat: add connection_jitter (#797) * feat: add flappin-detect protocol * feat: add cli for enable flapping-detect * feat: finish check_connectin_jitter * chore: 1. change toolchain in stable version 2. refactor error * style: rename flapping-detect to connection-jitter * style: rename flapping detect to connection jitter * chore: 1. rename flapping-detect to connection-jitter 2. refactor validator * refactor: refactor cache manager user * style: fix spelling errors * feat: add check connection jitter to mqtt server * feat: finish remove connection_jitter_condition not within window_time * refactor: 1. merge connection_jitter 2. merge sub * test: add test method to connection_jitter * test: add test * test * chore: refactoor check_connection_jitter * build: change config for pre-commit * docs: add a tips for readme.md (#791) * docs: add a introduce for pre-commit * tests: add a new test for client connection counter * feat: ingrate metric to connection-jitter * style: fix clippy suggestions about code * feat: test connect_jitter * feat: connect black list, but it has a error for acl * style: fix style code * docs: add a fix about connection jitter logic * chore: 1. delete unuse file 2. fix erors name * style: fix code style * style: fix code style * style: fix code style errors * style: rename connection-jitter to flapping-detect to avoid confusion

2025-01-23

feat: add prost validations for grpc methods (#795)

2025-01-17

feat: Add ShardConfig function (#774) * feat: Add ShardConfig function

2024-12-29

feat: optimization the topic rewrite

feat: placement support topic rewrite rule operation

feat: add broker admin api for topic rewrite and support topic rewrite in broker handle

2024-12-25

test: Add the Journal Engine test case (#718) * test: Add the Journal Engine test case --------- Co-authored-by: loboxu <loboxu.1227@bytedance.com>

2024-12-21

feat: Journa engine code optimization (#714) feat: Journa engine code optimization --------- Co-authored-by: loboxu <loboxu.1227@bytedance.com>

2024-12-16

feat: support slow subscribe (#701) * support slow subscribe

feat: Journa Client code optimization (#704) * feat: Journa Client code optimization --------- Co-authored-by: loboxu <loboxu.1227@bytedance.com>

2024-12-10

feat: MQTT Broker supports exclusive subscriptions (#689) * RBIP-28:MQTT Broker supports exclusive subscriptions

2024-12-08

feat: support list slow subscription feat (#686)

feat: 622 mqtt command supports viewing a list of mqtt topics (No test yet!!) (#681) * Add ListTopic in cli-command * Add mockall dependency into the project. Refactor the cmd module --------- Co-authored-by: HonokaKousaka <lightofspeedwork@gmail.com>

feat: storage adapter function development (#678) * storage adapter function developmen --------- Co-authored-by: loboxu <loboxu.1227@bytedance.com>

2024-12-06

feat: support enable slow subscription (#675) * support enable slow subscription

2024-12-05

mqtt implements blacklist storage interface (#673)

2024-12-03

fix: Delete raft v1 related GRPC code (#668)

2024-11-28

feat: Journal Engine Client send data flow optimization (#653) * Journal Engine Client send data flow optimization --------- Co-authored-by: loboxu <wenqiang.yq@gmail.com>

feat: implements acl related funtions (#652) * implements acl related funtions --------- Signed-off-by: pikady <2652917633@qq.com>

2024-11-25

feat: Journal Engine Client initializes development (#646) * Journal Engine Client initializes development --------- Co-authored-by: loboxu <wenqiang.yq@gmail.com>

2024-11-24

feat: MQTT Command supports viewing connection information (#643) * MQTT Command supports viewing connection information

refactor: Partial code optimization (#644) * Partial code optimization --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com> Co-authored-by: loboxu <wenqiang.yq@gmail.com>

2024-11-23

refactor: Read data according to Offset/Timestamp/Tag/Key (#640) * Read data according to Offset/Timestamp/Tag/Key --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

2024-11-21

refactor: Optimize the MQTT Connection structure (#637) Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

2024-11-17

feat: Journal reading and writing process development (#626) * Journal reading and writing process development --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

2024-11-15

feat: Journal Engine State Machine Optimization (#619) * Journal Engine State Machine Optimization --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

2024-11-12

test: Split integration tests and unit tests (#616) test: Split integration tests and unit tests --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

feat: Segment state machine development (#615) * Segment state machine development --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

2024-11-10

feat: Improve the Segment data writing process (#606) * Improve the Segment data writing process --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

2024-11-09

feat: journal code logic optimization (#604) * journal code logic optimization --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

2024-11-05

feat: Journal Engine related logic development (#595) * Journal Engine Segment storage module development * journal engine logic development --------- Co-authored-by: Lobo Xu <loboxu.1227@bytedance.com>

2024-11-02

feat: Journal Client read and write data flow test cases (#587) * feat: Journal Client read and write data flow test cases

2024-11-01

feat: Journal Engine Segment storage module development (#585) * Journal Engine Segment storage module development

2024-10-29

feat: Journal Engine Segment file storage development (#582) * feat: Journal Engine Segment file storage development

2024-10-28

refactor: Improve the Journal Engine read and write related logic (#576) * Improve the Journal Engine read and write related logic

2024-10-26

refactor: MQTT Broker supports CreateUser, DeleteUser, ListUser GRPC Admin interfaces (#572) * MQTT Broker supports CreateUser, DeleteUser, ListUser GRPC Admin interfaces --------- Signed-off-by: chenfeilong <2652917633@qq.com> Signed-off-by: pikady <2652917633@qq.com>

refactor: Journal Engine component initialization development (#574) * Journal Engine TCP network layer and protocol layer development --------- Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

refactor: Journal Engine component initialization development (#573) * Journal Engine TCP interface logic function development --------- Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

2024-10-23

feat: Journal Engine TCP interface logic function development (#570) * Journal Engine TCP interface logic function development --------- Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

feat: Placement Center completes the Shard/Segment logic (#566) * Refine the Create Shard and Segment logic Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

2024-10-21

feat: Refine the Create Shard and Segment logic (#560) * Refine the Create Shard and Segment logic --------- Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

2024-10-19

refactor: Placement Center adds implementation of add_learner and change_membership GRPC (#552) Placement Center adds implementation of add_learner and change_membership GRPC --------- Signed-off-by: chenfeilong <2652917633@qq.com>

2024-10-18

feat: Create Shard, UpdateCahce part of the development (#549) Create Shard, UpdateCahce part of the development --------- Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

2024-10-16

feat: Journal Engine component initialization development (#531) Journal Engine component initialization development

fix: Fix code warnings and remove invalid code (#530) * fixed: Fix code warnings and remove invalid code --------- Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

feat: Rust protobuf compilation implementation changed to tonic::include_proto (#529) * Rust protobuf compilation implementation changed to tonic::include_proto --------- Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

2024-10-15

feat: Fixed cargo clippy warning messages (#525) Fixed cargo clippy warning messages

2024-10-13

feat: Journal Engine TCP network layer and protocol layer development (#514) * Journal Engine TCP network layer and protocol layer development * Adjust the naming and functionality of the clients module --------- Co-authored-by: loboxu.1227 <loboxu.1227@bytedance.com>

2024-10-12

RBIP-24: Journal Engine component initialization development

2024-10-08

close #491

2024-10-06

Merge pull request #481 from socutes/main refactor: Optimize the rocksdb code

update pc status

2024-10-05

Merge pull request #479 from ltaodream/main MINOR: Add comments to placement_center's common.proto

2024-10-04

Supports openraft engine

2024-10-03

Add comments to placement_center's common.proto

2024-09-29

raft cluster optimization

2024-09-24

feat: Placement center node receives a write request to be forwarded to the Leader node for processing

2024-09-20

mqtt broker dev

command cli

2024-09-19

cli command

2024-09-12

close #408

2024-09-05

close #385 rename ListUserRequest 'username' to 'user_name'

2024-09-03

mqtt broker dev

2024-09-02

mqtt broker dev

2024-09-01

mqtt broker dev

mqtt broker dev

2024-08-30

mqtt broker blacklist

2024-08-27

mqtt broker acl dev

2024-08-24

RBIP-10: MQTT Broker supports the ACL feature

2024-08-16

placement center dev

2024-08-13

acl dev

2024-07-06

mqtt broker dev

2024-07-02

MQTT dev

2024-06-28

mqtt broker dev

mqtt broker dev

2024-06-27

mqtt broker dev

mqtt broker dev

2024-06-25

mqtt broker dev