cloudprovider

type AwsClient interface {
	AssignPrivateIPAddresses(request *ec2.AssignPrivateIpAddressesInput) (*ec2.AssignPrivateIpAddressesOutput, error)
	UnassignPrivateIPAddresses(request *ec2.UnassignPrivateIpAddressesInput) (*ec2.UnassignPrivateIpAddressesOutput, error)

	DescribeInstances(request *ec2.DescribeInstancesInput) (*ec2.DescribeInstancesOutput, error)
	DescribeNetworkInterfaces(request *ec2.DescribeNetworkInterfacesInput) (*ec2.DescribeNetworkInterfacesOutput, error)

	DescribeSubnets(request *ec2.DescribeSubnetsInput) (*ec2.DescribeSubnetsOutput, error)

	GetRegion() string
}

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

type AwsCloudProvider struct {
	Region string

	Aws AwsClient

	ClusterName string // name of the cluster -- will be the AWS tag key="kubernetes.io/cluster/<ClusterName>", value="owned"
	// contains filtered or unexported fields
}

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

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

type CloudInstance interface {
	ID() string       // InstanceId of this instance
	URI() string      // Unique Resource Identifier -- e.g. the ARN at AWS
	HostName() string // Hostname of this instance

	FailureRegion() string // Cloud Region of this instance
	FailureZone() string   // Failure zone this instance is located in

	Tags() *map[string]string // The tags of this instance
	NetworkInterface() string // The ids of the network interfaces of this instance

	PrimaryIP() *net.IP      // primary IP of this instance
	SecondaryIps() []*net.IP // secondary IPs of this instance
}

type CloudNetwork interface {
	IsIPInNetwork(ip *net.IP) bool

	Name() string
	URI() string // Unique Resource Identifier -- e.g. the ARN at AWS
	FailureZone() string
	DefaultForFailureZone() bool
	Cidr() *net.IPNet
	AvailableIPCount() int64
}

type CloudProvider interface {
	ClusterTag() (string, string)

	Instance(instanceID string) (*CloudInstance, error)
	InstanceByHostName(hostname string) (*CloudInstance, error)

	AddSpecifiedIPs(ips []*net.IP) ([]string, error)
	AddRandomIPs() ([]string, []*net.IP, error)
	RemoveIP(ip *net.IP) (string, error)
}