File tree
1,304 files changed
+1553
-1287
lines changed- base-cluster
- src
- main/java/com/baidu/bifromq/basecluster
- fd
- memberlist
- agent
- messenger
- transport
- util
- test
- java/com/baidu/bifromq/basecluster
- annotation
- fd
- memberlist
- agent
- messenger
- transport
- utils
- resources
- base-crdt
- base-crdt-service
- src
- main/java/com/baidu/bifromq/basecrdt/service
- test
- java/com/baidu/bifromq/basecrdt/service
- annotation
- resources
- base-crdt-store
- src
- main/java/com/baidu/bifromq/basecrdt
- core
- api
- exception
- internal
- util
- store
- compressor
- util
- test
- java/com/baidu/bifromq/basecrdt
- core
- benchmark
- internal
- util
- store
- annotation
- compressor
- resources
- base-env
- base-env-provider
- src
- main/java/com/baidu/bifromq/baseenv
- test
- java/com/baidu/bifromq/baseenv
- resources
- base-env-provider-spi
- src/main/java/com/baidu/bifromq/baseenv
- base-hlc
- src
- main/java/com/baidu/bifromq/basehlc
- test/java/com/baidu/bifromq/basehlc
- benchmark
- base-hookloader
- src
- main/java/com/baidu/bifromq/basehookloader
- test
- java/com/baidu/bifromq/basehookloader
- resources
- META-INF/services
- base-kv
- base-kv-local-engine
- src
- main/java/com/baidu/bifromq/basekv/localengine
- memory
- metrics
- rocksdb
- test
- java/com/baidu/bifromq/basekv/localengine
- benchmark
- memory
- metrics
- rocksdb
- resources
- base-kv-raft
- src
- main/java/com/baidu/bifromq/basekv/raft
- event
- exception
- test
- java/com/baidu/bifromq/basekv/raft
- event
- functest
- annotation
- template
- resources
- base-kv-raft-type
- base-kv-store-balance-controller
- src
- main/java/com/baidu/bifromq/basekv/balance
- impl
- option
- test
- java/com/baidu/bifromq/basekv/balance
- impl
- utils
- resources
- META-INF/services
- base-kv-store-balance-spi
- src/main/java/com/baidu/bifromq/basekv/balance
- command
- base-kv-store-client
- src
- main/java/com/baidu/bifromq/basekv/client
- scheduler
- test
- java/com/baidu/bifromq/basekv/client/scheduler
- resources
- base-kv-store-rpc-definition
- src
- main/java/com/baidu/bifromq/basekv
- exception
- store
- test/java/com/baidu/bifromq/basekv
- base-kv-store-server
- src
- main/java/com/baidu/bifromq/basekv
- server
- store
- api
- exception
- option
- range
- hinter
- stats
- util
- wal
- test
- java/com/baidu/bifromq/basekv
- annotation
- benchmark
- server
- store
- range
- hinter
- stats
- util
- wal
- resources
- base-kv-type-proto
- src
- main/java/com/baidu/bifromq/basekv/utils
- test/java/com/baidu/bifromq/basekv/utils
- base-logger
- src/main/java/com/baidu/bifromq/logger
- base-rpc
- src
- main/java
- com/baidu/bifromq/baserpc
- exception
- interceptor
- loadbalancer
- metrics
- nameresolver
- trafficgovernor
- utils
- io/grpc/netty
- test
- java/com/baidu/bifromq/baserpc
- benchmark
- trafficgovernor
- utils
- resources
- base-scheduler
- src
- main/java/com/baidu/bifromq/basescheduler
- exception
- test
- java/com/baidu/bifromq/basescheduler
- benchmark
- resources
- bifromq-apiserver
- src
- main/java/com/baidu/bifromq/apiserver
- http
- handler
- utils
- test
- java/com/baidu/bifromq/apiserver
- http
- handler
- resources
- bifromq-common-type
- src/main/java/com/baidu/bifromq/type
- bifromq-dist
- bifromq-dist-client
- src
- main/java/com/baidu/bifromq/dist/client
- scheduler
- test
- java/com/baidu/bifromq/dist/client
- resources
- bifromq-dist-coproc-proto
- src/main/java/com/baidu/bifromq/dist/util
- bifromq-dist-rpc-definition
- src
- main/java/com/baidu/bifromq/dist
- entity
- util
- test
- java/com/baidu/bifromq/dist
- entity
- util
- benchmark
- resources
- bifromq-dist-server
- src
- main/java/com/baidu/bifromq/dist/server
- scheduler
- test
- java/com/baidu/bifromq/dist/server
- resources
- bifromq-dist-spi
- src/main/java/com/baidu/bifromq/dist/server/scheduler
- bifromq-dist-worker
- src
- main
- java/com/baidu/bifromq/dist/worker
- balance
- hinter
- scheduler
- resources/META-INF/services
- test
- java/com/baidu/bifromq/dist/worker
- balance
- scheduler
- resources
- bifromq-inbox
- bifromq-inbox-client
- src
- main/java/com/baidu/bifromq/inbox/client
- test/java/com.baidu.bifromq.inbox.client
- bifromq-inbox-coproc-proto
- src/main/java/com/baidu/bifromq/inbox/util
- bifromq-inbox-gc
- src
- main/java/com/baidu/bifromq/inbox/store/gc
- test/java/com/baidu/bifromq/inbox/store/gc
- bifromq-inbox-rpc-definition
- src
- main/java/com/baidu/bifromq/inbox
- util
- test/java/com/baidu/bifromq/inbox/util
- bifromq-inbox-server
- src
- main/java/com/baidu/bifromq/inbox/server
- scheduler
- test
- java/com/baidu/bifromq/inbox/server
- resources
- bifromq-inbox-store
- src
- main
- java/com/baidu/bifromq/inbox/store
- balance
- resources/META-INF/services
- test
- java/com/baidu/bifromq/inbox/store
- balance
- resources
- bifromq-metrics
- src
- main/java/com/baidu/bifromq/metrics
- test
- java/com/baidu/bifromq/metrics
- benchmark
- resources
- bifromq-mqtt
- bifromq-mqtt-broker-client
- src/main/java/com/baidu/bifromq/mqtt/inbox
- bifromq-mqtt-broker-rpc-definition
- src/main/java/com/baidu/bifromq/mqtt/inbox
- util
- bifromq-mqtt-server
- src
- main/java/com/baidu/bifromq/mqtt
- handler
- event
- v3
- ws
- service
- session
- v3
- utils
- test
- java/com/baidu/bifromq/mqtt
- client
- handler
- v3
- utils
- resources
- bifromq-plugin
- bifromq-plugin-auth-provider
- src/main/java/com/baidu/bifromq/plugin/authprovider
- bifromq-plugin-auth-provider-helper
- src
- main/java/com/baidu/bifromq/plugin/authprovider
- test
- java/com/baidu/bifromq/plugin/authprovider
- resources
- bifromq-plugin-event-collector
- src/main/java/com/baidu/bifromq/plugin/eventcollector
- distservice
- inboxservice
- mqttbroker
- accessctrl
- channelclosed
- clientconnected
- clientdisconnect
- disthandling
- pushhandling
- retainhandling
- subhandling
- bifromq-plugin-event-collector-helper
- src
- main/java/com/baidu/bifromq/plugin/eventcollector
- test
- java/com/baidu/bifromq/plugin/eventcollector
- resources
- bifromq-plugin-manager
- src/main/java/com/baidu/bifromq/plugin/manager
- bifromq-plugin-setting-provider
- src
- main/java/com/baidu/bifromq/plugin/settingprovider
- test/java/com/baidu/bifromq/plugin/settingprovider
- bifromq-plugin-setting-provider-helper
- src
- main/java/com/baidu/bifromq/plugin/settingprovider
- test
- java/com/baidu/bifromq/plugin/settingprovider
- resources
- bifromq-plugin-sub-broker
- src/main/java/com/baidu/bifromq/plugin/subbroker
- bifromq-plugin-sub-broker-helper
- src
- main/java/com/baidu/bifromq/plugin/subbroker
- test/java/com/baidu/bifromq/plugin/subbroker
- bifromq-retain
- bifromq-retain-client
- src/main/java/com/baidu/bifromq/retain/client
- bifromq-retain-coproc-proto
- src/main/java/com/baidu/bifromq/retain/utils
- bifromq-retain-rpc-definition
- src
- main/java/com/baidu/bifromq/retain
- utils
- test/java/com/baidu/bifromq/retain/rpc/util
- bifromq-retain-server
- src
- main/java/com/baidu/bifromq/retain/server
- scheduler
- test/java/com/baidu/bifromq/retain/server
- bifromq-retain-store
- src
- main
- java/com/baidu/bifromq/retain/store
- balance
- resources/META-INF/services
- test
- java/com/baidu/bifromq/retain/store
- resources
- bifromq-session-dict
- bifromq-session-dict-client
- src
- main/java/com/baidu/bifromq/sessiondict/client
- test/java/com/baidu/bifromq/sessiondict/client
- bifromq-session-dict-rpc-definition
- src/main/java/com/baidu/bifromq/sessiondict
- bifromq-session-dict-server
- src
- main/java/com/baidu/bifromq/sessiondict/server
- test/java/com/baidu/bifromq/sessiondict/server
- bifromq-sysprops
- src
- main/java/com/baidu/bifromq/sysprops
- parser
- test
- java/com/baidu/bifromq/sysprops
- parser
- resources
- build
- build-bifromq-starters
- assembly
- bin
- conf
- src/main
- java/com/baidu/bifromq/starter
- config
- standalone
- model
- apiserver
- listener
- mqttserver
- listener
- utils
- resources
- test/resources
- build-plugin-demo
- src/main/java/com/baidu/demo/plugin
- coverage-report
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,304 files changed
+1553
-1287
lines changed+44
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 | 2 |
| |
3 |
| - | |
4 |
| - | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
5 | 6 |
| |
6 | 7 |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
|
0 commit comments