Inicio Explorar Axuda
Iniciar sesión
kennyh
/
emqx4.3
1
0
Fork 0
Ficheiros Incidencias 0 Pull Requests 0 Wiki
Árbore: cabe2ae100
Ramas Etiquetas
emqx4.3
/
apps
/
emqx_eviction_agent
Ilya Averyanov 500d4fedda fix(rebalance): fix start order of rebalance applications hai 1 ano
..
etc ce3ec351c7 chore: remove unused conf comments %!s(int64=2) %!d(string=hai) anos
src 500d4fedda fix(rebalance): fix start order of rebalance applications hai 1 ano
test 46877e979b chore: update copyright-year hai 1 ano
BSL.txt 82403167c2 chore: update BSL license change date %!s(int64=2) %!d(string=hai) anos
README.md 8d83dc12e7 chore(rebalance): move apps from lib-ee, add READMEs %!s(int64=2) %!d(string=hai) anos
rebar.config 5e100f52b8 style: erlfmt all `rebar.config` files and `bin/nodetool` %!s(int64=2) %!d(string=hai) anos

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.