rackspace

Documentation

Index

• Constants
• Variables
• type Config
• type Instances
  • func (i *Instances) AddSSHKeyToAllInstances(user string, keyData []byte) error
  • func (i *Instances) CurrentNodeName(hostname string) (types.NodeName, error)
  • func (i *Instances) ExternalID(nodeName types.NodeName) (string, error)
  • func (i *Instances) InstanceID(nodeName types.NodeName) (string, error)
  • func (i *Instances) InstanceType(name types.NodeName) (string, error)
  • func (i *Instances) List(name_filter string) ([]types.NodeName, error)
  • func (i *Instances) NodeAddresses(nodeName types.NodeName) ([]api.NodeAddress, error)
• type LoadBalancerOpts
• type MetaData
• type MyDuration
  • func (d *MyDuration) UnmarshalText(text []byte) error
• type Rackspace
  • func (rs *Rackspace) AttachDisk(instanceID string, diskName string) (string, error)
  • func (os *Rackspace) Clusters() (cloudprovider.Clusters, bool)
  • func (rs *Rackspace) CreateVolume(name string, size int, vtype, availability string, tags *map[string]string) (volumeName string, err error)
  • func (rs *Rackspace) DeleteVolume(volumeName string) error
  • func (rs *Rackspace) DetachDisk(instanceID string, partialDiskId string) error
  • func (rs *Rackspace) DiskIsAttached(diskName, instanceID string) (bool, error)
  • func (rs *Rackspace) DisksAreAttached(diskNames []string, instanceID string) (map[string]bool, error)
  • func (rs *Rackspace) GetAttachmentDiskPath(instanceID string, diskName string) (string, error)
  • func (rs *Rackspace) GetDevicePath(diskId string) string
  • func (os *Rackspace) GetZone() (cloudprovider.Zone, error)
  • func (rs *Rackspace) InstanceID() (string, error)
  • func (os *Rackspace) Instances() (cloudprovider.Instances, bool)
  • func (os *Rackspace) LoadBalancer() (cloudprovider.LoadBalancer, bool)
  • func (os *Rackspace) ProviderName() string
  • func (os *Rackspace) Routes() (cloudprovider.Routes, bool)
  • func (os *Rackspace) ScrubDNS(nameservers, searches []string) (nsOut, srchOut []string)
  • func (rs *Rackspace) ShouldTrustDevicePath() bool
  • func (os *Rackspace) Zones() (cloudprovider.Zones, bool)

Constants

const ProviderName = "rackspace"

Variables

var ErrAttrNotFound = errors.New("Expected attribute not found")

var ErrMultipleResults = errors.New("Multiple results where only one expected")

var ErrNoAddressFound = errors.New("No address found for host")

var ErrNotFound = errors.New("Failed to find object")

Types

type Config

type Config struct {
	Global struct {
		AuthUrl    string `gcfg:"auth-url"`
		Username   string
		UserId     string `gcfg:"user-id"`
		Password   string
		ApiKey     string `gcfg:"api-key"`
		TenantId   string `gcfg:"tenant-id"`
		TenantName string `gcfg:"tenant-name"`
		DomainId   string `gcfg:"domain-id"`
		DomainName string `gcfg:"domain-name"`
		Region     string
	}
	LoadBalancer LoadBalancerOpts
}

type Instances

type Instances struct {
	// contains filtered or unexported fields
}

func (*Instances) AddSSHKeyToAllInstances

func (i *Instances) AddSSHKeyToAllInstances(user string, keyData []byte) error

func (*Instances) CurrentNodeName

func (i *Instances) CurrentNodeName(hostname string) (types.NodeName, error)

Implementation of Instances.CurrentNodeName

func (*Instances) ExternalID

func (i *Instances) ExternalID(nodeName types.NodeName) (string, error)

ExternalID returns the cloud provider ID of the node with the specified Name (deprecated).

func (*Instances) InstanceID

func (i *Instances) InstanceID(nodeName types.NodeName) (string, error)

InstanceID returns the cloud provider ID of the node with the specified Name.

func (*Instances) InstanceType

func (i *Instances) InstanceType(name types.NodeName) (string, error)

