commit 5c75583b9a81eae5f3e951178d839b9a065982f3
author Jian Li <pyguni@gmail.com> Thu Apr 11 23:24:28 2019 +0900
committer Jian Li <pyguni@gmail.com> Fri May 31 10:46:17 2019 +0000
tree ef8a61aa4cc3eaa3107de29a3296c66d8db81d04
parent b77768e06e72dda3c84f917ca39b7d114f6d84bf

Add k8s POD events, trigger svc rule on receiving annotation event

Change-Id: I7fbbd071a9b078337c028791b7441603ae1e7473

apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sServiceHandler.java

diff --git a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sServiceHandler.java b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sServiceHandler.java
index 791cbc9..6a5f942 100644
--- a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sServiceHandler.java
+++ b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sServiceHandler.java
@@ -788,8 +788,8 @@
         @Override
         public void event(K8sPodEvent event) {
             switch (event.type()) {
-                case K8S_POD_UPDATED:
-                    eventExecutor.execute(() -> processPodUpdate(event.subject()));
+                case K8S_POD_ANNOTATION_ADDED:
+                    eventExecutor.execute(() -> processPodAnnotAddition(event.subject()));
                     break;
                 case K8S_POD_REMOVED:
                     eventExecutor.execute(() -> processPodRemoval(event.subject()));
@@ -799,7 +799,7 @@
             }
         }
 
-        private void processPodUpdate(Pod pod) {
+        private void processPodAnnotAddition(Pod pod) {
             if (!isRelevantHelper()) {
                 return;
             }