ecs

Documentation

Index

• func BuildConsoleURLForService(cluster, service string) string
• func CreateNewTaskWithEnvironment(existingTask *ecs.TaskDefinition, env []*ecs.KeyValuePair) (*ecs.TaskDefinition, error)
• func CreateScheduledTask(cluster, service, taskSuffix, scheduleExpression, command string) error
• func DeployTaskToService(cluster, service string, task *ecs.TaskDefinition) (*ecs.Service, error)
• func FindRoleByName(name string) (*iam.Role, error)
• func FindService(cluster, service string) (*ecs.Service, error)
• func GetAllLogs(region string, params *cloudwatchlogs.GetLogEventsInput) ([]string, error)
• func GetAllTasksByDefinition(cluster string, def *ecs.TaskDefinition, status string) ([]*ecs.Task, error)
• func GetAllTasksByDefinitionStatus(cluster string, def *ecs.TaskDefinition, status *string) ([]*ecs.Task, error)
• func GetClusterInstances(cluster string) ([]string, error)
• func GetClusterNames() ([]string, error)
• func GetContainerInstances(cluster string, service string) ([]string, error)
• func GetCurrentTaskDefinition(cluster, service string) (*ecs.TaskDefinition, error)
• func GetDeployedEssentialContainer(cluster, service string) (*ecs.ContainerDefinition, error)
• func GetEssentialContainer(task *ecs.TaskDefinition) (*ecs.ContainerDefinition, error)
• func GetLogs(cluster, service, status string) error
• func GetTaskDefinition(arn string) (*ecs.TaskDefinition, error)
• func GetTaskIDFromArn(arn string) string
• func GetTaskLogs(def *ecs.TaskDefinition, taskID string) error
• func KeyPairsToString(kv []*ecs.KeyValuePair) string
• func ListLogEvents(group, name, region string) error
• func ListServices(cluster string) ([]string, error)
• func RunTaskWithCommand(cluster, service, command string) (*ecs.RunTaskOutput, error)
• func ScaleService(cluster, service string, desiredCount int) (*ecs.Service, error)
• func StringToKeyPairs(input string) ([]*ecs.KeyValuePair, error)
• func TaskExitCode(task *ecs.Task) (*int64, error)
• func UpdateAgent(cluster, containerInstanceARN string) error
• func ValidateCluster(cluster string) error

Functions

func BuildConsoleURLForService

func BuildConsoleURLForService(cluster, service string) string

BuildConsoleURLForService builds the console url for a service

func CreateNewTaskWithEnvironment

func CreateNewTaskWithEnvironment(existingTask *ecs.TaskDefinition, env []*ecs.KeyValuePair) (*ecs.TaskDefinition, error)

CreateNewTaskWithEnvironment registers a new task, based on the passed task, but with new environment.

func CreateScheduledTask

func CreateScheduledTask(cluster, service, taskSuffix, scheduleExpression, command string) error

CreateScheduledTask creates a scheduled task in an ECS cluster with the specified paramters

func DeployTaskToService

func DeployTaskToService(cluster, service string, task *ecs.TaskDefinition) (*ecs.Service, error)

DeployTaskToService deploys a given task definition to a cluster/service

func FindRoleByName

func FindRoleByName(name string) (*iam.Role, error)

FindRoleByName paginates through roles and returns any found that match the name string

func FindService

func FindService(cluster, service string) (*ecs.Service, error)

FindService finds a service struct by name

func GetAllLogs

func GetAllLogs(region string, params *cloudwatchlogs.GetLogEventsInput) ([]string, error)

GetAllLogs retrieves the entire log history

func GetAllTasksByDefinition

func GetAllTasksByDefinition(cluster string, def *ecs.TaskDefinition, status string) ([]*ecs.Task, error)

GetAllTasksByDefinition gets the tasks that have run recently for a cluster and service

func GetAllTasksByDefinitionStatus

func GetAllTasksByDefinitionStatus(cluster string, def *ecs.TaskDefinition, status *string) ([]*ecs.Task, error)

GetAllTasksByDefinitionStatus gets all of the tasks of a certain status for a task definition

func GetClusterInstances

func GetClusterInstances(cluster string) ([]string, error)

GetClusterInstances returns the container instances of a cluster by id

func GetClusterNames

func GetClusterNames() ([]string, error)

GetClusterNames returns a slice of strings representing cluster names

func GetContainerInstances

func GetContainerInstances(cluster string, service string) ([]string, error)

GetContainerInstances returns the container instances of a cluster

func GetCurrentTaskDefinition

func GetCurrentTaskDefinition(cluster, service string) (*ecs.TaskDefinition, error)

GetCurrentTaskDefinition returns a service's current task definition

func GetDeployedEssentialContainer

func GetDeployedEssentialContainer(cluster, service string) (*ecs.ContainerDefinition, error)

GetDeployedEssentialContainer gets the currently deployed "essential" container definition of a cluster service

func GetEssentialContainer

func GetEssentialContainer(task *ecs.TaskDefinition) (*ecs.ContainerDefinition, error)

GetEssentialContainer returns the essential container

func GetLogs

func GetLogs(cluster, service, status string) error

GetLogs returns cloudwatch logs for a specific set of log streams matching a pattern within a log group and region

func GetTaskDefinition

func GetTaskDefinition(arn string) (*ecs.TaskDefinition, error)

GetTaskDefinition returns a task definition by arn

func GetTaskIDFromArn

func GetTaskIDFromArn(arn string) string

GetTaskIDFromArn returns the last part of an arn for an ecs task

func GetTaskLogs

func GetTaskLogs(def *ecs.TaskDefinition, taskID string) error

GetTaskLogs prints logs to stdout

func KeyPairsToString

func KeyPairsToString(kv []*ecs.KeyValuePair) string

KeyPairsToString takes a list of key pairs... and prints them into a multiline block

func ListLogEvents

func ListLogEvents(group, name, region string) error

ListLogEvents accepts a single group and stream name and prints the cloudwatch logs to stdout

func ListServices

func ListServices(cluster string) ([]string, error)

ListServices lists services for a cluster by plain name

func RunTaskWithCommand

func RunTaskWithCommand(cluster, service, command string) (*ecs.RunTaskOutput, error)

RunTaskWithCommand runs a one-off task with a command override.

func ScaleService

func ScaleService(cluster, service string, desiredCount int) (*ecs.Service, error)

ScaleService sets the desired count of a service

func StringToKeyPairs

func StringToKeyPairs(input string) ([]*ecs.KeyValuePair, error)

StringToKeyPairs takes a string, and turns it back into an array of key pairs

func TaskExitCode

func TaskExitCode(task *ecs.Task) (*int64, error)

TaskExitCode will tell you if the exit code of a task

func UpdateAgent

func UpdateAgent(cluster, containerInstanceARN string) error

UpdateAgent will update the agents for all instances in a cluster

func ValidateCluster

func ValidateCluster(cluster string) error

ValidateCluster returns an error if the cluster is not found