// Copyright 2021 EMQ Technologies Co., Ltd. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package plugin type PluginType int const ( SOURCE PluginType = iota SINK FUNCTION PORTABLE WASM ) var PluginTypes = []string{"sources", "sinks", "functions"} type Plugin interface { GetName() string GetFile() string GetShellParas() []string GetSymbols() []string SetName(n string) } // IOPlugin Unify model. Flat all properties for each kind. type IOPlugin struct { Name string `json:"name"` File string `json:"file"` ShellParas []string `json:"shellParas"` } func (p *IOPlugin) GetName() string { return p.Name } func (p *IOPlugin) GetFile() string { return p.File } func (p *IOPlugin) GetShellParas() []string { return p.ShellParas } func (p *IOPlugin) GetSymbols() []string { return nil } func (p *IOPlugin) SetName(n string) { p.Name = n } func NewPluginByType(t PluginType) Plugin { switch t { case FUNCTION: return &FuncPlugin{} default: return &IOPlugin{} } } type FuncPlugin struct { IOPlugin // Optional, if not specified, a default element with the same name of the file will be registered Functions []string `json:"functions"` } func (fp *FuncPlugin) GetSymbols() []string { return fp.Functions }