diff options
| author | Valery Piashchynski <[email protected]> | 2021-04-20 10:06:45 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2021-04-20 10:06:45 +0300 |
| commit | 3362f211f6358d60bea47ac2de4cc29a47373973 (patch) | |
| tree | d36dc3ce9a36fff1b15b8795e8fa08d397317d14 /pkg/pool/static_pool.go | |
| parent | 35d6a50aa3640c870b99c120b26c9b9012b424be (diff) | |
| parent | 779cc3f5aebb749ab4bc6190e03cc86ff3f151a0 (diff) | |
#634 feat(plugin): new plugin `service`v2.1.0-beta.2
feat(plugin): new plugin `service`
Diffstat (limited to 'pkg/pool/static_pool.go')
| -rwxr-xr-x | pkg/pool/static_pool.go | 4 |
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 { |