diff --git a/meshsync/logstream.go b/meshsync/logstream.go index 4719b87c..70808284 100644 --- a/meshsync/logstream.go +++ b/meshsync/logstream.go @@ -83,8 +83,10 @@ func (h *Handler) streamLogs(id string, req model.LogRequest, cfg config.Listene ObjectType: broker.LogStreamObject, EventType: broker.Add, Object: &model.LogObject{ - ID: req.ID, - Data: message, + ID: req.ID, + Data: message, + Primary: req.Name, + Secondary: req.Container, }, }) if err != nil { diff --git a/pkg/model/log.go b/pkg/model/log.go index 3d16ceb5..336def6e 100644 --- a/pkg/model/log.go +++ b/pkg/model/log.go @@ -3,6 +3,12 @@ package model type LogObject struct { ID string `json:"id,omitempty"` Data string `json:"data,omitempty"` + + // Name of Pod, Svc, Deply getting logs for + Primary string `json:"primary,omitempty"` + + // Specific detail about the log like Container or Pod Name + Secondary string `json:"secondary,omitempty"` } type LogRequest struct {