diff options
Diffstat (limited to 'plugins/server')
| -rw-r--r-- | plugins/server/interface.go | 4 | ||||
| -rw-r--r-- | plugins/server/plugin.go | 8 |
2 files changed, 6 insertions, 6 deletions
diff --git a/plugins/server/interface.go b/plugins/server/interface.go index 9c1079ea..98345694 100644 --- a/plugins/server/interface.go +++ b/plugins/server/interface.go @@ -15,6 +15,6 @@ type Env map[string]string // Server creates workers for the application. type Server interface { CmdFactory(env Env) (func() *exec.Cmd, error) - NewWorker(ctx context.Context, env Env, listeners ...events.EventListener) (worker.BaseProcess, error) - NewWorkerPool(ctx context.Context, opt poolImpl.Config, env Env, listeners ...events.EventListener) (pool.Pool, error) + NewWorker(ctx context.Context, env Env, listeners ...events.Listener) (worker.BaseProcess, error) + NewWorkerPool(ctx context.Context, opt poolImpl.Config, env Env, listeners ...events.Listener) (pool.Pool, error) } diff --git a/plugins/server/plugin.go b/plugins/server/plugin.go index b280d253..5b023bc6 100644 --- a/plugins/server/plugin.go +++ b/plugins/server/plugin.go @@ -104,10 +104,10 @@ func (server *Plugin) CmdFactory(env Env) (func() *exec.Cmd, error) { } // NewWorker issues new standalone worker. -func (server *Plugin) NewWorker(ctx context.Context, env Env, listeners ...events.EventListener) (worker.BaseProcess, error) { +func (server *Plugin) NewWorker(ctx context.Context, env Env, listeners ...events.Listener) (worker.BaseProcess, error) { const op = errors.Op("new worker") - list := make([]events.EventListener, 0, len(listeners)) + list := make([]events.Listener, 0, len(listeners)) list = append(list, server.collectWorkerLogs) spawnCmd, err := server.CmdFactory(env) @@ -124,14 +124,14 @@ 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.EventListener) (pool.Pool, error) { +func (server *Plugin) NewWorkerPool(ctx context.Context, opt poolImpl.Config, env Env, listeners ...events.Listener) (pool.Pool, error) { const op = errors.Op("server plugins new worker pool") spawnCmd, err := server.CmdFactory(env) if err != nil { return nil, errors.E(op, err) } - list := make([]events.EventListener, 0, len(listeners)) + list := make([]events.Listener, 0, len(listeners)) list = append(list, server.collectPoolLogs) p, err := poolImpl.Initialize(ctx, spawnCmd, server.factory, opt, poolImpl.AddListeners(list...)) |