diff options
author | Valery Piashchynski <[email protected]> | 2021-06-23 15:02:16 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-06-23 15:02:16 +0300 |
commit | 7fc09959619e9e400ecafcffcd63e38812f397a6 (patch) | |
tree | e6629f40cda53988facfb455ed460dbd05bbdc29 /plugins/server/plugin.go | |
parent | b0e7ac1aa40e9dbb688f88ac21b10a321a02c252 (diff) |
- Swithc from value to pointer to the pool configuration. Interface
value changed.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/server/plugin.go')
-rw-r--r-- | plugins/server/plugin.go | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/plugins/server/plugin.go b/plugins/server/plugin.go index e2fa0086..42273ed7 100644 --- a/plugins/server/plugin.go +++ b/plugins/server/plugin.go @@ -21,14 +21,14 @@ import ( "github.com/spiral/roadrunner/v2/utils" ) -// PluginName for the server -const PluginName = "server" - -// RrRelay env variable key (internal) -const RrRelay = "RR_RELAY" - -// RrRPC env variable key (internal) if the RPC presents -const RrRPC = "RR_RPC" +const ( + // PluginName for the server + PluginName = "server" + // RrRelay env variable key (internal) + RrRelay = "RR_RELAY" + // RrRPC env variable key (internal) if the RPC presents + RrRPC = "RR_RPC" +) // Plugin manages worker type Plugin struct { @@ -140,8 +140,9 @@ func (server *Plugin) NewWorker(ctx context.Context, env Env, listeners ...event } // NewWorkerPool issues new worker pool. -func (server *Plugin) NewWorkerPool(ctx context.Context, opt pool.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 { return nil, errors.E(op, err) |