mirror of
https://github.com/ultravioletrs/cocos.git
synced 2026-06-23 04:10:25 +00:00
NOISSUE - Format log messages from agent (#244)
* downgrade mod Signed-off-by: Sammy Oina <sammyoina@gmail.com> * add fields to logging Signed-off-by: Sammy Oina <sammyoina@gmail.com> --------- Signed-off-by: Sammy Oina <sammyoina@gmail.com>
This commit is contained in:
committed by
GitHub
parent
1546fbc4c2
commit
4c09b4bea5
@@ -1,6 +1,6 @@
|
||||
module github.com/ultravioletrs/cocos
|
||||
|
||||
go 1.23.0
|
||||
go 1.22.5
|
||||
|
||||
require (
|
||||
github.com/absmach/magistrala v0.14.1-0.20240709113739-04c359462746
|
||||
|
||||
@@ -4,6 +4,7 @@ package manager
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log/slog"
|
||||
"net"
|
||||
"regexp"
|
||||
"strconv"
|
||||
@@ -65,7 +66,26 @@ func (ms *managerService) handleConnections(conn net.Conn) {
|
||||
}
|
||||
ms.eventsChan <- &message
|
||||
|
||||
ms.logger.WithGroup("agent-events-logs").Info(message.String())
|
||||
args := []any{}
|
||||
|
||||
switch message.Message.(type) {
|
||||
case *manager.ClientStreamMessage_AgentEvent:
|
||||
args = append(args, slog.Group("agent-event",
|
||||
slog.String("event-type", message.GetAgentEvent().GetEventType()),
|
||||
slog.String("computation-id", message.GetAgentEvent().GetComputationId()),
|
||||
slog.String("status", message.GetAgentEvent().GetStatus()),
|
||||
slog.String("originator", message.GetAgentEvent().GetOriginator()),
|
||||
slog.String("timestamp", message.GetAgentEvent().GetTimestamp().String()),
|
||||
slog.String("details", string(message.GetAgentEvent().GetDetails()))))
|
||||
case *manager.ClientStreamMessage_AgentLog:
|
||||
args = append(args, slog.Group("agent-log",
|
||||
slog.String("computation-id", message.GetAgentLog().GetComputationId()),
|
||||
slog.String("level", message.GetAgentLog().GetLevel()),
|
||||
slog.String("timestamp", message.GetAgentLog().GetTimestamp().String()),
|
||||
slog.String("message", message.GetAgentLog().GetMessage())))
|
||||
}
|
||||
|
||||
ms.logger.Info("", args...)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user