capacity

Documentation

Index

• type AutoScalingAPI
• type AutoScalingGroup
  • func NewAutoScalingGroup(name string, asSvc AutoScalingAPI, ec2Svc EC2API) (*AutoScalingGroup, error)
  • func (asg *AutoScalingGroup) ReduceCapacity(ctx context.Context, amount int32, drainer Drainer) error
  • func (asg *AutoScalingGroup) ReplaceInstances(ctx context.Context, drainer Drainer, cluster Cluster) error
• type Cluster
  • func NewCluster(name string, ecsSvc ECSAPI) Cluster
• type Drainer
  • func NewDrainer(cluster string, batchSize int32, ecsSvc ECSAPI) (Drainer, error)
• type EC2API
• type ECSAPI
• type Poller
• type SQSAPI
• type SQSQueuePoller
  • func NewSQSQueuePoller(queueURL string, sqsSvc SQSAPI) *SQSQueuePoller
  • func (p *SQSQueuePoller) Poll(ctx context.Context, ...)
  • func (p *SQSQueuePoller) PollOnce(ctx context.Context, ...) error
• type SpotFleetRequest
  • func NewSpotFleetRequest(id string, ec2Svc EC2API) (*SpotFleetRequest, error)
  • func (sfr *SpotFleetRequest) ReduceCapacity(ctx context.Context, amount int32, drainer Drainer, poller Poller) error
  • func (sfr *SpotFleetRequest) TerminateAllInstances(ctx context.Context, drainer Drainer) error

Types

type AutoScalingAPI

type AutoScalingAPI interface {
	CreateOrUpdateTags(context.Context, *autoscaling.CreateOrUpdateTagsInput, ...func(*autoscaling.Options)) (*autoscaling.CreateOrUpdateTagsOutput, error)
	DeleteTags(context.Context, *autoscaling.DeleteTagsInput, ...func(*autoscaling.Options)) (*autoscaling.DeleteTagsOutput, error)
	DescribeAutoScalingGroups(context.Context, *autoscaling.DescribeAutoScalingGroupsInput, ...func(*autoscaling.Options)) (*autoscaling.DescribeAutoScalingGroupsOutput, error)
	DetachInstances(context.Context, *autoscaling.DetachInstancesInput, ...func(*autoscaling.Options)) (*autoscaling.DetachInstancesOutput, error)
	UpdateAutoScalingGroup(context.Context, *autoscaling.UpdateAutoScalingGroupInput, ...func(*autoscaling.Options)) (*autoscaling.UpdateAutoScalingGroupOutput, error)
}

type AutoScalingGroup

type AutoScalingGroup struct {
	OriginalDesiredCapacity *int32
	OriginalMaxSize         *int32
	StateSavedAt            *time.Time

	autoscalingtypes.AutoScalingGroup
	// contains filtered or unexported fields
}

func NewAutoScalingGroup

func NewAutoScalingGroup(name string, asSvc AutoScalingAPI, ec2Svc EC2API) (*AutoScalingGroup, error)

func (*AutoScalingGroup) ReduceCapacity

func (asg *AutoScalingGroup) ReduceCapacity(ctx context.Context, amount int32, drainer Drainer) error

func (*AutoScalingGroup) ReplaceInstances

func (asg *AutoScalingGroup) ReplaceInstances(ctx context.Context, drainer Drainer, cluster Cluster) error

type Cluster

type Cluster interface {
	Name() string
	WaitUntilContainerInstancesRegistered(context.Context, int, *time.Time) error
}

func NewCluster

func NewCluster(name string, ecsSvc ECSAPI) Cluster

type Drainer

type Drainer interface {
	Drain(context.Context, []string) error
	ProcessInterruptions(context.Context, []sqstypes.Message) ([]sqstypes.DeleteMessageBatchRequestEntry, error)
}

func NewDrainer

func NewDrainer(cluster string, batchSize int32, ecsSvc ECSAPI) (Drainer, error)

type EC2API

