feat: support viewing logs of multiple pods in UI (argoproj#5469)

* feat: support viewing logs of multiple pods in UI Signed-off-by: Alexander Matyushentsev <[email protected]>
tkasuz · Feb 11, 2021 · 223335d · 223335d
1 parent fb8096a
commit 223335d
Show file tree

Hide file tree

Showing 17 changed files with 945 additions and 381 deletions.
diff --git a/assets/swagger.json b/assets/swagger.json
@@ -652,6 +652,117 @@
         }
       }
     },
+    "/api/v1/applications/{name}/logs": {
+      "get": {
+        "tags": [
+          "ApplicationService"
+        ],
+        "summary": "PodLogs returns stream of log entries for the specified pod. Pod",
+        "operationId": "ApplicationService_PodLogs2",
+        "parameters": [
+          {
+            "type": "string",
+            "name": "name",
+            "in": "path",
+            "required": true
+          },
+          {
+            "type": "string",
+            "name": "namespace",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "name": "podName",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "name": "container",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "format": "int64",
+            "name": "sinceSeconds",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "format": "int64",
+            "description": "Represents seconds of UTC time since Unix epoch\n1970-01-01T00:00:00Z. Must be from 0001-01-01T00:00:00Z to\n9999-12-31T23:59:59Z inclusive.",
+            "name": "sinceTime.seconds",
+            "in": "query"
+          },
+          {
+            "type": "integer",
+            "format": "int32",
+            "description": "Non-negative fractions of a second at nanosecond resolution. Negative\nsecond values with fractions must still have non-negative nanos values\nthat count forward in time. Must be from 0 to 999,999,999\ninclusive. This field may be limited in precision depending on context.",
+            "name": "sinceTime.nanos",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "format": "int64",
+            "name": "tailLines",
+            "in": "query"
+          },
+          {
+            "type": "boolean",
+            "name": "follow",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "name": "untilTime",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "name": "filter",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "name": "kind",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "name": "group",
+            "in": "query"
+          },
+          {
+            "type": "string",
+            "name": "resourceName",
+            "in": "query"
+          }
+        ],
+        "responses": {
+          "200": {
+            "description": "A successful response.(streaming responses)",
+            "schema": {
+              "type": "object",
+              "title": "Stream result of applicationLogEntry",
+              "properties": {
+                "error": {
+                  "$ref": "#/definitions/runtimeStreamError"
+                },
+                "result": {
+                  "$ref": "#/definitions/applicationLogEntry"
+                }
+              }
+            }
+          },
+          "default": {
+            "description": "An unexpected error response.",
+            "schema": {
+              "$ref": "#/definitions/runtimeError"
+            }
+          }
+        }
+      }
+    },
     "/api/v1/applications/{name}/manifests": {
       "get": {
         "tags": [
@@ -3248,6 +3359,9 @@
         "last": {
           "type": "boolean"
         },
+        "podName": {
+          "type": "string"
+        },
         "timeStamp": {
           "$ref": "#/definitions/v1Time"
         },

diff --git a/pkg/apiclient/application/application.pb.go b/pkg/apiclient/application/application.pb.go
diff --git a/pkg/apiclient/application/application.pb.gw.go b/pkg/apiclient/application/application.pb.gw.go
diff --git a/pkg/apiclient/application/forwarder_overwrite.go b/pkg/apiclient/application/forwarder_overwrite.go
@@ -13,6 +13,7 @@ import (
 
 func init() {
 	forward_ApplicationService_PodLogs_0 = http.StreamForwarder
+	forward_ApplicationService_PodLogs_1 = http.StreamForwarder
 	forward_ApplicationService_WatchResourceTree_0 = http.StreamForwarder
 	forward_ApplicationService_Watch_0 = http.NewStreamForwarder(func(message proto.Message) (string, error) {
 		event, ok := message.(*v1alpha1.ApplicationWatchEvent)