engine

Apr 1, 2016

Changes in this version

type DockerTaskEngine

+ func (engine *DockerTaskEngine) GetTaskByArn(arn string) (*api.Task, bool)

type MockTaskEngine

+ func (_m *MockTaskEngine) GetTaskByArn(_param0 string) (*api.Task, bool)

type TaskEngine

+ GetTaskByArn func(string) (*api.Task, bool)

Dec 9, 2015

Changes in this version

+ type MockDockerClient struct

+ func NewMockDockerClient(ctrl *gomock.Controller) *MockDockerClient

+ func (_m *MockDockerClient) ContainerEvents(_param0 context.Context) (<-chan DockerContainerChangeEvent, error)

+ func (_m *MockDockerClient) CreateContainer(_param0 *go_dockerclient.Config, _param1 *go_dockerclient.HostConfig, ...) DockerContainerMetadata

+ func (_m *MockDockerClient) DescribeContainer(_param0 string) (api.ContainerStatus, DockerContainerMetadata)

+ func (_m *MockDockerClient) EXPECT() *_MockDockerClientRecorder

+ func (_m *MockDockerClient) GetContainerName(_param0 string) (string, error)

+ func (_m *MockDockerClient) InspectContainer(_param0 string) (*go_dockerclient.Container, error)

+ func (_m *MockDockerClient) ListContainers(_param0 bool) ListContainersResponse

+ func (_m *MockDockerClient) PullImage(_param0 string, _param1 *api.RegistryAuthenticationData) DockerContainerMetadata

+ func (_m *MockDockerClient) RemoveContainer(_param0 string) error

+ func (_m *MockDockerClient) StartContainer(_param0 string) DockerContainerMetadata

+ func (_m *MockDockerClient) StopContainer(_param0 string) DockerContainerMetadata

+ func (_m *MockDockerClient) SupportedVersions() []dockerclient.DockerVersion

+ func (_m *MockDockerClient) Version() (string, error)

+ func (_m *MockDockerClient) WithVersion(_param0 dockerclient.DockerVersion) DockerClient

+ type MockTaskEngine struct

+ func NewMockTaskEngine(ctrl *gomock.Controller) *MockTaskEngine

+ func (_m *MockTaskEngine) AddTask(_param0 *api.Task) error

+ func (_m *MockTaskEngine) Capabilities() []string

+ func (_m *MockTaskEngine) Disable()

+ func (_m *MockTaskEngine) EXPECT() *_MockTaskEngineRecorder

+ func (_m *MockTaskEngine) Init() error

+ func (_m *MockTaskEngine) ListTasks() ([]*api.Task, error)

+ func (_m *MockTaskEngine) MarshalJSON() ([]byte, error)

+ func (_m *MockTaskEngine) MustInit()

+ func (_m *MockTaskEngine) SetSaver(_param0 statemanager.Saver)

+ func (_m *MockTaskEngine) TaskEvents() (<-chan api.TaskStateChange, <-chan api.ContainerStateChange)

+ func (_m *MockTaskEngine) UnmarshalJSON(_param0 []byte) error

+ func (_m *MockTaskEngine) Version() (string, error)

Sep 29, 2015

Changes in this version

+ type CannotGetDockerClientError struct

+ func (CannotGetDockerClientError) ErrorName() string

+ func (c CannotGetDockerClientError) Error() string

type DockerClient

+ SupportedVersions func() []dockerclient.DockerVersion

+ WithVersion func(dockerclient.DockerVersion) DockerClient

type DockerGoClient

+ func (dg *DockerGoClient) SupportedVersions() []dockerclient.DockerVersion

+ func (dg *DockerGoClient) WithVersion(version dockerclient.DockerVersion) DockerClient

type DockerTaskEngine

+ func (engine *DockerTaskEngine) Capabilities() []string

type TaskEngine

+ Capabilities func() []string

Jun 9, 2015

Changes in this version

type DockerClient

+ ListContainers func(bool) ListContainersResponse

type DockerGoClient

+ func (dg *DockerGoClient) ListContainers(all bool) ListContainersResponse

+ type ListContainersResponse struct

+ DockerIds []string

+ Error error

May 6, 2015

Changes in this version

+ type CannotXContainerError struct

+ func (err CannotXContainerError) Error() string

+ func (err CannotXContainerError) ErrorName() string

+ type ContainerVanishedError struct

+ func (err ContainerVanishedError) Error() string

+ func (err ContainerVanishedError) ErrorName() string

+ type DockerContainerMetadata struct

+ DockerId string

+ Error error

+ ExitCode *int

+ PortBindings []api.PortBinding

+ Volumes map[string]string

type DockerGoClient

+ func (dg *DockerGoClient) SetGoDockerClient(to dockerclient.Client)

+ type DockerStateError struct

+ func NewDockerStateError(err string) DockerStateError

