diff options
author | Valery Piashchynski <[email protected]> | 2021-12-15 01:13:32 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-12-15 01:13:32 +0300 |
commit | 31112495808ae37f38f7b514de1f40b8b8a75238 (patch) | |
tree | a90cb8df7c1e3f6bacddca6913c143398a5e94b9 | |
parent | ff1401e97a9d1f3c059a60acbcae3f4507dcfe03 (diff) |
chore(supervisor_pool): specify event in the logv2.6.2
Signed-off-by: Valery Piashchynski <[email protected]>
-rwxr-xr-x | pool/supervisor_pool.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/pool/supervisor_pool.go b/pool/supervisor_pool.go index 3dbae417..5f87c8a4 100755 --- a/pool/supervisor_pool.go +++ b/pool/supervisor_pool.go @@ -160,7 +160,7 @@ func (sp *supervised) control() { //nolint:gocognit } // just to double check workers[i].State().Set(worker.StateInvalid) - sp.events.Send(events.NewEvent(events.EventTTL, supervisorName, fmt.Sprintf("worker's pid: %d", workers[i].Pid()))) + sp.events.Send(events.NewEvent(events.EventTTL, supervisorName, fmt.Sprintf("ttl reached, worker's pid: %d", workers[i].Pid()))) continue } @@ -180,7 +180,7 @@ func (sp *supervised) control() { //nolint:gocognit } // just to double check workers[i].State().Set(worker.StateInvalid) - sp.events.Send(events.NewEvent(events.EventMaxMemory, supervisorName, fmt.Sprintf("worker's pid: %d", workers[i].Pid()))) + sp.events.Send(events.NewEvent(events.EventMaxMemory, supervisorName, fmt.Sprintf("max memory reached, worker's pid: %d", workers[i].Pid()))) continue } @@ -235,7 +235,7 @@ func (sp *supervised) control() { //nolint:gocognit } // just to double-check workers[i].State().Set(worker.StateInvalid) - sp.events.Send(events.NewEvent(events.EventIdleTTL, supervisorName, fmt.Sprintf("worker's pid: %d", workers[i].Pid()))) + sp.events.Send(events.NewEvent(events.EventIdleTTL, supervisorName, fmt.Sprintf("idle ttl reached, worker's pid: %d", workers[i].Pid()))) } } } |