diff --git a/runtime/kubernetes/kubernetes.go b/runtime/kubernetes/kubernetes.go index dfe91808..479ae967 100644 --- a/runtime/kubernetes/kubernetes.go +++ b/runtime/kubernetes/kubernetes.go @@ -2,7 +2,6 @@ package kubernetes import ( - "encoding/json" "errors" "fmt" "strings" @@ -277,9 +276,6 @@ func (k *kubernetes) Create(s *runtime.Service, opts ...runtime.CreateOption) er service := newService(s, options) - bytes, _ := json.Marshal(service) - log.Debug(string(bytes)) - // start the service return service.Start(k.client) } diff --git a/runtime/kubernetes/service.go b/runtime/kubernetes/service.go index 2b0287e7..aa84585a 100644 --- a/runtime/kubernetes/service.go +++ b/runtime/kubernetes/service.go @@ -98,6 +98,9 @@ func serviceResource(s *client.Service) *client.Resource { // Start starts the Kubernetes service. It creates new kubernetes deployment and service API objects func (s *service) Start(k client.Client) error { + bytes, _ := json.Marshal(s.kdeploy) + log.Debug("kdeploy", string(bytes)) + // create deployment first; if we fail, we dont create service if err := k.Create(deploymentResource(s.kdeploy)); err != nil { log.Debugf("Runtime failed to create deployment: %v", err) diff --git a/util/kubernetes/client/client.go b/util/kubernetes/client/client.go index 478889d2..82df204a 100644 --- a/util/kubernetes/client/client.go +++ b/util/kubernetes/client/client.go @@ -267,8 +267,8 @@ func NewDeployment(name, version, typ string) *Deployment { Name: name, Image: DefaultImage, Env: []EnvVar{env}, - Command: []string{"go", "run", "mainx.go"}, - Ports: []ContainerPort{{ + Command: []string{"go", "run", "main.go"}, + Ports: []ContainerPort{ Name: "service-port", ContainerPort: 8080, }},