diff --git a/pkg/transformer/kubernetes/kubernetes.go b/pkg/transformer/kubernetes/kubernetes.go index aadaf0b0..9c15f553 100644 --- a/pkg/transformer/kubernetes/kubernetes.go +++ b/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 diff --git a/pkg/transformer/openshift/openshift.go b/pkg/transformer/openshift/openshift.go index b8bfef56..f13fd5f9 100644 --- a/pkg/transformer/openshift/openshift.go +++ b/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