Explorar o código

close pod logs stream when ws handshake close

Mohammed Nafees %!s(int64=4) %!d(string=hai) anos
pai
achega
69a8091088
Modificáronse 1 ficheiros con 1 adicións e 0 borrados
  1. 1 0
      internal/kubernetes/agent.go

+ 1 - 0
internal/kubernetes/agent.go

@@ -626,6 +626,7 @@ func (a *Agent) GetPodLogs(namespace string, name string, selectedContainer stri
 		for {
 			if _, _, err := rw.ReadMessage(); err != nil {
 				errorchan <- nil
+				podLogs.Close()
 				return
 			}
 		}