History

Thales Macedo Garitezi d0e6f22a79 feat: support purging durable sessions during cluster purge Fixes https://emqx.atlassian.net/browse/EMQX-12405		2024-06-12 11:19:53 -03:00
..
etc	chore: remove unused conf comments	2023-05-22 14:01:49 +08:00
src	feat: support purging durable sessions during cluster purge	2024-06-12 11:19:53 -03:00
test	chore: update copyright-year	2024-02-23 08:21:06 +01:00
BSL.txt	chore: update BSL license change date	2024-01-29 16:47:31 +01:00
README.md	chore(rebalance): move apps from lib-ee, add READMEs	2023-05-09 20:51:24 +05:00
rebar.config	style: erlfmt all `rebar.config` files and `bin/nodetool`	2023-12-29 09:08:03 +08:00

README.md

EMQX Eviction Agent

emqx_eviction_agent is a part of the node evacuation/node rebalance feature in EMQX. It is a low-level application that encapsulates working with actual MQTT connections.

Application Responsibilities

emqx_eviction_agent application:

Blocks incoming connection to the node it is running on.
Serves as a facade for connection/session eviction operations.
Reports blocking status via HTTP API.

The emqx_eviction_agent is relatively passive and has no eviction/rebalancing logic. It allows emqx_node_rebalance to perform eviction/rebalancing operations using high-level API, without having to deal with MQTT connections directly.

EMQX Integration

emqx_eviction_agent interacts with the following EMQX components:

emqx_cm - to get the list of active MQTT connections;
emqx_hooks subsystem - to block/unblock incoming connections;
emqx_channel and the corresponding connection modules to perform the eviction.

User Facing API

The application provided a very simple API (CLI and HTTP) to inspect the current blocking status.

Documentation

The rebalancing concept is described in the corresponding EIP.

Contributing

Please see our contributing.md.