api

package

Go to main page

Versions in this module

v1

v1.4.0

Aug 12, 2015

Changes in this version

type ApiECSClient

+ func (client *ApiECSClient) SetSubmitStateChangeSDK(sdk ECSSubmitStateSDK)

+ type ECSSubmitStateSDK interface

+ SubmitContainerStateChange func(*ecs.SubmitContainerStateChangeInput) (*ecs.SubmitContainerStateChangeOutput, error)

+ SubmitTaskStateChange func(*ecs.SubmitTaskStateChangeInput) (*ecs.SubmitTaskStateChangeOutput, error)

v1.3.1

Jul 30, 2015

Changes in this version

+ func ECSRetryHandler(r *aws.Request)

+ func IsInstanceTypeChangedError(err awserr.Error) bool

type ContainerStateChange

+ func (c *ContainerStateChange) String() string

type TaskStateChange

+ func (t *TaskStateChange) String() string

v1.3.0

Jul 6, 2015

Changes in this version

+ const INSTANCE_TYPE_CHANGED_ERROR_MESSAGE

type APIError

+ func (apiErr *APIError) IsInstanceTypeChangedError() bool

v1.2.1

Jun 19, 2015

v1.2.0

Jun 9, 2015

Changes in this version

+ const UnparseablePortErrorName

+ const UnrecognizedTransportProtocolErrorName

type ApiECSClient

+ func (client *ApiECSClient) DiscoverTelemetryEndpoint(containerInstanceArn string) (string, error)

type ECSClient

+ DiscoverTelemetryEndpoint func(containerInstanceArn string) (string, error)

type PortBinding

+ Protocol TransportProtocol

+ type TransportProtocol int32

+ const TransportProtocolTCP

+ const TransportProtocolUDP

+ func NewTransportProtocol(protocol string) (TransportProtocol, error)

+ func (tp *TransportProtocol) MarshalJSON() ([]byte, error)

+ func (tp *TransportProtocol) String() string

+ func (tp *TransportProtocol) UnmarshalJSON(b []byte) error

v1.1.0

May 6, 2015

Changes in this version

+ const RoundtripTimeout

type ApiECSClient

+ func (client *ApiECSClient) SetEC2MetadataClient(ec2MetadataClient ec2.EC2MetadataClient)

+ func (client *ApiECSClient) SetSDK(sdk ECSSDK)

type ContainerStateChange

+ SentStatus *ContainerStatus

type ContainerStatus

+ func (cs *ContainerStatus) BackendRecognized() bool

+ type DefaultNamedError struct

+ Err string

+ Name string

+ func NewNamedError(err error) *DefaultNamedError

+ func (err *DefaultNamedError) Error() string

+ func (err *DefaultNamedError) ErrorName() string

+ type DockerClientConfigError struct

+ func (err *DockerClientConfigError) Error() string

+ func (err *DockerClientConfigError) ErrorName() string

+ type ECSSDK interface

+ CreateCluster func(*ecs.CreateClusterInput) (*ecs.CreateClusterOutput, error)

+ DiscoverPollEndpoint func(*ecs.DiscoverPollEndpointInput) (*ecs.DiscoverPollEndpointOutput, error)

+ RegisterContainerInstance func(*ecs.RegisterContainerInstanceInput) (*ecs.RegisterContainerInstanceOutput, error)

+ SubmitContainerStateChange func(*ecs.SubmitContainerStateChangeInput) (*ecs.SubmitContainerStateChangeOutput, error)

+ SubmitTaskStateChange func(*ecs.SubmitTaskStateChangeInput) (*ecs.SubmitTaskStateChangeOutput, error)

type EmptyHostVolume

+ HostPath string

+ type HostConfigError struct

+ func (err *HostConfigError) Error() string

+ func (err *HostConfigError) ErrorName() string

+ type NamedError interface

+ ErrorName func() string

type Task

+ KnownStatusTime time.Time

+ StartSequenceNumber int64

+ StopSequenceNumber int64

+ func (t *Task) SetKnownStatus(status TaskStatus)

+ func (t *Task) UpdateDesiredStatus()

+ func (t *Task) UpdateStatus() bool

+ type TaskStateChange struct

+ Reason string

+ SentStatus *TaskStatus

+ Status TaskStatus

+ TaskArn string

type TaskStatus

+ func (ts *TaskStatus) BackendRecognized() bool

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL