aws

Documentation

Index

• Constants
• type ASGCLIENT
• type AwsCloudProvider
  • func CreateCloudProvider(ctx context.Context) (AwsCloudProvider, error)
  • func (p AwsCloudProvider) PrepareTermination(ctx context.Context, cloudProviderNodeId string) (string, error)
  • func (p AwsCloudProvider) TerminateNode(ctx context.Context, cloudProviderNodeId string) (string, error)
  • func (t AwsCloudProvider) ValidateConfig() error
• type EC2CLIENT
• type ELBCLIENT
• type ELBV2CLIENT

Constants

const (
	TerminationEventActionFailed           = "Instance Termination Failed"
	TerminationEventActionSucceeded        = "Instance Terminated"
	PrepareTerminationEventActionFailed    = "Instance Preparation For Termination Failed"
	PrepareTerminationEventActionSucceeded = "Instance Prepared For Termination "
)

Types

type ASGCLIENT

type ASGCLIENT interface {
	DescribeTrafficSources(ctx context.Context, params *autoscaling.DescribeTrafficSourcesInput, optFns ...func(*autoscaling.Options)) (*autoscaling.DescribeTrafficSourcesOutput, error)
	DescribeAutoScalingInstances(ctx context.Context, params *autoscaling.DescribeAutoScalingInstancesInput, optFns ...func(*autoscaling.Options)) (*autoscaling.DescribeAutoScalingInstancesOutput, error)
}

type AwsCloudProvider

type AwsCloudProvider struct {
	Ec2Client   EC2CLIENT
	ElbClient   ELBCLIENT
	Elbv2Client ELBV2CLIENT
	AsgClient   ASGCLIENT
}

func CreateCloudProvider

func CreateCloudProvider(ctx context.Context) (AwsCloudProvider, error)

func (AwsCloudProvider) PrepareTermination

func (p AwsCloudProvider) PrepareTermination(ctx context.Context, cloudProviderNodeId string) (string, error)

func (AwsCloudProvider) TerminateNode

func (p AwsCloudProvider) TerminateNode(ctx context.Context, cloudProviderNodeId string) (string, error)

func (AwsCloudProvider) ValidateConfig

func (t AwsCloudProvider) ValidateConfig() error

type EC2CLIENT

type EC2CLIENT interface {
	TerminateInstances(ctx context.Context, params *ec2.TerminateInstancesInput, optFns ...func(*ec2.Options)) (*ec2.TerminateInstancesOutput, error)
}

type ELBCLIENT

type ELBCLIENT interface {
	DeregisterInstancesFromLoadBalancer(ctx context.Context, params *elasticloadbalancing.DeregisterInstancesFromLoadBalancerInput, optFns ...func(*elasticloadbalancing.Options)) (*elasticloadbalancing.DeregisterInstancesFromLoadBalancerOutput, error)
}

type ELBV2CLIENT

type ELBV2CLIENT interface {
	DeregisterTargets(ctx context.Context, params *elasticloadbalancingv2.DeregisterTargetsInput, optFns ...func(*elasticloadbalancingv2.Options)) (*elasticloadbalancingv2.DeregisterTargetsOutput, error)
}