schema changes. v0.2 change

Appdynamics · May 1, 2018 · f0f5bdd · f0f5bdd
1 parent 0b52435
commit f0f5bdd
Show file tree

Hide file tree

Showing 5 changed files with 18 additions and 2 deletions.
diff --git a/CHANGES.MD b/CHANGES.MD
@@ -1,3 +1,8 @@
+### Version 0.2
+
+* Changed watermark strategy
+* Some minor Bug fixes
+
 ### Version 0.1
 
 * Initial open source pre-release
diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>com.appdynamics.monitors</groupId>
     <artifactId>kubernetes-events-extension</artifactId>
-    <version>0.1</version>
+    <version>0.2</version>
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>

diff --git a/src/main/java/com/appdynamics/monitors/kubernetes/Utilities.java b/src/main/java/com/appdynamics/monitors/kubernetes/Utilities.java
@@ -56,6 +56,13 @@ static ArrayNode createEventPayload(V1EventList eventList) {
                     objectNode = checkAddObject(objectNode, item.getMetadata().getNamespace(), "namespace");
                     objectNode = checkAddObject(objectNode, item.getMetadata().getResourceVersion(), "resourceVersion");
                     objectNode = checkAddObject(objectNode, item.getMetadata().getSelfLink(), "selfLink");
+                    objectNode = checkAddObject(objectNode, item.getType(), "type");
+                    objectNode = checkAddObject(objectNode, item.getReason(), "reason");
+                    objectNode = checkAddObject(objectNode, item.getCount(), "count");
+                    objectNode = checkAddObject(objectNode, item.getSource().getComponent(), "source_component");
+                    objectNode = checkAddObject(objectNode, item.getSource().getHost(), "source_host");
+
+
                     arrayNode.add(objectNode);
                     Globals.lastElementSelfLink = item.getMetadata().getSelfLink();
                 }

diff --git a/src/main/resources/conf/config.yml b/src/main/resources/conf/config.yml
@@ -47,6 +47,10 @@ eventsSchemaDefinition: '{
       "ownerReferences": "string",
       "resourceVersion": "string",
       "selfLink": "string",
+      "type": "string",
+      "count": "string",
+      "source_component": "string",
+      "source_host": "string",
       "reason": "string"
    }
 }'
diff --git a/src/test/java/com/appdynamics/monitors/kubernetes/KubernetesEventsMonitorTest.java b/src/test/java/com/appdynamics/monitors/kubernetes/KubernetesEventsMonitorTest.java
@@ -77,7 +77,7 @@ public Object answer(InvocationOnMock invocationOnMock) {
                 null,
                 null,
                 null);
-
+        System.out.println(eventList.toString());
         String payload = Utilities.createEventPayload(eventList).toString();
 
         if(!payload.equals("[]")){
-Original file line number
+Diff line change
@@ Expand Up / @@ -77,7 +77,7 @@ public Object answer(InvocationOnMock invocationOnMock) { @@
                     null,
                     null,
                     null);
+            System.out.println(eventList.toString());
             String payload = Utilities.createEventPayload(eventList).toString();
             if(!payload.equals("[]")){
@@ Expand Down @@