summaryrefslogtreecommitdiff
path: root/pkg/events/worker_events.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-04 12:26:16 +0300
committerGitHub <[email protected]>2021-02-04 12:26:16 +0300
commitb9c9909b98c1b3e15421a4bcad9e8fcc01332d37 (patch)
treeb969808a6bdd67bbb566421a2158a51c9de3713e /pkg/events/worker_events.go
parent8a8d9d7c64226397792e8f1aa7cc607ab413906e (diff)
parenta902a06e670d70b0f806899765bdb206977e7698 (diff)
Merge pull request #526 from spiral/fix/memory_leaksv2.0.0-beta.24
bug(leak): workers memory leak
Diffstat (limited to 'pkg/events/worker_events.go')
-rw-r--r--pkg/events/worker_events.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/pkg/events/worker_events.go b/pkg/events/worker_events.go
index 9d428f7d..11bd6ab7 100644
--- a/pkg/events/worker_events.go
+++ b/pkg/events/worker_events.go
@@ -3,9 +3,10 @@ package events
const (
// EventWorkerError triggered after WorkerProcess. Except payload to be error.
EventWorkerError W = iota + 11000
-
// EventWorkerLog triggered on every write to WorkerProcess StdErr pipe (batched). Except payload to be []byte string.
EventWorkerLog
+ // EventWorkerStderr is the worker standard error output
+ EventWorkerStderr
)
type W int64
@@ -16,6 +17,8 @@ func (ev W) String() string {
return "EventWorkerError"
case EventWorkerLog:
return "EventWorkerLog"
+ case EventWorkerStderr:
+ return "EventWorkerStderr"
}
return "Unknown event type"
}