event.go

type logEntry struct {
	Timestamp time.Time `json:"timestamp"`
	Message   string    `json:"message"`
	App       string    `json:"app"`
	Pod       string    `json:"pod"`
}

func buildLogEntry(e publisher.Event) logEntry {
	msg, _ := e.Content.GetValue("message")
	app, _ := e.Content.GetValue("kubernetes.label.app")
	pod, _ := e.Content.GetValue("kubernetes.pod.name")

	return logEntry{
		Timestamp: e.Content.Timestamp,
		Message:   msg,
		App:       app,
		Pod:       pod,
	}
}