f2d26f5e03
test(persistent_sessions): Remove bogus stopping of quicer
2021-10-21 15:23:21 +02:00
12639addb9
fix(persistent_session): Make sure the connection processs is dead
2021-10-21 15:23:21 +02:00
ed0f435546
chore(persistent_sessions): correct copyright information in new files
2021-10-21 15:23:21 +02:00
fdba441f4f
fix(persistent_sessions): revert bogus table type change
2021-10-21 15:23:21 +02:00
7808ffe600
fix(persistent_sessions): protect (un)subscribe from calling session router
2021-10-21 15:23:21 +02:00
7b394267dd
feat: persistent sessions stored in mnesia
...
* Persistent sessions can survive node/connection process down
* Internal SessionID is generated, external ClientID is as before
* Sessions are persisted to mnesia
* A session router is added in parallel to the ordinary router
* Messages that are subscribed to by a persistent session are
persisted by publisher
* Information about persisted and delivered messages are stored in
mnesia per session.
* A resume protocol similar to takeover is implemented for resuming
from mnesia
* Can be configured (and enabled) by the top lever config
"persistent_session_store"
2021-10-21 15:23:21 +02:00
fc7b4c0009
refactor: make it possible to use different tries
...
In preparation for persistent sessions
2021-10-21 15:23:21 +02:00
24e870672c
refactor: use set_session in preparation for persistent sessions
2021-10-21 15:23:21 +02:00
e37ecc10a6
style(behaviour attrs): unify behaviour declarations
2021-10-21 15:10:59 +03:00
d784e63b9f
emqx_conf ( #5939 )
...
* feat(emqx_conf): move conf manager for emqx_machine to emqx_conf
* chore(emqx_conf): change emqx:get_config/2 to emqx_conf:get/2
* fix: common test failed
* fix: badmatch by typo wrong key
* fix(emqx_conf): get the wrong core nodes
* fix(emqx_conf): get core node's tnx_id not latest tnx_id
* fix: add ro_transation when copy conf file
* fix: delete debug info
* fix: change ekka_rlog to mria_rlog
* fix: remove cluster_rpc from emqx_machine.
* fix: don't call ekka:start/0 explicitly
* fix: ekka should be start in emqx_machine
2021-10-21 18:08:51 +08:00
7fdcca587a
fix(authn): fix handling of pgsql response
2021-10-21 17:41:16 +08:00
e071a10fee
fix(authn): no longer use single quotes to wrap placeholders
2021-10-21 17:14:08 +08:00
3a834a822f
fix(authn): fix sql parse for mysql
2021-10-21 17:07:24 +08:00
9fdd5e6a7e
fix(emqx_machine): Fix start/stop callbacks ( #5969 )
...
* fix(emqx_machine): Fix start/stop callbacks
* chore(ekka): Bump version to 0.11.1
* fix(router): Wait for the tables
* fix(emqx_cluster_rpc): Stop cluster RPC when joining a cluster
* fix(emqx_app): Fix a deadlock when joining the cluster
* fix(emqx_telemetry): Wait for mnesia tables
* test(ct_helper): Start ekka before emqx
2021-10-21 14:49:21 +08:00
ed069cfecc
Merge pull request #5963 from zmstone/refactor-authn-schema
...
refactor(authn): check authenticator config with provider module
2021-10-21 08:07:48 +02:00
45b484a26a
Merge pull request #5967 from tigercl/fix/authn-mysql
...
fix(authn): fix placeholders are not replaced correctly
2021-10-21 10:20:05 +08:00
ef731c74eb
chore(deps): unify version of hocon
2021-10-21 09:35:00 +08:00
7b3537d822
Merge pull request #5966 from qzhuyan/dev/william/lc-0.1.2
...
feat(olp): bump to 0.1.2
2021-10-20 21:57:31 +02:00
ce5b456872
refactor(authn): make schema doc generation work
2021-10-20 17:42:06 +02:00
fa91e5f583
fix(authn): allow single authenticator instance from config
2021-10-20 15:06:08 +02:00
d468c21e61
fix(authn): rename config key http-server to http
2021-10-20 14:36:37 +02:00
019b9d17f6
refactor(emqx_config_handler): async remove
2021-10-20 14:12:46 +02:00
8e58699ff5
Merge pull request #5937 from k32/mria
...
feat(mria): Replace ekka_mnesia with mria
2021-10-20 13:15:23 +02:00
88d891a59a
feat: support check_config callback for authenticator provider
2021-10-20 13:04:55 +02:00
72c26931d7
fix: fill string fields' default value with binary
2021-10-20 11:52:30 +02:00
1b9c082563
refactor(authn): check authenticator config with provider module
...
mainly two changes:
1. the schema is simplified at root level, per-authenticator checks
are done after the type can be identified
2. the config handling part is split out from emqx_authentication
module to emqx_authentication_config module
2021-10-20 10:13:11 +02:00
e2f9b111b6
Merge pull request #5944 from Spycsh/slog
...
chore: change to structured logging under apps/emqx/authz and authn
2021-10-20 07:25:40 +02:00
9d4268e5e6
test(gw): ensure subscription established
2021-10-20 10:40:35 +08:00
7c04dbc585
test(gw): eliminate side effect between tests
2021-10-20 10:40:35 +08:00
69df027ee9
chore(gw): use SLOG to replace LOG
2021-10-20 10:40:35 +08:00
2416fa4e13
chore(gw): return 204 if no authn config
2021-10-20 10:40:35 +08:00
46e0609544
test(gw): add clients HTTP-API tests
2021-10-20 10:40:35 +08:00
6f0d0ab473
test(gw): eliminate side effect between tests
2021-10-20 10:40:35 +08:00
1cf833e1c0
test(gw): ensure emqx_authn starting state
2021-10-20 10:40:35 +08:00
7b211d35b8
test(gw): add basic tests for http-api
2021-10-20 10:40:35 +08:00
e56cbd8a30
chore(gw): refine test case
2021-10-20 10:40:35 +08:00
49adf2f7d2
chore(gw-lwm2m): set qmode to duration_s type
2021-10-20 10:40:35 +08:00
e4adc07add
chore(gw-exproto): refactor ssl options
2021-10-20 10:40:35 +08:00
ac42a91fc2
chore(gw-exproto): retry the closed grpc stream
2021-10-20 10:40:35 +08:00
fc2e358f01
chore(gw): add ssl feilds for exproto
2021-10-20 10:40:35 +08:00
b637764095
chore(gw): return unloaded status instead of 404
2021-10-20 10:40:35 +08:00
ec4198c91c
feat(gw-lw): return the special fields for lwm2m
2021-10-20 10:40:35 +08:00
92a5c333af
chore(gw-lwm2m): store lifetime in clientinfo
2021-10-20 10:40:35 +08:00
cfc905aa1a
fix(gw): insert channel info into ets table
2021-10-20 10:40:35 +08:00
4ae38b7c6a
fix(authn): fix placeholders are not replaced correctly
2021-10-20 10:14:47 +08:00
ac51ed81b7
chore: change to structured logging under apps/emqx/authz and authn
2021-10-20 10:00:13 +08:00
9c414096c7
test(authz): test HTTP apis for built-in-database
2021-10-20 09:17:21 +08:00
0fcb3a1e93
docs: add more schema docs for authz
2021-10-20 09:17:21 +08:00
0cf5aa5611
test: remove cuttlefish code
2021-10-20 09:17:21 +08:00
ae854db02d
test: fix match pattern of returned rules
2021-10-20 09:17:21 +08:00
891a185eda
test: enable emqx_authz_api_mnesia_SUITE tests
2021-10-20 09:17:21 +08:00
d3ddecb144
feat(olp): bump to 0.1.2
...
remove noop logging
2021-10-19 21:20:12 +02:00
2e01eeb6b4
fix(emqx_schema): typo in nullable prop
2021-10-19 15:42:34 +02:00
c780a1a53c
Merge pull request #5957 from qzhuyan/dev/william/quic-0.0.9
...
feat(quic): bump quicer 0.0.9
2021-10-19 14:52:08 +02:00
56d8e0f59f
feat(quic): bump quicer 0.0.9
2021-10-19 13:54:43 +02:00
b3a8753219
fix(mria): Replace mnesia calls with mria
2021-10-19 12:24:35 +02:00
d1b3377c52
fix(mongo): update the health check method
2021-10-19 15:52:36 +08:00
a8bb2a60b0
fix(gateway_api): client ip and port as two fields when clients query
2021-10-19 15:36:02 +08:00
6fb1d22e0c
fix(mgmt_api): client ip and port as two fields when clients query
2021-10-19 15:36:02 +08:00
bd53c488d1
Merge pull request #5950 from tigercl/fix/authn-version
...
fix(authn): fix the authentication instance cannot run after the update
2021-10-19 09:58:09 +08:00
31e2d9d2c0
fix(authn): fix the authentication instance cannot run after the update
2021-10-19 09:05:54 +08:00
0d2d5f6bf9
fix(emqx_alarm): Wait for tables
2021-10-18 22:40:18 +02:00
37a1c45af0
fix(dialyzer): Fix problems found by dialyzer
2021-10-18 22:04:05 +02:00
07ea6e5689
fix(mria): Fix startup sequence
2021-10-18 22:04:05 +02:00
fcdf10080d
chore(ct): ekka_mnesia -> mria_mnesia
2021-10-18 22:04:05 +02:00
73a4816d9c
fix(mria): Hook up mria to emqx_machine
2021-10-18 22:04:05 +02:00
7086135ec8
chore(mria): Remove the obsolete annotiation
2021-10-18 22:04:05 +02:00
d14b8e7da9
chore(mria): ekka_rlog -> mria_rlog
2021-10-18 22:04:05 +02:00
326923850c
chore(mria): Get rid of copy_mnesia callback
2021-10-18 22:04:05 +02:00
e14a62d4d6
chore(mria): ekka_mnesia:start/stop -> mria:start/stop
2021-10-18 22:04:05 +02:00
9965d6e028
chore(mria): ekka_mnesia:create_table -> mria:create_table
2021-10-18 22:04:05 +02:00
ae2056da1b
chore(mria): Fix clear_table and ro_transaction calls
2021-10-18 22:04:05 +02:00
ff48322e0c
chore(mria): ekka_mnesia:running_nodes -> mria:running_nodes
2021-10-18 22:04:05 +02:00
b515a45a4f
chore(mria): Rename module: ekka_mnesia -> mria
2021-10-18 22:04:05 +02:00
b1bf21c73b
fix(emqx schema): fix function clause by user_lookup_fun
2021-10-18 16:37:16 +08:00
c73205a589
Ct helpers migrate ( #5943 )
...
* chore: common test
* chore: delete emqx_ct_helpers deps
2021-10-18 13:45:52 +08:00
ad195d0eb0
chore(emqx_vm): delete unused function get_process_group_leader_info
2021-10-16 21:10:43 +02:00
71a11834ad
chore: pin rebar plugins and test deps
2021-10-15 16:46:49 +02:00
68d91e770b
test: remove ct_helpers from apps/emqx rebar.config
2021-10-15 16:11:48 +02:00
aa19c2a908
chore: Remove emqx_ct_helpers as dependency
2021-10-15 10:40:57 +02:00
30a0635ea5
fix: bump ekka to 10.0.9
...
fix ekka etcd cluster ssl options
2021-10-14 22:49:25 +02:00
c5b2bc86a2
chore(dashboard): enable by default ( #5926 )
2021-10-14 21:05:02 +08:00
40ab0064ae
fix(api): invalid params HTTP Code 400
2021-10-14 18:57:33 +08:00
cc36c7e48d
fix(mgmt_api): add page limit check.
2021-10-14 18:57:33 +08:00
dcca1d7544
Merge pull request #5867 from qzhuyan/dev/william/olp
...
feat(olp): first PR for overload protection
2021-10-14 10:00:01 +02:00
2e52ab9712
fix(rules): improve some code for emqx_rule_engine
2021-10-14 15:09:37 +08:00
dce57a3f92
fix(rules): add description to the config 'ignore_sys_message'
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2021-10-14 15:09:37 +08:00
0e7a3f89a9
feat(rules): support output functions in <<"Mod:Func">> format
2021-10-14 15:09:37 +08:00
9c7eef5295
feat(rules): update rule_engine configs from APIs
2021-10-14 15:09:37 +08:00
c3effca553
fix(rules): load rules from config file failed
2021-10-14 15:09:37 +08:00
467805855d
fix(rules): load rules from config file failed
2021-10-14 15:09:37 +08:00
c6c314de1a
fix(hocon): update hocon to 0.19.6
2021-10-14 15:09:37 +08:00
1ffae5d1b0
refactor(rule_engine): merge code for emqx_rule_registry and emqx_rule_engine
2021-10-14 15:09:37 +08:00
b063b6f253
feat(rules): support configure rules in config file
2021-10-14 15:09:37 +08:00
2de5e0157b
chore(doc): replace : by - in namespace ( #5920 )
2021-10-14 14:48:39 +08:00
8a2c5e2422
feat(rate_limiter): implement hierarchical token buckets
2021-10-14 10:20:05 +08:00
23fc8afc50
feat(olp): rename olp mgmt API
...
on -> enable
off -> disable
2021-10-13 10:18:57 +02:00
d80f20aca3
feat(swagger): define mgmt config_api by hocon schema ( #5814 )
...
* feat(swagger): define mgmt config_api by hocon schema
* fix: enum can't defined by integer, use union.
* fix: hocon schema union to enum
2021-10-13 14:04:43 +08:00
3df33da9ac
Merge pull request #5919 from tigercl/fix/scram-users
...
fix(authn): fix bad user_id for scram
2021-10-13 13:56:29 +08:00
ab060198a6
fix(authn): fix bad user_id for scram
2021-10-13 11:35:51 +08:00
Tobias Lindahl