summaryrefslogtreecommitdiff
path: root/pkg
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-14 19:13:09 +0300
committerValery Piashchynski <[email protected]>2021-07-14 19:13:09 +0300
commit04fde6d8d1a5a88602f8206e0d2c09c4b8346941 (patch)
tree6792c7711ff6c18374b8587d3df2e4f41f38d76c /pkg
parent3ce3b5a6e0839e31d2cfb3d3b6fa7f9c6ca2e0af (diff)
Merge master
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg')
-rw-r--r--pkg/pool/supervisor_test.go2
-rw-r--r--pkg/worker_watcher/interface.go18
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()
-}