| .. |
|
emqx.app.src
|
eed03ee297
Add replayq in emqx.app.src
|
7 rokov pred |
|
emqx.erl
|
2a747c9d53
Improve the subscription sharding.
|
7 rokov pred |
|
emqx_access_control.erl
|
7d3357e0f3
Merge emqx32
|
7 rokov pred |
|
emqx_access_rule.erl
|
97474171d0
Better report errors in acl.conf (#2065)
|
7 rokov pred |
|
emqx_acl_cache.erl
|
567aeb274f
Define types in emqx_types, emqx_mqtt_types modules
|
7 rokov pred |
|
emqx_acl_internal.erl
|
97474171d0
Better report errors in acl.conf (#2065)
|
7 rokov pred |
|
emqx_acl_mod.erl
|
0e3728c940
Add emqx_types module and 'credentials' type
|
7 rokov pred |
|
emqx_alarm_mgr.erl
|
ea1ae70833
Fix errors found by dialyzer
|
7 rokov pred |
|
emqx_app.erl
|
6fa183f847
Add CLI for log level (#1977)
|
7 rokov pred |
|
emqx_auth_mod.erl
|
32d3826440
Replace macro QOS$i to QOS_$I
|
7 rokov pred |
|
emqx_banned.erl
|
666d9706a3
Fixed conflicts
|
7 rokov pred |
|
emqx_base62.erl
|
ec456dcc73
Fix dialyze issue
|
7 rokov pred |
|
emqx_batch.erl
|
21ed012a0c
Add an elegant batch module
|
7 rokov pred |
|
emqx_bridge.erl
|
6a1ebe299a
Merge emqx32 to emqx30 (#2112)
|
7 rokov pred |
|
emqx_bridge_sup.erl
|
8f35d13e17
Improve bridges design (#1849)
|
7 rokov pred |
|
emqx_broker.erl
|
7a1ec580b0
Update broker test cases
|
7 rokov pred |
|
emqx_broker_helper.erl
|
1e2c5db36c
Modify batch size
|
7 rokov pred |
|
emqx_broker_sup.erl
|
721b72b96a
Add 'active_n' option to optimize the CPU usage of emqx_connection (#2060)
|
7 rokov pred |
|
emqx_cli.erl
|
e949e8cbd8
Add format output for test print (#2076)
|
7 rokov pred |
|
emqx_client.erl
|
6a1ebe299a
Merge emqx32 to emqx30 (#2112)
|
7 rokov pred |
|
emqx_client_sock.erl
|
2dc8ec8b11
Bridge via TLS
|
7 rokov pred |
|
emqx_cm.erl
|
1e2c5db36c
Modify batch size
|
7 rokov pred |
|
emqx_cm_sup.erl
|
4f84a31d02
Update copyright (#2093)
|
7 rokov pred |
|
emqx_config.erl
|
16821490ce
Fix issue#1874 (#1964)
|
7 rokov pred |
|
emqx_connection.erl
|
10e5210581
Workaround ssl:setopts(SslSock, [{active, N}]) (#2095)
|
7 rokov pred |
|
emqx_ctl.erl
|
6b538d2363
Add test cases for 'emqx_cm' and 'emqx_sm' (#2073)
|
7 rokov pred |
|
emqx_flapping.erl
|
53a2f93b7e
Add emqx_connection:attrs/1, emqx_protocol:attrs/1, emqx_session:attrs/1 APIs
|
7 rokov pred |
|
emqx_frame.erl
|
a748e8f1d8
Refactor send_fun in protocol and other connection module
|
7 rokov pred |
|
emqx_gc.erl
|
367b717c40
Implement a new 'emqx_gc' module (#2090)
|
7 rokov pred |
|
emqx_gen_mod.erl
|
62aa072f2f
Upgrade for MQTT Version 5.0 and Erlang/OTP R21
|
7 rokov pred |
|
emqx_guid.erl
|
96d251ec3c
Add encode and decode options and test suites
|
7 rokov pred |
|
emqx_hooks.erl
|
fb7b63c59b
Merge branch 'emqx32' into subscription-sharding
|
7 rokov pred |
|
emqx_inflight.erl
|
064db65206
improve receive maximum in connect packet
|
7 rokov pred |
|
emqx_json.erl
|
62aa072f2f
Upgrade for MQTT Version 5.0 and Erlang/OTP R21
|
7 rokov pred |
|
emqx_keepalive.erl
|
8653732bae
Revert "Calculate the 1.5 keep alive time exactly"
|
7 rokov pred |
|
emqx_kernel_sup.erl
|
7d0cba9427
Add MQTT 5.0 supports for connection, protocol and session modules
|
7 rokov pred |
|
emqx_listeners.erl
|
2611b6fc2a
Revert logger print to io:format
|
7 rokov pred |
|
emqx_local_bridge.erl
|
bce1ddc5c4
Implement a hash-based subscription sharding
|
7 rokov pred |
|
emqx_local_bridge_sup.erl
|
d3ed0853ef
Rename bridge module
|
7 rokov pred |
|
emqx_local_bridge_sup_sup.erl
|
d3ed0853ef
Rename bridge module
|
7 rokov pred |
|
emqx_logger.erl
|
eeb0cab3e3
Update proc meta-data for empty clientid (#1980)
|
7 rokov pred |
|
emqx_logger_formatter.erl
|
92cc171aaf
Support tracing log files for specific topics or clients
|
7 rokov pred |
|
emqx_message.erl
|
edf0ded9f3
Fix bug that no update message expiry interval (#2101)
|
7 rokov pred |
|
emqx_metrics.erl
|
36e7d63d66
Implement subscription sharding.
|
7 rokov pred |
|
emqx_misc.erl
|
721b72b96a
Add 'active_n' option to optimize the CPU usage of emqx_connection (#2060)
|
7 rokov pred |
|
emqx_mod_presence.erl
|
2a75105580
Improve the Hooks's design
|
7 rokov pred |
|
emqx_mod_rewrite.erl
|
7544a21e25
Add test cases for emqx_bridge, emqx_mod_rewrite (#1914)
|
7 rokov pred |
|
emqx_mod_subscription.erl
|
8a8729f9ea
Make rebar3 xref work.
|
7 rokov pred |
|
emqx_mod_sup.erl
|
62aa072f2f
Upgrade for MQTT Version 5.0 and Erlang/OTP R21
|
7 rokov pred |
|
emqx_modules.erl
|
94dbdffd59
New logger formatter with meta-data
|
7 rokov pred |
|
emqx_mountpoint.erl
|
1cf4532947
Add emqx_mountpoint module
|
7 rokov pred |
|
emqx_mqtt_caps.erl
|
2d354ca883
Improve topic alias maximum in connect packet
|
7 rokov pred |
|
emqx_mqtt_props.erl
|
9d67a64165
Fix type validation for User-Property
|
7 rokov pred |
|
emqx_mqtt_types.erl
|
32d3826440
Replace macro QOS$i to QOS_$I
|
7 rokov pred |
|
emqx_mqueue.erl
|
4f84a31d02
Update copyright (#2093)
|
7 rokov pred |
|
emqx_packet.erl
|
a2c658ba19
Add acking mechamism for shared dispatch (#1872)
|
7 rokov pred |
|
emqx_pd.erl
|
14cffcf7fb
Add the 'emqx_pd' module
|
7 rokov pred |
|
emqx_plugins.erl
|
6a1ebe299a
Merge emqx32 to emqx30 (#2112)
|
7 rokov pred |
|
emqx_pmon.erl
|
721b72b96a
Add 'active_n' option to optimize the CPU usage of emqx_connection (#2060)
|
7 rokov pred |
|
emqx_pool.erl
|
d11e734dae
Make some processes hibernate after 1s.
|
7 rokov pred |
|
emqx_pool_sup.erl
|
721b72b96a
Add 'active_n' option to optimize the CPU usage of emqx_connection (#2060)
|
7 rokov pred |
|
emqx_pqueue.erl
|
4b8cd18f5d
Merge with EMQ X project
|
8 rokov pred |
|
emqx_protocol.erl
|
1797aadbe7
Fix unsuback compat (#2102)
|
7 rokov pred |
|
emqx_rate_limiter.erl
|
4f84a31d02
Update copyright (#2093)
|
7 rokov pred |
|
emqx_reason_codes.erl
|
1797aadbe7
Fix unsuback compat (#2102)
|
7 rokov pred |
|
emqx_router.erl
|
721b72b96a
Add 'active_n' option to optimize the CPU usage of emqx_connection (#2060)
|
7 rokov pred |
|
emqx_router_helper.erl
|
2a747c9d53
Improve the subscription sharding.
|
7 rokov pred |
|
emqx_router_sup.erl
|
721b72b96a
Add 'active_n' option to optimize the CPU usage of emqx_connection (#2060)
|
7 rokov pred |
|
emqx_rpc.erl
|
62aa072f2f
Upgrade for MQTT Version 5.0 and Erlang/OTP R21
|
7 rokov pred |
|
emqx_sequence.erl
|
2a747c9d53
Improve the subscription sharding.
|
7 rokov pred |
|
emqx_session.erl
|
f7596b8131
Fix session shutdown bug
|
7 rokov pred |
|
emqx_session_sup.erl
|
892d9439b9
Implement a new session supervisor. (#2077)
|
7 rokov pred |
|
emqx_shared_sub.erl
|
33830d8120
Improve the design of trie, router and broker modules
|
7 rokov pred |
|
emqx_sm.erl
|
892d9439b9
Implement a new session supervisor. (#2077)
|
7 rokov pred |
|
emqx_sm_locker.erl
|
8f2f4b6b81
Optimize connection and session management
|
7 rokov pred |
|
emqx_sm_registry.erl
|
721b72b96a
Add 'active_n' option to optimize the CPU usage of emqx_connection (#2060)
|
7 rokov pred |
|
emqx_sm_sup.erl
|
4f84a31d02
Update copyright (#2093)
|
7 rokov pred |
|
emqx_stats.erl
|
36e7d63d66
Implement subscription sharding.
|
7 rokov pred |
|
emqx_sup.erl
|
4aaf0a7db4
Remove emqx_session_sup to handle massive concurrent sessions
|
7 rokov pred |
|
emqx_sys.erl
|
1607e576de
Update connection, session, stats modules
|
7 rokov pred |
|
emqx_sys_mon.erl
|
94dbdffd59
New logger formatter with meta-data
|
7 rokov pred |
|
emqx_sys_sup.erl
|
4297033415
Fix undefined emqx_vm:schedulers/1
|
7 rokov pred |
|
emqx_tables.erl
|
2a747c9d53
Improve the subscription sharding.
|
7 rokov pred |
|
emqx_time.erl
|
ce3f2e4d9e
fix emqx_broker test suite
|
7 rokov pred |
|
emqx_topic.erl
|
4c40f75f4b
Request & Response (broker and client) (#1819)
|
7 rokov pred |
|
emqx_tracer.erl
|
2bd0f16884
Add CLI for log tracer (#1973)
|
7 rokov pred |
|
emqx_trie.erl
|
33830d8120
Improve the design of trie, router and broker modules
|
7 rokov pred |
|
emqx_types.erl
|
5e3aed0b73
Add ok_or_error/1 type
|
7 rokov pred |
|
emqx_vm.erl
|
6a1ebe299a
Merge emqx32 to emqx30 (#2112)
|
7 rokov pred |
|
emqx_ws_connection.erl
|
6f4d517350
Fix conflicts
|
7 rokov pred |
|
emqx_zone.erl
|
36e7d63d66
Implement subscription sharding.
|
7 rokov pred |
Gilbert Wong