ecs

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 20, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateServiceInput 

type CreateServiceInput struct {
	Cluster           string
	DesiredCount      int64
	Name              string
	Port              int64
	SecurityGroupIds  []string
	SubnetIds         []string
	TargetGroupArn    string
	TaskDefinitionArn string
}

type CreateTaskDefinitionInput 

type CreateTaskDefinitionInput struct {
	Cpu              string
	EnvVars          []EnvVar
	ExecutionRoleArn string
	Image            string
	Memory           string
	Name             string
	Port             int64
	LogGroupName     string
	LogRegion        string
	SecretVars       []Secret
	TaskRole         string
	Type             string
	Tags             []*awsecs.Tag
}

CreateTaskDefinitionInput ...

func (*CreateTaskDefinitionInput) Environment 

func (input *CreateTaskDefinitionInput) Environment() []*awsecs.KeyValuePair

Environment converts envvars to AWS format

func (*CreateTaskDefinitionInput) Secrets added in v0.6.0 

func (input *CreateTaskDefinitionInput) Secrets() []*awsecs.Secret

Secrets converts secrets to AWS format

type Deployment 

type Deployment struct {
	CreatedAt    time.Time
	DesiredCount int64
	Id           string
	Image        string
	PendingCount int64
	RunningCount int64
	Status       string
}

type ECS 

type ECS struct {
	ClusterName string
	// contains filtered or unexported fields
}

func New 

func New(sess *session.Session, clusterName string) ECS

func (*ECS) AddEnvVarsToTaskDefinition 

func (ecs *ECS) AddEnvVarsToTaskDefinition(taskDefinitionArn string, envVars []EnvVar, secretVars []Secret) string

AddEnvVarsToTaskDefinition registers a new task definition with the envvars appended

func (*ECS) CreateCluster 

func (ecs *ECS) CreateCluster() (string, error)

func (*ECS) CreateService 

func (ecs *ECS) CreateService(input *CreateServiceInput)

func (*ECS) CreateTaskDefinition 

func (ecs *ECS) CreateTaskDefinition(input *CreateTaskDefinitionInput) string

CreateTaskDefinition creates a task definition from an input

func (*ECS) DescribeService 

func (ecs *ECS) DescribeService(serviceName string) Service

func (*ECS) DescribeServices 

func (ecs *ECS) DescribeServices(serviceArns []string) []Service

func (*ECS) DescribeTaskDefinition 

func (ecs *ECS) DescribeTaskDefinition(taskDefinitionArn string) *awsecs.DescribeTaskDefinitionOutput

DescribeTaskDefinition fetches a task definition output from cache or aws (includes the taskdefinition itself along with its tags)

func (*ECS) DescribeTasks 

func (ecs *ECS) DescribeTasks(taskIds []string) []Task

func (*ECS) DescribeTasksForService 

func (ecs *ECS) DescribeTasksForService(serviceName string) []Task

func (*ECS) DescribeTasksForTaskGroup 

func (ecs *ECS) DescribeTasksForTaskGroup(taskGroupName string) []Task

func (*ECS) DestroyService 

func (ecs *ECS) DestroyService(serviceName string)

func (*ECS) GetCpuAndMemoryFromTaskDefinition 

func (ecs *ECS) GetCpuAndMemoryFromTaskDefinition(taskDefinitionArn string) (string, string)

GetCpuAndMemoryFromTaskDefinition returns the cpu/memory from a task definition

func (*ECS) GetDesiredCount 

func (ecs *ECS) GetDesiredCount(serviceName string) int64

func (*ECS) GetEnvVarsFromTaskDefinition 

func (ecs *ECS) GetEnvVarsFromTaskDefinition(taskDefinitionArn string) []EnvVar

GetEnvVarsFromTaskDefinition retrieves envvars from an existing task definition

func (*ECS) GetRevisionNumber added in v0.5.0 

func (ecs *ECS) GetRevisionNumber(taskDefinitionArn string) string

GetRevisionNumber returns the revision number from a task definition

func (*ECS) GetSecretVarsFromTaskDefinition added in v0.6.0 

func (ecs *ECS) GetSecretVarsFromTaskDefinition(taskDefinitionArn string) []EnvVar

GetSecretVarsFromTaskDefinition retrieves secret vars from an existing task definition

func (*ECS) GetTaskDefinitionARN added in v0.5.0 

func (ecs *ECS) GetTaskDefinitionARN(region string, account string, family string, revisionNumber string) string

GetTaskDefinitionARN builds an ARN

func (*ECS) GetTaskFamily added in v0.5.0 

func (ecs *ECS) GetTaskFamily(taskDefinitionArn string) string

GetTaskFamily returns the task family from a task definition ARN

