插件体系
Firefly 插件用于承载可选能力,例如指标、告警、审计扩展和未来协议。插件通过 plugins/plugin-api 定义生命周期,具体能力放在独立模块中。
Plugin API
java
public interface FireflyPlugin extends AutoCloseable {
String id();
default FireflyPluginCompatibility compatibility() {
return FireflyPluginCompatibility.current();
}
void start(FireflyPluginContext context);
}compatibility() 声明插件支持的宿主 Plugin API level 范围。当前 API level 为 1,旧 1.x 插件通过默认方法继续声明 level 1,无需仅因 Firefly 升级到 1.0.2 而重新编译。
java
@Override
public FireflyPluginCompatibility compatibility() {
return new FireflyPluginCompatibility(1, 2);
}宿主会先校验所有已启用插件,再启动其中任何一个。不支持当前 level、返回非法范围或重复 ID 都会阻止节点启动,避免插件集合只启动一半。产品版本和 Plugin API level 是独立概念;只有 SPI 契约发生破坏性变化时才提升 API level。
插件通过 FireflyPluginContext 获取可选运行时能力:
java
FireflyPluginContext context = FireflyPluginContext.builder()
.jobRepository(jobRepository)
.nodeRegistry(nodeRegistry)
.executorRegistry(executorRegistry)
.build();启用插件
properties
firefly.plugins=metrics-prometheus,acme-alerts外部插件实现 FireflyPlugin 后,通过 JDK SPI 描述文件暴露:
text
META-INF/services/com.firefly.plugin.FireflyPlugin已有能力
| 插件或能力 | 模块 | 说明 |
|---|---|---|
| Admin HTTP API | apis/admin-http | API 节点内置 JSON 管理 API |
| Prometheus Metrics | plugins/metrics-prometheus | /metrics 文本指标 |
| Plugin API | plugins/plugin-api | 插件生命周期、配置读取和状态描述 |
Netty 是默认 Executor transport,不作为普通功能插件启用。