diff options
author | Valery Piashchynski <[email protected]> | 2021-04-20 10:06:45 +0300 |
---|---|---|
committer | GitHub <[email protected]> | 2021-04-20 10:06:45 +0300 |
commit | 3362f211f6358d60bea47ac2de4cc29a47373973 (patch) | |
tree | d36dc3ce9a36fff1b15b8795e8fa08d397317d14 /plugins/informer/plugin.go | |
parent | 35d6a50aa3640c870b99c120b26c9b9012b424be (diff) | |
parent | 779cc3f5aebb749ab4bc6190e03cc86ff3f151a0 (diff) |
#634 feat(plugin): new plugin `service`v2.1.0-beta.2
feat(plugin): new plugin `service`
Diffstat (limited to 'plugins/informer/plugin.go')
-rw-r--r-- | plugins/informer/plugin.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/plugins/informer/plugin.go b/plugins/informer/plugin.go index 416c0112..98081d34 100644 --- a/plugins/informer/plugin.go +++ b/plugins/informer/plugin.go @@ -3,7 +3,7 @@ package informer import ( endure "github.com/spiral/endure/pkg/container" "github.com/spiral/errors" - "github.com/spiral/roadrunner/v2/pkg/worker" + "github.com/spiral/roadrunner/v2/pkg/process" "github.com/spiral/roadrunner/v2/plugins/logger" ) @@ -21,7 +21,7 @@ func (p *Plugin) Init(log logger.Logger) error { } // Workers provides BaseProcess slice with workers for the requested plugin -func (p *Plugin) Workers(name string) ([]worker.BaseProcess, error) { +func (p *Plugin) Workers(name string) ([]process.State, error) { const op = errors.Op("informer_plugin_workers") svc, ok := p.registry[name] if !ok { @@ -49,7 +49,7 @@ func (p *Plugin) Name() string { return PluginName } -// RPCService returns associated rpc service. +// RPC returns associated rpc service. func (p *Plugin) RPC() interface{} { return &rpc{srv: p, log: p.log} } |