package aws_cloud

import "k8s.io/kubernetes/pkg/cloudprovider/aws"

Index ¶

• type AWSCloud
• func (aws *AWSCloud) Clusters() (cloudprovider.Clusters, bool)
• func (aws *AWSCloud) ExternalID(name string) (string, error)
• func (v *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) TCPLoadBalancer() (cloudprovider.TCPLoadBalancer, bool)
• func (aws *AWSCloud) Zones() (cloudprovider.Zones, bool)
• type AWSCloudConfig
• type AuthFunc
• type EC2
• type GoamzEC2
• func (self *GoamzEC2) GetMetaData(key string) ([]byte, error)
• func (self *GoamzEC2) Instances(instanceIds []string, filter *ec2InstanceFilter) (resp *ec2.InstancesResp, err error)

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) Clusters ¶

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

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 (v *AWSCloud) GetNodeResources(name string) (*api.NodeResources, error)

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) 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
		Region string
	}
}

type AuthFunc ¶

type AuthFunc func() (auth aws.Auth, err error)

type EC2 ¶

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

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

Abstraction over EC2, to allow mocking/other implementations

type GoamzEC2 ¶

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

goamzEC2 is an implementation of the EC2 interface, backed by goamz

func (*GoamzEC2) GetMetaData ¶

func (self *GoamzEC2) GetMetaData(key string) ([]byte, error)

func (*GoamzEC2) Instances ¶

func (self *GoamzEC2) Instances(instanceIds []string, filter *ec2InstanceFilter) (resp *ec2.InstancesResp, err error)

Implementation of EC2.Instances

Source Files ¶

aws.go