Log all state changes

sjenning · Jan 25, 2019 · 0f73be3 · 0f73be3
1 parent 996fa19
commit 0f73be3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/pkg/event/event.go b/pkg/event/event.go
@@ -2,6 +2,7 @@ package event
 
 import (
 	"encoding/json"
+	"fmt"
 	"net/http"
 	"sync"
 	"time"
@@ -120,6 +121,9 @@ func (s *store) Add(namespace, podname, description string) {
 					s.addCacheEntry(namespace, podname, logString)
 				}
 			}
+			s.addCacheEntry(namespace, podname, fmt.Sprintf(">>> %v %s -> %s\n", event.timestamp, lastEvent.description, event.description))
+		} else {
+			s.addCacheEntry(namespace, podname, fmt.Sprintf(">>> %v %s -> %s\n", event.timestamp, "(created)", event.description))
 		}
 		nsevents[podname] = append(nsevents[podname], event)
 	} else {

diff --git a/pkg/ui/ui.go b/pkg/ui/ui.go
@@ -28,7 +28,7 @@ func Run(store event.Store, client kubernetes.Interface, port uint16) {
 		namespace := vars["namespace"]
 		cachedLog, ok := store.GetCachedLog(namespace, podname)
 		if ok {
-			io.WriteString(w, fmt.Sprintf("(CACHED)\n\n%s", cachedLog))
+			io.WriteString(w, cachedLog)
 		}
 		if err := log.LogPod(client, w, namespace, podname); err != nil {
 			http.Error(w, err.Error(), http.StatusInternalServerError)