Documentation ¶
Index ¶
- func BuildConsoleURLForService(cluster, service string) string
- func CopyTaskDefinition(existingTask *ecs.TaskDefinition, toFamilyName string, ...) (*ecs.TaskDefinition, error)
- func CreateNewTaskWithEnvironment(existingTask *ecs.TaskDefinition, env []*ecs.KeyValuePair) (*ecs.TaskDefinition, error)
- func CreateNewTaskWithImage(existingTask *ecs.TaskDefinition, imageURL string) (*ecs.TaskDefinition, error)
- func CreateNewTaskWithMemory(existingTask *ecs.TaskDefinition, memory *int64, memoryReservation *int64) (*ecs.TaskDefinition, error)
- func CreatePostDeploymentTask(input *CreatePostDeploymentTaskInput) error
- func CreateRefreshDeployment(cluster, service string) error
- func CreateScheduledTask(cluster, service, taskSuffix, scheduleExpression, command string) error
- func DeployTaskToService(cluster, service string, task *ecs.TaskDefinition) (*ecs.Service, error)
- func EssentialImage(task *ecs.TaskDefinition) string
- func FindNewestDefinition(familyPrefix string) (*ecs.TaskDefinition, error)
- func FindRoleByName(name string) (*iam.Role, error)
- func FindService(cluster, service string) (*ecs.Service, error)
- func FindServicesWithEnvVar(envVar, envVarValue 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 GetNewestTaskDefinition(cluster, service string) (*ecs.TaskDefinition, error)
- func GetTask(cluster, arn string) (*ecs.Task, 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 ListClusters() ([]string, error)
- func ListLogEvents(group, name, region string) error
- func ListServices(cluster string) ([]string, error)
- func LocateTaskDef(cluster, service, source string) (*ecs.TaskDefinition, error)
- func PrintTaskURLs(clusterName string, service *ecs.Service) ([]string, error)
- func RunTaskWithCommand(cluster string, task *ecs.TaskDefinition, 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
- func WithCommand(command string) func(definition *ecs.ContainerDefinition)
- func WithName(name string) func(definition *ecs.ContainerDefinition)
- type CreatePostDeploymentTaskInput
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildConsoleURLForService ¶ added in v0.0.7
BuildConsoleURLForService builds the console url for a service
func CopyTaskDefinition ¶ added in v0.2.10
func CopyTaskDefinition(existingTask *ecs.TaskDefinition, toFamilyName string, modifiers ...func(*ecs.ContainerDefinition)) (*ecs.TaskDefinition, error)
CopyTaskDefinitionWithCommand registers a new task, based on the passed task, but with new command.
func CreateNewTaskWithEnvironment ¶ added in v0.0.7
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 CreateNewTaskWithImage ¶ added in v0.2.5
func CreateNewTaskWithImage(existingTask *ecs.TaskDefinition, imageURL string) (*ecs.TaskDefinition, error)
CreateNewTaskWithImage registers a new task, based on the passed task, but with new image.
func CreateNewTaskWithMemory ¶ added in v0.2.17
func CreateNewTaskWithMemory(existingTask *ecs.TaskDefinition, memory *int64, memoryReservation *int64) (*ecs.TaskDefinition, error)
CreateNewTaskWithMemory registers a new task definition, overwriting memory params
func CreatePostDeploymentTask ¶ added in v0.2.13
func CreatePostDeploymentTask(input *CreatePostDeploymentTaskInput) error
CreatePostDeploymentTask listens for SERVICE_STEADY_STATE events matching the service and cluster, and runs a custom command when a deployment is complete
func CreateRefreshDeployment ¶ added in v0.2.16
CreateRefreshDeployment forces a new deployment on a service.
func CreateScheduledTask ¶ added in v0.1.6
CreateScheduledTask creates a scheduled task in an ECS cluster with the specified paramters
func DeployTaskToService ¶ added in v0.0.7
DeployTaskToService deploys a given task definition to a cluster/service
func EssentialImage ¶ added in v0.2.5
func EssentialImage(task *ecs.TaskDefinition) string
EssentialImage returns the essential image of a task def
func FindNewestDefinition ¶ added in v0.2.5
func FindNewestDefinition(familyPrefix string) (*ecs.TaskDefinition, error)
FindNewestDefinition finds the most recent task definition of the service's task family
func FindRoleByName ¶ added in v0.1.6
FindRoleByName paginates through roles and returns any found that match the name string
func FindService ¶ added in v0.0.7
FindService finds a service struct by name
func FindServicesWithEnvVar ¶ added in v0.2.21
func GetAllLogs ¶ added in v0.1.9
func GetAllLogs(region string, params *cloudwatchlogs.GetLogEventsInput) ([]string, error)
GetAllLogs retrieves the entire log history
func GetAllTasksByDefinition ¶ added in v0.1.9
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 ¶ added in v0.1.9
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 ¶ added in v0.1.4
GetClusterInstances returns the container instances of a cluster by id
func GetClusterNames ¶
GetClusterNames returns a slice of strings representing cluster names
func GetContainerInstances ¶
GetContainerInstances returns the container instances of a cluster
func GetCurrentTaskDefinition ¶ added in v0.0.6
func GetCurrentTaskDefinition(cluster, service string) (*ecs.TaskDefinition, error)
GetCurrentTaskDefinition returns a service's current task definition
func GetDeployedEssentialContainer ¶ added in v0.0.6
func GetDeployedEssentialContainer(cluster, service string) (*ecs.ContainerDefinition, error)
GetDeployedEssentialContainer gets the currently deployed "essential" container definition of a cluster service
func GetEssentialContainer ¶ added in v0.0.6
func GetEssentialContainer(task *ecs.TaskDefinition) (*ecs.ContainerDefinition, error)
GetEssentialContainer returns the essential container
func GetLogs ¶ added in v0.0.14
GetLogs returns cloudwatch logs for a specific set of log streams matching a pattern within a log group and region
func GetNewestTaskDefinition ¶ added in v0.2.9
func GetNewestTaskDefinition(cluster, service string) (*ecs.TaskDefinition, error)
func GetTaskDefinition ¶ added in v0.1.7
func GetTaskDefinition(arn string) (*ecs.TaskDefinition, error)
GetTaskDefinition returns a task definition by arn
func GetTaskIDFromArn ¶ added in v0.1.9
GetTaskIDFromArn returns the last part of an arn for an ecs task
func GetTaskLogs ¶ added in v0.1.7
func GetTaskLogs(def *ecs.TaskDefinition, taskID string) error
GetTaskLogs prints logs to stdout
func KeyPairsToString ¶ added in v0.0.7
func KeyPairsToString(kv []*ecs.KeyValuePair) string
KeyPairsToString takes a list of key pairs... and prints them into a multiline block
func ListClusters ¶ added in v0.2.13
func ListLogEvents ¶ added in v0.0.14
ListLogEvents accepts a single group and stream name and prints the cloudwatch logs to stdout
func ListServices ¶ added in v0.0.10
ListServices lists services for a cluster by plain name
func LocateTaskDef ¶ added in v0.2.9
func LocateTaskDef(cluster, service, source string) (*ecs.TaskDefinition, error)
func PrintTaskURLs ¶ added in v0.2.17
func RunTaskWithCommand ¶ added in v0.1.4
func RunTaskWithCommand(cluster string, task *ecs.TaskDefinition, command string) (*ecs.RunTaskOutput, error)
RunTaskWithCommand runs a one-off task with a command override.
func ScaleService ¶ added in v0.0.11
ScaleService sets the desired count of a service
func StringToKeyPairs ¶ added in v0.0.7
func StringToKeyPairs(input string) ([]*ecs.KeyValuePair, error)
StringToKeyPairs takes a string, and turns it back into an array of key pairs
func TaskExitCode ¶ added in v0.1.7
TaskExitCode will tell you if the exit code of a task
func UpdateAgent ¶ added in v0.1.4
UpdateAgent will update the agents for all instances in a cluster
func ValidateCluster ¶
ValidateCluster returns an error if the cluster is not found
func WithCommand ¶ added in v0.2.10
func WithCommand(command string) func(definition *ecs.ContainerDefinition)
func WithName ¶ added in v0.2.10
func WithName(name string) func(definition *ecs.ContainerDefinition)