Added error handling for certs as commented

cmd/localkube/cmd/start.go

@@ -56,7 +56,11 @@ func init() {
 
 func SetupServer(s *localkube.LocalkubeServer) {
 
-	s.GenerateCerts()
+	err := s.GenerateCerts()
+	if err != nil {
+		fmt.Println("Failed to create certificates!")
+		panic(err)
+	}
 
 	// setup etcd
 	etcd, err := s.NewEtcd(localkube.KubeEtcdClientURLs, localkube.KubeEtcdPeerURLs, "kubeetcd", s.GetEtcdDataDirectory())

pkg/localkube/kube2sky/kube2sky.go

@@ -36,7 +36,6 @@ import (
 	etcd "github.com/coreos/go-etcd/etcd"
 	"github.com/golang/glog"
 	skymsg "github.com/skynetservices/skydns/msg"
-	//flag "github.com/spf13/pflag"
 	kapi "k8s.io/kubernetes/pkg/api"
 	"k8s.io/kubernetes/pkg/api/endpoints"
 	"k8s.io/kubernetes/pkg/api/unversioned"

pkg/localkube/localkube.go

@@ -82,11 +82,11 @@ func (lk LocalkubeServer) GetHostIP() (net.IP, error) {
 	return utilnet.ChooseBindAddress(net.ParseIP("0.0.0.0"))
 }
 
-func (lk LocalkubeServer) GenerateCerts() {
+func (lk LocalkubeServer) GenerateCerts() error {
 
 	if util.CanReadFile(lk.GetPublicKeyCertPath()) && util.CanReadFile(lk.GetPrivateKeyCertPath()) {
-		fmt.Println("Using existing certs")
-		return
+		fmt.Println("Using these existing certs: ", lk.GetPublicKeyCertPath(), lk.GetPrivateKeyCertPath())
+		return nil
 	}
 
 	alternateIPs := []net.IP{lk.ServiceClusterIPRange.IP}
@@ -94,9 +94,13 @@ func (lk LocalkubeServer) GenerateCerts() {
 	hostIP, err := lk.GetHostIP()
 	if err != nil {
 		fmt.Println("Failed to get host IP: ", err)
+		return err
 	}
 
 	if err := utilcrypto.GenerateSelfSignedCert(hostIP.String(), lk.GetPublicKeyCertPath(), lk.GetPrivateKeyCertPath(), alternateIPs, alternateDNS); err != nil {
 		fmt.Println("Failed to create certs: ", err)
+		return err
 	}
+
+	return nil
 }