summaryrefslogtreecommitdiff
path: root/static_pool.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-10-26 11:50:12 +0300
committerValery Piashchynski <[email protected]>2020-10-26 11:50:12 +0300
commit9aae9e2009bad07ebdee73e1c6cf56901d07880a (patch)
tree0ad9537bd438c63719fb83343ab77fc4ab34eb83 /static_pool.go
parentdb7695463e85faf3fba6a2767b2dfa6ef916785d (diff)
Fix linters warnings
Diffstat (limited to 'static_pool.go')
-rwxr-xr-xstatic_pool.go13
1 files changed, 7 insertions, 6 deletions
diff --git a/static_pool.go b/static_pool.go
index 31923134..4ecbdd41 100755
--- a/static_pool.go
+++ b/static_pool.go
@@ -3,10 +3,11 @@ package roadrunner
import (
"context"
"fmt"
- "github.com/spiral/roadrunner/v2/util"
"os/exec"
"sync"
+ "github.com/spiral/roadrunner/v2/util"
+
"github.com/pkg/errors"
)
@@ -35,7 +36,7 @@ type StaticPool struct {
ww *workerWatcher
// supervises memory and TTL of workers
- sp *supervisedPool
+ // sp *supervisedPool
}
// NewPool creates new worker pool and task multiplexer. StaticPool will initiate with one worker.
@@ -74,8 +75,8 @@ func NewPool(ctx context.Context, cmd func() *exec.Cmd, factory Factory, cfg Con
}
// todo: implement
- //p.sp = newPoolWatcher(p, p.events, p.cfg.Supervisor)
- //p.sp.Start()
+ // p.sp = newPoolWatcher(p, p.events, p.cfg.Supervisor)
+ // p.sp.Start()
return p, nil
}
@@ -167,7 +168,7 @@ func (p *StaticPool) Exec(rqs Payload) (Payload, error) {
}
// Exec one task with given payload and context, returns result or error.
-//func (p *StaticPool) ExecWithContext(ctx context.Context, rqs Payload) (Payload, error) {
+// func (p *StaticPool) ExecWithContext(ctx context.Context, rqs Payload) (Payload, error) {
// // todo: why TODO passed here?
// getWorkerCtx, cancel := context.WithTimeout(context.TODO(), p.cfg.AllocateTimeout)
// defer cancel()
@@ -235,7 +236,7 @@ func (p *StaticPool) Exec(rqs Payload) (Payload, error) {
// }
//
// return rsp, nil
-//}
+// }
// Destroy all underlying stack (but let them to complete the task).
func (p *StaticPool) Destroy(ctx context.Context) {