Versions in this module Expand all Collapse all v1 v1.0.0 Apr 3, 2015 Changes in this version + type APIError struct + Retriable bool + func NewAPIError(err error) *APIError + func (apiErr *APIError) Error() string + func (apiErr *APIError) Retry() bool type Task + func TaskFromACS(task *ecsacs.Task) (*Task, error) type TaskStatus + func (ts *TaskStatus) BackendStatus() string v0 v0.0.3 Feb 19, 2015 Changes in this version + const DOCKER_MINIMUM_MEMORY + const ECS_SERVICE + const EcsMaxReasonLength + type ApiECSClient struct + func (client *ApiECSClient) CreateCluster(clusterName string) (string, error) + func (client *ApiECSClient) CredentialProvider() credentials.AWSCredentialProvider + func (client *ApiECSClient) DeregisterContainerInstance(containerInstanceArn string) error + func (client *ApiECSClient) DiscoverPollEndpoint(containerInstanceArn string) (string, error) + func (client *ApiECSClient) RegisterContainerInstance() (string, error) + func (client *ApiECSClient) SubmitContainerStateChange(change ContainerStateChange) utils.RetriableError + func (client *ApiECSClient) SubmitTaskStateChange(change ContainerStateChange) utils.RetriableError + type ApplyingError struct + Err string + func NewApplyingError(err error) *ApplyingError + func (ae *ApplyingError) Error() string + type Container struct + AppliedStatus ContainerStatus + ApplyingError *ApplyingError + Command []string + Cpu uint + DesiredStatus ContainerStatus + EntryPoint *[]string + Environment map[string]string + Essential bool + Image string + IsInternal bool + KnownExitCode *int + KnownPortBindings []PortBinding + KnownStatus ContainerStatus + Links []string + Memory uint + MountPoints []MountPoint + Name string + Overrides ContainerOverrides + Ports []PortBinding + RunDependencies []string + SentStatus ContainerStatus + StatusLock sync.Mutex + VolumesFrom []VolumeFrom + func (c *Container) DesiredTerminal() bool + func (c *Container) KnownTerminal() bool + func (c *Container) Overridden() *Container + func (c *Container) String() string + type ContainerOverrides struct + Command *[]string + func (overrides *ContainerOverrides) UnmarshalJSON(b []byte) error + type ContainerOverridesCopy ContainerOverrides + type ContainerStateChange struct + Container *Container + ContainerName string + ExitCode *int + PortBindings []PortBinding + Reason string + Status ContainerStatus + Task *Task + TaskArn string + TaskStatus TaskStatus + type ContainerStatus int32 + const ContainerCreated + const ContainerDead + const ContainerPulled + const ContainerRunning + const ContainerStatusNone + const ContainerStatusUnknown + const ContainerStopped + const ContainerZombie + func (cs *ContainerStatus) MarshalJSON() ([]byte, error) + func (cs *ContainerStatus) String() string + func (cs *ContainerStatus) TaskStatus() TaskStatus + func (cs *ContainerStatus) Terminal() bool + func (cs *ContainerStatus) UnmarshalJSON(b []byte) error + type DockerContainer struct + Container *Container + DockerId string + DockerName string + func (dc *DockerContainer) String() string + type ECSClient interface + CredentialProvider func() credentials.AWSCredentialProvider + DeregisterContainerInstance func(containerInstanceArn string) error + DiscoverPollEndpoint func(containerInstanceArn string) (string, error) + RegisterContainerInstance func() (string, error) + SubmitContainerStateChange func(change ContainerStateChange) utils.RetriableError + SubmitTaskStateChange func(change ContainerStateChange) utils.RetriableError + func NewECSClient(credentialProvider credentials.AWSCredentialProvider, config *config.Config, ...) ECSClient + type EmptyHostVolume struct + func (e *EmptyHostVolume) SourcePath() string + type FSHostVolume struct + FSSourcePath string + func (fs *FSHostVolume) SourcePath() string + type HostVolume interface + SourcePath func() string + type MountPoint struct + ContainerPath string + ReadOnly bool + SourceVolume string + type PortBinding struct + BindIp string + ContainerPort uint16 + HostPort uint16 + func PortBindingFromDockerPortBinding(dockerPortBindings map[docker.Port][]docker.PortBinding) ([]PortBinding, error) + type Resource struct + DoubleValue float64 + LongValue int64 + Name string + Type string + type StateChangeError struct + Retriable bool + func NewStateChangeError(err error) *StateChangeError + func (sce *StateChangeError) Error() string + func (sce *StateChangeError) Retry() bool + type Task struct + Arn string + Containers []*Container + DesiredStatus TaskStatus + Family string + KnownStatus TaskStatus + KnownTime time.Time + Overrides TaskOverrides + SentStatus TaskStatus + Version string + Volumes []TaskVolume + func RemoveFromTaskArray(arr []*Task, ndx int) []*Task + func (t *Task) String() string + func (task *Task) ContainerByName(name string) (*Container, bool) + func (task *Task) DockerConfig(container *Container) (*docker.Config, error) + func (task *Task) DockerHostConfig(container *Container, dockerContainerMap map[string]*DockerContainer) (*docker.HostConfig, error) + func (task *Task) HostVolumeByName(name string) (HostVolume, bool) + func (task *Task) InferContainerDesiredStatus() + func (task *Task) Overridden() *Task + func (task *Task) PostUnmarshalTask() + func (task *Task) UpdateMountPoints(cont *Container, vols map[string]string) + func (task *Task) UpdateTaskStatus() (newStatus TaskStatus) + type TaskOverrides struct + type TaskStatus int32 + const TaskCreated + const TaskDead + const TaskPulled + const TaskRunning + const TaskStatusNone + const TaskStatusUnknown + const TaskStopped + func (ts *TaskStatus) ContainerStatus() ContainerStatus + func (ts *TaskStatus) MarshalJSON() ([]byte, error) + func (ts *TaskStatus) String() string + func (ts *TaskStatus) Terminal() bool + func (ts *TaskStatus) UnmarshalJSON(b []byte) error + type TaskVolume struct + Name string + Volume HostVolume + func (tv *TaskVolume) MarshalJSON() ([]byte, error) + func (tv *TaskVolume) UnmarshalJSON(b []byte) error + type VolumeFrom struct + ReadOnly bool + SourceContainer string
Go to main page