cluster

Documentation

Index

• func NodeIdsToAwsStrings(ids []NodeId) []*string
• type Cluster
  • func New(asgName string, ec2 ec2iface.EC2API, asg autoscalingiface.AutoScalingAPI) Cluster
• type NodeId

Functions

func NodeIdsToAwsStrings

func NodeIdsToAwsStrings(ids []NodeId) []*string

Types

type Cluster

type Cluster interface {
	// Add upscales the cluster by adding the given number of instances
	// to the autoscaling group
	Add(context.Context, int) error

	// Destroy downscales the cluster by nuking the EC2 instances whose IDs
	// are given
	Destroy(context.Context, []NodeId) error

	// List returns IDs of running drone agent nodes
	List(context.Context) ([]NodeId, error)

	// Describe returns information about agents whose IDs are given
	Describe(context.Context, []NodeId) ([]*ec2.Instance, error)

	// ScalingActivityInProgress returns true if number of instances in
	// cluster ASG is not the same as its desired capacity
	ScalingActivityInProgress(context.Context) (bool, error)
}

Cluster is used to communicate with a Drone agent cluster managed by an AWS autoscaling group.

func New

func New(asgName string, ec2 ec2iface.EC2API, asg autoscalingiface.AutoScalingAPI) Cluster

New returns a new Cluster object

type NodeId

type NodeId string