summaryrefslogtreecommitdiff
path: root/plugins/server/plugin.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-01-23 23:46:09 +0300
committerValery Piashchynski <[email protected]>2021-01-23 23:46:09 +0300
commita0fd0c5f7c8c5e9a45e75e7751576aa107cbb3bb (patch)
tree6c7c2bd425c27891c7b8070711cb37a2c2a0e7ae /plugins/server/plugin.go
parent134277f8d60287c0907843788a654b4667e892ad (diff)
Fix golangci-lint warnings
Diffstat (limited to 'plugins/server/plugin.go')
-rw-r--r--plugins/server/plugin.go5
1 files changed, 2 insertions, 3 deletions
diff --git a/plugins/server/plugin.go b/plugins/server/plugin.go
index 16123786..9cdb8401 100644
--- a/plugins/server/plugin.go
+++ b/plugins/server/plugin.go
@@ -15,7 +15,6 @@ import (
// core imports
"github.com/spiral/roadrunner/v2/pkg/events"
"github.com/spiral/roadrunner/v2/pkg/pool"
- poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
"github.com/spiral/roadrunner/v2/pkg/transport/pipe"
"github.com/spiral/roadrunner/v2/pkg/transport/socket"
"github.com/spiral/roadrunner/v2/pkg/worker"
@@ -136,7 +135,7 @@ func (server *Plugin) NewWorker(ctx context.Context, env Env, listeners ...event
}
// NewWorkerPool issues new worker pool.
-func (server *Plugin) NewWorkerPool(ctx context.Context, opt poolImpl.Config, env Env, listeners ...events.Listener) (pool.Pool, error) {
+func (server *Plugin) NewWorkerPool(ctx context.Context, opt pool.Config, env Env, listeners ...events.Listener) (pool.Pool, error) {
const op = errors.Op("server_plugin_new_worker_pool")
spawnCmd, err := server.CmdFactory(env)
if err != nil {
@@ -149,7 +148,7 @@ func (server *Plugin) NewWorkerPool(ctx context.Context, opt poolImpl.Config, en
list = append(list, listeners...)
}
- p, err := poolImpl.Initialize(ctx, spawnCmd, server.factory, opt, poolImpl.AddListeners(list...))
+ p, err := pool.Initialize(ctx, spawnCmd, server.factory, opt, pool.AddListeners(list...))
if err != nil {
return nil, errors.E(op, err)
}