Merge pull request #731 from bryk/generic-delete-backend

Backend for generic delete code

Author: bryk

src/app/backend/handler/apihandler.go

@@ -52,6 +52,7 @@ type ApiHandler struct {
 	client         *client.Client
 	heapsterClient HeapsterClient
 	clientConfig   clientcmd.ClientConfig
+	verber         common.ResourceVerber
 }
 
 // Web-service filter function used for request and response logging.
@@ -83,7 +84,8 @@ func FormatResponseLog(resp *restful.Response, req *restful.Request) string {
 func CreateHttpApiHandler(client *client.Client, heapsterClient HeapsterClient,
 	clientConfig clientcmd.ClientConfig) http.Handler {
 
-	apiHandler := ApiHandler{client, heapsterClient, clientConfig}
+	verber := common.NewResourceVerber(client.RESTClient)
+	apiHandler := ApiHandler{client, heapsterClient, clientConfig, verber}
 	wsContainer := restful.NewContainer()
 
 	deployWs := new(restful.WebService)
@@ -270,6 +272,16 @@ func CreateHttpApiHandler(client *client.Client, heapsterClient HeapsterClient,
 			Writes(resourceService.ServiceDetail{}))
 	wsContainer.Add(servicesWs)
 
+	resourceVerberWs := new(restful.WebService)
+	resourceVerberWs.Filter(wsLogger)
+	resourceVerberWs.Path("/api/v1").
+		Consumes(restful.MIME_JSON).
+		Produces(restful.MIME_JSON)
+	resourceVerberWs.Route(
+		resourceVerberWs.DELETE("/{kind}/namespace/{namespace}/name/{name}").
+			To(apiHandler.handleDeleteResource))
+	wsContainer.Add(resourceVerberWs)
+
 	return wsContainer
 }
 
@@ -527,6 +539,20 @@ func (apiHandler *ApiHandler) handleDeleteReplicationController(
 	response.WriteHeader(http.StatusOK)
 }
 
+func (apiHandler *ApiHandler) handleDeleteResource(
+	request *restful.Request, response *restful.Response) {
+	kind := request.PathParameter("kind")
+	namespace := request.PathParameter("namespace")
+	name := request.PathParameter("name")
+
+	if err := apiHandler.verber.Delete(kind, namespace, name); err != nil {
+		handleInternalError(response, err)
+		return
+	}
+
+	response.WriteHeader(http.StatusOK)
+}
+
 // Handles get Replication Controller Pods API call.
 func (apiHandler *ApiHandler) handleGetReplicationControllerPods(
 	request *restful.Request, response *restful.Response) {

src/app/backend/resource/common/types.go

@@ -21,28 +21,7 @@ import (
 	"k8s.io/kubernetes/pkg/api/unversioned"
 )
 
-type ResourceType string
-
-const (
-	ResourceTypeReplicaSet            = "replicaset"
-	ResourceTypeReplicationController = "replicationcontroller"
-)
-
-func CreateObjectMeta(k8SObjectMeta api.ObjectMeta) ObjectMeta {
-	return ObjectMeta{
-		Name:              k8SObjectMeta.Name,
-		Namespace:         k8SObjectMeta.Namespace,
-		Labels:            k8SObjectMeta.Labels,
-		CreationTimestamp: k8SObjectMeta.CreationTimestamp,
-	}
-}
-
-func CreateTypeMeta(k8STypeMeta unversioned.TypeMeta) TypeMeta {
-	return TypeMeta{
-		Kind: k8STypeMeta.Kind,
-	}
-}
-
+// ObjectMeta is metadata about an instance of a resource.
 type ObjectMeta struct {
 	// Name is unique within a namespace. Name is primarily intended for creation
 	// idempotence and configuration definition.
@@ -83,7 +62,7 @@ type TypeMeta struct {
 	// Servers may infer this from the endpoint the client submits requests to.
 	// In smalllettercase.
 	// More info: http://releases.k8s.io/HEAD/docs/devel/api-conventions.md#types-kinds
-	Kind string `json:"kind,omitempty"`
+	Kind ResourceKind `json:"kind,omitempty"`
 }
 
 // Endpoint describes an endpoint that is host and a list of available ports for that host.
@@ -148,6 +127,49 @@ type Event struct {
 }
 
 // Returns internal endpoint name for the given service properties, e.g.,
+// NewObjectMeta creates a new instance of ObjectMeta struct based on K8s object meta.
+func NewObjectMeta(k8SObjectMeta api.ObjectMeta) ObjectMeta {
+	return ObjectMeta{
+		Name:              k8SObjectMeta.Name,
+		Namespace:         k8SObjectMeta.Namespace,
+		Labels:            k8SObjectMeta.Labels,
+		CreationTimestamp: k8SObjectMeta.CreationTimestamp,
+	}
+}
+
+// NewTypeMeta creates new type mete for the resource kind.
+func NewTypeMeta(kind ResourceKind) TypeMeta {
+	return TypeMeta{
+		Kind: kind,
+	}
+}
+
+// ResourceKind is an unique name for each resource. It can used for API discovery and generic
+// code that does things based on the kind. For example, there may be a generic "deleter"
+// that based on resource kind, name and namespace deletes it.
+type ResourceKind string
+
+// List of all resource kinds supported by the UI.
+const (
+	ResourceKindReplicaSet            = "replicaset"
+	ResourceKindService               = "service"
+	ResourceKindDeployment            = "deployment"
+	ResourceKindPod                   = "pod"
+	ResourceKindReplicationController = "replicationcontroller"
+)
+
+// Mapping from resource kind to K8s apiserver API path. This is mostly pluralization, because
+// K8s apiserver uses plural paths and this project singular.
+// Must be kept in sync with the list of supported kinds.
+var kindToAPIPathMapping = map[string]string{
+	ResourceKindService:               "services",
+	ResourceKindPod:                   "pods",
+	ResourceKindReplicationController: "replicationcontrollers",
+	ResourceKindDeployment:            "deployments",
+	ResourceKindReplicaSet:            "replicasets",
+}
+
+// GetInternalEndpoint returns internal endpoint name for the given service properties, e.g.,
 // "my-service.namespace 80/TCP" or "my-service 53/TCP,53/UDP".
 func GetInternalEndpoint(serviceName, namespace string, ports []api.ServicePort) Endpoint {
 
@@ -165,7 +187,7 @@ func GetInternalEndpoint(serviceName, namespace string, ports []api.ServicePort)
 	}
 }
 
-// Gets human readable name for the given service ports list.
+// GetServicePorts returns human readable name for the given service ports list.
 func GetServicePorts(apiPorts []api.ServicePort) []ServicePort {
 	var ports []ServicePort
 	for _, port := range apiPorts {

src/app/backend/resource/common/verber.go

@@ -0,0 +1,53 @@
+// Copyright 2015 Google Inc. All Rights Reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package common
+
+import (
+	"errors"
+	"fmt"
+
+	"k8s.io/kubernetes/pkg/client/restclient"
+)
+
+// ResourceVerber is a struct responsible for doing common verb operations on resources, like
+// DELETE, PUT, UPDATE.
+type ResourceVerber struct {
+	client RESTClient
+}
+
+type RESTClient interface {
+	Delete() *restclient.Request
+}
+
+// NewResourceVerber creates a new resource verber that uses the given client for performing
+// operations.
+func NewResourceVerber(client RESTClient) ResourceVerber {
+	return ResourceVerber{client}
+}
+
+// Delete deletes the resource of the given kind in the given namespace with the given name.
+func (verber *ResourceVerber) Delete(kind string, namespace string, name string) error {
+	apiPath, ok := kindToAPIPathMapping[kind]
+	if !ok {
+		return errors.New(fmt.Sprintf("Unknown resource kind: %s", kind))
+	}
+
+	return verber.client.Delete().
+		Namespace(namespace).
+		Resource(apiPath).
+		Name(name).
+		Do().
+		Error()
+}

src/app/backend/resource/deployment/deploymentlist.go

@@ -116,8 +116,8 @@ func getDeploymentList(deployments []extensions.Deployment,
 
 		deploymentList.Deployments = append(deploymentList.Deployments,
 			Deployment{
-				ObjectMeta:      common.CreateObjectMeta(deployment.ObjectMeta),
-				TypeMeta:        common.CreateTypeMeta(deployment.TypeMeta),
+				ObjectMeta:      common.NewObjectMeta(deployment.ObjectMeta),
+				TypeMeta:        common.NewTypeMeta(common.ResourceKindDeployment),
 				ContainerImages: replicationcontroller.GetContainerImages(&deployment.Spec.Template.Spec),
 				Pods:            podInfo,
 			})

src/app/backend/resource/pod/podlist.go

@@ -92,8 +92,8 @@ func CreatePodList(pods []api.Pod, heapsterClient client.HeapsterClient) PodList
 
 	for _, pod := range pods {
 		podDetail := Pod{
-			ObjectMeta:   common.CreateObjectMeta(pod.ObjectMeta),
-			TypeMeta:     common.CreateTypeMeta(pod.TypeMeta),
+			ObjectMeta:   common.NewObjectMeta(pod.ObjectMeta),
+			TypeMeta:     common.NewTypeMeta(common.ResourceKindPod),
 			PodPhase:     pod.Status.Phase,
 			PodIP:        pod.Status.PodIP,
 			RestartCount: getRestartCount(pod),

src/app/backend/resource/replicaset/replicasetdetail.go

@@ -86,8 +86,8 @@ func getReplicaSetDetail(replicaSet *extensions.ReplicaSet, heapsterClient clien
 	podInfo := getPodInfo(replicaSet, matchingPods)
 
 	return ReplicaSetDetail{
-		ObjectMeta:      common.CreateObjectMeta(replicaSet.ObjectMeta),
-		TypeMeta:        common.CreateTypeMeta(replicaSet.TypeMeta),
+		ObjectMeta:      common.NewObjectMeta(replicaSet.ObjectMeta),
+		TypeMeta:        common.NewTypeMeta(common.ResourceKindReplicaSet),
 		ContainerImages: replicationcontroller.GetContainerImages(&replicaSet.Spec.Template.Spec),
 		PodInfo:         podInfo,
 		PodList:         pod.CreatePodList(matchingPods, heapsterClient),

src/app/backend/resource/replicaset/replicasetlist.go

@@ -116,8 +116,8 @@ func getReplicaSetList(replicaSets []extensions.ReplicaSet,
 
 		replicaSetList.ReplicaSets = append(replicaSetList.ReplicaSets,
 			ReplicaSet{
-				ObjectMeta:      common.CreateObjectMeta(replicaSet.ObjectMeta),
-				TypeMeta:        common.CreateTypeMeta(replicaSet.TypeMeta),
+				ObjectMeta:      common.NewObjectMeta(replicaSet.ObjectMeta),
+				TypeMeta:        common.NewTypeMeta(common.ResourceKindReplicaSet),
 				ContainerImages: replicationcontroller.GetContainerImages(&replicaSet.Spec.Template.Spec),
 				Pods:            podInfo,
 			})

src/app/backend/resource/replicationcontroller/replicationcontrollerdetail.go

@@ -85,8 +85,8 @@ func GetReplicationControllerDetail(client k8sClient.Interface, heapsterClient c
 	}
 
 	replicationControllerDetail := &ReplicationControllerDetail{
-		ObjectMeta:    common.CreateObjectMeta(replicationController.ObjectMeta),
-		TypeMeta:      common.CreateTypeMeta(replicationController.TypeMeta),
+		ObjectMeta:    common.NewObjectMeta(replicationController.ObjectMeta),
+		TypeMeta:      common.NewTypeMeta(common.ResourceKindReplicationController),
 		LabelSelector: replicationController.Spec.Selector,
 		PodInfo:       getReplicationPodInfo(replicationController, pods.Items),
 		ServiceList:   resourceService.ServiceList{Services: make([]resourceService.Service, 0)},

src/app/backend/resource/replicationcontroller/replicationcontrollerlist.go

@@ -135,8 +135,8 @@ func getReplicationControllerList(replicationControllers []api.ReplicationContro
 
 		replicationControllerList.ReplicationControllers = append(replicationControllerList.ReplicationControllers,
 			ReplicationController{
-				ObjectMeta:        common.CreateObjectMeta(replicationController.ObjectMeta),
-				TypeMeta:          common.CreateTypeMeta(replicationController.TypeMeta),
+				ObjectMeta:        common.NewObjectMeta(replicationController.ObjectMeta),
+				TypeMeta:          common.NewTypeMeta(common.ResourceKindReplicationController),
 				Pods:              podInfo,
 				ContainerImages:   GetContainerImages(&replicationController.Spec.Template.Spec),
 				InternalEndpoints: internalEndpoints,

src/app/backend/resource/service/servicecommon.go

@@ -23,8 +23,8 @@ import (
 // ToService returns api service object based on kubernetes service object
 func ToService(service *api.Service) Service {
 	return Service{
-		ObjectMeta:       common.CreateObjectMeta(service.ObjectMeta),
-		TypeMeta:         common.CreateTypeMeta(service.TypeMeta),
+		ObjectMeta:       common.NewObjectMeta(service.ObjectMeta),
+		TypeMeta:         common.NewTypeMeta(common.ResourceKindService),
 		InternalEndpoint: common.GetInternalEndpoint(service.Name, service.Namespace, service.Spec.Ports),
 		// TODO(maciaszczykm): Fill ExternalEndpoints with data.
 		Selector:  service.Spec.Selector,
@@ -35,8 +35,8 @@ func ToService(service *api.Service) Service {
 // ToServiceDetails returns api service object based on kubernetes service object
 func ToServiceDetail(service *api.Service) ServiceDetail {
 	return ServiceDetail{
-		ObjectMeta:       common.CreateObjectMeta(service.ObjectMeta),
-		TypeMeta:         common.CreateTypeMeta(service.TypeMeta),
+		ObjectMeta:       common.NewObjectMeta(service.ObjectMeta),
+		TypeMeta:         common.NewTypeMeta(common.ResourceKindService),
 		InternalEndpoint: common.GetInternalEndpoint(service.Name, service.Namespace, service.Spec.Ports),
 		// TODO(maciaszczykm): Fill ExternalEndpoints with data.
 		Selector:  service.Spec.Selector,