Set hostname based on resource type (#198)

Author: tamalsaha

schedule.go

@@ -62,6 +62,7 @@ func NewCmdSchedule() *cobra.Command {
 			case "Deployments", "Deployment", "deployments", "deployment":
 				opt.AppKind = "Deployment"
 				opt.SmartPrefix = ""
+				opt.SnapshotHostname = opt.AppName
 				_, err := kubeClient.AppsV1beta1().Deployments(opt.Namespace).Get(opt.AppName, metav1.GetOptions{})
 				if err != nil {
 					_, err := kubeClient.ExtensionsV1beta1().Deployments(opt.Namespace).Get(opt.AppName, metav1.GetOptions{})
@@ -72,27 +73,31 @@ func NewCmdSchedule() *cobra.Command {
 			case "ReplicaSets", "ReplicaSet", "replicasets", "replicaset", "rs":
 				opt.AppKind = "ReplicaSet"
 				opt.SmartPrefix = ""
+				opt.SnapshotHostname = opt.AppName
 				_, err := kubeClient.ExtensionsV1beta1().ReplicaSets(opt.Namespace).Get(opt.AppName, metav1.GetOptions{})
 				if err != nil {
 					log.Fatalf(`Unknown ReplicaSet %s/%s`, opt.Namespace, opt.AppName)
 				}
 			case "ReplicationControllers", "ReplicationController", "replicationcontrollers", "replicationcontroller", "rc":
 				opt.AppKind = "ReplicationController"
 				opt.SmartPrefix = ""
+				opt.SnapshotHostname = opt.AppName
 				_, err := kubeClient.CoreV1().ReplicationControllers(opt.Namespace).Get(opt.AppName, metav1.GetOptions{})
 				if err != nil {
 					log.Fatalf(`Unknown ReplicationController %s/%s`, opt.Namespace, opt.AppName)
 				}
 			case "StatefulSets", "StatefulSet":
 				opt.AppKind = "StatefulSet"
 				opt.SmartPrefix = opt.PodName
+				opt.SnapshotHostname = opt.PodName
 				_, err := kubeClient.AppsV1beta1().StatefulSets(opt.Namespace).Get(opt.AppName, metav1.GetOptions{})
 				if err != nil {
 					log.Fatalf(`Unknown StatefulSet %s/%s`, opt.Namespace, opt.AppName)
 				}
 			case "DaemonSets", "DaemonSet", "daemonsets", "daemonset":
 				opt.AppKind = "DaemonSet"
 				opt.SmartPrefix = opt.NodeName
+				opt.SnapshotHostname = opt.NodeName
 				_, err := kubeClient.ExtensionsV1beta1().DaemonSets(opt.Namespace).Get(opt.AppName, metav1.GetOptions{})
 				if err != nil {
 					log.Fatalf(`Unknown DaemonSet %s/%s`, opt.Namespace, opt.AppName)

snapshot_handler.go

@@ -35,7 +35,7 @@ func ExportSnapshots(w http.ResponseWriter, r *http.Request) {
 		http.Error(w, "Missing parameter:"+PathParamName, http.StatusBadRequest)
 		return
 	}
-	resticCLI := cli.New(scratchDir)
+	resticCLI := cli.New(scratchDir, "")
 
 	var resource *api.Restic
 	resource, err := stashClient.Restics(namespace).Get(name, metav1.GetOptions{})