diff --git a/core/src/main/golang/server/event.go b/core/src/main/golang/server/event.go index f12a253..48a95c9 100644 --- a/core/src/main/golang/server/event.go +++ b/core/src/main/golang/server/event.go @@ -134,9 +134,14 @@ func handlePullLogEvent(client *net.UnixConn) { for { select { case elm := <-subseribe: - buf.Reset() msg := elm.(*log.Event) + if msg.LogLevel < log.Level() { + break + } + + buf.Reset() + var payload struct { Level int `json:"level"` Messgae string `json:"message"`