func (*ECS) ListServices 

func (ecs *ECS) ListServices() []Service

func (*ECS) ListTaskGroups 

func (ecs *ECS) ListTaskGroups() []*TaskGroup

func (*ECS) RemoveEnvVarsFromTaskDefinition 

func (ecs *ECS) RemoveEnvVarsFromTaskDefinition(taskDefinitionArn string, keys []string) string

RemoveEnvVarsFromTaskDefinition registers a new task definition with the specified keys removed

func (*ECS) ResolveRevisionNumber added in v0.5.0 

func (ecs *ECS) ResolveRevisionNumber(taskDefinitionArn string, revisionExpression string) string

ResolveRevisionNumber returns a task defintion revision number by absolute value or expression

func (*ECS) RestartService added in v0.2.3 

func (ecs *ECS) RestartService(serviceName string)

func (*ECS) RunTask 

func (ecs *ECS) RunTask(i *RunTaskInput)

func (*ECS) SetDesiredCount 

func (ecs *ECS) SetDesiredCount(serviceName string, desiredCount int64)

func (*ECS) SortEnvVars added in v0.6.0 

func (ecs *ECS) SortEnvVars(envVars []EnvVar) []EnvVar

SortEnvVars sorts a slice of EnvVar's by Key

func (*ECS) StopTask 

func (ecs *ECS) StopTask(taskId string)

func (*ECS) StopTasks 

func (ecs *ECS) StopTasks(taskIds []string)

func (*ECS) UpdateServiceTaskDefinition 

func (ecs *ECS) UpdateServiceTaskDefinition(serviceName, taskDefinitionArn string)

func (*ECS) UpdateTaskDefinitionCpuAndMemory 

func (ecs *ECS) UpdateTaskDefinitionCpuAndMemory(taskDefinitionArn, cpu, memory string) string

UpdateTaskDefinitionCpuAndMemory registers a new task definition with the cpu/memory

func (*ECS) UpdateTaskDefinitionImage 

func (ecs *ECS) UpdateTaskDefinitionImage(taskDefinitionArn, image string) string

UpdateTaskDefinitionImage registers a new task definition with the updated image

func (*ECS) UpdateTaskDefinitionImageAndEnvVars added in v0.3.0 

func (ecs *ECS) UpdateTaskDefinitionImageAndEnvVars(taskDefinitionArnOrFamily string, image string, environmentVariables []EnvVar, replaceVars bool, secretVariables []Secret) string

UpdateTaskDefinitionImageAndEnvVars creates a new, updated task definition based on the specified image and env vars. Note that any existing envvars are replaced by the new ones

func (*ECS) WaitUntilServiceStable added in v0.8.0 

func (ecs *ECS) WaitUntilServiceStable(serviceName string)

type EnvVar 

type EnvVar struct {
	Key   string
	Value string
}

EnvVar ...

type Event 

type Event struct {
	CreatedAt time.Time
	Message   string
}

type RunTaskInput 

type RunTaskInput struct {
	ClusterName       string
	Count             int64
	SecurityGroupIds  []string
	SubnetIds         []string
	TaskDefinitionArn string
	TaskName          string
}

type Secret added in v0.6.0 

type Secret struct {
	Key       string
	ValueFrom string
}

Secret ...

type Service 

type Service struct {
	Cluster           string
	Cpu               string
	Deployments       []Deployment
	DesiredCount      int64
	EnvVars           []EnvVar
	Events            []Event
	Image             string
	Memory            string
	Name              string
	PendingCount      int64
	RunningCount      int64
	SecurityGroupIds  []string
	ServiceRegistries []ServiceRegistry
	TargetGroupArn    string
	TaskDefinitionArn string
	TaskRole          string
	SecretVars        []EnvVar
	SubnetIds         []string
	Status            string
}

func (*Service) AddDeployment 

func (s *Service) AddDeployment(d Deployment)

func (*Service) AddEvent 

func (s *Service) AddEvent(e Event)

type ServiceRegistry added in v0.4.0 

type ServiceRegistry struct {
	ContainerName string
	ContainerPort int64
	Port          int64
	RegistryArn   string
}

type Task 

type Task struct {
	Cpu              string
	CreatedAt        time.Time
	DeploymentId     string
	DesiredStatus    string
	EniId            string
	EnvVars          []EnvVar
	Image            string
	LastStatus       string
	Memory           string
	SecurityGroupIds []string
	StartedBy        string
	SubnetId         string
	TaskId           string
	TaskRole         string
}

func (*Task) RunningFor 

func (t *Task) RunningFor() time.Duration

type TaskGroup 

type TaskGroup struct {
	TaskGroupName string
	Instances     int64
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.