| package servers |
| |
| import ( |
| "encoding/base64" |
| "encoding/json" |
| |
| "github.com/gophercloud/gophercloud" |
| "github.com/gophercloud/gophercloud/openstack/compute/v2/flavors" |
| "github.com/gophercloud/gophercloud/openstack/compute/v2/images" |
| "github.com/gophercloud/gophercloud/pagination" |
| ) |
| |
| // ListOptsBuilder allows extensions to add additional parameters to the |
| // List request. |
| type ListOptsBuilder interface { |
| ToServerListQuery() (string, error) |
| } |
| |
| // ListOpts allows the filtering and sorting of paginated collections through |
| // the API. Filtering is achieved by passing in struct field values that map to |
| // the server attributes you want to see returned. Marker and Limit are used |
| // for pagination. |
| type ListOpts struct { |
| // A time/date stamp for when the server last changed status. |
| ChangesSince string `q:"changes-since"` |
| |
| // Name of the image in URL format. |
| Image string `q:"image"` |
| |
| // Name of the flavor in URL format. |
| Flavor string `q:"flavor"` |
| |
| // Name of the server as a string; can be queried with regular expressions. |
| // Realize that ?name=bob returns both bob and bobb. If you need to match bob |
| // only, you can use a regular expression matching the syntax of the |
| // underlying database server implemented for Compute. |
| Name string `q:"name"` |
| |
| // Value of the status of the server so that you can filter on "ACTIVE" for example. |
| Status string `q:"status"` |
| |
| // Name of the host as a string. |
| Host string `q:"host"` |
| |
| // UUID of the server at which you want to set a marker. |
| Marker string `q:"marker"` |
| |
| // Integer value for the limit of values to return. |
| Limit int `q:"limit"` |
| |
| // Bool to show all tenants |
| AllTenants bool `q:"all_tenants"` |
| } |
| |
| // ToServerListQuery formats a ListOpts into a query string. |
| func (opts ListOpts) ToServerListQuery() (string, error) { |
| q, err := gophercloud.BuildQueryString(opts) |
| return q.String(), err |
| } |
| |
| // List makes a request against the API to list servers accessible to you. |
| func List(client *gophercloud.ServiceClient, opts ListOptsBuilder) pagination.Pager { |
| url := listDetailURL(client) |
| if opts != nil { |
| query, err := opts.ToServerListQuery() |
| if err != nil { |
| return pagination.Pager{Err: err} |
| } |
| url += query |
| } |
| return pagination.NewPager(client, url, func(r pagination.PageResult) pagination.Page { |
| return ServerPage{pagination.LinkedPageBase{PageResult: r}} |
| }) |
| } |
| |
| // CreateOptsBuilder describes struct types that can be accepted by the Create call. |
| // The CreateOpts struct in this package does. |
| type CreateOptsBuilder interface { |
| ToServerCreateMap() (map[string]interface{}, error) |
| } |
| |
| // Network is used within CreateOpts to control a new server's network attachments. |
| type Network struct { |
| // UUID of a nova-network to attach to the newly provisioned server. |
| // Required unless Port is provided. |
| UUID string |
| |
| // Port of a neutron network to attach to the newly provisioned server. |
| // Required unless UUID is provided. |
| Port string |
| |
| // FixedIP [optional] specifies a fixed IPv4 address to be used on this network. |
| FixedIP string |
| } |
| |
| // Personality is an array of files that are injected into the server at launch. |
| type Personality []*File |
| |
| // File is used within CreateOpts and RebuildOpts to inject a file into the server at launch. |
| // File implements the json.Marshaler interface, so when a Create or Rebuild operation is requested, |
| // json.Marshal will call File's MarshalJSON method. |
| type File struct { |
| // Path of the file |
| Path string |
| // Contents of the file. Maximum content size is 255 bytes. |
| Contents []byte |
| } |
| |
| // MarshalJSON marshals the escaped file, base64 encoding the contents. |
| func (f *File) MarshalJSON() ([]byte, error) { |
| file := struct { |
| Path string `json:"path"` |
| Contents string `json:"contents"` |
| }{ |
| Path: f.Path, |
| Contents: base64.StdEncoding.EncodeToString(f.Contents), |
| } |
| return json.Marshal(file) |
| } |
| |
| // CreateOpts specifies server creation parameters. |
| type CreateOpts struct { |
| // Name is the name to assign to the newly launched server. |
| Name string `json:"name" required:"true"` |
| |
| // ImageRef [optional; required if ImageName is not provided] is the ID or full |
| // URL to the image that contains the server's OS and initial state. |
| // Also optional if using the boot-from-volume extension. |
| ImageRef string `json:"imageRef"` |
| |
| // ImageName [optional; required if ImageRef is not provided] is the name of the |
| // image that contains the server's OS and initial state. |
| // Also optional if using the boot-from-volume extension. |
| ImageName string `json:"-"` |
| |
| // FlavorRef [optional; required if FlavorName is not provided] is the ID or |
| // full URL to the flavor that describes the server's specs. |
| FlavorRef string `json:"flavorRef"` |
| |
| // FlavorName [optional; required if FlavorRef is not provided] is the name of |
| // the flavor that describes the server's specs. |
| FlavorName string `json:"-"` |
| |
| // SecurityGroups lists the names of the security groups to which this server should belong. |
| SecurityGroups []string `json:"-"` |
| |
| // UserData contains configuration information or scripts to use upon launch. |
| // Create will base64-encode it for you. |
| UserData []byte `json:"-"` |
| |
| // AvailabilityZone in which to launch the server. |
| AvailabilityZone string `json:"availability_zone,omitempty"` |
| |
| // Networks dictates how this server will be attached to available networks. |
| // By default, the server will be attached to all isolated networks for the tenant. |
| Networks []Network `json:"-"` |
| |
| // Metadata contains key-value pairs (up to 255 bytes each) to attach to the server. |
| Metadata map[string]string `json:"metadata,omitempty"` |
| |
| // Personality includes files to inject into the server at launch. |
| // Create will base64-encode file contents for you. |
| Personality Personality `json:"-"` |
| |
| // ConfigDrive enables metadata injection through a configuration drive. |
| ConfigDrive *bool `json:"config_drive,omitempty"` |
| |
| // AdminPass sets the root user password. If not set, a randomly-generated |
| // password will be created and returned in the rponse. |
| AdminPass string `json:"adminPass,omitempty"` |
| |
| // AccessIPv4 specifies an IPv4 address for the instance. |
| AccessIPv4 string `json:"accessIPv4,omitempty"` |
| |
| // AccessIPv6 pecifies an IPv6 address for the instance. |
| AccessIPv6 string `json:"accessIPv6,omitempty"` |
| |
| // ServiceClient will allow calls to be made to retrieve an image or |
| // flavor ID by name. |
| ServiceClient *gophercloud.ServiceClient `json:"-"` |
| } |
| |
| // ToServerCreateMap assembles a request body based on the contents of a CreateOpts. |
| func (opts CreateOpts) ToServerCreateMap() (map[string]interface{}, error) { |
| sc := opts.ServiceClient |
| opts.ServiceClient = nil |
| b, err := gophercloud.BuildRequestBody(opts, "") |
| if err != nil { |
| return nil, err |
| } |
| |
| if opts.UserData != nil { |
| encoded := base64.StdEncoding.EncodeToString(opts.UserData) |
| b["user_data"] = &encoded |
| } |
| |
| if len(opts.SecurityGroups) > 0 { |
| securityGroups := make([]map[string]interface{}, len(opts.SecurityGroups)) |
| for i, groupName := range opts.SecurityGroups { |
| securityGroups[i] = map[string]interface{}{"name": groupName} |
| } |
| b["security_groups"] = securityGroups |
| } |
| |
| if len(opts.Networks) > 0 { |
| networks := make([]map[string]interface{}, len(opts.Networks)) |
| for i, net := range opts.Networks { |
| networks[i] = make(map[string]interface{}) |
| if net.UUID != "" { |
| networks[i]["uuid"] = net.UUID |
| } |
| if net.Port != "" { |
| networks[i]["port"] = net.Port |
| } |
| if net.FixedIP != "" { |
| networks[i]["fixed_ip"] = net.FixedIP |
| } |
| } |
| b["networks"] = networks |
| } |
| |
| // If ImageRef isn't provided, use ImageName to ascertain the image ID. |
| if opts.ImageRef == "" { |
| if opts.ImageName == "" { |
| err := ErrNeitherImageIDNorImageNameProvided{} |
| err.Argument = "ImageRef/ImageName" |
| return nil, err |
| } |
| if sc == nil { |
| err := ErrNoClientProvidedForIDByName{} |
| err.Argument = "ServiceClient" |
| return nil, err |
| } |
| imageID, err := images.IDFromName(sc, opts.ImageName) |
| if err != nil { |
| return nil, err |
| } |
| b["imageRef"] = imageID |
| } |
| |
| // If FlavorRef isn't provided, use FlavorName to ascertain the flavor ID. |
| if opts.FlavorRef == "" { |
| if opts.FlavorName == "" { |
| err := ErrNeitherFlavorIDNorFlavorNameProvided{} |
| err.Argument = "FlavorRef/FlavorName" |
| return nil, err |
| } |
| if sc == nil { |
| err := ErrNoClientProvidedForIDByName{} |
| err.Argument = "ServiceClient" |
| return nil, err |
| } |
| flavorID, err := flavors.IDFromName(sc, opts.FlavorName) |
| if err != nil { |
| return nil, err |
| } |
| b["flavorRef"] = flavorID |
| } |
| |
| return map[string]interface{}{"server": b}, nil |
| } |
| |
| // Create requests a server to be provisioned to the user in the current tenant. |
| func Create(client *gophercloud.ServiceClient, opts CreateOptsBuilder) (r CreateResult) { |
| reqBody, err := opts.ToServerCreateMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Post(listURL(client), reqBody, &r.Body, nil) |
| return |
| } |
| |
| // Delete requests that a server previously provisioned be removed from your account. |
| func Delete(client *gophercloud.ServiceClient, id string) (r DeleteResult) { |
| _, r.Err = client.Delete(deleteURL(client, id), nil) |
| return |
| } |
| |
| // ForceDelete forces the deletion of a server |
| func ForceDelete(client *gophercloud.ServiceClient, id string) (r ActionResult) { |
| _, r.Err = client.Post(actionURL(client, id), map[string]interface{}{"forceDelete": ""}, nil, nil) |
| return |
| } |
| |
| // Get requests details on a single server, by ID. |
| func Get(client *gophercloud.ServiceClient, id string) (r GetResult) { |
| _, r.Err = client.Get(getURL(client, id), &r.Body, &gophercloud.RequestOpts{ |
| OkCodes: []int{200, 203}, |
| }) |
| return |
| } |
| |
| // UpdateOptsBuilder allows extensions to add additional attributes to the Update request. |
| type UpdateOptsBuilder interface { |
| ToServerUpdateMap() (map[string]interface{}, error) |
| } |
| |
| // UpdateOpts specifies the base attributes that may be updated on an existing server. |
| type UpdateOpts struct { |
| // Name changes the displayed name of the server. |
| // The server host name will *not* change. |
| // Server names are not constrained to be unique, even within the same tenant. |
| Name string `json:"name,omitempty"` |
| |
| // AccessIPv4 provides a new IPv4 address for the instance. |
| AccessIPv4 string `json:"accessIPv4,omitempty"` |
| |
| // AccessIPv6 provides a new IPv6 address for the instance. |
| AccessIPv6 string `json:"accessIPv6,omitempty"` |
| } |
| |
| // ToServerUpdateMap formats an UpdateOpts structure into a request body. |
| func (opts UpdateOpts) ToServerUpdateMap() (map[string]interface{}, error) { |
| return gophercloud.BuildRequestBody(opts, "server") |
| } |
| |
| // Update requests that various attributes of the indicated server be changed. |
| func Update(client *gophercloud.ServiceClient, id string, opts UpdateOptsBuilder) (r UpdateResult) { |
| b, err := opts.ToServerUpdateMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Put(updateURL(client, id), b, &r.Body, &gophercloud.RequestOpts{ |
| OkCodes: []int{200}, |
| }) |
| return |
| } |
| |
| // ChangeAdminPassword alters the administrator or root password for a specified server. |
| func ChangeAdminPassword(client *gophercloud.ServiceClient, id, newPassword string) (r ActionResult) { |
| b := map[string]interface{}{ |
| "changePassword": map[string]string{ |
| "adminPass": newPassword, |
| }, |
| } |
| _, r.Err = client.Post(actionURL(client, id), b, nil, nil) |
| return |
| } |
| |
| // RebootMethod describes the mechanisms by which a server reboot can be requested. |
| type RebootMethod string |
| |
| // These constants determine how a server should be rebooted. |
| // See the Reboot() function for further details. |
| const ( |
| SoftReboot RebootMethod = "SOFT" |
| HardReboot RebootMethod = "HARD" |
| OSReboot = SoftReboot |
| PowerCycle = HardReboot |
| ) |
| |
| // RebootOptsBuilder is an interface that options must satisfy in order to be |
| // used when rebooting a server instance |
| type RebootOptsBuilder interface { |
| ToServerRebootMap() (map[string]interface{}, error) |
| } |
| |
| // RebootOpts satisfies the RebootOptsBuilder interface |
| type RebootOpts struct { |
| Type RebootMethod `json:"type" required:"true"` |
| } |
| |
| // ToServerRebootMap allows RebootOpts to satisfiy the RebootOptsBuilder |
| // interface |
| func (opts *RebootOpts) ToServerRebootMap() (map[string]interface{}, error) { |
| return gophercloud.BuildRequestBody(opts, "reboot") |
| } |
| |
| // Reboot requests that a given server reboot. |
| // Two methods exist for rebooting a server: |
| // |
| // HardReboot (aka PowerCycle) starts the server instance by physically cutting power to the machine, or if a VM, |
| // terminating it at the hypervisor level. |
| // It's done. Caput. Full stop. |
| // Then, after a brief while, power is rtored or the VM instance rtarted. |
| // |
| // SoftReboot (aka OSReboot) simply tells the OS to rtart under its own procedur. |
| // E.g., in Linux, asking it to enter runlevel 6, or executing "sudo shutdown -r now", or by asking Windows to rtart the machine. |
| func Reboot(client *gophercloud.ServiceClient, id string, opts RebootOptsBuilder) (r ActionResult) { |
| b, err := opts.ToServerRebootMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Post(actionURL(client, id), b, nil, nil) |
| return |
| } |
| |
| // RebuildOptsBuilder is an interface that allows extensions to override the |
| // default behaviour of rebuild options |
| type RebuildOptsBuilder interface { |
| ToServerRebuildMap() (map[string]interface{}, error) |
| } |
| |
| // RebuildOpts represents the configuration options used in a server rebuild |
| // operation |
| type RebuildOpts struct { |
| // The server's admin password |
| AdminPass string `json:"adminPass" required:"true"` |
| // The ID of the image you want your server to be provisioned on |
| ImageID string `json:"imageRef"` |
| ImageName string `json:"-"` |
| //ImageName string `json:"-"` |
| // Name to set the server to |
| Name string `json:"name,omitempty"` |
| // AccessIPv4 [optional] provides a new IPv4 address for the instance. |
| AccessIPv4 string `json:"accessIPv4,omitempty"` |
| // AccessIPv6 [optional] provides a new IPv6 address for the instance. |
| AccessIPv6 string `json:"accessIPv6,omitempty"` |
| // Metadata [optional] contains key-value pairs (up to 255 bytes each) to attach to the server. |
| Metadata map[string]string `json:"metadata,omitempty"` |
| // Personality [optional] includes files to inject into the server at launch. |
| // Rebuild will base64-encode file contents for you. |
| Personality Personality `json:"personality,omitempty"` |
| ServiceClient *gophercloud.ServiceClient `json:"-"` |
| } |
| |
| // ToServerRebuildMap formats a RebuildOpts struct into a map for use in JSON |
| func (opts RebuildOpts) ToServerRebuildMap() (map[string]interface{}, error) { |
| b, err := gophercloud.BuildRequestBody(opts, "") |
| if err != nil { |
| return nil, err |
| } |
| |
| // If ImageRef isn't provided, use ImageName to ascertain the image ID. |
| if opts.ImageID == "" { |
| if opts.ImageName == "" { |
| err := ErrNeitherImageIDNorImageNameProvided{} |
| err.Argument = "ImageRef/ImageName" |
| return nil, err |
| } |
| if opts.ServiceClient == nil { |
| err := ErrNoClientProvidedForIDByName{} |
| err.Argument = "ServiceClient" |
| return nil, err |
| } |
| imageID, err := images.IDFromName(opts.ServiceClient, opts.ImageName) |
| if err != nil { |
| return nil, err |
| } |
| b["imageRef"] = imageID |
| } |
| |
| return map[string]interface{}{"rebuild": b}, nil |
| } |
| |
| // Rebuild will reprovision the server according to the configuration options |
| // provided in the RebuildOpts struct. |
| func Rebuild(client *gophercloud.ServiceClient, id string, opts RebuildOptsBuilder) (r RebuildResult) { |
| b, err := opts.ToServerRebuildMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Post(actionURL(client, id), b, &r.Body, nil) |
| return |
| } |
| |
| // ResizeOptsBuilder is an interface that allows extensions to override the default structure of |
| // a Resize request. |
| type ResizeOptsBuilder interface { |
| ToServerResizeMap() (map[string]interface{}, error) |
| } |
| |
| // ResizeOpts represents the configuration options used to control a Resize operation. |
| type ResizeOpts struct { |
| // FlavorRef is the ID of the flavor you wish your server to become. |
| FlavorRef string `json:"flavorRef" required:"true"` |
| } |
| |
| // ToServerResizeMap formats a ResizeOpts as a map that can be used as a JSON request body for the |
| // Resize request. |
| func (opts ResizeOpts) ToServerResizeMap() (map[string]interface{}, error) { |
| return gophercloud.BuildRequestBody(opts, "resize") |
| } |
| |
| // Resize instructs the provider to change the flavor of the server. |
| // Note that this implies rebuilding it. |
| // Unfortunately, one cannot pass rebuild parameters to the resize function. |
| // When the resize completes, the server will be in RESIZE_VERIFY state. |
| // While in this state, you can explore the use of the new server's configuration. |
| // If you like it, call ConfirmResize() to commit the resize permanently. |
| // Otherwise, call RevertResize() to restore the old configuration. |
| func Resize(client *gophercloud.ServiceClient, id string, opts ResizeOptsBuilder) (r ActionResult) { |
| b, err := opts.ToServerResizeMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Post(actionURL(client, id), b, nil, nil) |
| return |
| } |
| |
| // ConfirmResize confirms a previous resize operation on a server. |
| // See Resize() for more details. |
| func ConfirmResize(client *gophercloud.ServiceClient, id string) (r ActionResult) { |
| _, r.Err = client.Post(actionURL(client, id), map[string]interface{}{"confirmResize": nil}, nil, &gophercloud.RequestOpts{ |
| OkCodes: []int{201, 202, 204}, |
| }) |
| return |
| } |
| |
| // RevertResize cancels a previous resize operation on a server. |
| // See Resize() for more details. |
| func RevertResize(client *gophercloud.ServiceClient, id string) (r ActionResult) { |
| _, r.Err = client.Post(actionURL(client, id), map[string]interface{}{"revertResize": nil}, nil, nil) |
| return |
| } |
| |
| // RescueOptsBuilder is an interface that allows extensions to override the |
| // default structure of a Rescue request. |
| type RescueOptsBuilder interface { |
| ToServerRescueMap() (map[string]interface{}, error) |
| } |
| |
| // RescueOpts represents the configuration options used to control a Rescue |
| // option. |
| type RescueOpts struct { |
| // AdminPass is the desired administrative password for the instance in |
| // RESCUE mode. If it's left blank, the server will generate a password. |
| AdminPass string `json:"adminPass,omitempty"` |
| } |
| |
| // ToServerRescueMap formats a RescueOpts as a map that can be used as a JSON |
| // request body for the Rescue request. |
| func (opts RescueOpts) ToServerRescueMap() (map[string]interface{}, error) { |
| return gophercloud.BuildRequestBody(opts, "rescue") |
| } |
| |
| // Rescue instructs the provider to place the server into RESCUE mode. |
| func Rescue(client *gophercloud.ServiceClient, id string, opts RescueOptsBuilder) (r RescueResult) { |
| b, err := opts.ToServerRescueMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Post(actionURL(client, id), b, &r.Body, &gophercloud.RequestOpts{ |
| OkCodes: []int{200}, |
| }) |
| return |
| } |
| |
| // ResetMetadataOptsBuilder allows extensions to add additional parameters to the |
| // Reset request. |
| type ResetMetadataOptsBuilder interface { |
| ToMetadataResetMap() (map[string]interface{}, error) |
| } |
| |
| // MetadataOpts is a map that contains key-value pairs. |
| type MetadataOpts map[string]string |
| |
| // ToMetadataResetMap assembles a body for a Reset request based on the contents of a MetadataOpts. |
| func (opts MetadataOpts) ToMetadataResetMap() (map[string]interface{}, error) { |
| return map[string]interface{}{"metadata": opts}, nil |
| } |
| |
| // ToMetadataUpdateMap assembles a body for an Update request based on the contents of a MetadataOpts. |
| func (opts MetadataOpts) ToMetadataUpdateMap() (map[string]interface{}, error) { |
| return map[string]interface{}{"metadata": opts}, nil |
| } |
| |
| // ResetMetadata will create multiple new key-value pairs for the given server ID. |
| // Note: Using this operation will erase any already-existing metadata and create |
| // the new metadata provided. To keep any already-existing metadata, use the |
| // UpdateMetadatas or UpdateMetadata function. |
| func ResetMetadata(client *gophercloud.ServiceClient, id string, opts ResetMetadataOptsBuilder) (r ResetMetadataResult) { |
| b, err := opts.ToMetadataResetMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Put(metadataURL(client, id), b, &r.Body, &gophercloud.RequestOpts{ |
| OkCodes: []int{200}, |
| }) |
| return |
| } |
| |
| // Metadata requests all the metadata for the given server ID. |
| func Metadata(client *gophercloud.ServiceClient, id string) (r GetMetadataResult) { |
| _, r.Err = client.Get(metadataURL(client, id), &r.Body, nil) |
| return |
| } |
| |
| // UpdateMetadataOptsBuilder allows extensions to add additional parameters to the |
| // Create request. |
| type UpdateMetadataOptsBuilder interface { |
| ToMetadataUpdateMap() (map[string]interface{}, error) |
| } |
| |
| // UpdateMetadata updates (or creates) all the metadata specified by opts for the given server ID. |
| // This operation does not affect already-existing metadata that is not specified |
| // by opts. |
| func UpdateMetadata(client *gophercloud.ServiceClient, id string, opts UpdateMetadataOptsBuilder) (r UpdateMetadataResult) { |
| b, err := opts.ToMetadataUpdateMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Post(metadataURL(client, id), b, &r.Body, &gophercloud.RequestOpts{ |
| OkCodes: []int{200}, |
| }) |
| return |
| } |
| |
| // MetadatumOptsBuilder allows extensions to add additional parameters to the |
| // Create request. |
| type MetadatumOptsBuilder interface { |
| ToMetadatumCreateMap() (map[string]interface{}, string, error) |
| } |
| |
| // MetadatumOpts is a map of length one that contains a key-value pair. |
| type MetadatumOpts map[string]string |
| |
| // ToMetadatumCreateMap assembles a body for a Create request based on the contents of a MetadataumOpts. |
| func (opts MetadatumOpts) ToMetadatumCreateMap() (map[string]interface{}, string, error) { |
| if len(opts) != 1 { |
| err := gophercloud.ErrInvalidInput{} |
| err.Argument = "servers.MetadatumOpts" |
| err.Info = "Must have 1 and only 1 key-value pair" |
| return nil, "", err |
| } |
| metadatum := map[string]interface{}{"meta": opts} |
| var key string |
| for k := range metadatum["meta"].(MetadatumOpts) { |
| key = k |
| } |
| return metadatum, key, nil |
| } |
| |
| // CreateMetadatum will create or update the key-value pair with the given key for the given server ID. |
| func CreateMetadatum(client *gophercloud.ServiceClient, id string, opts MetadatumOptsBuilder) (r CreateMetadatumResult) { |
| b, key, err := opts.ToMetadatumCreateMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| _, r.Err = client.Put(metadatumURL(client, id, key), b, &r.Body, &gophercloud.RequestOpts{ |
| OkCodes: []int{200}, |
| }) |
| return |
| } |
| |
| // Metadatum requests the key-value pair with the given key for the given server ID. |
| func Metadatum(client *gophercloud.ServiceClient, id, key string) (r GetMetadatumResult) { |
| _, r.Err = client.Get(metadatumURL(client, id, key), &r.Body, nil) |
| return |
| } |
| |
| // DeleteMetadatum will delete the key-value pair with the given key for the given server ID. |
| func DeleteMetadatum(client *gophercloud.ServiceClient, id, key string) (r DeleteMetadatumResult) { |
| _, r.Err = client.Delete(metadatumURL(client, id, key), nil) |
| return |
| } |
| |
| // ListAddresses makes a request against the API to list the servers IP addresses. |
| func ListAddresses(client *gophercloud.ServiceClient, id string) pagination.Pager { |
| return pagination.NewPager(client, listAddressesURL(client, id), func(r pagination.PageResult) pagination.Page { |
| return AddressPage{pagination.SinglePageBase(r)} |
| }) |
| } |
| |
| // ListAddressesByNetwork makes a request against the API to list the servers IP addresses |
| // for the given network. |
| func ListAddressesByNetwork(client *gophercloud.ServiceClient, id, network string) pagination.Pager { |
| return pagination.NewPager(client, listAddressesByNetworkURL(client, id, network), func(r pagination.PageResult) pagination.Page { |
| return NetworkAddressPage{pagination.SinglePageBase(r)} |
| }) |
| } |
| |
| // CreateImageOptsBuilder is the interface types must satisfy in order to be |
| // used as CreateImage options |
| type CreateImageOptsBuilder interface { |
| ToServerCreateImageMap() (map[string]interface{}, error) |
| } |
| |
| // CreateImageOpts satisfies the CreateImageOptsBuilder |
| type CreateImageOpts struct { |
| // Name of the image/snapshot |
| Name string `json:"name" required:"true"` |
| // Metadata contains key-value pairs (up to 255 bytes each) to attach to the created image. |
| Metadata map[string]string `json:"metadata,omitempty"` |
| } |
| |
| // ToServerCreateImageMap formats a CreateImageOpts structure into a request body. |
| func (opts CreateImageOpts) ToServerCreateImageMap() (map[string]interface{}, error) { |
| return gophercloud.BuildRequestBody(opts, "createImage") |
| } |
| |
| // CreateImage makes a request against the nova API to schedule an image to be created of the server |
| func CreateImage(client *gophercloud.ServiceClient, id string, opts CreateImageOptsBuilder) (r CreateImageResult) { |
| b, err := opts.ToServerCreateImageMap() |
| if err != nil { |
| r.Err = err |
| return |
| } |
| resp, err := client.Post(actionURL(client, id), b, nil, &gophercloud.RequestOpts{ |
| OkCodes: []int{202}, |
| }) |
| r.Err = err |
| r.Header = resp.Header |
| return |
| } |
| |
| // IDFromName is a convienience function that returns a server's ID given its name. |
| func IDFromName(client *gophercloud.ServiceClient, name string) (string, error) { |
| count := 0 |
| id := "" |
| allPages, err := List(client, nil).AllPages() |
| if err != nil { |
| return "", err |
| } |
| |
| all, err := ExtractServers(allPages) |
| if err != nil { |
| return "", err |
| } |
| |
| for _, f := range all { |
| if f.Name == name { |
| count++ |
| id = f.ID |
| } |
| } |
| |
| switch count { |
| case 0: |
| return "", gophercloud.ErrResourceNotFound{Name: name, ResourceType: "server"} |
| case 1: |
| return id, nil |
| default: |
| return "", gophercloud.ErrMultipleResourcesFound{Name: name, Count: count, ResourceType: "server"} |
| } |
| } |
| |
| // GetPassword makes a request against the nova API to get the encrypted administrative password. |
| func GetPassword(client *gophercloud.ServiceClient, serverId string) (r GetPasswordResult) { |
| _, r.Err = client.Get(passwordURL(client, serverId), &r.Body, nil) |
| return |
| } |