awsecs

Documentation

Index

• Constants
• func GetLabelInfo(rpt report.Report) map[string]map[string]*TaskLabelInfo
• type EcsClient
• type EcsInfo
• type EcsService
• type EcsTask
  • func (t EcsTask) IsServiceManaged() bool
• type Reporter
  • func Make(cacheSize int, cacheExpiry time.Duration, ...) Reporter
  • func (r Reporter) Name() string
  • func (Reporter) Report() (report.Report, error)
  • func (r *Reporter) Stop()
  • func (r Reporter) Tag(rpt report.Report) (report.Report, error)
• type TaskLabelInfo

Constants

const (
	Cluster             = "ecs_cluster"
	CreatedAt           = "ecs_created_at"
	TaskFamily          = "ecs_task_family"
	ServiceDesiredCount = "ecs_service_desired_count"
	ServiceRunningCount = "ecs_service_running_count"
	ScaleUp             = "ecs_scale_up"
	ScaleDown           = "ecs_scale_down"
)

TaskFamily is the key that stores the task family of an ECS Task

Functions

func GetLabelInfo

func GetLabelInfo(rpt report.Report) map[string]map[string]*TaskLabelInfo

GetLabelInfo returns map from cluster to map of task arns to task infos. Exported for test.

Types

type EcsClient

type EcsClient interface {
	// Returns a EcsInfo struct containing data needed for a report.
	GetInfo([]string) EcsInfo
	// Scales a service up or down by amount
	ScaleService(string, int) error
}

EcsClient is a wrapper around an AWS client that makes all the needed calls and just exposes the final results. We create an interface so we can mock for testing.

type EcsInfo

type EcsInfo struct {
	Tasks          map[string]EcsTask
	Services       map[string]EcsService
	TaskServiceMap map[string]string
}

EcsInfo is exported for test

type EcsService

type EcsService struct {
	ServiceName string
	// The following values may be stale in a cached copy
	DeploymentIDs     []string
	DesiredCount      int64
	PendingCount      int64
	RunningCount      int64
	TaskDefinitionARN string
}

EcsService describes the parts of ECS services we care about. Services are highly mutable and so we can only cache them on a best-effort basis. We have to refresh referenced (ie. has an associated task) services each report but we avoid re-listing services unless we can't find a service for a task. Exported for test.

type EcsTask

type EcsTask struct {
	TaskARN           string
	CreatedAt         time.Time
	TaskDefinitionARN string

	// These started fields are immutable once set, and guaranteed to be set once the task is running,
	// which we know it is because otherwise we wouldn't be looking at it.
	StartedAt time.Time
	StartedBy string // tag or deployment id
}

EcsTask describes the parts of ECS tasks we care about. Since we're caching tasks heavily, we ensure no mistakes by casting into a structure that only contains immutable attributes of the resource. Exported for test.

func (EcsTask) IsServiceManaged

func (t EcsTask) IsServiceManaged() bool

IsServiceManaged returns true if the task was started by a service.

type Reporter

type Reporter struct {
	ClientsByCluster map[string]EcsClient // Exported for test
	// contains filtered or unexported fields
}

Reporter implements Tagger, Reporter

func Make

func Make(cacheSize int, cacheExpiry time.Duration, handlerRegistry *controls.HandlerRegistry, probeID string) Reporter

Make creates a new Reporter

func (Reporter) Name

func (r Reporter) Name() string

Name needed for Tagger, Reporter

func (Reporter) Report

func (Reporter) Report() (report.Report, error)

Report needed for Reporter

func (*Reporter) Stop

func (r *Reporter) Stop()

Stop unregisters controls.

func (Reporter) Tag

func (r Reporter) Tag(rpt report.Report) (report.Report, error)

Tag needed for Tagger

type TaskLabelInfo

type TaskLabelInfo struct {
	ContainerIDs []string
	Family       string
}

TaskLabelInfo is used in return value of GetLabelInfo. Exported for test.