+ func (err DockerStateError) Error() string

+ func (err DockerStateError) ErrorName() string

type DockerTaskEngine

+ func (engine *DockerTaskEngine) CheckTaskState(task *api.Task)

+ func (engine *DockerTaskEngine) SetDockerClient(client DockerClient)

+ func (engine *DockerTaskEngine) Shutdown()

+ type DockerTimeoutError struct

+ func (err *DockerTimeoutError) Error() string

+ func (err *DockerTimeoutError) ErrorName() string

+ type OutOfMemoryError struct

+ func (err OutOfMemoryError) Error() string

+ func (err OutOfMemoryError) ErrorName() string

Apr 3, 2015

Changes in this version

type DockerClient

+ Version func() (string, error)

type DockerGoClient

+ func (dg *DockerGoClient) Version() (string, error)

type DockerTaskEngine

+ func (engine *DockerTaskEngine) Disable()

+ func (engine *DockerTaskEngine) Version() (string, error)

type TaskEngine

+ Disable func()

+ Version func() (string, error)

Feb 19, 2015

Changes in this version

+ const DEFAULT_TIMEOUT_SECONDS

+ const DOCKER_DEFAULT_ENDPOINT

+ const DOCKER_ENDPOINT_ENV_VARIABLE

+ func TaskCompleted(task *api.Task) bool

+ type ContainerNotFound struct

+ ContainerName string

+ TaskArn string

+ func (cnferror ContainerNotFound) Error() string

+ type DockerClient interface

+ ContainerEvents func() (<-chan DockerContainerChangeEvent, error)

+ CreateContainer func(*docker.Config, string) (string, error)

+ DescribeContainer func(string) (api.ContainerStatus, error)

+ GetContainerName func(string) (string, error)

+ InspectContainer func(string) (*docker.Container, error)

+ PullImage func(image string) error

+ RemoveContainer func(string) error

+ StartContainer func(string, *docker.HostConfig) error

+ StopContainer func(string) error

+ type DockerContainerChangeEvent struct

+ DockerId string

+ Image string

+ Status api.ContainerStatus

+ type DockerGoClient struct

+ func NewDockerGoClient() (*DockerGoClient, error)

+ func (dg *DockerGoClient) ContainerEvents() (<-chan DockerContainerChangeEvent, error)

+ func (dg *DockerGoClient) CreateContainer(config *docker.Config, name string) (string, error)

+ func (dg *DockerGoClient) DescribeContainer(dockerId string) (api.ContainerStatus, error)

+ func (dg *DockerGoClient) DescribeDockerImages() (string, error)

+ func (dg *DockerGoClient) GetContainerName(id string) (string, error)

+ func (dg *DockerGoClient) InspectContainer(dockerId string) (*docker.Container, error)

+ func (dg *DockerGoClient) PullImage(image string) error

+ func (dg *DockerGoClient) RemoveContainer(dockerId string) error

+ func (dg *DockerGoClient) StartContainer(id string, hostConfig *docker.HostConfig) error

+ func (dg *DockerGoClient) StopContainer(dockerId string) error

+ func (dg *DockerGoClient) StopContainerById(id string) error

+ type DockerImageResponse struct

+ Images []docker.APIImages

+ type DockerTaskEngine struct

+ func NewDockerTaskEngine(cfg *config.Config) *DockerTaskEngine

+ func (engine *DockerTaskEngine) AddTask(task *api.Task)

+ func (engine *DockerTaskEngine) ApplyContainerState(task *api.Task, container *api.Container)

+ func (engine *DockerTaskEngine) ApplyTaskState(task *api.Task)

+ func (engine *DockerTaskEngine) CreateContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) Init() error

+ func (engine *DockerTaskEngine) ListTasks() ([]*api.Task, error)

+ func (engine *DockerTaskEngine) MarshalJSON() ([]byte, error)

+ func (engine *DockerTaskEngine) MustInit()

+ func (engine *DockerTaskEngine) PullContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) RemoveContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) SetSaver(saver statemanager.Saver)

+ func (engine *DockerTaskEngine) StartContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) State() *dockerstate.DockerTaskEngineState

+ func (engine *DockerTaskEngine) StopContainer(task *api.Task, container *api.Container) error

+ func (engine *DockerTaskEngine) TaskEvents() <-chan api.ContainerStateChange

+ func (engine *DockerTaskEngine) UnmarshalJSON(data []byte) error

+ type TaskEngine interface

+ AddTask func(*api.Task)

+ Init func() error

+ ListTasks func() ([]*api.Task, error)

+ MarshalJSON func() ([]byte, error)

+ MustInit func()

+ SetSaver func(statemanager.Saver)

+ TaskEvents func() <-chan api.ContainerStateChange

+ UnmarshalJSON func([]byte) error

+ func NewTaskEngine(cfg *config.Config) TaskEngine