Function innerNewClient

internal/cnpi/plugin/client/create.go:38–57

(ctx context.Context, enabledPlugin *stringset.Data)

}

func innerNewClient(ctx context.Context, enabledPlugin *stringset.Data) (Client, error) {
	contextLogger := log.FromContext(ctx)
	plugins := repository.New()

	// TODO: make che socketDir a parameter
	availablePluginNames, err := plugins.RegisterUnixSocketPluginsInPath(configuration.Current.PluginSocketDir)
	if err != nil {
		contextLogger.Error(err, "Error while loading local plugins")
		plugins.Close()
		return nil, err
	}

	availablePluginNamesSet := stringset.From(availablePluginNames)
	availableAndEnabled := stringset.From(availablePluginNamesSet.Intersect(enabledPlugin).ToList())
	return WithPlugins(
		ctx,
		plugins,
		availableAndEnabled.ToList()...,
	)
}