aws_cloud

Documentation

Index

• type AWSCloud
  • func (aws *AWSCloud) AttachDisk(instanceName string, diskName string, readOnly bool) (string, error)
  • func (aws *AWSCloud) Clusters() (cloudprovider.Clusters, bool)
  • func (aws *AWSCloud) CreateVolume(volumeOptions *VolumeOptions) (string, error)
  • func (aws *AWSCloud) DeleteVolume(volumeName string) error
  • func (aws *AWSCloud) DetachDisk(instanceName string, diskName string) error
  • func (aws *AWSCloud) ExternalID(name string) (string, error)
  • func (aws *AWSCloud) GetNodeResources(name string) (*api.NodeResources, error)
  • func (self *AWSCloud) GetZone() (cloudprovider.Zone, error)
  • func (aws *AWSCloud) Instances() (cloudprovider.Instances, bool)
  • func (aws *AWSCloud) List(filter string) ([]string, error)
  • func (aws *AWSCloud) NodeAddresses(name string) ([]api.NodeAddress, error)
  • func (aws *AWSCloud) Routes() (cloudprovider.Routes, bool)
  • func (aws *AWSCloud) TCPLoadBalancer() (cloudprovider.TCPLoadBalancer, bool)
  • func (aws *AWSCloud) Zones() (cloudprovider.Zones, bool)
• type AWSCloudConfig
• type AWSMetadata
• type AuthFunc
• type EC2
• type VolumeOptions
• type Volumes

Types

type AWSCloud

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

AWSCloud is an implementation of Interface, TCPLoadBalancer and Instances for Amazon Web Services.

func (*AWSCloud) AttachDisk

func (aws *AWSCloud) AttachDisk(instanceName string, diskName string, readOnly bool) (string, error)

Implements Volumes.AttachDisk

func (*AWSCloud) Clusters

func (aws *AWSCloud) Clusters() (cloudprovider.Clusters, bool)

func (*AWSCloud) CreateVolume

func (aws *AWSCloud) CreateVolume(volumeOptions *VolumeOptions) (string, error)

Implements Volumes.CreateVolume

func (*AWSCloud) DeleteVolume

func (aws *AWSCloud) DeleteVolume(volumeName string) error

Implements Volumes.DeleteVolume

func (*AWSCloud) DetachDisk

func (aws *AWSCloud) DetachDisk(instanceName string, diskName string) error

Implements Volumes.DetachDisk

func (*AWSCloud) ExternalID

func (aws *AWSCloud) ExternalID(name string) (string, error)

ExternalID returns the cloud provider ID of the specified instance.

func (*AWSCloud) GetNodeResources

func (aws *AWSCloud) GetNodeResources(name string) (*api.NodeResources, error)

GetNodeResources implements Instances.GetNodeResources

func (*AWSCloud) GetZone

func (self *AWSCloud) GetZone() (cloudprovider.Zone, error)

GetZone implements Zones.GetZone

func (*AWSCloud) Instances

func (aws *AWSCloud) Instances() (cloudprovider.Instances, bool)

Instances returns an implementation of Instances for Amazon Web Services.

func (*AWSCloud) List

func (aws *AWSCloud) List(filter string) ([]string, error)

List is an implementation of Instances.List.

func (*AWSCloud) NodeAddresses

func (aws *AWSCloud) NodeAddresses(name string) ([]api.NodeAddress, error)

NodeAddresses is an implementation of Instances.NodeAddresses.

func (*AWSCloud) Routes

func (aws *AWSCloud) Routes() (cloudprovider.Routes, bool)

Routes returns an implementation of Routes for Amazon Web Services.

func (*AWSCloud) TCPLoadBalancer

func (aws *AWSCloud) TCPLoadBalancer() (cloudprovider.TCPLoadBalancer, bool)

TCPLoadBalancer returns an implementation of TCPLoadBalancer for Amazon Web Services.

func (*AWSCloud) Zones

func (aws *AWSCloud) Zones() (cloudprovider.Zones, bool)

Zones returns an implementation of Zones for Amazon Web Services.

type AWSCloudConfig

type AWSCloudConfig struct {
	Global struct {
		// TODO: Is there any use for this?  We can get it from the instance metadata service
		Zone string
	}
}

type AWSMetadata

type AWSMetadata interface {
	// Query the EC2 metadata service (used to discover instance-id etc)
	GetMetaData(key string) ([]byte, error)
}

Abstraction over the AWS metadata service

type AuthFunc

type AuthFunc func() (creds *credentials.Credentials)

type EC2

type EC2 interface {
	// Query EC2 for instances matching the filter
	Instances(instanceIds []string, filter *ec2InstanceFilter) (instances []*ec2.Instance, err error)

	// Attach a volume to an instance
	AttachVolume(volumeID, instanceId, mountDevice string) (resp *ec2.VolumeAttachment, err error)
	// Detach a volume from whatever instance it is attached to
	// TODO: We should specify the InstanceID and the Device, for safety
	DetachVolume(volumeID, instanceId, mountDevice string) (resp *ec2.VolumeAttachment, err error)
	// Lists volumes
	Volumes(volumeIDs []string, filter *ec2.Filter) (resp *ec2.DescribeVolumesOutput, err error)
	// Create an EBS volume
	CreateVolume(request *ec2.CreateVolumeInput) (resp *ec2.Volume, err error)
	// Delete an EBS volume
	DeleteVolume(volumeID string) (resp *ec2.DeleteVolumeOutput, err error)
}

Abstraction over EC2, to allow mocking/other implementations

type VolumeOptions

type VolumeOptions struct {
	CapacityMB int
}

type Volumes

type Volumes interface {
	// Attach the disk to the specified instance
	// instanceName can be empty to mean "the instance on which we are running"
	// Returns the device (e.g. /dev/xvdf) where we attached the volume
	AttachDisk(instanceName string, volumeName string, readOnly bool) (string, error)
	// Detach the disk from the specified instance
	// instanceName can be empty to mean "the instance on which we are running"
	DetachDisk(instanceName string, volumeName string) error

	// Create a volume with the specified options
	CreateVolume(volumeOptions *VolumeOptions) (volumeName string, err error)
	DeleteVolume(volumeName string) error
}

Volumes is an interface for managing cloud-provisioned volumes