ecs

Documentation

Overview

Package ecs provides a client to retrieve Copilot ECS information.

Package ecs provides a client to retrieve Copilot ECS information.

Index

• type Client
  • func New(sess *session.Session) *Client
  • func (c Client) ClusterARN(app, env string) (string, error)
  • func (c Client) DescribeService(app, env, svc string) (*ServiceDesc, error)
  • func (c Client) ForceUpdateService(app, env, svc string) error
  • func (c Client) HasNonZeroExitCode(taskARNs []string, cluster string) error
  • func (c Client) LastUpdatedAt(app, env, svc string) (time.Time, error)
  • func (c Client) ListActiveAppEnvTasks(opts ListActiveAppEnvTasksOpts) ([]*ecs.Task, error)
  • func (c Client) ListActiveDefaultClusterTasks(filter ListTasksFilter) ([]*ecs.Task, error)
  • func (c Client) NetworkConfiguration(app, env, svc string) (*ecs.NetworkConfiguration, error)
  • func (c Client) NetworkConfigurationForJob(app, env, job string) (*ecs.NetworkConfiguration, error)
  • func (c Client) Service(app, env, svc string) (*ecs.Service, error)
  • func (c Client) StopDefaultClusterTasks(familyName string) error
  • func (c Client) StopOneOffTasks(app, env, family string) error
  • func (c Client) StopWorkloadTasks(app, env, workload string) error
  • func (c Client) TaskDefinition(app, env, svc string) (*ecs.TaskDefinition, error)
• type ECSServiceDescriber
• type ErrExitCode
  • func (e *ErrExitCode) Error() string
  • func (e *ErrExitCode) ExitCode() int
• type ErrMultipleContainersInTaskDef
  • func (e *ErrMultipleContainersInTaskDef) Error() string
• type JobDescriber
• type ListActiveAppEnvTasksOpts
• type ListTasksFilter
• type NetworkConfiguration
  • func (n *NetworkConfiguration) UnmarshalJSON(b []byte) error
• type RunTaskRequest
  • func RunTaskRequestFromECSService(client ECSServiceDescriber, cluster, service string) (*RunTaskRequest, error)
  • func RunTaskRequestFromJob(client JobDescriber, app, env, job string) (*RunTaskRequest, error)
  • func RunTaskRequestFromService(client ServiceDescriber, app, env, svc string) (*RunTaskRequest, error)
  • func (r RunTaskRequest) CLIString() (string, error)
• type ServiceDesc
• type ServiceDescriber

Types

type Client

type Client struct {
	StepFuncClient stepFunctionsClient
	// contains filtered or unexported fields
}

Client retrieves Copilot information from ECS endpoint.

func New

func New(sess *session.Session) *Client

New inits a new Client.

func (Client) ClusterARN

func (c Client) ClusterARN(app, env string) (string, error)

ClusterARN returns the ARN of the cluster in an environment.

func (Client) DescribeService

func (c Client) DescribeService(app, env, svc string) (*ServiceDesc, error)

DescribeService returns the description of an ECS service given Copilot service info.

func (Client) ForceUpdateService

func (c Client) ForceUpdateService(app, env, svc string) error

ForceUpdateService forces a new update for an ECS service given Copilot service info.

func (Client) HasNonZeroExitCode

func (c Client) HasNonZeroExitCode(taskARNs []string, cluster string) error

HasNonZeroExitCode returns an error if at least one of the tasks exited with a non-zero exit code. It assumes that all tasks are built on the same task definition.

func (Client) LastUpdatedAt

func (c Client) LastUpdatedAt(app, env, svc string) (time.Time, error)

LastUpdatedAt returns the last updated time of the ECS service.

func (Client) ListActiveAppEnvTasks

func (c Client) ListActiveAppEnvTasks(opts ListActiveAppEnvTasksOpts) ([]*ecs.Task, error)

ListActiveAppEnvTasks returns the active Copilot tasks in the environment of an application.

func (Client) ListActiveDefaultClusterTasks

func (c Client) ListActiveDefaultClusterTasks(filter ListTasksFilter) ([]*ecs.Task, error)

ListActiveDefaultClusterTasks returns the active Copilot tasks in the default cluster.

func (Client) NetworkConfiguration

func (c Client) NetworkConfiguration(app, env, svc string) (*ecs.NetworkConfiguration, error)

NetworkConfiguration returns the network configuration of the service.

func (Client) NetworkConfigurationForJob

func (c Client) NetworkConfigurationForJob(app, env, job string) (*ecs.NetworkConfiguration, error)

NetworkConfigurationForJob returns the network configuration of the job.

func (Client) Service

func (c Client) Service(app, env, svc string) (*ecs.Service, error)

Service returns an ECS service given Copilot service info.

func (Client) StopDefaultClusterTasks

func (c Client) StopDefaultClusterTasks(familyName string) error

StopDefaultClusterTasks stops all copilot tasks from the given family in the default cluster.

func (Client) StopOneOffTasks

func (c Client) StopOneOffTasks(app, env, family string) error

StopOneOffTasks stops all one-off tasks in the given application and environment with the family name.

func (Client) StopWorkloadTasks

