1 Star 0 Fork 0

sqos/beats

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
plugin.go 933 Bytes
一键复制 编辑 原始数据 按行查看 历史
package plugin
import "fmt"
type PluginLoader func(p interface{}) error
var registry = map[string]PluginLoader{}
func Bundle(
bundles ...map[string][]interface{},
) map[string][]interface{} {
ret := map[string][]interface{}{}
for _, bundle := range bundles {
for name, plugins := range bundle {
ret[name] = append(ret[name], plugins...)
}
}
return ret
}
func MakePlugin(key string, ifc interface{}) map[string][]interface{} {
return map[string][]interface{}{
key: {ifc},
}
}
func MustRegisterLoader(name string, l PluginLoader) {
err := RegisterLoader(name, l)
if err != nil {
panic(err)
}
}
func RegisterLoader(name string, l PluginLoader) error {
if l := registry[name]; l != nil {
return fmt.Errorf("plugin loader '%v' already registered", name)
}
registry[name] = l
return nil
}
func LoadPlugins(path string) error {
// TODO: add flag to enable/disable plugins?
return loadPlugins(path)
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/sqos/beats.git
git@gitee.com:sqos/beats.git
sqos
beats
beats
v6.1.3

搜索帮助

0d507c66 1850385 C8b1a773 1850385