Function Load

internal/dfplugin/dfplugin.go:53–88

(dir string, typ PluginType, name string, option map[string]string)

type PluginInitFunc func(option map[string]string) (plugin any, meta map[string]string, err error)

func Load(dir string, typ PluginType, name string, option map[string]string) (any, map[string]string, error) {
	soName := fmt.Sprintf(PluginFormat, string(typ), name)
	p, err := plugin.Open(path.Join(dir, soName))
	if err != nil {
		return nil, nil, err
	}

	symbol, err := p.Lookup(PluginInitFuncName)
	if err != nil {
		return nil, nil, err
	}

	// FIXME when use symbol.(PluginInitFunc), ok is always false
	f, ok := symbol.(func(option map[string]string) (plugin any, meta map[string]string, err error))
	if !ok {
		return nil, nil, errors.New("invalid plugin init function signature")
	}

	i, meta, err := f(option)
	if err != nil {
		return nil, nil, err
	}

	if meta == nil {
		return nil, nil, errors.New("empty plugin metadata")
	}

	if meta[PluginMetaKeyType] != string(typ) {
		return nil, nil, errors.New("plugin type not match")
	}

	if meta[PluginMetaKeyName] != name {
		return nil, nil, errors.New("plugin name not match")
	}
	return i, meta, nil
}