From fa8157a555dacf301c325338c11de0b8f0602bca Mon Sep 17 00:00:00 2001 From: Tuna Date: Fri, 6 Jan 2017 00:57:11 +0100 Subject: [PATCH 1/2] add deploy/undeploy pod only ref: #342 --- pkg/transformer/kubernetes/kubernetes.go | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) 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 From 5e59400345b5b370f14669642ba8def5c2a2f5d1 Mon Sep 17 00:00:00 2001 From: Tuna Date: Tue, 10 Jan 2017 17:04:22 +0100 Subject: [PATCH 2/2] deploy/undeploy pod to OpenShift provider --- pkg/transformer/openshift/openshift.go | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) 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