type EC2API interface {
	DescribeInstances(context.Context, *ec2.DescribeInstancesInput, ...func(*ec2.Options)) (*ec2.DescribeInstancesOutput, error)
	DescribeSpotFleetInstances(context.Context, *ec2.DescribeSpotFleetInstancesInput, ...func(*ec2.Options)) (*ec2.DescribeSpotFleetInstancesOutput, error)
	DescribeSpotFleetRequests(context.Context, *ec2.DescribeSpotFleetRequestsInput, ...func(*ec2.Options)) (*ec2.DescribeSpotFleetRequestsOutput, error)
	ModifySpotFleetRequest(context.Context, *ec2.ModifySpotFleetRequestInput, ...func(*ec2.Options)) (*ec2.ModifySpotFleetRequestOutput, error)
	TerminateInstances(context.Context, *ec2.TerminateInstancesInput, ...func(*ec2.Options)) (*ec2.TerminateInstancesOutput, error)
}

type ECSAPI

type ECSAPI interface {
	DescribeContainerInstances(context.Context, *ecs.DescribeContainerInstancesInput, ...func(*ecs.Options)) (*ecs.DescribeContainerInstancesOutput, error)
	DescribeServices(context.Context, *ecs.DescribeServicesInput, ...func(*ecs.Options)) (*ecs.DescribeServicesOutput, error)
	DescribeTasks(context.Context, *ecs.DescribeTasksInput, ...func(*ecs.Options)) (*ecs.DescribeTasksOutput, error)
	ListContainerInstances(context.Context, *ecs.ListContainerInstancesInput, ...func(*ecs.Options)) (*ecs.ListContainerInstancesOutput, error)
	ListTasks(context.Context, *ecs.ListTasksInput, ...func(*ecs.Options)) (*ecs.ListTasksOutput, error)
	StopTask(context.Context, *ecs.StopTaskInput, ...func(*ecs.Options)) (*ecs.StopTaskOutput, error)
	UpdateContainerInstancesState(context.Context, *ecs.UpdateContainerInstancesStateInput, ...func(*ecs.Options)) (*ecs.UpdateContainerInstancesStateOutput, error)
}

type Poller

type Poller interface {
	Poll(context.Context, func([]sqstypes.Message) ([]sqstypes.DeleteMessageBatchRequestEntry, error))
	PollOnce(context.Context, func([]sqstypes.Message) ([]sqstypes.DeleteMessageBatchRequestEntry, error), int32) error
}

type SQSAPI

type SQSAPI interface {
	DeleteMessageBatch(context.Context, *sqs.DeleteMessageBatchInput, ...func(*sqs.Options)) (*sqs.DeleteMessageBatchOutput, error)
	ReceiveMessage(context.Context, *sqs.ReceiveMessageInput, ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
}

type SQSQueuePoller

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

func NewSQSQueuePoller

func NewSQSQueuePoller(queueURL string, sqsSvc SQSAPI) *SQSQueuePoller

func (*SQSQueuePoller) Poll

func (p *SQSQueuePoller) Poll(ctx context.Context, callback func([]sqstypes.Message) ([]sqstypes.DeleteMessageBatchRequestEntry, error))

func (*SQSQueuePoller) PollOnce

func (p *SQSQueuePoller) PollOnce(ctx context.Context, callback func([]sqstypes.Message) ([]sqstypes.DeleteMessageBatchRequestEntry, error), waitTimeSeconds int32) error

type SpotFleetRequest

type SpotFleetRequest struct {
	SpotFleetRequestConfigData *ec2types.SpotFleetRequestConfigData

	ec2types.SpotFleetRequestConfig
	// contains filtered or unexported fields
}

func NewSpotFleetRequest

func NewSpotFleetRequest(id string, ec2Svc EC2API) (*SpotFleetRequest, error)

func (*SpotFleetRequest) ReduceCapacity

func (sfr *SpotFleetRequest) ReduceCapacity(ctx context.Context, amount int32, drainer Drainer, poller Poller) error

func (*SpotFleetRequest) TerminateAllInstances

func (sfr *SpotFleetRequest) TerminateAllInstances(ctx context.Context, drainer Drainer) error