diff options
author | Valery Piashchynski <[email protected]> | 2021-01-23 23:46:09 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-01-23 23:46:09 +0300 |
commit | a0fd0c5f7c8c5e9a45e75e7751576aa107cbb3bb (patch) | |
tree | 6c7c2bd425c27891c7b8070711cb37a2c2a0e7ae /plugins/server/plugin.go | |
parent | 134277f8d60287c0907843788a654b4667e892ad (diff) |
Fix golangci-lint warnings
Diffstat (limited to 'plugins/server/plugin.go')
-rw-r--r-- | plugins/server/plugin.go | 5 |
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) } |