(sym plugin.Symbol, path string, args []string)
| 290 | } |
| 291 | |
| 292 | func initPredicatePlugin(sym plugin.Symbol, path string, args []string) (routing.PredicateSpec, error) { |
| 293 | fn, ok := sym.(func([]string) (routing.PredicateSpec, error)) |
| 294 | if !ok { |
| 295 | return nil, fmt.Errorf("plugin %s's InitPredicate function has wrong signature", path) |
| 296 | } |
| 297 | spec, err := fn(args) |
| 298 | if err != nil { |
| 299 | return nil, fmt.Errorf("plugin %s returned: %s", path, err) |
| 300 | } |
| 301 | return spec, nil |
| 302 | } |
| 303 | |
| 304 | func (o *Options) loadDataClientPlugins(found map[string]string, done map[string][]string) error { |
| 305 | for _, pred := range o.DataClientPlugins { |
no test coverage detected
searching dependent graphs…