WIP: LXD: Add services APIs and support for copying across services of type lxd (clusters)

client/interfaces.go

@@ -428,6 +428,13 @@ type InstanceServer interface {
 	UpdateClusterGroup(name string, group api.ClusterGroupPut, ETag string) error
 	GetClusterGroup(name string) (*api.ClusterGroup, string, error)
 
+	// Service functions ("services" API extension)
+	GetService(name string) (service *api.Service, ETag string, err error)
+	GetServices() (services []api.Service, err error)
+	AddService(service api.ServicePost) error
+	UpdateService(name string, service api.ServicePut, ETag string) error
+	DeleteService(name string) error
+
 	// Warning functions
 	GetWarningUUIDs() (uuids []string, err error)
 	GetWarnings() (warnings []api.Warning, err error)

client/lxd_services.go

@@ -0,0 +1,89 @@
+package lxd
+
+import (
+	"net/http"
+
+	"github.com/canonical/lxd/shared/api"
+)
+
+// GetServices returns all services.
+func (r *ProtocolLXD) GetServices() ([]api.Service, error) {
+	err := r.CheckExtension("services")
+	if err != nil {
+		return nil, err
+	}
+
+	services := []api.Service{}
+	u := api.NewURL().Path("services")
+	_, err = r.queryStruct(http.MethodGet, u.String(), nil, "", &services)
+	if err != nil {
+		return nil, err
+	}
+
+	return services, nil
+}
+
+// GetService returns information about a service.
+func (r *ProtocolLXD) GetService(name string) (*api.Service, string, error) {
+	err := r.CheckExtension("services")
+	if err != nil {
+		return nil, "", err
+	}
+
+	service := &api.Service{}
+	u := api.NewURL().Path("services", name)
+	etag, err := r.queryStruct(http.MethodGet, u.String(), nil, "", &service)
+	if err != nil {
+		return nil, "", err
+	}
+
+	return service, etag, nil
+}
+
+// AddService requests add a new service.
+func (r *ProtocolLXD) AddService(service api.ServicePost) error {
+	err := r.CheckExtension("services")
+	if err != nil {
+		return err
+	}
+
+	u := api.NewURL().Path("service", "add")
+	_, _, err = r.query(http.MethodPost, u.String(), service, "")
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// UpdateService updates a service.
+func (r *ProtocolLXD) UpdateService(name string, service api.ServicePut, ETag string) error {
+	err := r.CheckExtension("services")
+	if err != nil {
+		return err
+	}
+
+	u := api.NewURL().Path("services", name)
+	_, _, err = r.query(http.MethodPut, u.String(), service, ETag)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// DeleteService deletes a service.
+func (r *ProtocolLXD) DeleteService(name string) error {
+	err := r.CheckExtension("services")
+	if err != nil {
+		return err
+	}
+
+	u := api.NewURL().Path("services", name)
+	_, _, err = r.query(http.MethodDelete, u.String(), nil, "")
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

doc/api-extensions.md

@@ -2618,3 +2618,17 @@ Note that the `openid` and `email` scopes are always required.
 ## `project_default_network_and_storage`
 
 Adds flags --network and --storage. The --network flag adds a network device connected to the specified network to the default profile. The --storage flag adds a root disk device using the specified storage pool to the default profile.
+
+## services
+
+This introduces the services API to enable services (server-side remotes).
+
+This includes the following new endpoints (see [RESTful API](rest-api.md) for details):
+
+* `GET /1.0/services/<name>` - returns information about a specific service.
+* `GET /1.0/services` - returns a combined view of self-created and delegated services (if any).
+* `PUT /1.0/services/<name>` - allows for modification of a specific service.
+* `POST /1.0/service/add` - adds a specific service using a provided trust token.
+* `DELETE /1.0/services/<name>` - deletes a service.
+
+This also includes the new `services` and `services_config` database tables and their corresponding functions.