services

Documentation

Index

• type AddonInput
• type AutoScaling
  • func NewAutoScaling(session *session.Session) AutoScaling
• type CloudFormation
  • func NewCloudFormation(session *session.Session) CloudFormation
• type CloudWatch
  • func NewCloudWatch(session *session.Session) CloudWatch
• type EC2
  • func NewEC2(session *session.Session) EC2
• type EKS
  • func NewEKS(session *session.Session, endpoint string) EKS
• type IAM
  • func NewIAM(session *session.Session) IAM
• type PolicyDocument
• type StatementEntry

Types

type AddonInput

type AddonInput struct {
	AddonName    string
	ClusterName  string
	AddonVersion string
	K8sVersion   string
}

Internal Addon Input struct subset of eks.AddonInput used by ginkgo tests

type AutoScaling

type AutoScaling interface {
	DescribeAutoScalingGroup(autoScalingGroupName string) ([]*autoscaling.Group, error)
}

func NewAutoScaling

func NewAutoScaling(session *session.Session) AutoScaling

type CloudFormation

type CloudFormation interface {
	WaitTillStackCreated(stackName string, stackParams []*cloudformation.Parameter, templateBody string) (*cloudformation.DescribeStacksOutput, error)
	WaitTillStackDeleted(stackName string) error
}

func NewCloudFormation

func NewCloudFormation(session *session.Session) CloudFormation

type CloudWatch

type CloudWatch interface {
	GetMetricStatistics(getMetricStatisticsInput *cloudwatch.GetMetricStatisticsInput) (*cloudwatch.GetMetricStatisticsOutput, error)
}

func NewCloudWatch

func NewCloudWatch(session *session.Session) CloudWatch

type EC2

type EC2 interface {
	DescribeInstanceType(instanceType string) ([]*ec2.InstanceTypeInfo, error)
	DescribeInstance(instanceID string) (*ec2.Instance, error)
	DescribeVPC(vpcID string) (*ec2.DescribeVpcsOutput, error)
	DescribeNetworkInterface(interfaceIDs []string) (*ec2.DescribeNetworkInterfacesOutput, error)
	AuthorizeSecurityGroupIngress(groupID string, protocol string, fromPort int, toPort int, cidrIP string) error
	RevokeSecurityGroupIngress(groupID string, protocol string, fromPort int, toPort int, cidrIP string) error
	AuthorizeSecurityGroupEgress(groupID string, protocol string, fromPort int, toPort int, cidrIP string) error
	RevokeSecurityGroupEgress(groupID string, protocol string, fromPort int, toPort int, cidrIP string) error
	AssociateVPCCIDRBlock(vpcId string, cidrBlock string) (*ec2.AssociateVpcCidrBlockOutput, error)
	TerminateInstance(instanceIDs []string) error
	DisAssociateVPCCIDRBlock(associationID string) error
	DescribeSubnet(subnetID string) (*ec2.DescribeSubnetsOutput, error)
	CreateSubnet(cidrBlock string, vpcID string, az string) (*ec2.CreateSubnetOutput, error)
	DeleteSubnet(subnetID string) error
	DescribeRouteTables(subnetID string) (*ec2.DescribeRouteTablesOutput, error)
	DescribeRouteTablesWithVPCID(vpcID string) (*ec2.DescribeRouteTablesOutput, error)
	CreateSecurityGroup(groupName string, description string, vpcID string) (*ec2.CreateSecurityGroupOutput, error)
	DeleteSecurityGroup(groupID string) error
	AssociateRouteTableToSubnet(routeTableId string, subnetID string) error
	CreateKey(keyName string) (*ec2.CreateKeyPairOutput, error)
	DeleteKey(keyName string) error
	DescribeKey(keyName string) (*ec2.DescribeKeyPairsOutput, error)
	ModifyNetworkInterfaceSecurityGroups(securityGroupIds []*string, networkInterfaceId *string) (*ec2.ModifyNetworkInterfaceAttributeOutput, error)
}

func NewEC2

func NewEC2(session *session.Session) EC2

type EKS

type EKS interface {
	DescribeCluster(clusterName string) (*eks.DescribeClusterOutput, error)
	CreateAddon(addonInput *AddonInput) (*eks.CreateAddonOutput, error)
	DescribeAddonVersions(AddonInput *AddonInput) (*eks.DescribeAddonVersionsOutput, error)
	DescribeAddon(addonInput *AddonInput) (*eks.DescribeAddonOutput, error)
	DeleteAddon(AddOnInput *AddonInput) (*eks.DeleteAddonOutput, error)
	GetLatestVersion(addonInput *AddonInput) (string, error)
}

func NewEKS

func NewEKS(session *session.Session, endpoint string) EKS

type IAM

type IAM interface {
	AttachRolePolicy(policyArn string, roleName string) error
	DetachRolePolicy(policyARN string, roleName string) error
	CreatePolicy(policyName string, policyDocument string) (*iam.CreatePolicyOutput, error)
	DeletePolicy(policyARN string) error
	GetInstanceProfile(instanceProfileName string) (*iam.GetInstanceProfileOutput, error)
	ListPolicies(scope string) (*iam.ListPoliciesOutput, error)
}

func NewIAM

func NewIAM(session *session.Session) IAM

type PolicyDocument

type PolicyDocument struct {
	Version   string
	Statement []StatementEntry
}

type StatementEntry

type StatementEntry struct {
	Effect   string
	Action   []string
	Resource string
}