https://github.com/childe/gohangout 插件示例.

把一条消息 Split 成多条. 解决 childe/gohangout#96

Golang 的 Plugin 文档参考 https://tip.golang.org/pkg/plugin/

编译

将 split.go 复制到 gohangout 主目录下面, 运行

go build -buildmode=plugin -o split.so split.go

gohangout 配置示例

inputs:
    - Stdin: {}

filters:
    - 'path/to/split.so':
        field: message
        sep: '#'
        drop_original_event: false
        deep_copy: true

outputs:
    - Stdout: {}

代码说明

New

一定要有 New 函数, 定义如下: New(config map[interface{}]interface{}) interface{}

在 Gohangout 里面会调用 plugin 的 New 方法来生成一个 Filter 实例.

Filter

Filter 定义如下 Filter(event map[string]interface{}) (map[string]interface{}, bool) , 实现 Gohangout 里面的 Filter 接口