InstanceType returns the type of the specified instance.

func (*Instances) List

func (i *Instances) List(name_filter string) ([]types.NodeName, error)

func (*Instances) NodeAddresses

func (i *Instances) NodeAddresses(nodeName types.NodeName) ([]api.NodeAddress, error)

type LoadBalancerOpts

type LoadBalancerOpts struct {
	SubnetId          string     `gcfg:"subnet-id"` // required
	CreateMonitor     bool       `gcfg:"create-monitor"`
	MonitorDelay      MyDuration `gcfg:"monitor-delay"`
	MonitorTimeout    MyDuration `gcfg:"monitor-timeout"`
	MonitorMaxRetries uint       `gcfg:"monitor-max-retries"`
}

type MetaData

type MetaData struct {
	UUID string `json:"uuid"`
	Name string `json:"name"`
}

type MyDuration

type MyDuration struct {
	time.Duration
}

encoding.TextUnmarshaler interface for time.Duration

func (*MyDuration) UnmarshalText

func (d *MyDuration) UnmarshalText(text []byte) error

type Rackspace

type Rackspace struct {
	// contains filtered or unexported fields
}

Rackspace is an implementation of cloud provider Interface for Rackspace.

func (*Rackspace) AttachDisk

func (rs *Rackspace) AttachDisk(instanceID string, diskName string) (string, error)

Attaches given cinder volume to the compute running kubelet

func (*Rackspace) Clusters

func (os *Rackspace) Clusters() (cloudprovider.Clusters, bool)

func (*Rackspace) CreateVolume

func (rs *Rackspace) CreateVolume(name string, size int, vtype, availability string, tags *map[string]string) (volumeName string, err error)

Create a volume of given size (in GiB)

func (*Rackspace) DeleteVolume

func (rs *Rackspace) DeleteVolume(volumeName string) error

func (*Rackspace) DetachDisk

func (rs *Rackspace) DetachDisk(instanceID string, partialDiskId string) error

Detaches given cinder volume from the compute running kubelet

func (*Rackspace) DiskIsAttached

func (rs *Rackspace) DiskIsAttached(diskName, instanceID string) (bool, error)

query if a volume is attached to a compute instance

func (*Rackspace) DisksAreAttached

func (rs *Rackspace) DisksAreAttached(diskNames []string, instanceID string) (map[string]bool, error)

query if a list volumes are attached to a compute instance

func (*Rackspace) GetAttachmentDiskPath

func (rs *Rackspace) GetAttachmentDiskPath(instanceID string, diskName string) (string, error)

Get device path of attached volume to the compute running kubelet, as known by cinder

func (*Rackspace) GetDevicePath

func (rs *Rackspace) GetDevicePath(diskId string) string

GetDevicePath returns the path of an attached block storage volume, specified by its id.

func (*Rackspace) GetZone

func (os *Rackspace) GetZone() (cloudprovider.Zone, error)

func (*Rackspace) InstanceID

func (rs *Rackspace) InstanceID() (string, error)

InstanceID returns the cloud provider ID of the kubelet's instance.

func (*Rackspace) Instances

func (os *Rackspace) Instances() (cloudprovider.Instances, bool)

Instances returns an implementation of Instances for Rackspace.

func (*Rackspace) LoadBalancer

func (os *Rackspace) LoadBalancer() (cloudprovider.LoadBalancer, bool)

func (*Rackspace) ProviderName

func (os *Rackspace) ProviderName() string

ProviderName returns the cloud provider ID.

func (*Rackspace) Routes

func (os *Rackspace) Routes() (cloudprovider.Routes, bool)

func (*Rackspace) ScrubDNS

func (os *Rackspace) ScrubDNS(nameservers, searches []string) (nsOut, srchOut []string)

ScrubDNS filters DNS settings for pods.

func (*Rackspace) ShouldTrustDevicePath

func (rs *Rackspace) ShouldTrustDevicePath() bool

query if we should trust the cinder provide deviceName, See issue #33128

func (*Rackspace) Zones

func (os *Rackspace) Zones() (cloudprovider.Zones, bool)