blob: d247bf934195438884d6655f91dc7f7dd809cf89 [file] [log] [blame]
package nodes
import (
"fmt"
"gerrit.mcp.mirantis.net/debian/gophercloud.git"
"gerrit.mcp.mirantis.net/debian/gophercloud.git/pagination"
)
// ListOptsBuilder allows extensions to add additional parameters to the
// List request.
type ListOptsBuilder interface {
ToNodeListQuery() (string, error)
ToNodeListDetailQuery() (string, error)
}
// Provision state reports the current provision state of the node, these are only used in filtering
type ProvisionState string
const (
Enroll ProvisionState = "enroll"
Verifying ProvisionState = "verifying"
Manageable ProvisionState = "manageable"
Available ProvisionState = "available"
Active ProvisionState = "active"
DeployWait ProvisionState = "wait call-back"
Deploying ProvisionState = "deploying"
DeployFail ProvisionState = "deploy failed"
DeployDone ProvisionState = "deploy complete"
Deleting ProvisionState = "deleting"
Deleted ProvisionState = "deleted"
Cleaning ProvisionState = "cleaning"
CleanWait ProvisionState = "clean wait"
CleanFail ProvisionState = "clean failed"
Error ProvisionState = "error"
Rebuild ProvisionState = "rebuild"
Inspecting ProvisionState = "inspecting"
InspectFail ProvisionState = "inspect failed"
InspectWait ProvisionState = "inspect wait"
Adopting ProvisionState = "adopting"
AdoptFail ProvisionState = "adopt failed"
Rescue ProvisionState = "rescue"
RescueFail ProvisionState = "rescue failed"
Rescuing ProvisionState = "rescuing"
UnrescueFail ProvisionState = "unrescue failed"
)
// TargetProvisionState is used when setting the provision state for a node.
type TargetProvisionState string
const (
TargetActive TargetProvisionState = "active"
TargetDeleted TargetProvisionState = "deleted"
TargetManage TargetProvisionState = "manage"
TargetProvide TargetProvisionState = "provide"
TargetInspect TargetProvisionState = "inspect"
TargetAbort TargetProvisionState = "abort"
TargetClean TargetProvisionState = "clean"
TargetAdopt TargetProvisionState = "adopt"
TargetRescue TargetProvisionState = "rescue"
TargetUnrescue TargetProvisionState = "unrescue"
)
// 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 node attributes you want to see returned. Marker and Limit are used
// for pagination.
type ListOpts struct {
// Filter the list by specific instance UUID
InstanceUUID string `q:"instance_uuid"`
// Filter the list by chassis UUID
ChassisUUID string `q:"chassis_uuid"`
// Filter the list by maintenance set to True or False
Maintenance bool `q:"maintenance"`
// Nodes which are, or are not, associated with an instance_uuid.
Associated bool `q:"associated"`
// Only return those with the specified provision_state.
ProvisionState ProvisionState `q:"provision_state"`
// Filter the list with the specified driver.
Driver string `q:"driver"`
// Filter the list with the specified resource class.
ResourceClass string `q:"resource_class"`
// Filter the list with the specified conductor_group.
ConductorGroup string `q:"conductor_group"`
// Filter the list with the specified fault.
Fault string `q:"fault"`
// One or more fields to be returned in the response.
Fields []string `q:"fields"`
// Requests a page size of items.
Limit int `q:"limit"`
// The ID of the last-seen item.
Marker string `q:"marker"`
// Sorts the response by the requested sort direction.
SortDir string `q:"sort_dir"`
// Sorts the response by the this attribute value.
SortKey string `q:"sort_key"`
// A string or UUID of the tenant who owns the baremetal node.
Owner string `q:"owner"`
}
// ToNodeListQuery formats a ListOpts into a query string.
func (opts ListOpts) ToNodeListQuery() (string, error) {
q, err := gophercloud.BuildQueryString(opts)
return q.String(), err
}
// List makes a request against the API to list nodes accessible to you.
func List(client *gophercloud.ServiceClient, opts ListOptsBuilder) pagination.Pager {
url := listURL(client)
if opts != nil {
query, err := opts.ToNodeListQuery()
if err != nil {
return pagination.Pager{Err: err}
}
url += query
}
return pagination.NewPager(client, url, func(r pagination.PageResult) pagination.Page {
return NodePage{pagination.LinkedPageBase{PageResult: r}}
})
}
// ToNodeListDetailQuery formats a ListOpts into a query string for the list details API.
func (opts ListOpts) ToNodeListDetailQuery() (string, error) {
// Detail endpoint can't filter by Fields
if len(opts.Fields) > 0 {
return "", fmt.Errorf("fields is not a valid option when getting a detailed listing of nodes")
}
q, err := gophercloud.BuildQueryString(opts)
return q.String(), err
}
// Return a list of bare metal Nodes with complete details. Some filtering is possible by passing in flags in ListOpts,
// but you cannot limit by the fields returned.
func ListDetail(client *gophercloud.ServiceClient, opts ListOptsBuilder) pagination.Pager {
// This URL is deprecated. In the future, we should compare the microversion and if >= 1.43, hit the listURL
// with ListOpts{Detail: true,}
url := listDetailURL(client)
if opts != nil {
query, err := opts.ToNodeListDetailQuery()
if err != nil {
return pagination.Pager{Err: err}
}
url += query
}
return pagination.NewPager(client, url, func(r pagination.PageResult) pagination.Page {
return NodePage{pagination.LinkedPageBase{PageResult: r}}
})
}
// Get requests details on a single node, 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},
})
return
}
// CreateOptsBuilder allows extensions to add additional parameters to the
// Create request.
type CreateOptsBuilder interface {
ToNodeCreateMap() (map[string]interface{}, error)
}
// CreateOpts specifies node creation parameters.
type CreateOpts struct {
// The boot interface for a Node, e.g. “pxe”.
BootInterface string `json:"boot_interface,omitempty"`
// The conductor group for a node. Case-insensitive string up to 255 characters, containing a-z, 0-9, _, -, and ..
ConductorGroup string `json:"conductor_group,omitempty"`
// The console interface for a node, e.g. “no-console”.
ConsoleInterface string `json:"console_interface,omitempty"`
// The deploy interface for a node, e.g. “iscsi”.
DeployInterface string `json:"deploy_interface,omitempty"`
// All the metadata required by the driver to manage this Node. List of fields varies between drivers, and can
// be retrieved from the /v1/drivers/<DRIVER_NAME>/properties resource.
DriverInfo map[string]interface{} `json:"driver_info,omitempty"`
// name of the driver used to manage this Node.
Driver string `json:"driver,omitempty"`
// A set of one or more arbitrary metadata key and value pairs.
Extra map[string]interface{} `json:"extra,omitempty"`
// The interface used for node inspection, e.g. “no-inspect”.
InspectInterface string `json:"inspect_interface,omitempty"`
// Interface for out-of-band node management, e.g. “ipmitool”.
ManagementInterface string `json:"management_interface,omitempty"`
// Human-readable identifier for the Node resource. May be undefined. Certain words are reserved.
Name string `json:"name,omitempty"`
// Which Network Interface provider to use when plumbing the network connections for this Node.
NetworkInterface string `json:"network_interface,omitempty"`
// Interface used for performing power actions on the node, e.g. “ipmitool”.
PowerInterface string `json:"power_interface,omitempty"`
// Physical characteristics of this Node. Populated during inspection, if performed. Can be edited via the REST
// API at any time.
Properties map[string]interface{} `json:"properties,omitempty"`
// Interface used for configuring RAID on this node, e.g. “no-raid”.
RAIDInterface string `json:"raid_interface,omitempty"`
// The interface used for node rescue, e.g. “no-rescue”.
RescueInterface string `json:"rescue_interface,omitempty"`
// A string which can be used by external schedulers to identify this Node as a unit of a specific type
// of resource.
ResourceClass string `json:"resource_class,omitempty"`
// Interface used for attaching and detaching volumes on this node, e.g. “cinder”.
StorageInterface string `json:"storage_interface,omitempty"`
// The UUID for the resource.
UUID string `json:"uuid,omitempty"`
// Interface for vendor-specific functionality on this node, e.g. “no-vendor”.
VendorInterface string `json:"vendor_interface,omitempty"`
// A string or UUID of the tenant who owns the baremetal node.
Owner string `json:"owner,omitempty"`
}
// ToNodeCreateMap assembles a request body based on the contents of a CreateOpts.
func (opts CreateOpts) ToNodeCreateMap() (map[string]interface{}, error) {
body, err := gophercloud.BuildRequestBody(opts, "")
if err != nil {
return nil, err
}
return body, nil
}
// Create requests a node to be created
func Create(client *gophercloud.ServiceClient, opts CreateOptsBuilder) (r CreateResult) {
reqBody, err := opts.ToNodeCreateMap()
if err != nil {
r.Err = err
return
}
_, r.Err = client.Post(createURL(client), reqBody, &r.Body, nil)
return
}
type Patch interface {
ToNodeUpdateMap() (map[string]interface{}, error)
}
// UpdateOpts is a slice of Patches used to update a node
type UpdateOpts []Patch
type UpdateOp string
const (
ReplaceOp UpdateOp = "replace"
AddOp UpdateOp = "add"
RemoveOp UpdateOp = "remove"
)
type UpdateOperation struct {
Op UpdateOp `json:"op" required:"true"`
Path string `json:"path" required:"true"`
Value interface{} `json:"value,omitempty"`
}
func (opts UpdateOperation) ToNodeUpdateMap() (map[string]interface{}, error) {
return gophercloud.BuildRequestBody(opts, "")
}
// Update requests that a node be updated
func Update(client *gophercloud.ServiceClient, id string, opts UpdateOpts) (r UpdateResult) {
body := make([]map[string]interface{}, len(opts))
for i, patch := range opts {
result, err := patch.ToNodeUpdateMap()
if err != nil {
r.Err = err
return
}
body[i] = result
}
_, r.Err = client.Patch(updateURL(client, id), body, &r.Body, &gophercloud.RequestOpts{
JSONBody: &body,
OkCodes: []int{200},
})
return
}
// Delete requests that a node be removed
func Delete(client *gophercloud.ServiceClient, id string) (r DeleteResult) {
_, r.Err = client.Delete(deleteURL(client, id), nil)
return
}
// Request that Ironic validate whether the Node’s driver has enough information to manage the Node. This polls each
// interface on the driver, and returns the status of that interface.
func Validate(client *gophercloud.ServiceClient, id string) (r ValidateResult) {
_, r.Err = client.Get(validateURL(client, id), &r.Body, &gophercloud.RequestOpts{
OkCodes: []int{200},
})
return
}
// Inject NMI (Non-Masking Interrupts) for the given Node. This feature can be used for hardware diagnostics, and
// actual support depends on a driver.
func InjectNMI(client *gophercloud.ServiceClient, id string) (r InjectNMIResult) {
_, r.Err = client.Put(injectNMIURL(client, id), map[string]string{}, nil, &gophercloud.RequestOpts{
OkCodes: []int{204},
})
return
}
type BootDeviceOpts struct {
BootDevice string `json:"boot_device"` // e.g., 'pxe', 'disk', etc.
Persistent bool `json:"persistent"` // Whether this is one-time or not
}
// BootDeviceOptsBuilder allows extensions to add additional parameters to the
// SetBootDevice request.
type BootDeviceOptsBuilder interface {
ToBootDeviceMap() (map[string]interface{}, error)
}
// ToBootDeviceSetMap assembles a request body based on the contents of a BootDeviceOpts.
func (opts BootDeviceOpts) ToBootDeviceMap() (map[string]interface{}, error) {
body, err := gophercloud.BuildRequestBody(opts, "")
if err != nil {
return nil, err
}
return body, nil
}
// Set the boot device for the given Node, and set it persistently or for one-time boot. The exact behaviour
// of this depends on the hardware driver.
func SetBootDevice(client *gophercloud.ServiceClient, id string, bootDevice BootDeviceOptsBuilder) (r SetBootDeviceResult) {
reqBody, err := bootDevice.ToBootDeviceMap()
if err != nil {
r.Err = err
return
}
_, r.Err = client.Put(bootDeviceURL(client, id), reqBody, nil, &gophercloud.RequestOpts{
OkCodes: []int{204},
})
return
}
// Get the current boot device for the given Node.
func GetBootDevice(client *gophercloud.ServiceClient, id string) (r BootDeviceResult) {
_, r.Err = client.Get(bootDeviceURL(client, id), &r.Body, &gophercloud.RequestOpts{
OkCodes: []int{200},
})
return
}
// Retrieve the acceptable set of supported boot devices for a specific Node.
func GetSupportedBootDevices(client *gophercloud.ServiceClient, id string) (r SupportedBootDeviceResult) {
_, r.Err = client.Get(supportedBootDeviceURL(client, id), &r.Body, &gophercloud.RequestOpts{
OkCodes: []int{200},
})
return
}
// A cleaning step has required keys ‘interface’ and ‘step’, and optional key ‘args’. If specified,
// the value for ‘args’ is a keyword variable argument dictionary that is passed to the cleaning step
// method.
type CleanStep struct {
Interface string `json:"interface" required:"true"`
Step string `json:"step" required:"true"`
Args map[string]interface{} `json:"args,omitempty"`
}
// ProvisionStateOptsBuilder allows extensions to add additional parameters to the
// ChangeProvisionState request.
type ProvisionStateOptsBuilder interface {
ToProvisionStateMap() (map[string]interface{}, error)
}
// Starting with Ironic API version 1.56, a configdrive may be a JSON object with structured data.
// Prior to this version, it must be a base64-encoded, gzipped ISO9660 image.
type ConfigDrive struct {
MetaData map[string]interface{} `json:"meta_data,omitempty"`
NetworkData map[string]interface{} `json:"network_data,omitempty"`
UserData interface{} `json:"user_data,omitempty"`
}
// ProvisionStateOpts for a request to change a node's provision state. A config drive should be base64-encoded
// gzipped ISO9660 image.
type ProvisionStateOpts struct {
Target TargetProvisionState `json:"target" required:"true"`
ConfigDrive interface{} `json:"configdrive,omitempty"`
CleanSteps []CleanStep `json:"clean_steps,omitempty"`
RescuePassword string `json:"rescue_password,omitempty"`
}
// ToProvisionStateMap assembles a request body based on the contents of a CreateOpts.
func (opts ProvisionStateOpts) ToProvisionStateMap() (map[string]interface{}, error) {
body, err := gophercloud.BuildRequestBody(opts, "")
if err != nil {
return nil, err
}
return body, nil
}
// Request a change to the Node’s provision state. Acceptable target states depend on the Node’s current provision
// state. More detailed documentation of the Ironic State Machine is available in the developer docs.
func ChangeProvisionState(client *gophercloud.ServiceClient, id string, opts ProvisionStateOptsBuilder) (r ChangeStateResult) {
reqBody, err := opts.ToProvisionStateMap()
if err != nil {
r.Err = err
return
}
_, r.Err = client.Put(provisionStateURL(client, id), reqBody, nil, &gophercloud.RequestOpts{
OkCodes: []int{202},
})
return
}
type TargetPowerState string
// TargetPowerState is used when changing the power state of a node.
const (
PowerOn TargetPowerState = "power on"
PowerOff TargetPowerState = "power off"
Rebooting TargetPowerState = "rebooting"
SoftPowerOff TargetPowerState = "soft power off"
SoftRebooting TargetPowerState = "soft rebooting"
)
// PowerStateOptsBuilder allows extensions to add additional parameters to the ChangePowerState request.
type PowerStateOptsBuilder interface {
ToPowerStateMap() (map[string]interface{}, error)
}
// PowerStateOpts for a request to change a node's power state.
type PowerStateOpts struct {
Target TargetPowerState `json:"target" required:"true"`
Timeout int `json:"timeout,omitempty"`
}
// ToPowerStateMap assembles a request body based on the contents of a PowerStateOpts.
func (opts PowerStateOpts) ToPowerStateMap() (map[string]interface{}, error) {
body, err := gophercloud.BuildRequestBody(opts, "")
if err != nil {
return nil, err
}
return body, nil
}
// Request to change a Node's power state.
func ChangePowerState(client *gophercloud.ServiceClient, id string, opts PowerStateOptsBuilder) (r ChangePowerStateResult) {
reqBody, err := opts.ToPowerStateMap()
if err != nil {
r.Err = err
return
}
_, r.Err = client.Put(powerStateURL(client, id), reqBody, nil, &gophercloud.RequestOpts{
OkCodes: []int{202},
})
return
}
// This is the desired RAID configuration on the bare metal node.
type RAIDConfigOpts struct {
LogicalDisks []LogicalDisk `json:"logical_disks"`
}
// RAIDConfigOptsBuilder allows extensions to modify a set RAID config request.
type RAIDConfigOptsBuilder interface {
ToRAIDConfigMap() (map[string]interface{}, error)
}
// RAIDLevel type is used to specify the RAID level for a logical disk.
type RAIDLevel string
const (
RAID0 RAIDLevel = "0"
RAID1 RAIDLevel = "1"
RAID2 RAIDLevel = "2"
RAID5 RAIDLevel = "5"
RAID6 RAIDLevel = "6"
RAID10 RAIDLevel = "1+0"
RAID50 RAIDLevel = "5+0"
RAID60 RAIDLevel = "6+0"
)
// DiskType is used to specify the disk type for a logical disk, e.g. hdd or ssd.
type DiskType string
const (
HDD DiskType = "hdd"
SSD DiskType = "ssd"
)
// InterfaceType is used to specify the interface for a logical disk.
type InterfaceType string
const (
SATA InterfaceType = "sata"
SCSI InterfaceType = "scsi"
SAS InterfaceType = "sas"
)
type LogicalDisk struct {
// Size (Integer) of the logical disk to be created in GiB. If unspecified, "MAX" will be used.
SizeGB *int `json:"size_gb"`
// RAID level for the logical disk.
RAIDLevel RAIDLevel `json:"raid_level" required:"true"`
// Name of the volume. Should be unique within the Node. If not specified, volume name will be auto-generated.
VolumeName string `json:"volume_name,omitempty"`
// Set to true if this is the root volume. At most one logical disk can have this set to true.
IsRootVolume *bool `json:"is_root_volume,omitempty"`
// Set to true if this logical disk can share physical disks with other logical disks.
SharePhysicalDisks *bool `json:"share_physical_disks,omitempty"`
// If this is not specified, disk type will not be a criterion to find backing physical disks
DiskType DiskType `json:"disk_type,omitempty"`
// If this is not specified, interface type will not be a criterion to find backing physical disks.
InterfaceType InterfaceType `json:"interface_type,omitempty"`
// Integer, number of disks to use for the logical disk. Defaults to minimum number of disks required
// for the particular RAID level.
NumberOfPhysicalDisks int `json:"number_of_physical_disks,omitempty"`
// The name of the controller as read by the RAID interface.
Controller string `json:"controller,omitempty"`
// A list of physical disks to use as read by the RAID interface.
PhysicalDisks []string `json:"physical_disks,omitempty"`
}
func (opts RAIDConfigOpts) ToRAIDConfigMap() (map[string]interface{}, error) {
body, err := gophercloud.BuildRequestBody(opts, "")
if err != nil {
return nil, err
}
for _, v := range body["logical_disks"].([]interface{}) {
if logicalDisk, ok := v.(map[string]interface{}); ok {
if logicalDisk["size_gb"] == nil {
logicalDisk["size_gb"] = "MAX"
}
}
}
return body, nil
}
// Request to change a Node's RAID config.
func SetRAIDConfig(client *gophercloud.ServiceClient, id string, raidConfigOptsBuilder RAIDConfigOptsBuilder) (r ChangeStateResult) {
reqBody, err := raidConfigOptsBuilder.ToRAIDConfigMap()
if err != nil {
r.Err = err
return
}
_, r.Err = client.Put(raidConfigURL(client, id), reqBody, nil, &gophercloud.RequestOpts{
OkCodes: []int{204},
})
return
}