util

Documentation

Index

• Variables
• func GetTaskDefinition(name string) (string, error)
• type AgentOptions
• type TestAgent
  • func RunAgent(t *testing.T, options *AgentOptions) *TestAgent
  • func (agent *TestAgent) Cleanup()
  • func (agent *TestAgent) RequireVersion(version string)
  • func (agent *TestAgent) ResolveTaskDockerID(task *TestTask, containerName string) (string, error)
  • func (agent *TestAgent) StartAgent() error
  • func (agent *TestAgent) StartMultipleTasks(t *testing.T, task string, num int) ([]*TestTask, error)
  • func (agent *TestAgent) StartTask(t *testing.T, task string) (*TestTask, error)
  • func (agent *TestAgent) StartTaskWithOverrides(t *testing.T, task string, overrides []*ecs.ContainerOverride) (*TestTask, error)
  • func (agent *TestAgent) StopAgent() error
• type TestTask
  • func (task *TestTask) ContainerExitcode(name string) (int, bool)
  • func (task *TestTask) ExpectErrorType(containerName, errType string, timeout time.Duration) error
  • func (task *TestTask) Redescribe()
  • func (task *TestTask) Stop() error
  • func (task *TestTask) WaitRunning(timeout time.Duration) error
  • func (task *TestTask) WaitStopped(timeout time.Duration) error
• type Version
  • func (lhs Version) Matches(selector string) (bool, error)

Variables

var Cluster string

var ECS *ecs.ECS

Functions

func GetTaskDefinition

func GetTaskDefinition(name string) (string, error)

GetTaskDefinition is a helper that provies the family:revision for the named task definition where the name matches the folder in which the task definition is present. In order to avoid re-registering a task definition when it has already been regestered in the past, this registers a task definition of the pattern 'family-md5sum' with md5sum being the input task definition json's md5. This special family name is checked for existence before a new one is registered and it is assumed that if it exists, the task definition currently represented by the file was registered as such already.

Types

type AgentOptions

type AgentOptions struct {
	ExtraEnvironment map[string]string
	ContainerLinks   []string
}

type TestAgent

type TestAgent struct {
	Image                string
	DockerID             string
	IntrospectionURL     string
	Version              string
	ContainerInstanceArn string
	Cluster              string
	TestDir              string
	Logdir               string
	Options              *AgentOptions

	DockerClient *docker.Client
	// contains filtered or unexported fields
}

func RunAgent

func RunAgent(t *testing.T, options *AgentOptions) *TestAgent

RunAgent launches the agent and returns an object which may be used to reference it. It will wait until the agent is correctly registered before returning. 'version' may be a docker image (e.g. amazon/amazon-ecs-agent:v1.0.0) with tag that may be used to run the agent. It defaults to 'amazon/amazon-ecs-agent:make', the version created locally by running 'make'

func (*TestAgent) Cleanup

func (agent *TestAgent) Cleanup()

func (*TestAgent) RequireVersion

func (agent *TestAgent) RequireVersion(version string)

func (*TestAgent) ResolveTaskDockerID

func (agent *TestAgent) ResolveTaskDockerID(task *TestTask, containerName string) (string, error)

ResolveTaskDockerID determines the Docker ID for a container within a given task that has been run by the Agent.

func (*TestAgent) StartAgent

func (agent *TestAgent) StartAgent() error

func (*TestAgent) StartMultipleTasks

func (agent *TestAgent) StartMultipleTasks(t *testing.T, task string, num int) ([]*TestTask, error)

func (*TestAgent) StartTask

func (agent *TestAgent) StartTask(t *testing.T, task string) (*TestTask, error)

func (*TestAgent) StartTaskWithOverrides

func (agent *TestAgent) StartTaskWithOverrides(t *testing.T, task string, overrides []*ecs.ContainerOverride) (*TestTask, error)

func (*TestAgent) StopAgent

func (agent *TestAgent) StopAgent() error

type TestTask

type TestTask struct {
	*ecs.Task
}

func (*TestTask) ContainerExitcode

func (task *TestTask) ContainerExitcode(name string) (int, bool)

func (*TestTask) ExpectErrorType

func (task *TestTask) ExpectErrorType(containerName, errType string, timeout time.Duration) error

func (*TestTask) Redescribe

func (task *TestTask) Redescribe()

func (*TestTask) Stop

func (task *TestTask) Stop() error

func (*TestTask) WaitRunning

func (task *TestTask) WaitRunning(timeout time.Duration) error

func (*TestTask) WaitStopped

func (task *TestTask) WaitStopped(timeout time.Duration) error

type Version

type Version string

func (Version) Matches

func (lhs Version) Matches(selector string) (bool, error)