util

May 2, 2016

Changes in this version

+ const ExecDriverDir

+ func DeleteCluster(t *testing.T, clusterName string)

+ func RoundTimeUp(realTime time.Time, duration time.Duration) time.Time

+ func VerifyMetrics(cwclient *cloudwatch.CloudWatch, params *cloudwatch.GetMetricStatisticsInput, ...) error

Apr 1, 2016

Changes in this version

type TestAgent

+ func (agent *TestAgent) WaitRunningViaIntrospection(task *TestTask) (bool, error)

+ func (agent *TestAgent) WaitStoppedViaIntrospection(task *TestTask) (bool, error)

Dec 9, 2015

Changes in this version

+ func RequireDockerVersion(t *testing.T, selector string)

Oct 26, 2015

Changes in this version

type AgentOptions

+ ContainerLinks []string

Sep 29, 2015

Changes in this version

+ type AgentOptions struct

+ ExtraEnvironment map[string]string

type TestAgent

+ Logdir string

+ Options *AgentOptions

+ func (agent *TestAgent) RequireVersion(version string)

+ type Version string

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

Aug 12, 2015

Changes in this version

+ var Cluster string

+ var ECS *ecs.ECS

+ func GetTaskDefinition(name string) (string, error)

+ type TestAgent struct

+ Cluster string

+ ContainerInstanceArn string

+ DockerClient *docker.Client

+ DockerID string

+ Image string

+ IntrospectionURL string

+ TestDir string

+ Version string

+ func RunAgent(t *testing.T, version *string) *TestAgent

+ func (agent *TestAgent) Cleanup()

+ 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 struct

+ 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