Populate 'Kind' field in all API types being returned.

pkg/api/types.go

@@ -130,6 +130,7 @@ type TaskTemplate struct {
 
 // ServiceList holds a list of services
 type ServiceList struct {
+	JSONBase
 	Items []Service `json:"items" yaml:"items"`
 }
 

pkg/apiserver/api_server.go

@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-// Package apiserver is ...
+// Package apiserver contains the code that provides a RESTful api service
 package apiserver
 
 import (
@@ -50,13 +50,14 @@ type Status struct {
 // TODO: consider migrating this to go-restful which is a more full-featured version of the same thing.
 type ApiServer struct {
 	prefix  string
+	apiName string
 	storage map[string]RESTStorage
 }
 
 // New creates a new ApiServer object.
 // 'storage' contains a map of handlers.
 // 'prefix' is the hosting path prefix.
-func New(storage map[string]RESTStorage, prefix string) *ApiServer {
+func New(storage map[string]RESTStorage, prefix, apiName string) *ApiServer {
 	return &ApiServer{
 		storage: storage,
 		prefix:  prefix,

pkg/registry/controller_registry.go

@@ -35,7 +35,7 @@ func MakeControllerRegistryStorage(registry ControllerRegistry) apiserver.RESTSt
 }
 
 func (storage *ControllerRegistryStorage) List(*url.URL) (interface{}, error) {
-	var result ReplicationControllerList
+	result := ReplicationControllerList{JSONBase: JSONBase{Kind: "cluster#replicationControllerList"}}
 	controllers, err := storage.registry.ListControllers()
 	if err == nil {
 		result = ReplicationControllerList{
@@ -46,7 +46,9 @@ func (storage *ControllerRegistryStorage) List(*url.URL) (interface{}, error) {
 }
 
 func (storage *ControllerRegistryStorage) Get(id string) (interface{}, error) {
-	return storage.registry.GetController(id)
+	controller, err := storage.registry.GetController(id)
+	controller.Kind = "cluster#replicationController"
+	return controller, err
 }
 
 func (storage *ControllerRegistryStorage) Delete(id string) error {

pkg/registry/service_registry.go

@@ -60,11 +60,15 @@ func GetServiceEnvironmentVariables(registry ServiceRegistry, machine string) ([
 }
 
 func (sr *ServiceRegistryStorage) List(*url.URL) (interface{}, error) {
-	return sr.registry.ListServices()
+	list, err := sr.registry.ListServices()
+	list.Kind = "cluster#serviceList"
+	return list, err
 }
 
 func (sr *ServiceRegistryStorage) Get(id string) (interface{}, error) {
-	return sr.registry.GetService(id)
+	service, err := sr.registry.GetService(id)
+	service.Kind = "cluster#service"
+	return service, err
 }
 
 func (sr *ServiceRegistryStorage) Delete(id string) error {

pkg/registry/task_registry.go

@@ -76,6 +76,7 @@ func (storage *TaskRegistryStorage) List(url *url.URL) (interface{}, error) {
 			Items: tasks,
 		}
 	}
+	result.Kind = "cluster#taskList"
 	return result, err
 }
 
@@ -89,6 +90,7 @@ func (storage *TaskRegistryStorage) Get(id string) (interface{}, error) {
 		return task, err
 	}
 	task.CurrentState.Info = info
+	task.Kind = "cluster#task"
 	return task, err
 }