diff options
| -rw-r--r-- | pkg/pool/supervisor_test.go | 2 | ||||
| -rw-r--r-- | pkg/worker_watcher/interface.go | 18 |
2 files changed, 1 insertions, 19 deletions
diff --git a/pkg/pool/supervisor_test.go b/pkg/pool/supervisor_test.go index a321fdf0..234eec3f 100644 --- a/pkg/pool/supervisor_test.go +++ b/pkg/pool/supervisor_test.go @@ -125,7 +125,7 @@ func TestSupervisedPool_ExecTTL_TimedOut(t *testing.T) { } func TestSupervisedPool_ExecTTL_WorkerRestarted(t *testing.T) { - var cfgExecTTL = Config{ + var cfgExecTTL = &Config{ NumWorkers: uint64(1), Supervisor: &SupervisorConfig{ WatchTick: 1 * time.Second, diff --git a/pkg/worker_watcher/interface.go b/pkg/worker_watcher/interface.go deleted file mode 100644 index e7503467..00000000 --- a/pkg/worker_watcher/interface.go +++ /dev/null @@ -1,18 +0,0 @@ - -package worker_watcher //nolint:stylecheck - -import ( - "context" - - "github.com/spiral/roadrunner/v2/pkg/worker" -) - -// Vector interface represents vector container -type Vector interface { - // Enqueue used to put worker to the vector - Enqueue(worker.BaseProcess) - // Dequeue used to get worker from the vector - Dequeue(ctx context.Context) (worker.BaseProcess, error) - // Destroy used to stop releasing the workers - Destroy() -} |