Skip to content
This repository has been archived by the owner on Nov 8, 2022. It is now read-only.

Commit

Permalink
Refactor code to use key function
Browse files Browse the repository at this point in the history
  • Loading branch information
geauxvirtual committed Sep 28, 2016
1 parent e3ce8f9 commit fea7d5e
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions control/subscription_group.go
Original file line number Diff line number Diff line change
Expand Up @@ -245,7 +245,7 @@ func (p *subscriptionGroups) validatePluginSubscription(pl core.SubscribedPlugin
"_block": "validate-plugin-subscription",
"plugin": fmt.Sprintf("%s:%d", pl.Name(), pl.Version()),
}).Info(fmt.Sprintf("validating dependencies for plugin %s:%d", pl.Name(), pl.Version()))
lp, err := p.pluginManager.get(fmt.Sprintf("%s"+core.Separator+"%s"+core.Separator+"%d", pl.TypeName(), pl.Name(), pl.Version()))
lp, err := p.pluginManager.get(key(pl))
if err != nil {
serrs = append(serrs, pluginNotFoundError(pl))
return serrs
Expand Down Expand Up @@ -429,9 +429,7 @@ func (p *subscriptionGroup) unsubscribePlugins(id string,
"version": plugin.Version(),
"_block": "subscriptionGroup.unsubscribePlugins",
}).Debug("plugin unsubscription")
pool, err := p.pluginRunner.AvailablePlugins().getPool(
fmt.Sprintf("%s"+core.Separator+"%s"+core.Separator+"%d", plugin.TypeName(),
plugin.Name(), plugin.Version()))
pool, err := p.pluginRunner.AvailablePlugins().getPool(key(plugin))
if err != nil {
serrs = append(serrs, err)
return serrs
Expand Down

0 comments on commit fea7d5e

Please sign in to comment.