summaryrefslogtreecommitdiff
path: root/balancer.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-01-06 20:28:14 +0300
committerWolfy-J <[email protected]>2018-01-06 20:28:14 +0300
commitfc7b4269e32cb2a92c706c93a2ef496a333729fd (patch)
tree2611cd9a3af5376e55236e6cf66ad700c683db68 /balancer.go
parentfa4bd78d9f7c5f74e8445374370927c742fc4e78 (diff)
more tests
Diffstat (limited to 'balancer.go')
-rw-r--r--balancer.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/balancer.go b/balancer.go
index 29fcd8d5..52479632 100644
--- a/balancer.go
+++ b/balancer.go
@@ -35,14 +35,14 @@ func (b *Balancer) Spawn(cmd func() *exec.Cmd, factory Factory, cfg Config) erro
return nil
}
-// Execute one task with given payload and context, returns result and context or error. Must not be used once pool is
-// being destroyed.
-func (b *Balancer) Execute(payload []byte, ctx interface{}) (resp []byte, rCtx []byte, err error) {
+// Exec one task with given payload and context, returns result and context
+// or error. Must not be used once pool is being destroyed.
+func (b *Balancer) Exec(payload []byte, ctx interface{}) (resp []byte, rCtx []byte, err error) {
b.mu.Lock()
pool := b.pool
b.mu.Unlock()
- return pool.Execute(payload, ctx)
+ return pool.Exec(payload, ctx)
}
// Workers return list of active workers.