add Reset method to the pool

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 6 insertions, 0 deletions

diff --git a/pool/supervisor_pool.go b/pool/supervisor_pool.go
index 5f87c8a4..0502dc9a 100755
--- a/pool/supervisor_pool.go
+++ b/pool/supervisor_pool.go
@@ -51,6 +51,12 @@ func (sp *supervised) execWithTTL(_ context.Context, _ *payload.Payload) (*paylo
 	panic("used to satisfy pool interface")
 }
 
+func (sp *supervised) Reset(ctx context.Context) error {
+	sp.mu.Lock()
+	defer sp.mu.Unlock()
+	return sp.pool.Reset(ctx)
+}
+
 func (sp *supervised) Exec(rqs *payload.Payload) (*payload.Payload, error) {
 	const op = errors.Op("supervised_exec_with_context")
 	if sp.cfg.ExecTTL == 0 {