go - KrakenD 插件读取配置设置

标签 go plugins krakend

我用 GO 语言为 KrakenD Gateway 编写了一个简单的服务器插件。它在路由开始之前注入(inject)代码。
我正在尝试从我的 krakend.json 中读取配置设置在启动时将设置传递给我的插件。下面我使用了设置mysetting举个例子(请看注释之间的代码 HERE THE READ OF MY SETTING STARTS/ENDS )。
如何使用 mysetting 的值从插件内部的配置?
这是我的krakend.json配置文件用作 -c启动参数:

{
  "version": 2,
  "timeout": "3000ms",
  "cache_ttl": "300s",
  "output_encoding": "json",
  "name": "Gateway",
  "plugin": {
    "pattern": ".so",
    "folder": "./plugins/"
  },
  "extra_config": {
    "github_com/devopsfaith/krakend/transport/http/server/handler": {
      "name": "testPlugin",
      "mysetting": "Hello"
    }
  },
  "endpoints": [
    ...
  ],
  "port": 9010,
}
这是 registerHandlers 函数的代码:
func (r registerer) registerHandlers(ctx context.Context, extra map[string]interface{}, _ http.Handler) (http.Handler, error) {
    
        // check the passed configuration and initialize the plugin
        name, ok := extra["name"].(string)
        
        if !ok {
            return nil, errors.New("wrong config")
        }
        
        if name != string(r) {
            return nil, fmt.Errorf("unknown register %s", name)
        }

        //************ HERE THE READ OF MY SETTING STARTS ************
        
        setting, ok := extra["mysetting"].(string)

        if !ok {
            return nil, errors.New("mysetting missing in config")
        }

        fmt.Printf("PLUGIN: My custom setting: %s\n", setting)
        
        //************ HERE THE READ OF MY SETTING ENDS ************
        
        // return the actual handler wrapping or your custom logic so it can be used as a replacement for the default http handler
        return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
            fmt.Fprintf(w, "%s, %q", setting, html.EscapeString(req.URL.Path))
        }), nil
}

最佳答案

我自己想通了。在为问题构建示例代码时,我注意到它的工作方式与问题中的编码方式完全相同。

关于go - KrakenD 插件读取配置设置,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63826263/

相关文章:

去检查字符串是否在字符串 slice 中

node.js - 允许在Node.js应用程序/Electronic中使用插件

http-redirect - 如何配置 Krakend 使其按原样返回 http 重定向响应而不是遵循 http 重定向?

azure - 如何在Azure Web App中为容器挂载docker卷?

Android Plugin 将特定代码添加到源代码的某些方法中

go - 检查值是否为 int

go - 如何顺序运行处理程序函数

go - 在处理程序 slice 中注册 http URL 处理程序

python - 如何访问 CKAN 扩展中的 session 对象?