Merge pull request #363 from ngtuna/up-down-pod

add deploy/undeploy pod only

pkg/transformer/kubernetes/kubernetes.go

@@ -583,6 +583,12 @@ func (k *Kubernetes) Deploy(komposeObject kobject.KomposeObject, opt kobject.Con
 				return err
 			}
 			logrus.Infof("Successfully created Ingress: %s", t.Name)
+		case *api.Pod:
+			_, err := client.Pods(namespace).Create(t)
+			if err != nil {
+				return err
+			}
+			logrus.Infof("Successfully created Pod: %s", t.Name)
 		}
 	}
 
@@ -656,6 +662,17 @@ func (k *Kubernetes) Undeploy(komposeObject kobject.KomposeObject, opt kobject.C
 			}
 			logrus.Infof("Successfully deleted Ingress: %s", t.Name)
 
+		case *api.Pod:
+			rpPod, err := kubectl.ReaperFor(api.Kind("Pod"), client)
+			if err != nil {
+				return err
+			}
+			//FIXME: gracePeriod is nil
+			err = rpPod.Stop(namespace, t.Name, TIMEOUT*time.Second, nil)
+			if err != nil {
+				return err
+			}
+			logrus.Infof("Successfully deleted Pod: %s", t.Name)
 		}
 	}
 	return nil

pkg/transformer/openshift/openshift.go

@@ -459,6 +459,12 @@ func (o *OpenShift) Deploy(komposeObject kobject.KomposeObject, opt kobject.Conv
 				return err
 			}
 			logrus.Infof("Successfully created Route: %s", t.Name)
+		case *api.Pod:
+			_, err := kclient.Pods(namespace).Create(t)
+			if err != nil {
+				return err
+			}
+			logrus.Infof("Successfully created Pod: %s", t.Name)
 		}
 	}
 
@@ -534,6 +540,17 @@ func (o *OpenShift) Undeploy(komposeObject kobject.KomposeObject, opt kobject.Co
 			}
 			logrus.Infof("Successfully deleted Route: %s", t.Name)
 
+		case *api.Pod:
+			rpPod, err := kubectl.ReaperFor(api.Kind("Pod"), kclient)
+			if err != nil {
+				return err
+			}
+			//FIXME: gracePeriod is nil
+			err = rpPod.Stop(namespace, t.Name, TIMEOUT*time.Second, nil)
+			if err != nil {
+				return err
+			}
+			logrus.Infof("Successfully deleted Pod: %s", t.Name)
 		}
 	}
 	return nil