summaryrefslogtreecommitdiff
path: root/pkg/pool/static_pool.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-04-19 16:42:28 +0300
committerValery Piashchynski <[email protected]>2021-04-19 16:42:28 +0300
commitbaa12b092578d41218585d918fb7e1425700272d (patch)
tree91881bd0ac32c609ea01fafe3bbc15a13a67c392 /pkg/pool/static_pool.go
parent112b7b60bbc045f4935e1766be9d2266abf68b31 (diff)
- Add tests, update Informer implementation
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/pool/static_pool.go')
-rwxr-xr-xpkg/pool/static_pool.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/pool/static_pool.go b/pkg/pool/static_pool.go
index c8e45b82..129c6f7d 100755
--- a/pkg/pool/static_pool.go
+++ b/pkg/pool/static_pool.go
@@ -119,7 +119,7 @@ func (sp *StaticPool) addListener(listener events.Listener) {
sp.events.AddListener(listener)
}
-// Config returns associated pool configuration. Immutable.
+// GetConfig returns associated pool configuration. Immutable.
func (sp *StaticPool) GetConfig() interface{} {
return sp.cfg
}
@@ -134,7 +134,7 @@ func (sp *StaticPool) RemoveWorker(wb worker.BaseProcess) error {
return nil
}
-// Be careful, sync Exec with ExecWithContext
+// Exec executes provided payload on the worker
func (sp *StaticPool) Exec(p payload.Payload) (payload.Payload, error) {
const op = errors.Op("static_pool_exec")
if sp.cfg.Debug {