diff options
author | Valery Piashchynski <[email protected]> | 2021-09-11 01:04:05 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-09-11 01:04:05 +0300 |
commit | 0c4dd160a3eec4d76b9b82799c55eea4c5f50629 (patch) | |
tree | abc3eef044d6da54e1ba118637564e4d911e0fa6 /plugins/broadcast/plugin.go | |
parent | 6984e25ecdfc113400007c45fd69822f09b46ff0 (diff) |
Update .vscode settings
Update codecov
Update configs
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/broadcast/plugin.go')
-rw-r--r-- | plugins/broadcast/plugin.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/plugins/broadcast/plugin.go b/plugins/broadcast/plugin.go index 47b68fe7..40263eaa 100644 --- a/plugins/broadcast/plugin.go +++ b/plugins/broadcast/plugin.go @@ -53,7 +53,7 @@ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error { } func (p *Plugin) Serve() chan error { - return make(chan error) + return make(chan error, 1) } func (p *Plugin) Stop() error { @@ -158,7 +158,7 @@ func (p *Plugin) GetDriver(key string) (pubsub.SubReader, error) { p.publishers[configKey] = ps return ps, nil - default: + case p.cfgPlugin.Has(key): // try global driver section after local ps, err := p.constructors[drStr].PSConstruct(key) if err != nil { @@ -170,6 +170,8 @@ func (p *Plugin) GetDriver(key string) (pubsub.SubReader, error) { p.publishers[configKey] = ps return ps, nil + default: + p.log.Error("can't find local or global configuration, this section will be skipped", "local: ", configKey, "global: ", key) } } } |