From 931081787615df009a3c77230444e3608c8ad080 Mon Sep 17 00:00:00 2001
From: MOZGIII <mike-n@narod.ru>
Date: Wed, 25 Mar 2020 02:09:45 +0300
Subject: [PATCH] Add an integration test for partial message merging at
 kubernetes

Signed-off-by: MOZGIII <mike-n@narod.ru>
---
 src/sources/kubernetes/test.rs | 30 ++++++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)

diff --git a/src/sources/kubernetes/test.rs b/src/sources/kubernetes/test.rs
index 35d140ec90ed9e..a8b58b6dd265c5 100644
--- a/src/sources/kubernetes/test.rs
+++ b/src/sources/kubernetes/test.rs
@@ -641,3 +641,33 @@ fn kube_diff_pod_uid() {
         false
     });
 }
+
+#[test]
+fn kube_partial() {
+    let namespace = format!("partial-{}", Uuid::new_v4());
+    let message = random_string(64 * 1024); // 64 kb
+    let user_namespace = user_namespace(&namespace);
+
+    let kube = Kube::new(&namespace);
+    let user = Kube::new(&user_namespace);
+
+    // Start vector
+    let vector = start_vector(&kube, user_namespace.as_str(), None);
+
+    // Start echo
+    let _echo = echo(&user, "echo", &message);
+    // Verify logs
+    wait_for(|| {
+        // If any daemon logged message, done.
+        for line in logs(&kube, &vector) {
+            if line["message"].as_str().unwrap() == message {
+                // Very long message arrived as a single (merged) message.
+                // DONE
+                return true;
+            } else {
+                debug!(namespace=%namespace,log=%line);
+            }
+        }
+        false
+    });
+}