func (c Client) StopWorkloadTasks(app, env, workload string) error

StopWorkloadTasks stops all tasks in the given application, enviornment, and workload.

func (Client) TaskDefinition

func (c Client) TaskDefinition(app, env, svc string) (*ecs.TaskDefinition, error)

TaskDefinition returns the task definition of the service.

type ECSServiceDescriber

type ECSServiceDescriber interface {
	Service(clusterName, serviceName string) (*awsecs.Service, error)
	TaskDefinition(taskDefName string) (*awsecs.TaskDefinition, error)
	NetworkConfiguration(cluster, serviceName string) (*awsecs.NetworkConfiguration, error)
}

ECSServiceDescriber provides information on an ECS service.

type ErrExitCode

type ErrExitCode struct {
	// contains filtered or unexported fields
}

ErrExitCode builds custom non-zero exit code error

func (*ErrExitCode) Error

func (e *ErrExitCode) Error() string

func (*ErrExitCode) ExitCode

func (e *ErrExitCode) ExitCode() int

type ErrMultipleContainersInTaskDef

type ErrMultipleContainersInTaskDef struct {
	// contains filtered or unexported fields
}

func (*ErrMultipleContainersInTaskDef) Error

func (e *ErrMultipleContainersInTaskDef) Error() string

type JobDescriber

type JobDescriber interface {
	TaskDefinition(app, env, job string) (*awsecs.TaskDefinition, error)
	NetworkConfigurationForJob(app, env, job string) (*awsecs.NetworkConfiguration, error)
	ClusterARN(app, env string) (string, error)
}

JobDescriber provides information on a Copilot job.

type ListActiveAppEnvTasksOpts

type ListActiveAppEnvTasksOpts struct {
	App string
	Env string
	ListTasksFilter
}

ListActiveAppEnvTasksOpts contains the parameters for ListActiveAppEnvTasks.

type ListTasksFilter

type ListTasksFilter struct {
	TaskGroup   string // Returns only tasks with the given TaskGroup name.
	TaskID      string // Returns only tasks with the given ID.
	CopilotOnly bool   // Returns only tasks with the `copilot-task` tag.
}

ListTasksFilter contains the filtering parameters for listing Copilot tasks.

type NetworkConfiguration

type NetworkConfiguration ecs.NetworkConfiguration

NetworkConfiguration wraps an ecs.NetworkConfiguration struct.

func (*NetworkConfiguration) UnmarshalJSON

func (n *NetworkConfiguration) UnmarshalJSON(b []byte) error

UnmarshalJSON implements custom logic to unmarshal only the network configuration from a state machine definition. Example state machine definition:

 "Version": "1.0",
 "Comment": "Run AWS Fargate task",
 "StartAt": "Run Fargate Task",
 "States": {
   "Run Fargate Task": {
	 "Type": "Task",
	 "Resource": "arn:aws:states:::ecs:runTask.sync",
	 "Parameters": {
	   "LaunchType": "FARGATE",
	   "PlatformVersion": "1.4.0",
	   "Cluster": "cluster",
	   "TaskDefinition": "def",
	   "PropagateTags": "TASK_DEFINITION",
	   "Group.$": "$$.Execution.Name",
	   "NetworkConfiguration": {
		 "AwsvpcConfiguration": {
		   "Subnets": ["sbn-1", "sbn-2"],
		   "AssignPublicIp": "ENABLED",
		   "SecurityGroups": ["sg-1", "sg-2"]
		 }
	   }
	 },
	 "End": true
   }

type RunTaskRequest

type RunTaskRequest struct {
	// contains filtered or unexported fields
}

RunTaskRequest contains information to generate a task run command.

func RunTaskRequestFromECSService

func RunTaskRequestFromECSService(client ECSServiceDescriber, cluster, service string) (*RunTaskRequest, error)

RunTaskRequestFromECSService populates a RunTaskRequest with information from an ECS service.

func RunTaskRequestFromJob

func RunTaskRequestFromJob(client JobDescriber, app, env, job string) (*RunTaskRequest, error)

RunTaskRequestFromJob populates a RunTaskRequest with information from a Copilot job.

func RunTaskRequestFromService

func RunTaskRequestFromService(client ServiceDescriber, app, env, svc string) (*RunTaskRequest, error)

RunTaskRequestFromService populates a RunTaskRequest with information from a Copilot service.

func (RunTaskRequest) CLIString

func (r RunTaskRequest) CLIString() (string, error)

String stringifies a RunTaskRequest.

type ServiceDesc

type ServiceDesc struct {
	Name         string
	ClusterName  string
	Tasks        []*ecs.Task // Tasks is a list of tasks with DesiredStatus being RUNNING.
	StoppedTasks []*ecs.Task
}

ServiceDesc contains the description of an ECS service.

type ServiceDescriber

type ServiceDescriber interface {
	TaskDefinition(app, env, svc string) (*awsecs.TaskDefinition, error)
	NetworkConfiguration(app, env, svc string) (*awsecs.NetworkConfiguration, error)
	ClusterARN(app, env string) (string, error)
}

ServiceDescriber provides information on a Copilot service.