From 3212a5b59b6dcd8aa6edac137e945d42f6f9e0ce Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Wed, 25 Aug 2021 18:03:30 +0300 Subject: BoltDB local queue initial commit Signed-off-by: Valery Piashchynski --- plugins/kv/plugin.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'plugins/kv/plugin.go') diff --git a/plugins/kv/plugin.go b/plugins/kv/plugin.go index 53fade97..9a19f96c 100644 --- a/plugins/kv/plugin.go +++ b/plugins/kv/plugin.go @@ -109,6 +109,7 @@ func (p *Plugin) Serve() chan error { //nolint:gocognit // config key for the particular sub-driver kv.memcached configKey := fmt.Sprintf("%s.%s", PluginName, k) // at this point we know, that driver field present in the configuration + // TODO(rustatian): refactor, made generic, with checks like in the broadcast, websockets or jobs switch v.(map[string]interface{})[driver] { case memcached: if _, ok := p.constructors[memcached]; !ok { @@ -220,5 +221,4 @@ func (p *Plugin) Name() string { } // Available interface implementation -func (p *Plugin) Available() { -} +func (p *Plugin) Available() {} -- cgit v1.2.3